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