本文主要是介绍Mina初识(二),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
Apache MINA是Apache组织的一个优秀的项目。主要通过Apache Mina2.0来实现TCP协议长连接和短连接应用。长连接:同信双方长期保持一个连接状态不断开,除非发生异常,需要消耗更多IO资源。
短连接:通信双方不是保持一个长期连接状态,当客户端发起http请求,服务端处理http请求,当服务器处理完成后,返回客户端数据后就断开连接,对于下次的连接请求需要重新发起连接请求,较为常用。
IoService 是一mina中非常重要的一个接口,他贯穿了整个mina 通信流程,建立远程连接、发送消息、连接等,实现了对网络通信的客户端和服务端的抽象,用于描述客户端的子接口
IOConncetion,用于描述服务器的子接口IOAcceptor,也可以管理网络通信客户端和服务端,连接双方对话的session,也可以添加过滤器。
IoService接口提供了一些连接常用接口,在server端IoAcceptor继承了IoService,在client端 IoConnector 继承了IoService 完成客户端功能,IoService是创建服务的顶层接口,无论客户端还是服务端,均由其继承实现。
IOFilter:对应用程序和网络传输,二进制文件之间的相互转化,可以用做日志,消息转化功能。
服务端:
static int PORT =7000;static IOAcceptor accept=null;public static void main(String[] args){try{acccept = new NioSocketAcceptor();accept.getFilterChain().addLast("codec",new ProtocolCodeFilter(new TextLineCodeFactory(Charset.forname("UTF- 8"),LineDelimiter.WINDOWS.getValue (),LineDelimiter.WINDOWS.getValue())));accept.getSessionConfig().setReadBufferSize(1024);accept.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE,10);accept.setHandler(new MyServerHandler());accept.bind(new InetSocketAddress(PORT));
}catch(Exception e){........}}}}
客户端:
public class MinaClient{private static String host ="127.0.0.1" ;private static int PORT =7080;public static void main(String[] args){IoSession session =null;IoConncetion conncetion new NioSocketConnector();connector setConnecTimeout(3000);connector.getFilterChain().addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-
8"),LineDelimiter。WINDOWS.getValue(),LineDelimiter。WINDOWS.getValue()));connector.setHandler(new MyClientHandler);ConnectFuture future = connector.connect(new InetSocketAddress(host,port));future.awaitUninterrupribly();session = future.getSession();session.getCloseFuture().awaitUninterrupribly();connector.diapose();}}
}
这篇关于Mina初识(二)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!