ByteDecoder.java
831 Bytes
package com.example.mina.client.coder;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolDecoder;
import org.apache.mina.filter.codec.ProtocolDecoderAdapter;
import org.apache.mina.filter.codec.ProtocolDecoderOutput;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author dy
* @date 2021/3/3
*/
public class ByteDecoder extends ProtocolDecoderAdapter {
//打印日志信息
private final static Logger log = LoggerFactory
.getLogger(ProtocolDecoder.class);
@Override
public void decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) throws Exception {
int limit = in.limit();
byte[] bytes = new byte[limit];
in.get(bytes);
out.write(bytes);
}
}