DANCE WITH JAVA

開(kāi)發(fā)出高質(zhì)量的系統(tǒng)

導(dǎo)航

<

2007年7月

>

日

一

二

三

四

五

六

24

25

26

27

28

29

30

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

1

2

3

4

隨筆分類(lèi)(277)

隨筆檔案(238)

閱讀排行榜

常用鏈接

統(tǒng)計(jì)

隨筆 - 239
文章 - 0
評(píng)論 - 664
引用 - 0

積分與排名

積分 - 985011
排名 - 34

好友之家

apache mina (異步連接框架)介紹

一、介紹
mina(Multipurpose Infrastructure for Network Applications) 是apache的頂級(jí)項(xiàng)目之一，用于構(gòu)造異步連接的各種網(wǎng)絡(luò)應(yīng)用
二、最簡(jiǎn)單的使用實(shí)例

package aicu.mina;

import java.io.IOException;

import java.net.InetSocketAddress;

import java.nio.charset.Charset;

import org.apache.mina.common.ByteBuffer;

import org.apache.mina.common.IoAcceptor;

import org.apache.mina.common.SimpleByteBufferAllocator;

import org.apache.mina.filter.LoggingFilter;

import org.apache.mina.filter.codec.ProtocolCodecFilter;

import org.apache.mina.filter.codec.textline.TextLineCodecFactory;

import org.apache.mina.transport.socket.nio.SocketAcceptor;

import org.apache.mina.transport.socket.nio.SocketAcceptorConfig;

public class MinaTimeServer {

private static final int PORT = 9123;

public static void main(String[] args) throws IOException {

//設(shè)置buffer

ByteBuffer.setUseDirectBuffers(false);

ByteBuffer.setAllocator(new SimpleByteBufferAllocator());

//定義acceptor

IoAcceptor acceptor = new SocketAcceptor();

//定義config

SocketAcceptorConfig cfg = new SocketAcceptorConfig();

//設(shè)置config,加入filter

cfg.getSessionConfig().setReuseAddress( true );

cfg.getFilterChain().addLast( "logger", new LoggingFilter() );

cfg.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));

//加入port handler cfg

acceptor.bind( new InetSocketAddress(PORT), new TimeServerHandler(), cfg);

System.out.println("MINA Time server started.");

}

對(duì)應(yīng)的handler ,handler的作用是在對(duì)應(yīng)的網(wǎng)事件的處理代碼

package aicu.mina;

import java.util.Date;

import org.apache.mina.common.IdleStatus;

import org.apache.mina.common.IoHandlerAdapter;

import org.apache.mina.common.IoSession;

import org.apache.mina.common.TransportType;

import org.apache.mina.transport.socket.nio.SocketSessionConfig;

public class TimeServerHandler extends IoHandlerAdapter {

public void exceptionCaught(IoSession session, Throwable t) throws Exception {

t.printStackTrace();

session.close();

}

public void messageReceived(IoSession session, Object msg) throws Exception {

String str = msg.toString();

//如果是quit就關(guān)閉session退出

if( str.trim().equalsIgnoreCase("quit") ) {

session.close();

return;

}

//否則打印當(dāng)前日期

Date date = new Date();

session.write( date.toString() );

System.out.println("Message written

");

}

public void sessionCreated(IoSession session) throws Exception {

System.out.println("Session created

");

if( session.getTransportType() == TransportType.SOCKET )

((SocketSessionConfig) session.getConfig() ).setReceiveBufferSize( 2048 );

session.setIdleTime( IdleStatus.BOTH_IDLE, 10 );

}

三、使用方法：
編譯上邊兩個(gè)類(lèi)（需要加入mina的jar文件)，然后運(yùn)行terminalServer
開(kāi)始->運(yùn)行->cmd進(jìn)入控制臺(tái)
telnet 127.0.0.1 9123
輸入hello
得到當(dāng)前日期
輸入quit關(guān)閉session。

posted on 2007-07-09 11:26 dreamstone 閱讀(6413) 評(píng)論(6) 編輯收藏所屬分類(lèi): 利器、其它開(kāi)源框架

評(píng)論

# re: apache mina (異步連接框架)介紹 2007-07-09 12:54 BeanSoft

NIO, 好啊, 支持! 回復(fù) 更多評(píng)論

# re: apache mina (異步連接框架)介紹 2007-07-09 13:15 永恒

介紹的簡(jiǎn)單了點(diǎn)，能不能給個(gè)詳細(xì)的介紹呢，呵呵回復(fù) 更多評(píng)論

# re: apache mina (異步連接框架)介紹 2007-07-09 14:09 flybean

Apache MINA (Multipurpose Infrastructure for Network Applications) is a network application framework which helps users develop high performance and high scalability network applications easily.

哪里看出來(lái)是異步? 回復(fù) 更多評(píng)論

# re: apache mina (異步連接框架)介紹 2007-07-09 15:01 BeanSoft

啊, 不會(huì)吧, 自從 JDK 1.4 后, Tomcat 就用 NIO 改寫(xiě)了, 其它很多廠商也是, 畢竟 NIO 效率要高很多. 回復(fù) 更多評(píng)論

# re: apache mina (異步連接框架)介紹 2007-07-09 16:49 dreamstone

@flybean
我也是剛開(kāi)始接觸，所說(shuō)的異步是只mina內(nèi)部，使用它封裝的各種類(lèi)，就實(shí)現(xiàn)了異步。我理解這個(gè)框架的作用就是不用自己再去實(shí)現(xiàn)異步。利用mina的類(lèi)來(lái)編寫(xiě)程序，在mina內(nèi)部實(shí)現(xiàn)了異步。這也是它的作用。回復(fù) 更多評(píng)論

# re: apache mina (異步連接框架)介紹 2009-10-18 17:03 tablechair

如果我要同步的，mina實(shí)現(xiàn)不了？回復(fù) 更多評(píng)論

新用戶注冊(cè) 刷新評(píng)論列表


只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問(wèn) 管理
相關(guān)文章: 使用Apache+tomcat比單獨(dú)使用tomcat能帶來(lái)什么樣的好處及壞處 apache Ant中文手冊(cè) 2.0版 (教程) jdom 或 dom4j讀取xml文件時(shí)如何讓dtd驗(yàn)證使用本地dtd文件或者不生效 eclipse3.3的一些新的特性通過(guò)httpClient連接 tomcat https (ssl) apache mina (異步連接框架)介紹 SLF4J 教程（自由在各種log中切換) 讓linux開(kāi)機(jī)自動(dòng)啟動(dòng)oracle eclipse3.3 m7 配置tomcat5.5 jndi 各種配置方式分析總結(jié)（mysql）