netty udp接收超过2048字节数据

谁践踏了优雅 2022-11-26 09:45 282阅读 0赞

默认netty udp接收DatagramPacket字节数最大是2048，如果数据大，超过这个限制，就会报错，抛出异常，虽然这个包解析失败，不会影响其他包的解析，但是总得来说，这种失败是不利于数据收集的。

我们先来看看这个错误：

java.lang.IndexOutOfBoundsException: readerIndex(57) + length(2503) exceeds writerIndex(2048): PooledUnsafeDirectByteBuf(ridx: 57, widx: 2048, cap: 2048)

报错代码出自AbstractByteBuf.java的checkReadableBytes0()这个方法：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaW5pZmk_size_16_color_FFFFFF_t_70][]

通过调试，我们可以看到(DatagramPacket msg) 默认writerIndex=2048：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaW5pZmk_size_16_color_FFFFFF_t_70 1][]

报错的原因就是读取的数据索引readerIndex超过writerIndex，解决办法就是在udp服务创建的时候，指定RCVBUF\_ALLOCATOR，如下所示：

EventLoopGroup group = new NioEventLoopGroup(threadNum);
    try {
    	Bootstrap bootstrap = new Bootstrap();
    	bootstrap.group(group)
    		.channel(NioDatagramChannel.class)
    		.option(ChannelOption.SO_BROADCAST, true)
    		.option(ChannelOption.RCVBUF_ALLOCATOR, new FixedRecvByteBufAllocator(65535))
    		.handler(new UdpDataHandler(businessSender));
    	ChannelFuture future = bootstrap.bind(port).sync();
    	future.channel().closeFuture().await();
    } finally {
    	group.shutdownGracefully();
    }

关键的一句代码就是：.option(ChannelOption.RCVBUF\_ALLOCATOR, new FixedRecvByteBufAllocator(65535))

经过这个改进，udp可以接收超过2048数据长度的报文了。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaW5pZmk_size_16_color_FFFFFF_t_70]: /images/20221124/58d378dbb2bc4c5dbcc35755a90f13ae.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaW5pZmk_size_16_color_FFFFFF_t_70 1]: /images/20221124/4cd31d11496f4ee79984c149eefba902.png