| 注册
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
jopen
10年前发布

Apache Mina开发手册

作者：chszs，转载需注明。博客主页：http://blog.csdn.net/chszs

一、介绍

Apache Mina是一个网络应用框架，简化用户开发高性能、高可扩展性的网络应用程序的难度。Mina提供了一个抽象的事件驱动的异步API，通过Java NIO实现各种传输协议如TCP/IP和UDP/IP。

 

Apache Mina经常用作：

1）NIO框架库

2）客户端/服务器通信框架库

3）网络Socket通信库

 

Apache Mina还伴随有不少子项目：

1）Asyncweb

构建于Apache Mina异步框架之上的HTTP服务器

2）FtpServer

一个FTP服务器

3）SSHd

一个Java库，支持SSHH协议

4）Vysper

一个XMPP服务器

 

二、Apache Mina下载

下载最新的Mina v2.0.8版

地址见：http://mina.apache.org/mina-project/downloads.html

 

三、用Mina开发时间服务器

说明一下，其实是基于官方的例子，略作了修改，因为发现官方的例子太陈旧，甚至包含了deprecated的方法。

 

1、先决条件

Apache Mina 2.0.8 Core

JDK 7

SLF4J+LOGBACK

 

2、项目依赖包

mina-core-2.0.8.jar

slf4j-api-1.6.6.jar

20140924172015724.jpg

 

3、编写基于Mina的Time服务器

    package ch.chiqms.server;                import java.io.IOException;        import java.net.InetSocketAddress;        import java.nio.charset.Charset;                 importorg.apache.mina.core.service.IoAcceptor;        importorg.apache.mina.core.session.IdleStatus;        importorg.apache.mina.filter.codec.ProtocolCodecFilter;        importorg.apache.mina.filter.codec.textline.TextLineCodecFactory;        importorg.apache.mina.filter.logging.LoggingFilter;        import org.apache.mina.transport.socket.nio.NioSocketAcceptor;                 public class MinaTimeServer {                 privatestatic final int PORT = 9123;                 publicstatic void main(String[] args){                           //监听连接的对象                           IoAcceptoracceptor = new NioSocketAcceptor();                                                     //配置过滤器                           //logger过滤器会输出所有的信息，例如新创建的会话、消息的接收、消息的发送、会话的关闭                           //codec过滤器会转换二进制活协议规定的数据为消息对象，这里是处理基于文本的消息                           acceptor.getFilterChain().addLast("logger",new LoggingFilter());                           acceptor.getFilterChain().addLast("codec",new ProtocolCodecFilter(                                             newTextLineCodecFactory(Charset.forName("UTF-8"))));                                                    //                           acceptor.setHandler(newTimeServerHandler());                                                     //设置输入缓冲区的大小和会话的IDLE熟悉                           acceptor.getSessionConfig().setReadBufferSize(2048);                           acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE,10);                                                     try{                                    acceptor.bind(newInetSocketAddress(PORT));                           }catch (IOException e) {                                    e.printStackTrace();                           }                 }        }
</div> </div>
4、编写Time服务的Handler
 
    package ch.chiqms.server;                 import java.text.SimpleDateFormat;        import java.util.Calendar;                 import org.apache.mina.core.service.IoHandlerAdapter;        importorg.apache.mina.core.session.IdleStatus;        importorg.apache.mina.core.session.IoSession;                 public class TimeServerHandler extendsIoHandlerAdapter {                          @Override                 publicvoid exceptionCaught(IoSession session, Throwable cause)                                    throwsException {                           cause.printStackTrace();                 }                          @Override                 publicvoid messageReceived(IoSession session, Object message) throws Exception {                           Stringstr = message.toString();                           if(str.trim().equalsIgnoreCase("quit")){                                    session.close(true);                                    return;                           }                           Calendartime = Calendar.getInstance();                           SimpleDateFormatdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");                           session.write(df.format(time.getTime()));                           System.out.println("TimeMessage written...");                 }                          @Override                 publicvoid sessionIdle(IoSession session, IdleStatus status) throws Exception {                           System.out.println("IDLE"+session.getIdleCount(status));                 }                 }
</div> </div>
5、运行MinaTimeServer

在命令行输入telnet 127.0.0.1 9123

20140924171923937.jpg

 

服务器端的输出也可以看到：

  1. SLF4J: Failed to load class"org.slf4j.impl.StaticLoggerBinder".  
  2. SLF4J: Defaulting to no-operation (NOP)logger implementation  
  3. SLF4J: Seehttp://www.slf4j.org/codes.html#StaticLoggerBinder for further details.  
  4. Time Message written...  
  5. Time Message written...  
  6. Time Message written... 

 本文由用户 jopen 自行上传分享，仅供网友学习交流。所有权归原作者，若您的权利被侵害，请联系管理员。
 转载本站原创文章，请注明出处，并保留原始链接、图片水印。
 本站是一个以用户分享为主的开源技术平台，欢迎各类分享！