DANCE WITH JAVA

開發出高質量的系統

隨筆分類(277)

隨筆檔案(238)

閱讀排行榜

常用鏈接

統計

隨筆 - 239
文章 - 0
評論 - 664
引用 - 0

積分與排名

積分 - 985506
排名 - 34

好友之家

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

一、介紹
mina(Multipurpose Infrastructure for Network Applications) 是apache的頂級項目之一，用于構造異步連接的各種網絡應用
二、最簡單的使用實例

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 {

//設置buffer

ByteBuffer.setUseDirectBuffers(false);

ByteBuffer.setAllocator(new SimpleByteBufferAllocator());

//定義acceptor

IoAcceptor acceptor = new SocketAcceptor();

//定義config

SocketAcceptorConfig cfg = new SocketAcceptorConfig();

//設置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.");

}

對應的handler ,handler的作用是在對應的網事件的處理代碼

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就關閉session退出

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

session.close();

return;

}

//否則打印當前日期

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 );

}

三、使用方法：
編譯上邊兩個類（需要加入mina的jar文件)，然后運行terminalServer
開始->運行->cmd進入控制臺
telnet 127.0.0.1 9123
輸入hello
得到當前日期
輸入quit關閉session。

posted on 2007-07-09 11:26 dreamstone 閱讀(6414) 評論(6) 編輯收藏所屬分類: 利器、其它開源框架


只有注冊用戶登錄后才能發表評論。




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

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

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

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

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

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

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