NettyUDP通信Demo

1.服务端代码

package udp;

import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.DatagramPacket;
import io.netty.channel.socket.nio.NioDatagramChannel;

public class UdpServer {

public static void main(String[] args) {try {Bootstrap b &＃61; new Bootstrap();EventLoopGroup group &＃61; new NioEventLoopGroup();b.group(group).channel(NioDatagramChannel.class).option(ChannelOption.SO_BROADCAST, true).handler(new UdpServerHandler());b.bind(2555).sync().channel().closeFuture().await();} catch (InterruptedException e) {e.printStackTrace();}
}private static class UdpServerHandler extends SimpleChannelInboundHandler {&＃64;Overrideprotected void channelRead0(ChannelHandlerContext ctx, DatagramPacket packet) throws Exception {ByteBuf buf &＃61; packet.copy().content();byte[] req &＃61; new byte[buf.readableBytes()];buf.readBytes(req);String body &＃61; new String(req, "UTF-8");System.out.println(body);//打印收到的信息//向客户端发送消息String json &＃61; "来自服务端: 南无阿弥陀佛";// 由于数据报的数据是以字符数组传的形式存储的&＃xff0c;所以传转数据byte[] bytes &＃61; json.getBytes("UTF-8");DatagramPacket data &＃61; new DatagramPacket(Unpooled.copiedBuffer(bytes), packet.sender());ctx.writeAndFlush(data);//向客户端发送消息}
}


}

2.客户端代码

package udp;

import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.Unpooled;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.DatagramPacket;
import io.netty.channel.socket.nio.NioDatagramChannel;
import io.netty.util.CharsetUtil;

import java.net.InetSocketAddress;

public class UdpClient {

public static final int MessageReceived &＃61; 0x99;
private static int scanPort &＃61; 2555;public UdpClient(int scanPort) {this.scanPort &＃61; scanPort;
}private static class CLientHandler extends SimpleChannelInboundHandler {&＃64;Overrideprotected void channelRead0(ChannelHandlerContext ctx, DatagramPacket packet) throws Exception {String body &＃61; packet.content().toString(CharsetUtil.UTF_8);System.out.println(body);}
}public static void main(String[] args) {EventLoopGroup group &＃61; new NioEventLoopGroup();try {Bootstrap b &＃61; new Bootstrap();b.group(group).channel(NioDatagramChannel.class).handler(new CLientHandler());Channel ch &＃61; b.bind(0).sync().channel();ch.writeAndFlush(new DatagramPacket(Unpooled.copiedBuffer("来自客户端:南无本师释迦牟尼佛", CharsetUtil.UTF_8),new InetSocketAddress("127.0.0.1", scanPort))).sync();ch.closeFuture().await();} catch (Exception e) {e.printStackTrace();} finally {group.shutdownGracefully();}
}


}

3.分别启动