【Andorid開發框架學習】之Mina開發之服務器開發

　　　　

　　　　下午那篇博客我們講到了Mina的客戶端的開發，如果還有沒看過的同學可以看一下，我是傳送門。現在，我們來學習一下，Mina的服務器的開發。

 

　　一、首先看一下，我的服務器的代碼圖片：

　　　　　  服務器代碼我是在MyEclipse下寫的。

 

 

　　　二、服務器的整體思路：（同客戶端差不多）

• • • 首先，產生一個socket接收對象（SocketAcceptor），用於接收客戶端的連接請求；
    • 然后，對這個接收器添加我們的I/O過濾器（SSL加密、日志過濾器、編碼過濾器等，這里注意，如果添加SSL過濾器，那么一定要第一個添加，否則無法對數據加密）；
    • 接下來，為連接設置I/O處理器，顧名思義就是處理接收到的消息（這里我們只能設置一個處理器，如果有設置多個，那么默認進入到最后一個I/O處理器中進行處理）；
    • 最后，將服務器綁定到某端口（如：3456，最好是1024以上，因為1024以下的端口系統占用）。

 

　　　三、正式編碼

　　　　　　這里我同樣展示幾個比較重要的類來詳細說明一下：

• • • MinaServer.Java

      package com.mina.example;
      
      import java.io.IOException;
      import java.net.InetSocketAddress;
      
      import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
      import org.apache.mina.core.session.IdleStatus;
      import org.apache.mina.filter.codec.ProtocolCodecFilter;
      import org.apache.mina.filter.logging.LoggingFilter;
      import org.apache.mina.filter.ssl.SslFilter;
      import org.apache.mina.transport.socket.SocketAcceptor;
      import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
      
      import com.mina.charset.CharsetFactory;
      import com.mina.hanlder.MsgHanler;
      import com.mina.ssl.SSLContextGenerator;
      
      /**
       * <pre>
       * Project Name:MinaServer
       * Package:com.mina.example
       * FileName:MinaServer.java
       * Purpose:服務器
       * Create Time: 2014-8-19 下午4:59:55
       * Create Specification:
       * Modified Time:
       * Modified by:
       * Modified Specification:
       * Version: 1.0
       * </pre>
       * 
       * @author myp
       */
      public class MinaServer {
      
          private SocketAcceptor acceptor;
      
          public MinaServer() {
              /*
               * 1.創建一個socket連接,連接到服務器
               */
              acceptor = new NioSocketAcceptor();
          }
      
          public boolean start() {
              /*
               * 獲取過濾器鏈,用於添加過濾器
               */
              DefaultIoFilterChainBuilder filterChain = acceptor.getFilterChain();
      
              /*
               * 2.為連接添加過濾器，SSL、日志、編碼過濾器
               */
              // SSLContextGenerator是我們自己寫的一個SSL上下文產生器,稍后會講到
              SslFilter sslFilter = new SslFilter(
                      new SSLContextGenerator().getSslContext());
              // a.ssl過濾器，這個一定要第一個添加，否則數據不會進行加密
              filterChain.addLast("sslFilter", sslFilter);
              System.out.println("SSL support is added..");
              // b.添加日志過濾器
              filterChain.addLast("loger", new LoggingFilter());
              // c.添加字符的編碼過濾器
              filterChain.addLast("codec", new ProtocolCodecFilter(
                      new CharsetFactory()));
      
              /*
               * 3.設置消息處理器，用於處理接收到的消息
               */
              acceptor.setHandler(new MsgHanler());
              // 設置空閑的時間是30s
              acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 30);
              try {
                  /*
                   * 4.將服務器綁定到3456端口
                   */
                  acceptor.bind(new InetSocketAddress(3456));
              } catch (IOException e) {
                  e.printStackTrace();
                  return false;
              }
              return true;
          }
      
          public static void main(String[] args) {
              MinaServer server = new MinaServer();
              server.start();
          }
      }

      MinaServer就是按照第二步當中的流程走過來的；所以編程的時候最主要的是整體的思路，思路明白了那么編程就會變得異常效率。

 

