Netty粘包拆包問題解決方案
更新時間：2020年08月13日 08:42:13 作者：猿天地
這篇文章主要介紹了Netty粘包拆包問題解決方案,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
TCP黏包拆包
TCP是一個流協(xié)議，就是沒有界限的一長串二進制數據。TCP作為傳輸層協(xié)議并不不了解上層業(yè)務數據的具體含義，它會根據TCP緩沖區(qū)的實際情況進行數據包的劃分，所以在業(yè)務上認為是一個完整的包，可能會被TCP拆分成多個包進行發(fā)送，也有可能把多個小的包封裝成一個大的數據包發(fā)送，這就是所謂的TCP粘包和拆包問題。
怎么解決？
- • 消息定長度，傳輸的數據大小固定長度，例如每段的長度固定為100字節(jié)，如果不夠空位補空格
- • 在數據包尾部添加特殊分隔符，比如下劃線，中劃線等
- • 將消息分為消息頭和消息體，消息頭中包含表示信息的總長度
Netty提供了多個解碼器，可以進行分包的操作，分別是：
- • LineBasedFrameDecoder （回車換行分包）
- • DelimiterBasedFrameDecoder（特殊分隔符分包）
- • FixedLengthFrameDecoder（固定長度報文來分包）
- • LengthFieldBasedFrameDecoder（自定義長度來分包）
制造粘包和拆包問題
為了驗證我們的解碼器能夠解決這種粘包和拆包帶來的問題，首先我們就制造一個這樣的問題，以此用來做對比。
服務端：
public static void main(String[] args) {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
ServerBootstrap bootstrap = new ServerBootstrap();
bootstrap.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast("decoder", new StringDecoder());
ch.pipeline().addLast("encoder", new StringEncoder());
ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
System.err.println("server:" + msg.toString());
ctx.writeAndFlush(msg.toString() + "你好" );
}
});
}
})
.option(ChannelOption.SO_BACKLOG, 128)
.childOption(ChannelOption.SO_KEEPALIVE, true);
try {
ChannelFuture f = bootstrap.bind(2222).sync();
f.channel().closeFuture().sync();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
workerGroup.shutdownGracefully();
bossGroup.shutdownGracefully();
}
}
客戶端我們發(fā)送一個比較長的字符串，如果服務端收到的消息是一條，那么就是對的，如果是多條，那么就有問題了。
public static void main(String[] args) {
EventLoopGroup workerGroup = new NioEventLoopGroup();
Channel channel = null;
try {
Bootstrap b = new Bootstrap();
b.group(workerGroup);
b.channel(NioSocketChannel.class);
b.option(ChannelOption.SO_KEEPALIVE, true);
b.handler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast("decoder", new StringDecoder());
ch.pipeline().addLast("encoder", new StringEncoder());
ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
System.err.println("client:" + msg.toString());
}
});
}
});
ChannelFuture f = b.connect("127.0.0.1", 2222).sync();
channel = f.channel();
StringBuilder msg = new StringBuilder();
for (int i = 0; i < 100; i++) {
msg.append("hello yinjihuan");
}
channel.writeAndFlush(msg);
} catch(Exception e) {
e.printStackTrace();
}
}
首先啟動服務端，然后再啟動客戶端，通過控制臺可以看到服務接收的數據分成了2次,這就是我們要解決的問題。
server:hello yinjihuanhello....
server:o yinjihuanhello...
LineBasedFrameDecoder
用LineBasedFrameDecoder 來解決需要在發(fā)送的數據結尾加上回車換行符，這樣LineBasedFrameDecoder 才知道這段數據有沒有讀取完整。
改造服務端代碼，只需加上LineBasedFrameDecoder 解碼器即可,構造函數的參數是數據包的最大長度。
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast(new LineBasedFrameDecoder(10240));
ch.pipeline().addLast("decoder", new StringDecoder());
ch.pipeline().addLast("encoder", new StringEncoder());
ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
System.err.println("server:" + msg.toString());
ctx.writeAndFlush(msg.toString() + "你好");
}
});
}
改造客戶端發(fā)送代碼，再數據后面加上回車換行符
ChannelFuture f = b.connect("127.0.0.1", 2222).sync();
channel = f.channel();
StringBuilder msg = new StringBuilder();
for (int i = 0; i < 100; i++) {
msg.append("hello yinjihuan");
}
channel.writeAndFlush(msg + System.getProperty("line.separator"));
DelimiterBasedFrameDecoder
DelimiterBasedFrameDecoder和LineBasedFrameDecoder差不多，DelimiterBasedFrameDecoder可以自己定義需要分割的符號，比如下劃線，中劃線等等。
改造服務端代碼，只需加上DelimiterBasedFrameDecoder解碼器即可,構造函數的參數是數據包的最大長度。我們用下劃線來分割。
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast(new DelimiterBasedFrameDecoder(10240, Unpooled.copiedBuffer("_".getBytes())));
ch.pipeline().addLast("decoder", new StringDecoder());
ch.pipeline().addLast("encoder", new StringEncoder());
ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
System.err.println("server:" + msg.toString());
ctx.writeAndFlush(msg.toString() + "你好");
}
});
}
改造客戶端發(fā)送代碼，再數據后面加上下劃線
ChannelFuture f = b.connect("127.0.0.1", 2222).sync();
channel = f.channel();
StringBuilder msg = new StringBuilder();
for (int i = 0; i < 100; i++) {
msg.append("hello yinjihuan");
}
channel.writeAndFlush(msg + "_");
FixedLengthFrameDecoder
FixedLengthFrameDecoder是按固定的數據長度來進行解碼的，也就是說你客戶端發(fā)送的每條消息的長度是固定的，下面我們看看怎么使用。
服務端還是一樣，增加FixedLengthFrameDecoder解碼器即可。
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast(new FixedLengthFrameDecoder(1500));
ch.pipeline().addLast("decoder", new StringDecoder());
ch.pipeline().addLast("encoder", new StringEncoder());
ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
System.err.println("server:" + msg.toString());
ctx.writeAndFlush(msg.toString() + "你好");
}
});
}
客戶端，msg輸出的長度就是1500
ChannelFuture f = b.connect("127.0.0.1", 2222).sync();
channel = f.channel();
StringBuilder msg = new StringBuilder();
for (int i = 0; i < 100; i++) {
msg.append("hello yinjihuan");
}
System.out.println(msg.length());
channel.writeAndFlush(msg);
服務端代碼：
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast("frameDecoder", new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4, 0, 4));
ch.pipeline().addLast("frameEncoder", new LengthFieldPrepender(4));
ch.pipeline().addLast("decoder", new StringDecoder());
ch.pipeline().addLast("encoder", new StringEncoder());
ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
System.err.println("server:" + msg.toString());
ctx.writeAndFlush(msg.toString() + "你好");
}
});
}
客戶端，直接發(fā)送就行
ChannelFuture f = b.connect("127.0.0.1", 2222).sync();
channel = f.channel();
StringBuilder msg = new StringBuilder();
for (int i = 0; i < 100; i++) {
msg.append("hello yinjihuan");
}
channel.writeAndFlush(msg);
源碼參考：https://github.com/yinjihuan/netty-im
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
這篇文章主要介紹了Mybatis基于注解實現多表查詢功能，非常不錯，具有一定的參考借鑒價值,需要的朋友可以參考下2019-09-09
基于servlet的執(zhí)行原理與生命周期(全面解析)
下面小編就為大家分享一篇servlet的執(zhí)行原理與生命周期全面解析，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2017-12-12
Fork/Join框架是Java7中新增的一項特性，也是Java7平臺的其中一項主要改進。下面我們就來簡單探討下Java的Fork/Join框架2016-09-09
spring整合redis以及使用RedisTemplate的方法
本篇文章主要介紹了spring整合redis以及使用RedisTemplate的方法，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-05-05
了解spring中的CloudNetflix Hystrix彈性客戶端
這篇文章主要介紹了了解spring中的CloudNetflix Hystrix彈性客戶端，客戶端彈性模式是在遠程服務發(fā)生錯誤或表現不佳時保護遠程資源（另一個微服務調用或者數據庫查詢）免于崩潰。,需要的朋友可以參考下2019-06-06
這篇文章主要介紹了關于Kafka消息隊列原理的總結，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-05-05
這篇文章主要介紹了Spring?Cloud?Eureka基礎應用,Eureka?Client中內置一個負載均衡器，用來進行基本的負載均衡，下面我們將通過搭建一個簡單的Eureka例子來了解Eureka的運作原理，感興趣的朋友一起看看吧2022-05-05
這篇文章主要介紹了Mybatis查詢語句返回對象和泛型集合的操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-07-07
這篇文章主要給大家介紹了關于Java 9中如何對IntegerCache進行修改的相關資料，文中通過示例代碼介紹的非常詳細，對大家學習或使用java9具有一定的參考學習價值，需要的朋友們下面隨著小編來一起看看吧。2017-12-12
這篇文章主要介紹了Java代碼生成器的制作流程詳解，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-07-07