Mina框架初识

Mina框架

      Apache Mina Server是一个网络通信应用框架,也就是说,它主要是对基于TCP/IPUDP/IP协议栈的通信框架(当然,也可以提供JAVA对象的序列化服务、虚拟机管道通信服务等),Mina可以帮助我们快速开发高性能、高扩展性的网络通信应用,Mina提供了事件驱动、异步(Mina的异步IO默认使用的是JAVA NIO作为底层支持)操作的编程模型。

      Mina同时提供了网络通信的Server端、Client端的封装,无论是哪端,Mina在整个网通通信结构中都处于如下的位置:可见MinaAPI将真正的网络通信与我们的应用程序隔离开来,你只需要关心你要发送、接收的数据以及你的业务逻辑即可。同样的,无论是哪端,Mina的执行流程如下所示:

         

(以上都为网络摘抄)

  • IoService 负责IO的相关工作。主要是隐藏底层的IO细节,每当有数据到达时,IOService会先调用底层IO接口读取数据,封装成IoBuffer,之后以事件的形式通知上层代码。
  • IOFilter  顾名思义,IO过滤器,主要处理数据包的解析,封装,过滤等。使业务代码和数据包的处理分开,逻辑更加清晰。
  • IOHandler是实现业务逻辑的地方,需要开发者自己实现这个接口IoHandlerAdapter。每一个IOServer都要制定一个IOhandler

      有关于Mina框架的类和方法有许多,我也是新手,不可能全部掌握,只能是用到的时候再去查。下边我写了一个简单例子。

     下边是模拟服务器端

public class EchoServer {
	public static void main(String[] args) {
		int PORT = 3333;
		NioSocketAcceptor acceptor = new NioSocketAcceptor();
		// 设置IOHandler处理业务逻辑
		acceptor.setHandler(new EchoHandler());
		// 编写过滤器
		acceptor.getFilterChain().addLast("codec",
				new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"),
						LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue())));
		try {
			// 绑定需要监听的端口号
			acceptor.bind(new InetSocketAddress(PORT));
			System.out.println("Listening on " + PORT);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

 下边是自己编写的IOHandler,需要继承IoHandlerAdapter

public class EchoHandler extends IoHandlerAdapter {
	@Override
	public void messageReceived(IoSession session, Object message) throws Exception {
		String s = message.toString();
		System.out.println("client send message is:" + s);
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd mm:hh:ss");
		Date date = new Date();
		session.write(sdf.format(date));// 返回当前时间的字符串
		if (s.endsWith("quit")) {
			session.closeNow();
			return;
		}
	}

	// 当一个客户端连接进入时
	@Override
	public void sessionOpened(IoSession session) throws Exception {
		System.out.println("incoming client:" + session.getRemoteAddress());
	}

	// 当一个客户端连接关闭时
	@Override
	public void sessionClosed(IoSession session) throws Exception {
		System.out.println("one client closed");
	}
}

如何验证呢:启动项目后,可以运行cmd打开命令窗口,输入telnet 127.0.0.1 3333

回车,就可以看到:

     

下边是控制台的显示: 

 

项目需要的jar包或者pom.xml可以去官网下载:http://mina.apache.org/downloads-mina.html

 


版权声明:本文为qq_37874262原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。