• • • SSLContextGenerator.Java（同客戶端的代碼，看過客戶端的可以不看）

      package com.mina.ssl;
      
      import java.io.File;
      import java.security.KeyStore;
      
      import javax.net.ssl.SSLContext;
      
      import org.apache.mina.filter.ssl.KeyStoreFactory;
      import org.apache.mina.filter.ssl.SslContextFactory;
      
      /**
       * <pre>
       * Project Name:SSLContextGenerator
       * Package:com.example.mina.ssl
       * FileName:SSLContextGenerator.java
       * Purpose:SSL加密的上下文產生器
       * Create Time: 2014-8-19 下午4:41:55
       * Create Specification:
       * Modified Time:
       * Modified by:
       * Modified Specification:
       * Version: 1.0
       * </pre>
       * 
       * @author myp
       */
      public class SSLContextGenerator {
      
          /**
           * 這個方法，通過keystore和truststore文件返回一個SSLContext對象
           * 
           * @return
           */
          public SSLContext getSslContext() {
              SSLContext sslContext = null;
              try {
                  /*
                   * 提供keystore的存放目錄，讀取keystore的文件內容
                   */
                  File keyStoreFile = new File("C:/Users/Myp/keystore.jks");
      
                  /*
                   * 提供truststore的存放目錄，讀取truststore的文件內容
                   */
                  File trustStoreFile = new File("C:/Users/Myp/truststore.jks");
      
                  if (keyStoreFile.exists() && trustStoreFile.exists()) {
                      final KeyStoreFactory keyStoreFactory = new KeyStoreFactory();
                      System.out.println("Url is: " + keyStoreFile.getAbsolutePath());
                      keyStoreFactory.setDataFile(keyStoreFile);
      
                      /*
                       * 這個是當初我們使用keytool創建keystore和truststore文件的密碼,也是上次讓你們一定要記住密碼的原因了
                       */
                      keyStoreFactory.setPassword("123456");
      
                      final KeyStoreFactory trustStoreFactory = new KeyStoreFactory();
                      trustStoreFactory.setDataFile(trustStoreFile);
                      trustStoreFactory.setPassword("123456");
      
                      final SslContextFactory sslContextFactory = new SslContextFactory();
                      final KeyStore keyStore = keyStoreFactory.newInstance();
                      sslContextFactory.setKeyManagerFactoryKeyStore(keyStore);
      
                      final KeyStore trustStore = trustStoreFactory.newInstance();
                      sslContextFactory.setTrustManagerFactoryKeyStore(trustStore);
                      sslContextFactory
                              .setKeyManagerFactoryKeyStorePassword("123456");
                      sslContext = sslContextFactory.newInstance();
                      System.out.println("SSL provider is: "
                              + sslContext.getProvider());
                  } else {
                      System.out
                              .println("Keystore or Truststore file does not exist");
                  }
              } catch (Exception ex) {
                  ex.printStackTrace();
              }
              return sslContext;
          }
      }

      如果不知道如何創建keystore和truststore文件的話，請查看我的這篇博客：http://www.cnblogs.com/getherBlog/p/3930317.html

 

