加入收藏 | 设为首页 | 会员中心 | 我要投稿 安卓应用网 (https://www.0791zz.com/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 编程开发 > Java > 正文

Apache的Mina简单实例

发布时间:2020-05-24 15:32:04 所属栏目:Java 来源:互联网
导读:Apache的Mina简单实例

下面是脚本之家 jb51.cc 通过网络收集整理的代码片段。

脚本之家小编现在分享给大家,也给大家做个参考。

 // 创建客户端连接器.
        NioSocketConnector connector = new NioSocketConnector();

        connector.getFilterChain().addLast("logger",new LoggingFilter());
        // 设置编码过滤器
        connector.getFilterChain().addLast(
                "codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset
                        .forName("UTF-8"))));
        connector.setConnectTimeout(30);
        // 设置事件处理器
        connector.setHandler(new ClientHandler());
        // 建立连接
        ConnectFuture cf = connector.connect(new InetSocketAddress("127.0.0.1",9100));
        // 等待连接创建完成
        cf.awaitUninterruptibly();
        // 发送消息
        cf.getSession().write("hello");
     
        // 等待连接断开
        cf.getSession().getCloseFuture().awaitUninterruptibly();

        connector.dispose();
IoAcceptor acceptor = new NioSocketAcceptor();

 acceptor.getFilterChain().addLast("logger",new LoggingFilter());
// 指定编码过滤器
acceptor.getFilterChain().addLast(
"codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset
.forName("UTF-8"))));
// 指定业务逻辑处理器
acceptor.setHandler(new ServerHandler());
// 设置端口号
acceptor.setDefaultLocalAddress(new InetSocketAddress(9100));
// 启动监听
acceptor.bind();

server 处理器
class ServerHandler extends IoHandlerAdapter
{

    @Override
    public void sessionCreated(IoSession session)
    {
        // 显示客户端的ip和端口
        System.out
                .println(session.getRemoteAddress().toString() + "   service");
    }

    @Override
    public void messageReceived(IoSession session,Object message)
            throws Exception
    {
        String str = message.toString();

        if (str.trim().equalsIgnoreCase("hello"))
        {
            // System.out.println(str + "  client sent : hello");
            // 结束会话
            session.close();
            return;
        }

        Date date = new Date();
        // 返回当前时间的字符串
        session.write(date.toString());
    }


}

以上是脚本之家(jb51.cc)为你收集整理的全部代码内容,希望文章能够帮你解决所遇到的程序开发问题。

如果觉得脚本之家网站内容还不错,欢迎将脚本之家网站推荐给程序员好友。

(编辑:安卓应用网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读