专栏首页CodeGuide | 程序员编码指南netty案例,netty4.1基础入门篇九《自定义编码解码器,处理半包、粘包数据》

netty案例,netty4.1基础入门篇九《自定义编码解码器,处理半包、粘包数据》

前言介绍

在实际应用场景里,只要是支持sokcet通信的都可以和Netty交互,比如中继器、下位机、PLC等。这些场景下就非常需要自定义编码解码器,来处理字节码传输,并控制半包、粘包以及安全问题。那么本章节我们通过实现ByteToMessageDecoder、MessageToByteEncoder来实现我们的需求。

数据传输过程中有各种情况;整包数据、半包数据、粘包数据,比如我们设定开始符号02、结束符号03; 整包数据;02 89 78 54 03 半包数据;02 89 78 粘包数据;02 89 78 54 03 02 89

环境准备

1、jdk1.8【jdk1.7以下只能部分支持netty】 2、Netty4.1.36.Final【netty3.x 4.x 5每次的变化较大,接口类名也随着变化】 3、telnet 测试【可以现在你的win7机器上测试这个命令,用于链接到服务端的测试命令】

代码示例

itstack-demo-netty-1-09
└── src
    ├── main
    │   └── java
    │       └── org.itstack.demo.netty
    │           ├── codec
    │           │   ├── MyDecoder.java
    │           │   └── MyEncoder.java
    │           └── server
    │               ├── MyChannelInitializer.java
    │               ├── MyServerHandler.java
    │               └── NettyServer.java
    └── test
         └── java
             └── org.itstack.demo.test
                 └── ApiTest.java

MyDecoder.java *用于处理解码,02开始 03结束

public class MyDecoder extends ByteToMessageDecoder {

    //数据包基础长度
    private final int BASE_LENGTH = 4;

    @Override
    protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf in, List<Object> out) throws Exception {

        //基础长度不足,我们设定基础长度为4
        if (in.readableBytes() < BASE_LENGTH) {
            return;
        }

        int beginIdx; //记录包头位置

        while (true) {
            // 获取包头开始的index
            beginIdx = in.readerIndex();
            // 标记包头开始的index
            in.markReaderIndex();
            // 读到了协议的开始标志,结束while循环
            if (in.readByte() == 0x02) {
                break;
            }
            // 未读到包头,略过一个字节
            // 每次略过,一个字节,去读取,包头信息的开始标记
            in.resetReaderIndex();
            in.readByte();
            // 当略过,一个字节之后,
            // 数据包的长度,又变得不满足
            // 此时,应该结束。等待后面的数据到达
            if (in.readableBytes() < BASE_LENGTH) {
                return;
            }

        }

        //剩余长度不足可读取数量[没有内容长度位]
        int readableCount = in.readableBytes();
        if (readableCount <= 1) {
            in.readerIndex(beginIdx);
            return;
        }

        //长度域占4字节,读取int
        ByteBuf byteBuf = in.readBytes(1);
        String msgLengthStr = byteBuf.toString(Charset.forName("GBK"));
        int msgLength = Integer.parseInt(msgLengthStr);

        //剩余长度不足可读取数量[没有结尾标识]
        readableCount = in.readableBytes();
        if (readableCount < msgLength + 1) {
            in.readerIndex(beginIdx);
            return;
        }

        ByteBuf msgContent = in.readBytes(msgLength);

        //如果没有结尾标识,还原指针位置[其他标识结尾]
        byte end = in.readByte();
        if (end != 0x03) {
            in.readerIndex(beginIdx);
            return;
        }

        out.add(msgContent.toString(Charset.forName("GBK")));
    }
}

MyEncoder.java *用于处理编码,在byte开始和结束加上02 03

public class MyEncoder extends MessageToByteEncoder {

    @Override
    protected void encode(ChannelHandlerContext channelHandlerContext, Object in, ByteBuf out) throws Exception {

        String msg = in.toString();
        byte[] bytes = msg.getBytes();

        byte[] send = new byte[bytes.length + 2];
        System.arraycopy(bytes, 0, send, 1, bytes.length);
        send[0] = 0x02;
        send[send.length - 1] = 0x03;

        out.writeInt(send.length);
        out.writeBytes(send);

    }

}

MyChannelInitializer.java

public class MyChannelInitializer extends ChannelInitializer<SocketChannel> {

