| | |
| | | package com.ard.tianyu.netty.handler;// MessageProtocolEncoder.java |
| | | |
| | | import com.ard.tianyu.netty.command.BaseCommand; |
| | | import com.ard.tianyu.netty.command.BaseCmd; |
| | | import io.netty.buffer.ByteBuf; |
| | | import io.netty.channel.ChannelHandlerContext; |
| | | import io.netty.handler.codec.MessageToByteEncoder; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | |
| | | import java.util.Arrays; |
| | | |
| | | @Slf4j |
| | | public class MessageProtocolEncoder extends MessageToByteEncoder<BaseCommand> { |
| | | public class MessageProtocolEncoder extends MessageToByteEncoder<BaseCmd> { |
| | | @Override |
| | | protected void encode(ChannelHandlerContext ctx, BaseCommand command, ByteBuf out) throws Exception { |
| | | protected void encode(ChannelHandlerContext ctx, BaseCmd command, ByteBuf out) throws Exception { |
| | | |
| | | command.encode(out); // 编码具体负载 |
| | | // 打印 |