diff --git a/src/main/java/com/example/mina/client/box/aeroflex/AeroflexClient.java b/src/main/java/com/example/mina/client/box/aeroflex/AeroflexClient.java index 477cdac..a336dce 100644 --- a/src/main/java/com/example/mina/client/box/aeroflex/AeroflexClient.java +++ b/src/main/java/com/example/mina/client/box/aeroflex/AeroflexClient.java @@ -1,7 +1,6 @@ package com.example.mina.client.box.aeroflex; import com.example.mina.client.base.AbstractClient; -import com.example.mina.client.coder.ByteFactory; import com.example.mina.client.entity.AbstractClientMessage; import com.example.mina.server.entity.AeroflexDataBuffer; @@ -13,7 +12,7 @@ public class AeroflexClient extends AbstractClient { @Override protected void init(AbstractClientMessage abstractClientMessage) { - protocolCodecFactory = new ByteFactory(); + protocolCodecFactory = new AeroflexByteFactory(); abstractVirtualBoxClientHandler = new AeroflexClientHandler(abstractClientMessage, hardwareDataBuffer); } diff --git a/src/main/java/com/example/mina/client/coder/ByteDecoder.java b/src/main/java/com/example/mina/client/coder/ByteDecoder.java deleted file mode 100644 index ab119bb..0000000 --- a/src/main/java/com/example/mina/client/coder/ByteDecoder.java +++ /dev/null @@ -1,29 +0,0 @@ -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); - } -} diff --git a/src/main/java/com/example/mina/client/coder/ByteEnCoder.java b/src/main/java/com/example/mina/client/coder/ByteEnCoder.java deleted file mode 100644 index e2a50f9..0000000 --- a/src/main/java/com/example/mina/client/coder/ByteEnCoder.java +++ /dev/null @@ -1,39 +0,0 @@ -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.ProtocolEncoder; -import org.apache.mina.filter.codec.ProtocolEncoderAdapter; -import org.apache.mina.filter.codec.ProtocolEncoderOutput; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * @author dy - * @date 2021/3/3 - */ -public class ByteEnCoder extends ProtocolEncoderAdapter { - //用于打印日志信息 - private final static Logger log = LoggerFactory - .getLogger(ProtocolEncoder.class); - - //编码 将数据包转成字节数组 - @Override - public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception { - byte[] bytes = (byte[]) message; - - IoBuffer buffer = IoBuffer.allocate(bytes.length); - buffer.setAutoExpand(true); - - // 将数据放入缓冲IoBuffer - buffer.put(bytes); - // 写状态切换到读状态 - buffer.flip(); - - out.write(buffer); -// out.flush(); -// -// buffer.free(); - } - -} diff --git a/src/main/java/com/example/mina/client/coder/ByteFactory.java b/src/main/java/com/example/mina/client/coder/ByteFactory.java deleted file mode 100644 index 32e47ed..0000000 --- a/src/main/java/com/example/mina/client/coder/ByteFactory.java +++ /dev/null @@ -1,34 +0,0 @@ -package com.example.mina.client.coder; - -import org.apache.mina.core.session.IoSession; -import org.apache.mina.filter.codec.ProtocolCodecFactory; -import org.apache.mina.filter.codec.ProtocolDecoder; -import org.apache.mina.filter.codec.ProtocolEncoder; - -/** - * @author dy - * @date 2021/3/3 - */ -public class ByteFactory implements ProtocolCodecFactory { - private final ByteDecoder decoder; - private final ByteEnCoder encoder; - - //构造 - public ByteFactory() { - encoder = new ByteEnCoder(); - decoder = new ByteDecoder(); - } - - @Override - public ProtocolDecoder getDecoder(IoSession arg0) throws Exception { - // TODO Auto-generated method stub - return decoder; - } - - @Override - public ProtocolEncoder getEncoder(IoSession arg0) throws Exception { - // TODO Auto-generated method stub - return encoder; - } - -} -- libgit2 0.21.2