• • • MsgHandler.Java（同客戶端的代碼，看過客戶端的可以不看）

      package com.mina.hanlder;
      
      import org.apache.mina.core.service.IoHandlerAdapter;
      import org.apache.mina.core.session.IdleStatus;
      import org.apache.mina.core.session.IoSession;
      import org.slf4j.Logger;
      import org.slf4j.LoggerFactory;
      
      /**
       * <pre>
       * Project Name:MsgHanler
       * Package:com.mina.handler
       * FileName:MsgHanler.java
       * Purpose:I/O消息處理器,從這里我們就可以看出Mina是事件驅動的
       * Create Time: 2014-8-19 下午4:55:55
       * Create Specification:
       * Modified Time:
       * Modified by:
       * Modified Specification:
       * Version: 1.0
       * </pre>
       * 
       * @author myp
       */
      public class MsgHanler extends IoHandlerAdapter {
          private static final Logger log = LoggerFactory.getLogger(MsgHanler.class);
      
          @Override
          public void exceptionCaught(IoSession session, Throwable cause)
                  throws Exception {
              // 出現異常
              log.error("--------exception--------");
              super.exceptionCaught(session, cause);
          }
      
          @Override
          public void messageReceived(IoSession session, Object message)
                  throws Exception {
              // 從服務器中接收到消息后的處理
              log.info("--------msg receive--------");
              log.info("Message:{}", message.toString());
              super.messageReceived(session, message);
          }
      
          @Override
          public void messageSent(IoSession session, Object message) throws Exception {// 往服務器中發送消息
              log.info("Message Send {}", message.toString());
              super.messageSent(session, message);
          }
      
          @Override
          public void sessionIdle(IoSession session, IdleStatus status)
                  throws Exception {
              // session處於空閑的時候
              log.info("當前連接{}處於空閑狀態：{}", session.getRemoteAddress(), status);
          }
      
          @Override
          public void sessionClosed(IoSession session) throws Exception {
              // session關閉
              log.info("Session closed {}->{}", session.getId(),
                      session.getRemoteAddress());
              super.sessionClosed(session);
          }
      }

      基本上我們最主要的就是對在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文件，下面是他的代碼；

      log4j.rootCategory=INFO, stdout , R   
         
      log4j.appender.stdout=org.apache.log4j.ConsoleAppender   
      log4j.appender.stdout.layout=org.apache.log4j.PatternLayout   
      log4j.appender.stdout.layout.ConversionPattern=[QC] %p [%t] %C.%M(%L) | %m%n   
          
      log4j.appender.R=org.apache.log4j.DailyRollingFileAppender   
      log4j.appender.R.File=D\:\\Mina\\logs\\server.log
      log4j.appender.R.layout=org.apache.log4j.PatternLayout   
      1log4j.appender.R.layout.ConversionPattern=%d-[TS] %p %t %c - %m%n   
         
      log4j.logger.com.neusoft=DEBUG   
      log4j.logger.com.opensymphony.oscache=ERROR   
      log4j.logger.net.sf.navigator=ERROR   
      log4j.logger.org.apache.commons=ERROR   
      log4j.logger.org.apache.struts=WARN   
      log4j.logger.org.displaytag=ERROR   
      log4j.logger.org.springframework=DEBUG   
      log4j.logger.com.ibatis.db=WARN   
      log4j.logger.org.apache.velocity=FATAL   
         
      log4j.logger.com.canoo.webtest=WARN   
         
      log4j.logger.org.hibernate.ps.PreparedStatementCache=WARN   
      log4j.logger.org.hibernate=DEBUG   
      log4j.logger.org.logicalcobwebs=WARN  

      我們可以再這里設置我們的日志輸出目錄：log4j.appender.R.File=D:\\Mina\\logs\\server.log                                                                                           

　　　　　 3. SSL加密中，如果不知道如何使用keystore生成keystore和truststore文件，可以查看這篇博客：http://www.cnblogs.com/getherBlog/p/3930317.html       

　　　　 　4. 在添加過濾器的時候，處理的順序是按照添加過濾器的順序；                                                                                                                                

　　　　　 5. Mina在使用過濾器的時候，只要在需要的地方添加就可以了，不一定是服務器、客戶端都要添加的。就是說，服務器、客戶端編程的時候服務器有這個過濾器，客戶端可以有也可以沒有。

　　

　　

　　　六、Mina服務器源碼下載

　　　　　　　　點我下載

　　　　　　　　下載后導入到MyEclipse當中，將com.mina.example包下面的MinaServer類中的下面代碼注釋掉，然后就可以正常運行了！原因是你本地不存在keystore和　truststore文件，如果需要生成請看注意事項中第三條。

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

 

　　　　　　　　

　　　那么到這里Mina的開發就暫時告一段落了，如果還有什么需要添加的我以后會在發博客的，歡迎訂閱！我的CSDN地址：http://blog.csdn.net/u010049692/article/details/38864541