    @Override
    protected void initChannel(SocketChannel channel) {
        //自定义解码器
        channel.pipeline().addLast(new MyDecoder());
        //自定义编码器
        channel.pipeline().addLast(new MyEncoder());
        //在管道中添加我们自己的接收数据实现方法
        channel.pipeline().addLast(new MyServerHandler());
    }

}

MyServerHandler.java

public class MyServerHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        SocketChannel channel = (SocketChannel) ctx.channel();
        System.out.println("链接报告开始 {公众号:bugstack虫洞栈 >获取学习源码}");
        System.out.println("链接报告信息:有一客户端链接到本服务端");
        System.out.println("链接报告IP:" + channel.localAddress().getHostString());
        System.out.println("链接报告Port:" + channel.localAddress().getPort());
        System.out.println("链接报告完毕");
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        //接收msg消息{与上一章节相比,此处已经不需要自己进行解码}
        System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " 接收到消息:" + msg);

        ctx.writeAndFlush("hi I'm ok");
    }

}

测试结果

启动NettyServer

itstack-demo-netty server start done.
链接报告开始 
链接报告信息:有一客户端链接到本服务端
链接报告IP:10.13.28.13
链接报告Port:7397
链接报告完毕
2019-08-28 14:40:01 接收到消息:hihi  -整包测试
2019-08-28 14:40:16 接收到消息:hihi  -半包测试
2019-08-28 14:40:23 接收到消息:hihi  -粘包测试
2019-08-28 14:40:27 接收到消息:hihi  -粘包测试

Process finished with exit code -1

启动模拟器NetAssist,用TcpClient链接服务端

分别发送三组数据;

02;开始位
03;结束位
34;变量,内容长度位

第一组;整包测试数据:
02 34 68 69 68 69 03

第二组;半包测试数据
02 34 68 69 68 69
03

第三组:粘包测试数据
02 34 68 69 68 69 03 02 34
68 69 68 69 03

本文分享自微信公众号 - bugstack虫洞栈(bugstack),作者:付政委

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2019-08-28

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • netty案例,netty4.1基础入门篇九《自定义编码解码器,处理半包、粘包数据》

    在实际应用场景里,只要是支持sokcet通信的都可以和Netty交互,比如中继器、下位机、PLC等。这些场景下就非常需要自定义编码解码器,来处理字节码传输,并控...

    小傅哥
  • netty案例,netty4.1基础入门篇九《自定义编码解码器》

    在实际应用场景里,只要是支持sokcet通信的都可以和Netty交互,比如中继器、下位机、PLC等。这些场景下就非常需要自定义编码解码器,来处理字节码传输,并控...

    小傅哥
  • netty案例,netty4.1中级拓展篇十《Netty接收发送多种协议消息类型的通信处理方案》

    在我们实际做应用级开发的过程中,客户端与服务端需要发送多种消息类型,比如一个聊天室场景包括的消息类型;登录验证、组建群聊、发送消息、退出登录等等,但如果我们都是...

    小傅哥
  • netty案例,netty4.1基础入门篇九《自定义编码解码器,处理半包、粘包数据》

    在实际应用场景里,只要是支持sokcet通信的都可以和Netty交互,比如中继器、下位机、PLC等。这些场景下就非常需要自定义编码解码器,来处理字节码传输,并控...

    小傅哥
  • Java语言实现爬虫实战

    https://blog.csdn.net/uniquewonderq/article/details/50619899#comments

    用户5224393
  • python高级进阶#002第一个pyqt5程序

    在上一节的教程中,我们已经将图形化界面开发的基本环境已经搭建完毕,本节,我们继续使用pyqt5开发程序。以下 ,我们对生成代码知识点简要解析:

    刘金玉编程
  • java visualvm监控远程服务 原

    1、首先确保hostname绑定的不是localhost或者127.0.0.1、0.0.0.0,否则报

    尚浩宇
  • 【专业技术】Win32 SDK编程:我们如何输出文本

    在使用Win32编程时,我们常常需要输出文本到窗口上,Windows所有的文本字符或者图形输出都是通过图形设备接口(GDI)进行的,Windows的三大组件之一...

    程序员互动联盟
  • Fei-Fei Li, Fei Sha, Ke Yang, 余凯,漆远,雷鸣等关于人工智能和深度学习的讨论(先睹为快版)

    用户1737318
  • CentOS7上安装与配置开源堡垒机Teleport

    Teleport是一款简单易用的堡垒机系统,具有小巧、易用的特点,支持 RDP/SSH/SFTP/Telnet 协议的远程连接和审计管理。

    yuanfan2012

扫码关注云+社区

领取腾讯云代金券