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