package com.casic.handler; import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBufUtil; import io.netty.channel.ChannelHandlerContext; import io.netty.handler.codec.MessageToMessageDecoder; import lombok.extern.slf4j.Slf4j; import java.nio.charset.Charset; import java.util.List; /** * @description: 将从接口取到的数据编码 * @author: Stone * @create: 2019-01-11 15:15 **/ @Slf4j public class ReceiverDecoder extends MessageToMessageDecoder<ByteBuf> { @Override protected void decode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) throws Exception { log.info("hexBytes : " + ByteBufUtil.hexDump(msg) + ";" + " String : " + msg.toString(Charset.defaultCharset())); out.add(msg.toString(Charset.defaultCharset())); } }