「Netty」UDP廣播事件

一、前言

前面學習了WebSocket協議，並且通過示例講解了WebSocket的具體使用，接著學習如何使用無連接的UDP來廣播事件。

二、UDP廣播事件

2.1 UDP基礎

面向連接的TCP協議管理端到端的連接，在連接生命周期中，發送的消息會有序並且可靠地進行傳輸，最後連接有序地終止。然而，在無連接協議（如UDP）中，沒有持久連接的概念，每個消息（UDP數據報）都是獨立的傳輸，此外，UDP沒有TCP的糾錯機制（即每個對等體會確認其接收到的分組，並且發送者會重傳未確認的分組）。

UDP的限制比TCP多，但是比TCP快很多，這是因為消除了握手和消息管理的所有開銷，UDP非常適合處理或容忍消息丟失的應用。

2.2 UDP廣播

迄今為止所有的示例都使用了單播的傳輸模式，其被定義為將消息發送到由唯一地址標識的單個網路目的地，有連接和無連接的協議都支持這種模式，UDP為多個收件人發送消息提供了額外的傳輸模式：

· 組播--傳輸到定義的主機組。

· 廣播--傳輸到網路（或子網）上的所有主機。

本章中的示例將通過發送在同一網路上的所有主機接收的消息來使用UDP廣播。

2.3 UDP簡單示例

示例將打開一個文件，並通過UDP將每一行廣播為指定埠。下圖展示了應用的結構圖。

2.4 LogEvent POJO

在消息應用中，消息經常以POJO形式展現，LogEvent的POJO如下。

public final class LogEvent {
public static final byte SEPARATOR = (byte) ":";
private final InetSocketAddress source;
private final String logfile;
private final String msg;
private final long received;
public LogEvent(String logfile, String msg) {
this(null, -1, logfile, msg);
}
public LogEvent(InetSocketAddress source, long received,
String logfile, String msg) {
this.source = source;
this.logfile = logfile;
this.msg = msg;
this.received = received;
}
public InetSocketAddress getSource {
return source;
}
public String getLogfile {
return logfile;
}
public String getMsg {
return msg;
}
public long getReceivedTimestamp {
return received;
}
}

2.5 編寫broadcaster

Netty提供了許多類來支持UDP應用程序，如Netty的DatagramPacket是DatagramChannel實現與遠程對等體進行通信的簡單消息容器，我們需要一個編碼器將EventLog消息轉換為DatagramPackets，可以擴展Netty的MessageToMessageEncoder，LogEventEncoder的代碼如下。

public class LogEventEncoder extends MessageToMessageEncoder {
private final InetSocketAddress remoteAddress;
public LogEventEncoder(InetSocketAddress remoteAddress) {
this.remoteAddress = remoteAddress;
}
@Override
protected void encode(ChannelHandlerContext channelHandlerContext,
LogEvent logEvent, List