1：mina之淺談

????????????mina是apache基于socket nio的一套框架，可以從apache官網下載jar包和源碼。試用起來非常方便，也非常強大。如果對socket nio還不是很了解的話：請看一下這兩篇文章

??????????? ?學習bytebuffer和socket nio實例

??????????? 這里我簡單的介紹一下mina的框架：

????????????IoService：這個接口是網絡的入口，IoAcceptor和IoConnector都實現這個接口。從名字上我們可以看得出來IoAcceptor是接受鏈接的（服務端），而IoConnector是用來鏈接的（客戶端）。

??????????? IoFilter：過濾器。他是用來過濾消息的。從IoService（網絡接口）出來的數據或者進入IoService（網絡接口）的數據都會經過IoFilter的處理。最重要的就是日志和解碼和編碼。

?????????? IoHandler：處理器。它是鏈接應用和IoFilter的橋梁，是進行業(yè)務處理的，從IoFilter出來的數據會發(fā)到IoHandler中處理。

?????????? 從一個圖中我們來了解一下，這幾個接口之間的關系：

?

看著這張圖片，就應該明白mina中的數據時怎么傳輸的了吧。看起來很簡單的樣子？

2：mina實例

目標：

???? 不管客戶端發(fā)送什么數據到服務端，服務端口返回Hello world。

服務端實現

IoHandler：業(yè)務處理層

import org.apache.mina.core.service.IoHandlerAdapter; import org.apache.mina.core.session.IdleStatus; import org.apache.mina.core.session.IoSession;public class ServerHandler extends IoHandlerAdapter{@Overridepublic void exceptionCaught(IoSession session, Throwable cause) throws Exception{System.out.println("報錯啦............");cause.printStackTrace();}@Overridepublic void messageReceived( IoSession session, Object message ) throws Exception{String str = message.toString();System.out.println("messageReceived:"+str);session.write("hello world");}@Overridepublic void sessionIdle( IoSession session, IdleStatus status ) throws Exception{System.out.println( "IDLE " + session.getIdleCount( status ));} } ?

IoFilter：過濾器層

??????? ?這里我們做一個解碼的編碼的過濾層，這也是mina中最常用的。首先我們需要定義屬于我們自己的協(xié)議，也就是數據包的格式：別以為這很復雜，其實很簡單的。

??????? 我們知道數據都是字節(jié)類型的，那么我們的協(xié)議格式如下：前兩位表示數據包的長度（一個short類型正好兩個字節(jié)），第三位是閑置位，后面的是數據。長度是閑置位和

數據長度的和。這樣我們就可以根據前兩位確定，我們的數據包到那里結束。那么我們循環(huán)這么讀，就會取得所有的數據包。是不是很簡單啊，這個格式就是我們的協(xié)議。

????? 為了更簡單，這里我們客戶端發(fā)往服務端的數據進行編碼和解碼，服務端發(fā)往客戶端的就不編碼了，客戶端也就不用解碼。服務端使用mina，客戶端我們就使用基本的socket nio。

編碼工廠類：

