1. package cn.enjoyedu.udp.unicast;
    2. import io.netty.bootstrap.Bootstrap;
    3. import io.netty.channel.ChannelFuture;
    4. import io.netty.channel.EventLoopGroup;
    5. import io.netty.channel.nio.NioEventLoopGroup;
    6. import io.netty.channel.socket.nio.NioDatagramChannel;
    7. /**
    8. * 类说明:应答端
    9. */
    10. public class UdpAnswerSide {
    11. public static final int ANSWER_PORT = 8080;
    12. public final static String ANSWER = "古诗来了:";
    13. public void run(int port) throws Exception{
    14. EventLoopGroup group = new NioEventLoopGroup();
    15. try {
    16. /*udp无连接,没有接受连接说法,即使是接受端,也应该用Bootstrap*/
    17. Bootstrap b = new Bootstrap();
    18. /*由于我们用的是UDP协议,所以要用NioDatagramChannel来创建*/
    19. b.group(group)
    20. .channel(NioDatagramChannel.class)
    21. .handler(new AnswerHandler());
    22. //没有接受客户端连接的过程,监听本地端口即可
    23. ChannelFuture f = b.bind(port).sync();
    24. System.out.println("应答服务已启动.....");
    25. f.channel().closeFuture().sync();
    26. } finally {
    27. group.shutdownGracefully();
    28. }
    29. }
    30. public static void main(String [] args) throws Exception{
    31. new UdpAnswerSide().run(ANSWER_PORT);
    32. }
    33. }