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."); }
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-core-2.0.0-M1.jar
slf4j-api.jarslf4j-jdk14.jar到项目类路径三、使用方法:
1. windos命令行 开始->运行->cmd进入控制台 telnet 127.0.0.1 9123 输入hello 得到当前日期 输入quit关闭session。
2. 浏览器,在地址栏中输入