碼上快樂

相關內容    簡體    繁體

【Andorid開發框架學習】之Mina開發之客戶端開發

本文轉載自   查看原文   2014-08-26 14:20   2051    網絡通信庫/ nio/ mina開發/ android框架學習/ 事件驅動/ android框架/ 高性能網絡框架

　　

　　　　昨天我們講到了Mina的基本知識點。如果還有不懂得同學可以看一下我昨天的博客。http://www.cnblogs.com/getherBlog/p/3934927.html今天我着重來講一下基於Mina的客戶端的開發（代碼均在最后鏈接地址中，歡迎下載）。

 

　　　一、首先看一下，我的客戶端的代碼圖片：

　　　　　　　客戶端代碼我是在Eclipse下寫的。

 

　　　二、客戶端的整體思路：

      • 首先，產生一個socket連接對象，用於連接到服務器；
      • 然后，對這個連接添加我們的I/O過濾器（SSL加密、日志過濾器、編碼過濾器等，這里注意，如果添加SSL過濾器，那么一定要第一個添加，否則無法對數據加密）；
      • 接下來，為連接設置I/O處理器，顧名思義就是處理接收到的消息（這里我們只能設置一個處理器，如果有設置多個，那么默認進入到最后一個I/O處理器中進行處理）；
      • 最后，連接到通過IP和端口號連接到服務器；保存連接的獲取到的session，如果需要發送消息，我們就可以對session進行操作。

 

　　　三、正式編碼

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

      • MinaClient.Java 
        package com.example.mina.server;

import java.net.InetSocketAddress;

import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.core.future.CloseFuture;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.session.IoSession;
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.SocketConnector;
import org.apache.mina.transport.socket.nio.NioSocketConnector;

import com.example.mina.charset.CharsetFactory;
import com.example.mina.hanlder.MsgHanler;
import com.example.mina.ssl.SSLContextGenerator;

/**
 * <pre>
 * Project Name:MinaClient
 * Package:com.example.mina.server
 * FileName:MinaClient.java
 * Purpose:客戶端
 * Create Time: 2014-8-19 下午4:36:55
 * Create Specification:
 * Modified Time:
 * Modified by:
 * Modified Specification:
 * Version: 1.0
 * </pre>
 * 
 * @author myp
 */
public class MinaClient {

    private SocketConnector connector;
    private ConnectFuture future;
    private IoSession session;

    public boolean connect() {
        /*
         * 1.創建一個socket連接,連接到服務器
         */
        connector = new NioSocketConnector();

        /*
         * 獲取過濾器鏈,用於添加過濾器
         */
        DefaultIoFilterChainBuilder chain = connector.getFilterChain();

        /*
         * 2.為連接添加過濾器，SSL、日志、編碼過濾器
         */
        // SSLContextGenerator是我們自己寫的一個SSL上下文產生器,稍后會講到
        SslFilter sslFilter = new SslFilter(
                new SSLContextGenerator().getSslContext());
        // 設置為客戶端模式
        sslFilter.setUseClientMode(true);
        // a.ssl過濾器，這個一定要第一個添加，否則數據不會進行加密
        chain.addFirst("sslFilter", sslFilter);

        // b.添加日志過濾器
        chain.addLast("logger", new LoggingFilter());

        // c.添加字符的編碼過濾器
        chain.addLast("codec", new ProtocolCodecFilter(new CharsetFactory()));

        /*
         * 3.設置消息處理器，用於處理接收到的消息
         */
        connector.setHandler(new MsgHanler());

        /*
         * 4.根據IP和端口號連接到服務器
         */
        future = connector.connect(new InetSocketAddress("192.168.1.12", 3456));
        // 等待連接創建完成
        future.awaitUninterruptibly();

        /*
         * 5.獲取session對象,通過session可以向服務器發送消息；
         */
        session = future.getSession();
        session.getConfig().setUseReadOperation(true);
        return future.isConnected();
    }

    /**
     * 往服務器發送消息
     * 
     * @param message
     */
    public void sendMsg2Server(String message) {
        session.write(message);
    }

    /**
     * 關閉與服務器的連接
     * 
     * @return
     */
    public boolean close() {
        CloseFuture future = session.getCloseFuture();
        future.awaitUninterruptibly(1000);
        connector.dispose();
        return true;
    }
}
        View Code

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

 

      • SSLContextGenerator.Java 
        package com.example.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:客戶端
 * 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/Administrator/keystore.jks");

            /*
             * 提供truststore的存放目錄，讀取truststore的文件內容
             */
            File trustStoreFile = new File(
                    "C:/Users/Administrator/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("134426myp");

                final KeyStoreFactory trustStoreFactory = new KeyStoreFactory();
                trustStoreFactory.setDataFile(trustStoreFile);
                trustStoreFactory.setPassword("134426myp");

                final SslContextFactory sslContextFactory = new SslContextFactory();
                final KeyStore keyStore = keyStoreFactory.newInstance();
                sslContextFactory.setKeyManagerFactoryKeyStore(keyStore);

                final KeyStore trustStore = trustStoreFactory.newInstance();
                sslContextFactory.setTrustManagerFactoryKeyStore(trustStore);
                sslContextFactory
                        .setKeyManagerFactoryKeyStorePassword("134426myp");
                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;
    }
}
        View Code

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

 

      • MsgHandler.Java 
        package com.example.mina.hanlder;

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * <pre>
 * Project Name:MsgHanler
 * Package:com.example.mina.handler
 * FileName:MsgHanler.java
 * Purpose:I/O消息處理器,從這里我們就可以看出Mina是事件驅動的
 * Create Time: 2014-8-19 下午4:39: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("--------msg sent--------");
        super.messageSent(session, message);
    }

    @Override
    public void sessionCreated(IoSession session) throws Exception {
        // 當session被創建的時候調用
        log.info("--------session create--------");
        super.sessionCreated(session);
    }
}
        View Code

        基本上我們最主要的就是對在I/O處理器這里對收到的消息進行處理，也是編程的核心所在！

         

　　　四、注意事項

      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\\client.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.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:\\Tomcat 5.5\\logs\\qc.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
        View Code

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

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

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

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

　　　　　　　　

　　

　　　五、Mina客戶端源碼下載

　　　　　　　　點我下載

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

　　　　SslFilter sslFilter = new SslFilter(
                new SSLContextGenerator().getSslContext());
        sslFilter.setUseClientMode(true);
        chain.addFirst("sslFilter", sslFilter);

　　　　　　　　

 　　　　

　　　下一篇應該是Mina的服務器的開發，歡迎訂閱！我的CSDN地址：http://blog.csdn.net/u010049692/article/details/38847129

 


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 【Andorid開發框架學習】之Mina開發之服務器開發 Mina框架的學習筆記——Android客戶端的實現 W5500 學習開發: TCP客戶端 Redis客戶端開發包：Jedis學習-入門 Redis客戶端開發包：Jedis學習-高級應用 CefSharp-基於C#的客戶端開發框架技術棧開發全記錄 cross socket tcp客戶端開發 游戲客戶端開發勸退 使用CXF開發WebService客戶端 ElasticSearch java 客戶端開發
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM