【开源中国 APP 全新上线】“动弹” 回归、集成大模型对话、畅读技术报告”
//代码如下:
public class GatewayServer {
EventLoopGroup group = new NioEventLoopGroup();
public void run(int port) throws Exception{
Bootstrap b = new Bootstrap();
b.group(group).channel(NioDatagramChannel.class);
b.option(ChannelOption.SO_BROADCAST, true);
b.handler(new ChannelInitializer<NioDatagramChannel>(){
@Override
protected void initChannel(NioDatagramChannel ch) throws Exception {
ChannelPipeline cp = ch.pipeline();
cp.addLast(new IdleStateHandler(30, 0, 0, TimeUnit.SECONDS));
cp.addLast(new GatewayServerHandler());
cp.addLast(new HeartBeatServerHandler());
}
});
ChannelFuture f = b.bind(port).sync();
f.channel().closeFuture().sync();
}
public class GatewayServerHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
DatagramPacket pack = (DatagramPacket) msg;
ByteBuf result = pack.content();
byte[] result1 = new byte[result.readableBytes()];
result.readBytes(result1);
String resultStr = new String(result1);
System.out.println(resultStr);
result.release();
}
}
你要解码啊