第一步： Mina服务端 Server 的创建

public class MinaServer {
public static final int PORT = 1989;

private static final Logger logger = Logger.getLogger(MinaServer.class);
public static void main(String[] args) {
IoAcceptor ioAcceptor = null;
try {
//创建一个非阻塞 的Server端Socket
ioAcceptor = new NioSocketAcceptor();
//
ioAcceptor.getFilterChain().addLast(
"codec",
new ProtocolCodecFilter(new TextLineCodecFactory(Charset
.forName("UTF-8"),LineDelimiter.WINDOWS.getValue(),LineDelimiter.WINDOWS.getValue())));

//设置读取数据的缓冲区大小
ioAcceptor.getSessionConfig().setReadBufferSize(4096);
//设置10秒没有任何操作进入空闲状态

ioAcceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);

//设置业务逻辑处理程序
ioAcceptor.setHandler(new DefaultServerHander());

ioAcceptor.bind(new InetSocketAddress(PORT));

logger.info("在端口" + PORT + "启动Mina监听程序成功");

} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}


}
}

第二部： 创建Mina服务端处理程序

public class MinaServer {
public static final int PORT = 1989;

private static final Logger logger = Logger.getLogger(MinaServer.class);
public static void main(String[] args) {
IoAcceptor ioAcceptor = null;
try {
//创建一个非阻塞 的Server端Socket
ioAcceptor = new NioSocketAcceptor();
//
ioAcceptor.getFilterChain().addLast(
"codec",
new ProtocolCodecFilter(new TextLineCodecFactory(Charset
.forName("UTF-8"),LineDelimiter.WINDOWS.getValue(),LineDelimiter.WINDOWS.getValue())));

//设置读取数据的缓冲区大小
ioAcceptor.getSessionConfig().setReadBufferSize(4096);
//设置10秒没有任何操作进入空闲状态

ioAcceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);

//设置业务逻辑处理程序
ioAcceptor.setHandler(new DefaultServerHander());

ioAcceptor.bind(new InetSocketAddress(PORT));

logger.info("在端口" + PORT + "启动Mina监听程序成功");

} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

第三部：客户端连接程序代码

public class MinaClient {
private static final int PORT = 1989;
private static final String Host = "localhost";
public static void main(String[] args) {

// 创建一个非阻塞的客户端连接
IoConnector connector = new NioSocketConnector();

connector.getFilterChain().addLast(
"codec",
new ProtocolCodecFilter(new TextLineCodecFactory(Charset
.forName("UTF-8"),LineDelimiter.WINDOWS.getValue(),LineDelimiter.WINDOWS.getValue())));


connector.setHandler(new MinaClientHander());

ConnectFuture connectFuture = connector.connect(new InetSocketAddress(Host, PORT));

connectFuture.awaitUninterruptibly(); //等待连接创建完成

IoSession session = connectFuture.getSession();

session.write("高江涛");

session.getCloseFuture().awaitUninterruptibly(); //等待连接断开
connector.dispose();

}
}

第四步： 客户端处理程序