您的位置:首页 > 其它

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

2011-08-30 16:29 1176 查看
这个问题比较常见,在高并发大数据传输时数据分包接收会乱

在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之前,例如:

bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
public ChannelPipeline getPipeline() throws Exception {
ChannelPipeline pipeline = new DefaultChannelPipeline();
pipeline.addFirst("decoder", new LengthFieldBasedFrameDecoder(100000000,0,4,0,4));
pipeline.addLast("handler", new XXX(config));
return pipeline;
}
});


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

至此,接收端会按照decoder指定的长度接收完整后才会调用handler继续处理信息。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: