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