Netty——高级内置解码器、编码器、ByteBuf

/**
 * 解码
 * DelimiterBasedFrameDecoder  防止 沾包
 * @author flm 
 * 2017年10月30日
 */
public class IODecoder extends DelimiterBasedFrameDecoder {

    public static final AttributeKey<DeviceSession> KEY = AttributeKey.valueOf("IO"); // 保存
    private static final Logger log = Logger.getLogger(IODecoder.class);

    // 防止 沾包 分隔符
    private static ByteBuf delimiter = Unpooled.copiedBuffer("\n".getBytes());  // 沾包 分割符 \n
    private static int maxFrameLength = 1024 * 6; 　　　　　　　　　　　　　　　　　　//数据大小

    
    
    public IODecoder() {
        super(maxFrameLength, delimiter);
    }

    /**
     * 重新 自定义解码
     */
    @Override
    protected Object decode(ChannelHandlerContext ctx, ByteBuf buffer) throws Exception {
        // 对数据  buffer 解码
        return super.decode(ctx, buffer);
    }
｝

/**
 * 指令 编码 
 * MessageToMessageEncoder<PushEntity>
 * 把 PushEnty 编码为string
 * @author flm
 * 2017年11月3日
 */
public class IOEncoder extends MessageToMessageEncoder<PushEntity> {

    private static final Logger LOG = Logger.getLogger(IOEncoder.class);

    
    public IOEncoder() {
        super();
    }
    
    
    /**
     * 重写 编码
     */
    @Override
    protected void encode(ChannelHandlerContext ctx, PushEntity msg, List<Object> out) throws Exception {
        try {
　　　　　　　　PushEntity push = (PushEntity) msg;

            }
    
            // 以字符串 形式 发送
            out.add(ByteBufUtil.encodeString(ctx.alloc(), CharBuffer.wrap(msg.toString()), Charset.defaultCharset()));
            
            
        } catch (Exception e) {
            
            e.printStackTrace();
            
        }
    }
}
    

/** 
 *  
 * 功能描述：协议消息解码器  
 * 把 btyeBuf 转为 RootMessage对象
 *     
 */
public class GT06MsgDecoder extends LengthFieldBasedFrameDecoder
{
    public GT06MsgDecoder()
    {
        super(65540, 2, 1, 2, 0);   //继承
    }


　　/*
　　* 重写 解码
　　*/
    @Override
    public Object decode(ChannelHandlerContext ctx, ByteBuf in) throws Exception
    {
        ByteBuf frame = (ByteBuf) super.decode(ctx, in);
        
　　　　 // 读取 ByteBuf 是根据 位数来读取的
        try
        {
            if (frame == null)
            {
                return null;
            }
            
            int frameLen = frame.readableBytes();
            
            // 起始位
            byte[] header = new byte[GT06Constant.START_DELIMITER_LEN];
            
            frame.readBytes(header);
            
            // 是否是0x79 0x79 开头的扩展包
            boolean extPacket = false;
            
            if(Arrays.equals(GT06Constant.PACKET_START_EXT, header))
            {
                extPacket = true;
            }
            
            int contentLen = MessageUtils.getContentLen(frameLen, extPacket);
            
            // 跳过包长度
            frame.skipBytes(MessageUtils.getPacketSizeLen(extPacket));
            
            // 消息内容
            byte[] msgContent = new byte[contentLen];
            
            // 消息序列号
            byte[] sequence = new byte[GT06Constant.MESSAGE_SERIAL_LEN];
            
            // crc校验码
            byte[] crc = new byte[GT06Constant.CRC_ITU_LEN];
            
            // 终止符
            byte[] endDelimiter = new byte[GT06Constant.END_DELIMITER_LEN];

    　　　　　return new RootMessage(action, sequence, msgContent);
        }
        finally
        {
            if(frame != null)
            {
                frame.release();
            }
        }
    }