mina mysql_Mina学习笔记(二)
昨天初步了解了Mina的主要層次結構并創建了服務端,今天創建一下客戶端,與服務端大同小異,一個接收,一個發送,也就是IoAcceptor/IoConnector。
1、先創建客戶端的程序,創建IoConnector:
package com.hylandtec.client;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.charset.Charset;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.service.IoConnector;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.LineDelimiter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketConnector;
import com.hylandtec.client.handler.MyClinetHandler;
/**
* Mina測試客戶端.
* @author boy
*
*/
public class MyClient {
private static final int SERVER_HOST = 9999;
public static void main(String[] args) {
//發送器
IoConnector connector = new NioSocketConnector();
//設置超時時間為30秒
connector.setConnectTimeoutMillis(30000);
//過濾器
connector.getFilterChain().addLast(
"codec",
new ProtocolCodecFilter(new TextLineCodecFactory(Charset
.forName("UTF-8"), LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue())));
//設置Handler,通過Handler的構造函數傳值給服務端
connector.setHandler(new MyClinetHandler("Hello world\r\nMy name is Mina.\r\nquit\r\n"));
//連接服務器
ConnectFuture future = connector.connect(new InetSocketAddress("localhost",SERVER_HOST));
// 等待連接創建完成
future.awaitUninterruptibly();
// 獲得session
IoSession session = future.getSession();
//打印出來瞅瞅
System.out.println(session);
}
}
2、創建IoHandler,IoHandler實現很簡單,只是通過構造函數給IoSession傳值過去
package com.hylandtec.client.handler;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
/**
* Mina 測試客戶端Handler.
* @author boy
*
*/
public class MyClinetHandler extends IoHandlerAdapter{
private final String values;
public MyClinetHandler(String values) {
this.values = values;
}
@Override
public void sessionOpened(IoSession session) throws Exception {
session.write(values);
}
}
3、首先運行昨天創建的服務端程序,啟動成功后,運行MyClient程序,觀察發現我們通過客戶端IoHandler設置?"Hello world\r\nMy name is Mina.\r\nquit\r\n" 被接收在控制臺打印出來。
Mina是不是很方便,這樣一個簡單的服務端和客戶端就創建成功了,并實現了通迅
總結
以上是生活随笔為你收集整理的mina mysql_Mina学习笔记(二)的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: change element 原始值_c
- 下一篇: mysql 优化设计库_数据库优化设计与