說明

NIO API是在Java 1.4引入的。MINA是基於NIO編寫的。首先要了解NIO與BIO的概念以及區別，NIO代表非阻塞IO，BIO代表著阻塞式IO。具體細節請百度。。。

MINA是一個簡單但功能齊全的網路應用框架（其實已經被NettyPK掉了，但都是一型別的東西，很多東西相通的，因為我們單位在用MINA所以優先看這個）。下載地址：http://mina.apache.org/downloads-mina.html    或者在maven中新增：

        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.6.6</version>
            <type>jar.sha256</type>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>1.6.6</version>
        </dependency>
        <dependency>
            <groupId>org.rxtx</groupId>
            <artifactId>rxtx</artifactId>
            <version>2.1.7</version>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>
        <dependency>
            <groupId>org.apache.mina</groupId>
            <artifactId>mina-core</artifactId>
            <version>2.0.7</version>
        </dependency>
        <dependency>
 

MINA的使用流程：

編寫自己的IoService，在這裡我們建立IoService的子類。隨後編寫不同的過濾器（例如關於編解碼的過濾器），將這些過濾器新增到過濾器鏈中，設定當前IoService監聽的埠（可以是多個），設定處理器也就是業務邏輯編寫的地方。

MINA說明：

當客戶端向這一埠傳送訊息，IoService會監聽這個埠，並經過過濾鏈進行處理後，傳給IoHandler，在這個處理器中有很多函式，這些函式會在不同情況下觸發（連線建立時、接收到訊息時、連線關閉時、連線超時時等等）。你需要重寫你需要的方法，在裡面編寫你的業務邏輯。

下面是MINA的一個示意圖：

一個簡單的demo：首先是編寫一個服務端

1. 首先是IoService的程式碼：

package com.mina;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;

import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

public class MinaTimeServer {

	public static void main(String[] args) throws IOException {
		//建立IoService的例項
		IoAcceptor acceptor = new NioSocketAcceptor();
		//設定過濾鏈  日誌、編解碼
		acceptor.getFilterChain().addLast("logger", new LoggingFilter());
		acceptor.getFilterChain().addLast("codec",
				new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));
		//設定處理器 就是業務邏輯處理的地方
		acceptor.setHandler(new TimeServerHandler());
		//讓其監聽某個埠
		acceptor.bind(new InetSocketAddress(9123));
	}
}
 

2. 接下來就是編寫這個TimeServerHndler類了

package com.mina;

import java.util.Date;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;

public class TimeServerHandler extends IoHandlerAdapter{
    //設定一個變數  
	 public static int count=0;
	
    //當捕獲到異常時會觸發（這裡不做任何處理，僅僅列印一下）
	public void execptionCaught(IoSession session,Throwable cause) throws Exception {	
		cause.printStackTrace();
	}
    //當接收到資料時觸發
	public void messageReceived(IoSession session, Object message) {
		String mes=message.toString();
    //當接受到的資料是quit時或者使用者請求大於2次關閉連線
	if(mes.trim().equalsIgnoreCase("quit")||count>2) {
		System.out.println("正在退出時間伺服器");
		session.write("正在退出時間伺服器。。。。");
		session.close();
		return;
	}
        //向客戶端回覆一個當前時間
		Date date = new Date();
		session.write(date.toString());
		System.out.println("message writen："+mes);
		count++;
	}
	
}

這個時間伺服器就寫完了。可以在cmd視窗縣通過telnet命令向這個埠傳送資料，來測試一下。

測試服務端

開啟cmd視窗，輸入命令Telnet localhost 9123

注意：如果顯示這個不是內部命令什麼的，先檢查拼寫，沒問題後百度怎麼開啟電腦的teinet。

輸入該命令後窗口如下：

這時可以輸入任意字元，會發送到該埠，輸入quit退出。或者次數到了後也會自動斷開連線。

向伺服器傳送任意字元，伺服器會向你回覆一個時間戳。

下面我們自己寫一個客戶端來和服務端連線。

客戶端的編寫

客戶端和伺服器端的編寫幾乎是一樣的，將IoService替換一下，伺服器時我們用的是NioSocketAcceptor，客戶端我們換成NioSocketConnector。這兩個都是IoService的實現類。寫法差不多直接上程式碼：

這是IoService的程式碼：

package com.minaTcpClient;

import java.net.InetSocketAddress;
import java.nio.charset.Charset;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketConnector;

public class TcpClient {

	public static void main(String[] args) {
		//建立IoService例項
		NioSocketConnector connector = new NioSocketConnector();
		//設定過濾鏈
		connector.getFilterChain().addLast("logger", new LoggingFilter());
		connector.getFilterChain().addLast("codec",
				new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));
		//設定處理器
		connector.setHandler(new TcpClientHandler());
		//連線地址
          ConnectFuture connect = connector.connect(new InetSocketAddress("localhost",9123));
	}
}

下面是TcpClientHandler的程式碼：

package com.minaTcpClient;

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;

public class TcpClientHandler extends IoHandlerAdapter{
    //會話建立時觸發
	public void sessionCreated(IoSession session) throws Exception {
        System.out.println("session  Created");
    }
	//會話開啟時觸發（第一次連線時先觸發sessionCreated函式，後觸發本函式）
	 public void sessionOpened(IoSession session) throws Exception {
	       session.write("Hello....");
	    }
	 //當接收到訊息時觸發
	 public void messageReceived(IoSession session, Object message) throws Exception {
		 System.out.println("收到："+message.toString());
	        session.write("Received ："+message.toString());
	    }
}

寫完上面的程式碼後先啟動伺服器，讓後啟動客戶端。這個順序應該能理解。。。。。。

關於UDP協議

UDP協議的寫法是一樣的，MINA在一定程度上遮蔽了兩者的差異。

在編寫上只需要將IoService的實現類替換一下

伺服器端的NioSocketAcceptor替換為NioDatagramAcceptor

客戶端的NioSocketConnector替換為NioDatagramConnector

他們都是IoService的實現類。