netty实现 tcp和udp的区别

netty实现 tcp和udp的区别

public void run(int port)throws Exception{
2 EventLoopGroup group = new NioEventLoopGroup();
3 try {
4 Bootstrap b = new Bootstrap();
5 b.group(group).channel(NioDatagramChannel.class)
6 .option(ChannelOption.SO_BROADCAST,true)
7 .handler(new UdpServerHandler());
8
9 b.bind(port).sync().channel().closeFuture().await();
10 }
11 finally {
12 group.shutdownGracefully();
13 }
14 }

1 @Override
2 public void messageReceived(ChannelHandlerContext channelHandlerContext,
3 DatagramPacket datagramPacket) throws Exception {
4 // 因为Netty对UDP进行了封装，所以接收到的是DatagramPacket对象。
5 String req = datagramPacket.content().toString(CharsetUtil.UTF_8);
6 System.out.println(req);
7
8 if("啪啪啪来拉！！！".equals(req)){
9 channelHandlerContext.writeAndFlush(new DatagramPacket(Unpooled.copiedBuffer(
10 "结果：",CharsetUtil.UTF_8),datagramPacket.sender()));
11 }
12 }