package com.dy.testClient.tcpConnect; import org.apache.mina.filter.codec.ProtocolCodecFactory; import org.apache.mina.filter.codec.ProtocolEncoder; import org.apache.mina.filter.codec.ProtocolDecoder; import org.apache.mina.core.session.IoSession; public class LocalCodecFactory implements ProtocolCodecFactory { private ProtocolEncoder encoder; private ProtocolDecoder decoder; public LocalCodecFactory() { encoder = new LocalEncoder(); decoder = new LocalDecoder(); } /** * 得到协议编码器 * @param ioSession 网络会话 * @return 协议编码器 */ @Override public ProtocolEncoder getEncoder(IoSession ioSession) { return encoder; } /** * 得到协议解码器 * @param ioSession 网络会话 * @return 协议解码器 */ @Override public ProtocolDecoder getDecoder(IoSession ioSession) { return decoder; } }