改正发布判断bug

zhubaomin

2025-04-17 d711c899e42e8cacee3ed6408f4c57e91c962dc8

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/tcp/DataEncoder.java

New file
@@ -0,0 +1,19 @@
package com.dy.common.mw.channel.tcp;

import org.apache.mina.filter.codec.ProtocolEncoderOutput;
import org.apache.mina.filter.codec.ProtocolEncoderAdapter;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;

public class DataEncoder extends ProtocolEncoderAdapter {
	
   //private static Logger log = LogManager.getLogger(DataEncoder.class.getName()) ;

    public void encode(IoSession session, Object message, ProtocolEncoderOutput out){
        byte[] data = (byte[])message;
        
        //log.info("下行数据：" + ByteUtil.bytes2Hex(data, true));
        
        out.write(IoBuffer.allocate((data==null?0:data.length), false).put(data).flip());
    }
 }