UdpDataSink.java 文件源码

public UdpDataSink(ServerConfig serverConfig) {
    System.out.println("Opening UDP channel for sending");
    try {
        channel = DatagramChannel.open(StandardProtocolFamily.INET);
        channel.connect(new InetSocketAddress(serverConfig.getInetAddress(), serverConfig.getPort()));
    } catch (IOException e) {
        throw new IllegalStateException("Unable to start UDP channel for sending", e);
    }
}