过长内容分成了多次发送 问题 LengthFieldBasedFrameDecoder使用

这个问题比较常见,在高并发大数据传输时数据分包接收会乱

在org.jboss.netty.handler.codec.frame包中,有LengthFieldBasedFrameDecoder类用来解析带有长度属性的包,只要我们在传输协议中加入包的总长度就行了(也许有更好的方法)

 

具体方法:

1.可在数据包前加4个字节表示包的总长度,例如:

 

/** 
* 传输协议
* |------------------------------------------
* |总长度4byte |pkey长度4byte      |
* |------------------------------------------
* | value 4byte|name 4byte|zip  1 |
* |------------------------------------------
* |skey值      8byte(long型时间,固定) |
* |------------------------------------------------
* |  包体内容                                             |
* |                    
* |------------------------------------------------

在通过netty传输数据之前,执行

 

2.在接受的ChannelPipeline中加入decoder,加在handler之前,例如:

 

 

[java] view plaincopy
  1. bootstrap.setPipelineFactory(new ChannelPipelineFactory() {  
  2.            public ChannelPipeline getPipeline() throws Exception {  
  3.             ChannelPipeline pipeline = new DefaultChannelPipeline();  
  4.             pipeline.addFirst("decoder", new LengthFieldBasedFrameDecoder(100000000,0,4,0,4));  
  5.             pipeline.addLast("handler", new XXX(config));  
  6.             return pipeline;  
  7.            }  
  8.        });  

 

 

使用LengthFieldBasedFrameDecoder作为decoder实现,LengthFieldBasedFrameDecoder构造函数,第一个参数为信息最大长度,超过这个长度回报异常,第二参数为长度属性的起始(偏移)位,我们的协议中长度是0到第3个字节,所以这里写0,第三个参数为“长度属性”的长度,我们是4个字节,所以写4,第四个参数为长度调节值,在总长被定义为包含包头长度时,修正信息长度,第五个参数为跳过的字节数,根据需要我们跳过前4个字节,以便接收端直接接受到不含“长度属性”的内容。

 

至此,接收端会按照decoder指定的长度接收完整后才会调用handler继续处理信息。

转载于:https://www.cnblogs.com/gehonglin/p/4174459.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/574991.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java为什么需要枚举_java – 什么是枚举,为什么它们有用?

当变量(特别是方法参数)只能从一组可能的值中取出一个时,应该总是使用枚举。示例将是类型常量(合同状态:“永久”,“临时”,“学徒”)或标志(“立即执行”,“延迟执行”)。如果使用枚举而不是整数(或字符串代码)&#…

python args kw_Python基础-参数魔法,*args,**kwags

最近在带着新成员一起学习《Python基础教程》这本书,看到参数魔法的时候突然感觉好多术语真的不知道呀~Python参数:位置参数,关键字参数经常看Python我们肯定经常看见,下面类似这样的代码def add(x,y):return xy# 1add(1,2)# 2add(x1,y2)上面的两段代码结…

程序一旦发觉写得不理想,那就得重构它

早上有写一篇《设计模式--建造者(Builder)模式》http://www.cnblogs.com/insus/p/4179620.html。是在ASP.NET环境中,应用与演示设计模式(Builder)。现在Insus.NET从博文中最后的下载链接下载取源程序,它是有写得不够理想,现在重构它。问题点&…

java爬小说_java爬虫实战开发小说网站

用Java做一个自己的小说网站共10课,教程完结,带完整依赖jar。【课程内容】第一课更新:本教程要求:有一定Java开发基础有一点网页开发基础开发环境:JDK1.7及以上MavenEclipseTomcat7及以上第二课更新:1.为原…

python画多边形_python – 使用matplotlib更有效地绘制多边形

您可以考虑创建多边形的集合而不是单个多边形。举个例子:import numpy as npimport matplotlib.pyplot as pltfrom matplotlib.collections import PolyCollectionimport matplotlib as mpl# Generate data. In this case, well make a bunch of center-points and …

python小程序

#!/bin/env python# -*- coding: UTF-8 -*-import time import datetimeday_list list() day_dict dict()def day_constancy_check():检查日期是否连续, 小时是否全部存在Args:Returns:day_list.sort()first_day for i in range(len(day_list)):if first_day ! :input_day …

java post 图片上传_java 发送 post 请求上传图片

构造http header时,设置content-length为内容部分字节数,但是总是无效。通过wireshark抓到的包和设置的content-length不符合。private void initConnection() throws Exception {conn (HttpURLConnection) this.url.openConnection();conn.setDoOutput…

ASP.NET MVC4中用 BundleCollection

来源&#xff1a;http://www.cnblogs.com/madyina/p/3702314.html ASP.NET MVC4中对JS和CSS的引用又做了一次变化&#xff0c;在MVC3中我们这样引用资源文件&#xff1a; <link href"Url.Content("~/Content/Site.css")" rel"stylesheet" typ…

java数组对角线的和_java – 2d数组对角线填充

那么&#xff0c;如果你要枚举这些填充模式的索引&#xff0c;你会得到0,01,00,12,01,10,22,11,22,2所以&#xff0c;你需要遍历两个指标的总和。也就是说&#xff0c;总添加量。如您所见&#xff0c;0,0总计0&#xff0c;1,0和0,1总计1&#xff0c;依此类推。给我们这样的东西…

python如何下载安装spacy_使用pip安装Spacy时出错

它可能与虚拟环境(venv)中安装的其他python包发生冲突。我就是这样。我尝试将pip安装到已经安装了以下软件包的venv中&#xff1a;appnope0.1.0beautifulsoup44.5.1bs40.0.1chardet2.3.0cloudpickle0.2.1cssselect1.0.0cymem1.31.2decorator4.0.10entrypoints0.2.2headers-work…

入门monkeyrunner7-monkeyrunner demo3 EasyMonkeyDevice+hierarchyviewer +monkeyrunner+截图对比

1 #该demo为monkeyrunner测试安卓系统自带的计计算器2 #测试图片对比&#xff0c;测试EasyMonkeyDevice对象&#xff0c;一些他的元素操作3 #作者&#xff1a;Mads Spiral QQ&#xff1a;79523822 如有疑问留言或者加qq&#xff0c;验证wyx4 #codingutf-85 import sys6 import …

小程序向java后台发送图片_微信小程序在后台如何将二进制流转换成图片

我在前端请求了小程序码返回的是一堆乱码&#xff0c;java不太熟网上找了一个方法可以将二进制流和图片互转&#xff0c;但是从微信小程序码接口获取的数据用这个方法无法获取正确的图片&#xff0c;不知道哪里有问题&#xff1b;有没有只在前端就能获取小程序码的方法RequestM…

python end of statement_17个新手常见Python运行时错误

12) Trying to use a Python keyword for a variable name. (Causes “SyntaxError: invalid syntax”)The Python keywords (also called reserved words) cannot be used for variable names. This happens with code like:class algebraThe Python 3 keywords are: and, as…

Android Fragment功能的例子

实现的功能很简单&#xff0c;也是最基本的&#xff0c;上下分别是两个Fragment&#xff0c;上面的Fragment中是一个listview&#xff0c;当点击item时&#xff0c;下面的Fragment显示对应的文字详细信息 具体的实现步骤如下&#xff1a;①创建工程FragmentExam&#xff0c;目录…

java上传图片http错误_上传图片出错

源码&#xff1a;package action;import java.io.IOException;import com.qiniu.common.QiniuException;import com.qiniu.http.Client;import com.qiniu.http.Response;import com.qiniu.storage.UploadManager;import com.qiniu.util.Auth;public class UploadAction {public…

template标签_C++核心准则T.65:使用标签分发提供函数的不同实现

T.65: Use tag dispatch to provide alternative implementations of a functionT.65:使用标签分发提供函数的不同实现Reason(原因)A template defines a general interface.模板定义普遍接口。Tag dispatch allows us to select implementations based on specific properties…

Windows服务器学习篇:服务器连接与退出

此文是我早期在公司内部发布的一篇给予新入职程序员基础技术培训的文章&#xff0c;非常基础简单&#xff0c;现拿出来给大家分享。当然&#xff0c;已工作人士可直接忽略... 一、Windows服务器连接 1. 在桌面菜单中的“运行”里&#xff0c;输入mstsc命令&#xff0c;然后回车…

nginx动静分离配置_Nginx动静分离

动静分离动静分离&#xff0c;就是将JSP、Servlet等动态资源交由Tomcat或其他Web服务器处理&#xff0c;将CSS、js、image等静态资源交由Nginx或其他Http服务器处理&#xff0c;充分发挥各自的优势&#xff0c;减轻其他服务器的压力&#xff0c;搭建更为高效的系统架构。Nginx动…

用java自动化访问百度测试_java+eclipse+selenium+百度搜索设置自动化测试

在eclipse中新建一个项目baidutest&#xff1b;再在src文件夹中新建一个包com.baidutest.homework&#xff1b;再在包中新建一个java类baidusetting&#xff0c;并设置为静态类&#xff1b;最后在项目中新建一个lib文件夹&#xff0c;将selenium的所有架包拷贝到lib文件夹中&am…