Netty（六）UDP在netty中的使用

關於UDP的介紹，這里不在闡述。
相比於TCP而言，UDP不存在客戶端和服務端的實際鏈接，因此不需要為連接(ChannelPipeline)設置handler。

 

服務端：

public void run(int port)throws Exception{
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            Bootstrap b = new Bootstrap();
            b.group(group).channel(NioDatagramChannel.class)
                    .option(ChannelOption.SO_BROADCAST,true)
                    .handler(new UdpServerHandler());

            b.bind(port).sync().channel().closeFuture().await();
        }
        finally {
            group.shutdownGracefully();
        }
    }

    @Override
    public void messageReceived(ChannelHandlerContext channelHandlerContext,
                                   DatagramPacket datagramPacket) throws Exception {
        // 因為Netty對UDP進行了封裝，所以接收到的是DatagramPacket對象。
        String req = datagramPacket.content().toString(CharsetUtil.UTF_8);
        System.out.println(req);

        if("啪啪啪來拉！！！".equals(req)){
            channelHandlerContext.writeAndFlush(new DatagramPacket(Unpooled.copiedBuffer(
                    "結果：",CharsetUtil.UTF_8),datagramPacket.sender()));
        }
    }

 

客戶端：

    public void run(int port)throws Exception{
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            Bootstrap b = new Bootstrap();
            b.group(group).channel(NioDatagramChannel.class)
                    .option(ChannelOption.SO_BROADCAST,true)
                    .handler(new UdpClientHandler());

            Channel ch = b.bind(0).sync().channel();
            // 向網段類所有機器廣播發UDP
            ch.writeAndFlush(
                    new DatagramPacket(
                            Unpooled.copiedBuffer("啪啪啪來拉！！！", CharsetUtil.UTF_8),
                            new InetSocketAddress(
                                    "255.255.255.255",port
                            ))).sync();
            if(!ch.closeFuture().await(15000)){
                System.out.println("查詢超時！！！");
            }
        }
        finally {
            group.shutdownGracefully();
        }
    }

    public void messageReceived(ChannelHandlerContext channelHandlerContext,
                                   DatagramPacket datagramPacket) throws Exception {
        String response = datagramPacket.content().toString(CharsetUtil.UTF_8);

        if(response.startsWith("結果：")){
            System.out.println(response);
            channelHandlerContext.close();
        }
    }

源碼下載

源碼在src/main/java/Unp下，分為客戶端和服務端，他們的代碼基本和Netty入門章節的代碼類似，只是減少了相關的解碼器使用。

GitHub地址：https://github.com/orange1438/Netty_Course