| | |
|---|
| | | package org.springblade.jfpt.nettyUdpServer.handle; |
|---|
| | | |
|---|
| | | import io.netty.buffer.ByteBuf; |
|---|
| | | import io.netty.buffer.Unpooled; |
|---|
| | | import io.netty.channel.ChannelHandlerContext; |
|---|
| | | import io.netty.channel.SimpleChannelInboundHandler; |
|---|
| | | import io.netty.channel.socket.DatagramPacket; |
|---|
| | |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * Created by wangshikai on 2016/7/18. |
|---|
| | | * updHandler udp 服务端数据接收处理 |
|---|
| | | */ |
|---|
| | | @Component |
|---|
| | | public class UdpServerHandler extends SimpleChannelInboundHandler<DatagramPacket> { |
|---|
| | |
|---|
| | | byte[] req = new byte[buf.readableBytes()]; |
|---|
| | | buf.readBytes(req); |
|---|
| | | String body = new String(req, CharsetUtil.UTF_8); |
|---|
| | | System.out.println("【NOTE】>>>>>> 收到客户端的数据："+body); |
|---|
| | | System.out.println("【UDP】>>>>>> 收到客户端的数据："+body); |
|---|
| | | |
|---|
| | | // 回复一条信息给客户端 |
|---|
| | | // channelHandlerContext.writeAndFlush(new DatagramPacket( |
|---|
