Socket网络编程-Mina 实例

第一步： 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（）;

}
}第四步：客户端处理程序public class MinaClientHander extends IoHandlerAdapter {
@Override
public void exceptionCaught（IoSession session, Throwable cause）
throws Exception {
// TODO Auto-generated method stub
super.exceptionCaught（session, cause）;
}
@Override
public void messageReceived（IoSession session, Object message）
throws Exception {
// TODO Auto-generated method stub
super.messageReceived（session, message）;
}
@Override
public void messageSent（IoSession session, Object message） throws Exception {
// TODO Auto-generated method stub
super.messageSent（session, message）;
}
@Override
public void sessionClosed（IoSession session） throws Exception {
// TODO Auto-generated method stub
super.sessionClosed（session）;
}
@Override
public void sessionCreated（IoSession session） throws Exception {
// TODO Auto-generated method stub
super.sessionCreated（session）;
}
@Override
public void sessionIdle（IoSession session, IdleStatus status）
throws Exception {
// TODO Auto-generated method stub
super.sessionIdle（session, status）;
}
@Override
public void sessionOpened（IoSession session） throws Exception {
// TODO Auto-generated method stub
super.sessionOpened（session）;
}
}