您好,欢迎来到站长目录(28sn.com)!


如何解决netty自定义协议粘包分包问题

来源:网络整理 浏览:199次 时间:2022-12-06

又一次发现公司同事用netty竟然都不处理粘包分包的问题,出了问题都不知道怎么回事,呵呵哒。sp厂商反馈数据已推送至我方提供的地址,但未收到我方的应答,正常推送了一次,又重试三次,都没有收到我方应答。

看了下代码,又跟踪了几条日志,发现sp数据确实有推送,只是我方解析失败。好多数据都是几条信息拼一起过来的,我方只按照头部长度解析了一条,导致许多数据都没有正常更新;还有部分数据是分两次过来的,本来应该放在一起解析一次,我方却解析了两次,自然失败了。

看了下报文约定,基本是这个样子,头部是总长度+固定的命令+序列号+报文数据。

这种自定义的,我一般使用 ByteToMessageDecoder来处理,要注意结合自定义报文约定,这里主要判定头长度和指定命令。









































/*** 基本长度(4+4+12) 4:总长度 4:命令标识 12:序列号*/private static final int BASE_LENGTH = 20;
@Overrideprotected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {   LOG.debug("decode channelId:{}",ctx.channel().id().asShortText());   if (in.readableBytes() <= BASE_LENGTH) {       LOG.debug("readables:{} channelId:{}",in.readableBytes(),ctx.channel().id().asShortText());       return;   }   int length, command;   while (true) {       in.markReaderIndex();       length = in.readInt();       command = in.readInt();       LOG.debug("length:{},command:{}, channelId:{}",length,command,ctx.channel().id().asShortText());       if (length > BASE_LENGTH && command == 0xF) {           LOG.debug("find command:{},channelId:{}",command,ctx.channel().id().asShortText());           break;       }       in.resetReaderIndex();       byte temp = in.readByte();       LOG.debug("skip a byte:{},channelId:{}",temp,ctx.channel().id().asShortText());
      if (in.readableBytes() <= BASE_LENGTH) {           LOG.debug("length:{} less than 20,channelId:{}",in.readableBytes(),ctx.channel().id().asShortText());           return;       }   }   in.resetReaderIndex();   if (in.readableBytes() < length) {       LOG.debug("can read:{} less than length:{},channelId:{}",in.readableBytes(),length,ctx.channel().id().asShortText());       return;   }   byte[] data = new byte[length];   in.readBytes(data);   LOG.debug("success,length:{} data:{},channelId:{}",length,data,ctx.channel().id().asShortText());   out.add(data);
比较简单,查看日志数据已经正常处理了,粘包数据会按报文约定分成多条数据处理,分包问题会等到数据到达指定长度时正确处理。netty用起来很简单,但数据还是要小心处理。


推荐站点

  • 我爱发烧音乐我爱发烧音乐

    我爱发烧音乐囊括了从流行音乐到古典音乐多个类型的音乐作品,专栏推荐最新的音乐,提供音乐排名榜单!可供免费线上收听音乐,歌曲流畅,音效极佳! 网站提供的钢琴以及二胡专栏,可供收听者,陶冶情操,改善心情,是难得的轻音乐典藏!

    www.520fs.com
  • 世纪音乐网世纪音乐网

    世纪音乐网是专业的在线音乐试听MP3下载网站。歌曲总计30余万首,收录了网上最新歌曲和流行音乐,DJ舞曲,非主流音乐,经典老歌,劲舞团歌曲,搞笑歌曲,儿童歌曲,英文歌曲等。是您上网听歌的最佳网站。

    www.ssjj.com
  • 杭州网杭州网

      杭州网是杭州地区唯一的新闻门户网站,由中共杭州市委宣传部、杭州日报报业集团和杭州广播电视集团共同组建的杭州网络传媒有限公司运营。

    www.hangzhou.com.cn
  • 深圳在线深圳在线

      深圳在线 www.szol.net是深圳本地最大、最早的地方生活资讯网站之一,网站名“深圳在线www.szol.net”由南方报业传媒集团编辑委员会总编辑、南方日报社总编辑、南方都市报总编辑、南方书画院名誉院长王春芙亲笔题名,深圳在线www.szol.net团队与深圳热线www.szonline.net、奥一网www.oeeee.com都源于全国最早成立于1996年的知名网络公司——深圳万用网。

    www.szol.net
  • 今题网今题网

     今题网- 中国领先的社区服务网,提供社区服务, 在线交友和商家推广服务,于2004年创建上线,公司现有员工超过百名。今题网自成立以来,凭借其独特的定位和丰富的社区交友功能, 凭借其团队超强的搜索引擎优化技术吸引超过千万的用户成为今题网的注册会员。

    www.jinti.com

鄂公网安备 42062502000001号