netty案例，netty4.1基础入门篇九《自定义编码解码器》-阿里云开发者社区

netty案例，netty4.1基础入门篇九《自定义编码解码器》

2022-01-12 165

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

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

前言介绍

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

环境准备

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结束

/**
 * 自定义解码器
 * 虫洞栈：https://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛关注获取学习源码｝
 * 虫洞群：①群5398358 ②群5360692
 * Create by fuzhengwei on 2019
 */
public class MyDecoder extends ByteToMessageDecoder {
    @Override
    protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf in, List<Object> out) throws Exception {
        int size = in.readableBytes();
        byte[] data = new byte[size];
        in.readBytes(data);
        byte begin = data[0];     //开始符02
        byte end = data[size - 1];//结束符03
        //无开始符，只有结束符，数据丢包
        if (begin != 0x02 && end == 0x03){
            System.out.println("公众号：bugstack虫洞栈 提示；byteBuf数据，无开始符，只有结束符，数据丢包。");
            channelHandlerContext.writeAndFlush("error");
            return; //直接返回，不置位指针
        }
        //有开始符，无结束符号，数据半包。置位指针，接收余下数据
        if (begin != 0x02 || end != 0x03) {
            in.resetReaderIndex();
            System.out.println("公众号：bugstack虫洞栈 提示；byteBuf数据，有开始符，无结束符号，数据半包。置位指针，接收余下数据。");
            return;
        }
        //数据完整，解析处理
        System.out.println(JSON.toJSONString(data));
        //越过02 03位
        ByteBuf copy = in.copy(1, size - 1);
        //转换
        String msg = copy.toString(Charset.forName("GBK"));
        //填充
        out.add(msg);
    }
}

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

/**
 * 自定义编码器
 * 虫洞栈：https://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛关注获取学习源码｝
 * 虫洞群：①群5398358 ②群5360692
 * Create by fuzhengwei on 2019
 */
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

/**
 * 虫洞栈：https://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛关注获取学习源码｝
 * 虫洞群：①群5398358 ②群5360692
 * Create by fuzhengwei on 2019
 */
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

/**
 * 虫洞栈：https://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛关注获取学习源码｝
 * 虫洞群：①群5398358 ②群5360692
 * Create by fuzhengwei on 2019
 */
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. {关注公众号：bugstack虫洞栈，获取源码}
链接报告开始 {公众号：bugstack虫洞栈 >获取学习源码}
链接报告信息：有一客户端链接到本服务端
链接报告IP:192.168.1.121
链接报告Port:7397
链接报告完毕
"AmhpILmr1tq6xaO6YnVnc3RhY2uz5ra01bsgAw=="
2019-08-18 15:32:47 接收到消息：hi 公众号：bugstack虫洞栈 
"AmhpILmr1tq6xaO6YnVnc3RhY2uz5ra01bsgAw=="
2019-08-18 15:32:48 接收到消息：hi 公众号：bugstack虫洞栈 
"AmhpILmr1tq6xaO6YnVnc3RhY2uz5ra01bsgAw=="
2019-08-18 15:32:49 接收到消息：hi 公众号：bugstack虫洞栈 
"AmhpILmr1tq6xaO6YnVnc3RhY2uz5ra01bsgAw=="
2019-08-18 15:32:49 接收到消息：hi 公众号：bugstack虫洞栈 
"AmhpILmr1tq6xaO6YnVnc3RhY2uz5ra01bsgAw=="
2019-08-18 15:32:50 接收到消息：hi 公众号：bugstack虫洞栈 
"AmhpILmr1tq6xaO6YnVnc3RhY2uz5ra01bsgAw=="
2019-08-18 15:32:51 接收到消息：hi 公众号：bugstack虫洞栈 
"AmhpILmr1tq6xaO6YnVnc3RhY2uz5ra01bsgAw=="
2019-08-18 15:32:51 接收到消息：hi 公众号：bugstack虫洞栈 
Process finished with exit code -1

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