public class CodecFactory extends DemuxingProtocolCodecFactory{public CodecFactory(){super.addMessageEncoder(String.class, Encoder.class);super.addMessageDecoder(Decoder.class);} } 解碼類: import java.util.ArrayList; import java.util.List;import org.apache.mina.core.buffer.IoBuffer; import org.apache.mina.core.session.IoSession; import org.apache.mina.filter.codec.ProtocolDecoderOutput; import org.apache.mina.filter.codec.demux.MessageDecoder; import org.apache.mina.filter.codec.demux.MessageDecoderResult; public class Decoder implements MessageDecoder {private byte[] r_curPkg = null;private int r_pos = -1; // 包計數器static private final int PKG_SIZE_BYTES = 2;//包長度public Decoder() { }@Overridepublic MessageDecoderResult decodable(IoSession session, IoBuffer in) {return MessageDecoderResult.OK;}@Overridepublic MessageDecoderResult decode(IoSession session, IoBuffer in,ProtocolDecoderOutput out) throws Exception {List<String> list = new ArrayList<String>();while (in.remaining() >= PKG_SIZE_BYTES || (r_pos >= 0 && in.hasRemaining())) {// 循環(huán)接收包,4為一個整型，表示包長度b, 如果上一個包未接收完成時，繼續(xù)接收// 如果上個包已收完整，則創(chuàng)建新的包if (r_pos == -1) {//得到下一個包的長度,長度不包括前兩位,即包的長度=壓縮位長度+數據位長度int pkgLen = in.getShort(); //如果包長度小于0，那么此包錯誤，解碼失敗，返回。if (pkgLen < 0) {return MessageDecoderResult.NOT_OK;}in.get(); r_curPkg = new byte[pkgLen-1]; //數組長度為數據長度r_pos = 0;}int need = r_curPkg.length - r_pos; //需要讀取的數據長度int length = in.remaining();//緩沖區(qū)中可讀的數據長度if (length >= need) {// 可以把當前包讀完整in.get(r_curPkg, r_pos, need); // 復制緩沖區(qū)中的數據到r_curPkg中// 處理接收到一個完整的包數據后，把包添加到池中，判斷是否需要需要解壓byte[] data = r_curPkg;String str = new String(data);list.add(str);r_curPkg = null;r_pos = -1;} else {// 如果剩下的字節(jié)數，不夠一個包則int remainBytes = in.remaining();in.get(r_curPkg, r_pos, remainBytes);r_pos += remainBytes;return MessageDecoderResult.NEED_DATA;}}for (String protocol : list) {out.write(protocol);}return MessageDecoderResult.OK;}@Overridepublic void finishDecode(IoSession session, ProtocolDecoderOutput out) {}} 編碼類：（沒有進行編碼，只進行了數據發(fā)送） import org.apache.mina.core.buffer.IoBuffer; import org.apache.mina.core.session.IoSession; import org.apache.mina.filter.codec.ProtocolEncoderOutput; import org.apache.mina.filter.codec.demux.MessageEncoder; public class Encoder implements MessageEncoder<String>{public Encoder(){}@Overridepublic void encode(IoSession session, String message, ProtocolEncoderOutput out)throws Exception {System.out.println("encode..................");String value = (String) message; IoBuffer buf = IoBuffer.allocate(value.getBytes().length); buf.setAutoExpand(true); if (value != null){buf.put(value.trim().getBytes()); } buf.flip(); out.write(buf); out.flush();} }

IoService層：

import java.io.IOException; import java.net.InetSocketAddress;import org.apache.mina.core.service.IoAcceptor; 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.transport.socket.nio.NioSocketAcceptor;public class MinaServer {private static final int PORT = 9123;public static void main(String [] args) throws IOException{IoAcceptor acceptor = new NioSocketAcceptor();acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter(new CodecFactory()));acceptor.setHandler(new ServerHandler());acceptor.getSessionConfig().setReadBufferSize( 3 );acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );acceptor.bind( new InetSocketAddress(PORT) );} }

到這里我們的服務端代碼就寫完了，

客戶端實現

<span style="font-size:12px">public class SocketClient {public static void main(String...args)throws Exception{SocketChannel socketChannel = SocketChannel.open();socketChannel.connect(new InetSocketAddress("localhost",9123));byte [] bytes = "aaaa".getBytes();//對數據包進行編碼ByteBuffer buffer = ByteBuffer.allocate(bytes.length+3);buffer.putShort((short)(bytes.length+1)); //包長度buffer.put((byte)1);//閑置位buffer.put(bytes);//數據buffer.flip();socketChannel.write(buffer);socketChannel.socket().shutdownOutput();String obj = receive(socketChannel);System.out.println(obj);}private static String receive(SocketChannel socketChannel)throws Exception{ByteBuffer buffer = ByteBuffer.allocate(1024);ByteArrayOutputStream baos = new ByteArrayOutputStream();int size = 0;byte [] bytes = null;while((size = socketChannel.read(buffer))>=0){buffer.flip();bytes = new byte[size];buffer.get(bytes);baos.write(bytes);buffer.clear();}bytes = baos.toByteArray();baos.close();return new String(bytes);} } </span>

所有的代碼都寫完了，先啟動服務端的MinaServer，然后再啟動客戶端，我們就會看到結果。

?

?

總結

以上是生活随笔為你收集整理的学习socket nio 之 mina实例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。