博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Mina hello
阅读量:6980 次
发布时间:2019-06-27

本文共 2780 字,大约阅读时间需要 9 分钟。

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.jar
slf4j-jdk14.jar到项目类路径

三、使用方法: 

1. windos命令行 开始->运行->cmd进入控制台 telnet 127.0.0.1 9123 输入hello 得到当前日期 输入quit关闭session。

2. 浏览器,在地址栏中输入 

转载于:https://my.oschina.net/wjgood/blog/35922

你可能感兴趣的文章
[转载]分享WCF聊天程序--WCFChat
查看>>
程序员说话技巧大放送,受教了
查看>>
Linux指令--文件和目录属性
查看>>
PHP smarty缓存
查看>>
[数位dp] spoj 10738 Ra-One Numbers
查看>>
HDU 2206 IP的计算(字符串处理)
查看>>
您会让自己的小孩将来从事软件研发吗?
查看>>
【Maven】maven的安装配置和ecplise结合
查看>>
CHIL-SQL-MIN() 函数
查看>>
驾考试题的json代码
查看>>
黑马基础阶段测试题:通过字符输入流读取info.txt中的所有内容,每次读取一行,将每一行的第一个文字截取出来并打印在控制台上。...
查看>>
优秀博客
查看>>
iOS 开发 OC编程 数组冒泡排序.图书管理
查看>>
VS 2010 快捷键大全
查看>>
决策树算法
查看>>
前端的一些小的效果
查看>>
angular指令ng-class巧用
查看>>
解密FFmpeg播放track mode控制
查看>>
前端基础之JavaScript
查看>>
暂时喘口气,
查看>>