文章目录

• 前言
• 一、ByteToMessageDecoder
• 二、使用步骤
• • 1.netty基本配置这里不再阐述
  • 2.编写ServerChannelInitializer
  • 3.编写ByteToNbMessageDecoder
  • • 这里有三个参数ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List list
    • channelHandlerContext这里不详细叙述
    • ByteBuf 对象
    • List list
• 总结
• • 关键点就在于继承ByteToNbMessageDecoder类，重写解析方法，处理缓冲区数据解析成自己想要的，放入list交给下一个处理器进行处理

前言

Netty是由JBOSS提供的一个java开源框架，现为 Github上的独立项目。Netty提供异步的、事件驱动的网络应用程序框架和工具，用以快速开发高性能、高可靠性的网络服务器和客户端程序。
也就是说，Netty 是一个基于NIO的客户、服务器端的编程框架，使用Netty 可以确保你快速和简单的开发出一个网络应用，例如实现了某种协议的客户、服务端应用。Netty相当于简化和流线化了网络应用的编程开发过程，例如：基于TCP和UDP的socket服务开发。

提示：以下是本篇文章正文内容，下面案例可供参考

一、ByteToMessageDecoder

ByteToMessageDecoder是解码器, 具有将字节解码成消息, 所以我们可以自定义实现ByteToMessageDecoder，编写解析代码，实现我们自己的解码器

二、使用步骤

1.netty基本配置这里不再阐述

2.编写ServerChannelInitializer

配置处理管道，见自定义解析器加入
代码如下（示例）：

public class ServerChannelInitializer extends ChannelInitializer<SocketChannel> {    @Override    protected void initChannel(SocketChannel socketChannel) throws Exception { ChannelPipeline pipeline = socketChannel.pipeline(); //添加IdleStateHandler，120s检测一次读事件 pipeline.addLast(new IdleStateHandler(120, 0, 0, TimeUnit.SECONDS)); //添加自定义解析器 pipeline.addLast("handler",new ByteToNbMessageDecoder());    }}

3.编写ByteToNbMessageDecoder

/** * @Auther: jiliugang * @Date: 2020/10/19 10:33 * @Description: 自定义协议解析 */public class ByteToNbMessageDecoder  extends ByteToMessageDecoder {    @Override    protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {    //这里协商具体的解析代码 //deal(byteBuf,list,channelHandlerContext);    }    @Override    public void channelRegistered(ChannelHandlerContext ctx) throws Exception { super.channelRegistered(ctx); System.out.println("连接成功");    }    /**     * 心跳检测处理     * @param ctx     * @param evt     * @throws Exception     */    @Override    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception { if (evt instanceof IdleStateEvent) {     IdleState state = ((IdleStateEvent) evt).state();     if (state == IdleState.READER_IDLE) {  // 在规定时间内没有收到客户端的上行数据, 主动断开连接  disconnect();  ctx.channel().disconnect();     } } else {     super.userEventTriggered(ctx, evt); }    }    /**     * 断开连接处理     * @param ctx     * @throws Exception     */    @Override    public void channelInactive(ChannelHandlerContext ctx) throws Exception { disconnect(); super.channelInactive(ctx);    }    //断开连接处理    public void disconnect(){ System.out.println("断开连接！");    }}

这里有三个参数ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List list

channelHandlerContext这里不详细叙述

ByteBuf 对象

ByteBuf 对象
这个有我之前文章的可以看看
连接数据全部都暂存在这个缓冲区中，所以我们要对里面的数据进行处理。可以先看文章理解ByteBuf对象
我们一边读取里面的数据进行处理，最终的处理完成的有用的信息就放入List中

List list

最终处理好的数据我们可以放在这个list中，他会携带着解析过的数据叫个下一个处理器

总结

关键点就在于继承ByteToNbMessageDecoder类，重写解析方法，处理缓冲区数据解析成自己想要的，放入list交给下一个处理器进行处理