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