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());
    }

}