下午那篇博客我们讲到了Mina的客户端的开发，如果还有没看过的同学可以看一下，。现在，我们来学习一下，Mina的服务器的开发。

 

　　一、首先看一下，我的服务器的代码图片：

　　　　　  服务器代码我是在MyEclipse下写的。

 

 

　　　二、服务器的整体思路：（同客户端差不多）

• • • 首先，产生一个socket接收对象（SocketAcceptor），用于接收客户端的连接请求；
    • 然后，对这个接收器添加我们的I/O过滤器（SSL加密、日志过滤器、编码过滤器等，这里注意，如果添加SSL过滤器，那么一定要第一个添加，否则无法对数据加密）；
    • 接下来，为连接设置I/O处理器，顾名思义就是处理接收到的消息（这里我们只能设置一个处理器，如果有设置多个，那么默认进入到最后一个I/O处理器中进行处理）；
    • 最后，将服务器绑定到某端口（如：3456，最好是1024以上，因为1024以下的端口系统占用）。

 

　　　三、正式编码

　　　　　　这里我同样展示几个比较重要的类来详细说明一下：

• • • MinaServer.Java
      1 package com.mina.example; 2  3 import java.io.IOException; 4 import java.net.InetSocketAddress; 5  6 import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder; 7 import org.apache.mina.core.session.IdleStatus; 8 import org.apache.mina.filter.codec.ProtocolCodecFilter; 9 import org.apache.mina.filter.logging.LoggingFilter;10 import org.apache.mina.filter.ssl.SslFilter;11 import org.apache.mina.transport.socket.SocketAcceptor;12 import org.apache.mina.transport.socket.nio.NioSocketAcceptor;13 14 import com.mina.charset.CharsetFactory;15 import com.mina.hanlder.MsgHanler;16 import com.mina.ssl.SSLContextGenerator;17 18 /**19  * 
      20  * Project Name:MinaServer21  * Package:com.mina.example22  * FileName:MinaServer.java23  * Purpose:服务器24  * Create Time: 2014-8-19 下午4:59:5525  * Create Specification:26  * Modified Time:27  * Modified by:28  * Modified Specification:29  * Version: 1.030  * 
      31  * 32  * @author myp33  */34 public class MinaServer {35 36     private SocketAcceptor acceptor;37 38     public MinaServer() {39         /*40          * 1.创建一个socket连接,连接到服务器41          */42         acceptor = new NioSocketAcceptor();43     }44 45     public boolean start() {46         /*47          * 获取过滤器链,用于添加过滤器48          */49         DefaultIoFilterChainBuilder filterChain = acceptor.getFilterChain();50 51         /*52          * 2.为连接添加过滤器，SSL、日志、编码过滤器53          */54         // SSLContextGenerator是我们自己写的一个SSL上下文产生器,稍后会讲到55         SslFilter sslFilter = new SslFilter(56                 new SSLContextGenerator().getSslContext());57         // a.ssl过滤器，这个一定要第一个添加，否则数据不会进行加密58         filterChain.addLast("sslFilter", sslFilter);59         System.out.println("SSL support is added..");60         // b.添加日志过滤器61         filterChain.addLast("loger", new LoggingFilter());62         // c.添加字符的编码过滤器63         filterChain.addLast("codec", new ProtocolCodecFilter(64                 new CharsetFactory()));65 66         /*67          * 3.设置消息处理器，用于处理接收到的消息68          */69         acceptor.setHandler(new MsgHanler());70         // 设置空闲的时间是30s71         acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 30);72         try {73             /*74              * 4.将服务器绑定到3456端口75              */76             acceptor.bind(new InetSocketAddress(3456));77         } catch (IOException e) {78             e.printStackTrace();79             return false;80         }81         return true;82     }83 84     public static void main(String[] args) {85         MinaServer server = new MinaServer();86         server.start();87     }88 }

      MinaServer就是按照第二步当中的流程走过来的；所以编程的时候最主要的是整体的思路，思路明白了那么编程就会变得异常效率。

 

• • • SSLContextGenerator.Java（同客户端的代码，看过客户端的可以不看）
      1 package com.mina.ssl; 2  3 import java.io.File; 4 import java.security.KeyStore; 5  6 import javax.net.ssl.SSLContext; 7  8 import org.apache.mina.filter.ssl.KeyStoreFactory; 9 import org.apache.mina.filter.ssl.SslContextFactory;10 11 /**12  * 
      13  * Project Name:SSLContextGenerator14  * Package:com.example.mina.ssl15  * FileName:SSLContextGenerator.java16  * Purpose:SSL加密的上下文产生器17  * Create Time: 2014-8-19 下午4:41:5518  * Create Specification:19  * Modified Time:20  * Modified by:21  * Modified Specification:22  * Version: 1.023  * 
      24  * 25  * @author myp26  */27 public class SSLContextGenerator {28 29     /**30      * 这个方法，通过keystore和truststore文件返回一个SSLContext对象31      * 32      * @return33      */34     public SSLContext getSslContext() {35         SSLContext sslContext = null;36         try {37             /*38              * 提供keystore的存放目录，读取keystore的文件内容39              */40             File keyStoreFile = new File("C:/Users/Myp/keystore.jks");41 42             /*43              * 提供truststore的存放目录，读取truststore的文件内容44              */45             File trustStoreFile = new File("C:/Users/Myp/truststore.jks");46 47             if (keyStoreFile.exists() && trustStoreFile.exists()) {48                 final KeyStoreFactory keyStoreFactory = new KeyStoreFactory();49                 System.out.println("Url is: " + keyStoreFile.getAbsolutePath());50                 keyStoreFactory.setDataFile(keyStoreFile);51 52                 /*53                  * 这个是当初我们使用keytool创建keystore和truststore文件的密码,也是上次让你们一定要记住密码的原因了54                  */55                 keyStoreFactory.setPassword("123456");56 57                 final KeyStoreFactory trustStoreFactory = new KeyStoreFactory();58                 trustStoreFactory.setDataFile(trustStoreFile);59                 trustStoreFactory.setPassword("123456");60 61                 final SslContextFactory sslContextFactory = new SslContextFactory();62                 final KeyStore keyStore = keyStoreFactory.newInstance();63                 sslContextFactory.setKeyManagerFactoryKeyStore(keyStore);64 65                 final KeyStore trustStore = trustStoreFactory.newInstance();66                 sslContextFactory.setTrustManagerFactoryKeyStore(trustStore);67                 sslContextFactory68                         .setKeyManagerFactoryKeyStorePassword("123456");69                 sslContext = sslContextFactory.newInstance();70                 System.out.println("SSL provider is: "71                         + sslContext.getProvider());72             } else {73                 System.out74                         .println("Keystore or Truststore file does not exist");75             }76         } catch (Exception ex) {77             ex.printStackTrace();78         }79         return sslContext;80     }81 }

      如果不知道如何创建keystore和truststore文件的话，请查看我的这篇博客：

 

• • • MsgHandler.Java（同客户端的代码，看过客户端的可以不看）
      1 package com.mina.hanlder; 2  3 import org.apache.mina.core.service.IoHandlerAdapter; 4 import org.apache.mina.core.session.IdleStatus; 5 import org.apache.mina.core.session.IoSession; 6 import org.slf4j.Logger; 7 import org.slf4j.LoggerFactory; 8  9 /**10  * 
      11  * Project Name:MsgHanler12  * Package:com.mina.handler13  * FileName:MsgHanler.java14  * Purpose:I/O消息处理器,从这里我们就可以看出Mina是事件驱动的15  * Create Time: 2014-8-19 下午4:55:5516  * Create Specification:17  * Modified Time:18  * Modified by:19  * Modified Specification:20  * Version: 1.021  * 
      22  * 23  * @author myp24  */25 public class MsgHanler extends IoHandlerAdapter {26     private static final Logger log = LoggerFactory.getLogger(MsgHanler.class);27 28     @Override29     public void exceptionCaught(IoSession session, Throwable cause)30             throws Exception {31         // 出现异常32         log.error("--------exception--------");33         super.exceptionCaught(session, cause);34     }35 36     @Override37     public void messageReceived(IoSession session, Object message)38             throws Exception {39         // 从服务器中接收到消息后的处理40         log.info("--------msg receive--------");41         log.info("Message:{}", message.toString());42         super.messageReceived(session, message);43     }44 45     @Override46     public void messageSent(IoSession session, Object message) throws Exception {
                // 往服务器中发送消息47         log.info("Message Send {}", message.toString());48         super.messageSent(session, message);49     }50 51     @Override52     public void sessionIdle(IoSession session, IdleStatus status)53             throws Exception {54         // session处于空闲的时候55         log.info("当前连接{}处于空闲状态：{}", session.getRemoteAddress(), status);56     }57 58     @Override59     public void sessionClosed(IoSession session) throws Exception {60         // session关闭61         log.info("Session closed {}->{}", session.getId(),62                 session.getRemoteAddress());63         super.sessionClosed(session);64     }65 }

      基本上我们最主要的就是对在I/O处理器这里对收到的消息进行处理，也是编程的核心所在！

 

 

　　　四、向服务器发送请求

　　　　　　　　1.打开CMD命令；

 

　　　　　　　　2.telnet 你的IP 端口号（如：telnet 192.168.191.1 3456）；

 

　　　　　　　　3.然后就可以往服务器输入数据，以换行结束输入（这是因为Mina是以换行来判断输入是否结束的）；

　　　　　　　　  注意：如果遇到cmd命令提示无法识别telnet这个命令的话，你可以这样设置：打开控制面板--》程序和功能--》打开或关闭Windows功能--》勾选然后点击确定即可。如下图：  

　　　　　　　　　　　　　　 

 

　　　　　　　　4.然后我们可以看到MyEclipse的控制台输出的信息：可以参考下图（这里我将ssl加密注释了）：

                         

 

　　　五、注意事项（同客户端，看过客户端的可以不看）

1. 1. 关于Mina的日志过滤器误区，不知道会不会有同学有这样的认为，我们的log4j-1.2.17.jar就是我们的mina的日志，那么我告诉你你理解错了，log4j是Apache的一个开源项目，通过使用Log4j，我们可以控制日志信息输出。Mina的日志过滤器是使用了slf4j-log4j12-1.7.6.jar、slf4j-api-1.7.6.jar包；                                  
   2. log4j的配置问题，如果需要使用Apache的开源项目，我们需要配置log4j.properties文件，下面是他的代码；
      1 log4j.rootCategory=INFO, stdout , R    2     3 log4j.appender.stdout=org.apache.log4j.ConsoleAppender    4 log4j.appender.stdout.layout=org.apache.log4j.PatternLayout    5 log4j.appender.stdout.layout.ConversionPattern=[QC] %p [%t] %C.%M(%L) | %m%n    6      7 log4j.appender.R=org.apache.log4j.DailyRollingFileAppender    8 log4j.appender.R.File=D\:\\Mina\\logs\\server.log 9 log4j.appender.R.layout=org.apache.log4j.PatternLayout   10 1log4j.appender.R.layout.ConversionPattern=%d-[TS] %p %t %c - %m%n   11    12 log4j.logger.com.neusoft=DEBUG   13 log4j.logger.com.opensymphony.oscache=ERROR   14 log4j.logger.net.sf.navigator=ERROR   15 log4j.logger.org.apache.commons=ERROR   16 log4j.logger.org.apache.struts=WARN   17 log4j.logger.org.displaytag=ERROR   18 log4j.logger.org.springframework=DEBUG   19 log4j.logger.com.ibatis.db=WARN   20 log4j.logger.org.apache.velocity=FATAL   21    22 log4j.logger.com.canoo.webtest=WARN   23    24 log4j.logger.org.hibernate.ps.PreparedStatementCache=WARN   25 log4j.logger.org.hibernate=DEBUG   26 log4j.logger.org.logicalcobwebs=WARN

      我们可以再这里设置我们的日志输出目录：log4j.appender.R.File=D:\\Mina\\logs\\server.log                                                                                           

　　　　　 3. SSL加密中，如果不知道如何使用keystore生成keystore和truststore文件，可以查看这篇博客：       

　　　　 　4. 在添加过滤器的时候，处理的顺序是按照添加过滤器的顺序；                                                                                                                                

　　　　　 5. Mina在使用过滤器的时候，只要在需要的地方添加就可以了，不一定是服务器、客户端都要添加的。就是说，服务器、客户端编程的时候服务器有这个过滤器，客户端可以有也可以没有。

　　

　　

　　　六、Mina服务器源码下载

　　　　　　　　

　　　　　　　　下载后导入到MyEclipse当中，将com.mina.example包下面的MinaServer类中的下面代码注释掉，然后就可以正常运行了！原因是你本地不存在keystore和　truststore文件，如果需要生成请看注意事项中第三条。

1 SslFilter sslFilter = new SslFilter(2                 new SSLContextGenerator().getSslContext());3         filterChain.addFirst("sslFilter", sslFilter);4         System.out.println("SSL support is added..");

 

　　　　　　　　

　　　那么到这里Mina的开发就暂时告一段落了，如果还有什么需要添加的我以后会在发博客的，欢迎订阅！我的CSDN地址：