mina nio server与io client通讯

网上的例子多数是两端同为nio
对于nio server 与 io client的通讯比较少
改造了一下 看下面代码
server端 共两个类

public class MainServer {
	public static void main(String[] args) throws Exception {
		SocketAcceptor socketAcceptor = new NioSocketAcceptor();
		DefaultIoFilterChainBuilder chain = socketAcceptor.getFilterChain();
		//设定这个过滤器将一行一行(/r/n)的读取数据
		chain.addLast( "myChain", new ProtocolCodecFilter(new TextLineCodecFactory()) );
		
		socketAcceptor.setHandler(new NioServerHandler());
		
		int port = 9988;
		socketAcceptor.bind(new InetSocketAddress(port));
		
		System.out.println("Mina Server is Listing on:= " + port);
	}
}

SocketAcceptor 相当如 ServerSocket类  实现服务端的接受功能
DefaultIoFilterChainBuilder 是一个 IoFilter链，可以对接受到数据进行处理 跟 http filter 类似
TextLineCodecFactory的意思是按行读取，每读取一行就传递给IoHandler来处理
socketAcceptor.setHandler(new NioServerHandler()); 绑定请求处理器，客户端的请求有NioServerHandler处理
更多 http://blog.csdn.net/sinboy/archive/2009/03/11/3981680.aspx

好下面来看看 NioServerHandler

public class NioServerHandler implements IoHandler{
	@Override
	public void sessionOpened(IoSession session) throws Exception {
		System.out.println("<server> client connected : "+session.getRemoteAddress());
	}
	
	public void sessionClosed(IoSession session){
		System.out.println("<server> client disconnection" + session.getRemoteAddress());
	}
	
	public void messageReceived(IoSession session, Object message) throws Exception{
		String s = (String)message;
		System.out.println("<server> received message:" + s);
		session.write("<server> Roger" );
		
	}
  //省略若干接口
}

重点是messageReceived方法 接受到的数据通过 message 参数传过来
message参数是Ojbect类型 就是说你可以吧接受到的数据在Filter中封装成任何你希望的类型然后传递过来处理

ok server端就讲到这里

client端
public class IoClient {

public static void main(String[] args) throws Exception {
Socket socket = new Socket("localhost", 9988);

PrintWriter pw = new PrintWriter(socket.getOutputStream());
pw.println("hello server");
pw.flush();

BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

System.out.println(reader.readLine());

socket.close();
}

}

1 创建一个socket
2 发送数据到server端 这里用pw.println("hello server");方法一行一行的发送
3 接受server返回的数据
ok！ run it

这里有一个问题 一点要加

pw.flush();

否则数据不会被提交 或者用

PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);