dreamstone

永久域名 http://dreamstone.javaeye.com

hibernate 3.2中的session接口的不同 | ice vs corba

2007-07-11

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。

13:11
浏览 (2833)
评论 (2)
相关推荐

测试通过，使用如下包：
log4j-1.2.9
mina-core-1.1.5
slf4j-api-1.4.2
slf4j-log4j12-1.4.2
jdk1.5.0_13
log4j包的版本和slf4j-log4j的版本要一致，具体见：http://mina.apache.org/quick-start-guide.html

log4j.properties放到src目录下：

log4j.rootLogger=info, CONSOLE

log4j.appender.A1=org.apache.log4j.ConsoleAppender
log4j.appender.A1.layout=org.apache.log4j.PatternLayout

log4j.appender.A1.layout.ConversionPattern=%d [%t] %-5p %c - %m%n

log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender

log4j.appender.CONSOLE.Target=System.out
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout

log4j.appender.CONSOLE.layout.ConversionPattern=%d [%t] %-5p %c - %m%n