package com.dy.rtuMw3rd.tcp4Bjnl;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
import org.apache.mina.core.buffer.IoBuffer;
|
import org.apache.mina.core.session.IoSession;
|
import org.apache.mina.filter.codec.ProtocolEncoderAdapter;
|
import org.apache.mina.filter.codec.ProtocolEncoderOutput;
|
|
import java.io.IOException;
|
|
/**
|
* @Author: liurunyu
|
* @Date: 2025/03/18 14:20
|
* @Description
|
*/
|
public class NetDataEncoder extends ProtocolEncoderAdapter {
|
|
private static final Logger log = LogManager.getLogger(NetDataEncoder.class) ;
|
|
/**
|
* 对数据进行编码，以备网络传输
|
*/
|
public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws IOException, Exception{
|
byte[] data = (byte[])message;
|
//log.info("上行数据：" + ByteUtil.bytes2Hex(data, true));
|
|
out.write(IoBuffer.allocate((data==null?0:data.length), false).put(data).flip());
|
}
|
|
}
|
