首页 / JAVA / java socket 多线程通讯 使用mina作为服务端

java socket 多线程通讯 使用mina作为服务端

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java socket 多线程通讯 使用mina作为服务端，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1952字，纯文字阅读大概需要3分钟。

内容图文

客户端代码不变,参照 http://www.cnblogs.com/Westfalen/p/6251473.html

服务端代码如下:

            import
             java.io.IOException;

            import
             java.net.InetSocketAddress;


            import
             org.apache.mina.core.service.IoHandlerAdapter;

            import
             org.apache.mina.core.session.IdleStatus;

            import
             org.apache.mina.core.session.IoSession;

            import
             org.apache.mina.filter.codec.ProtocolCodecFilter;

            import
             org.apache.mina.filter.codec.textline.TextLineCodecFactory;

            import
             org.apache.mina.transport.socket.nio.NioSocketAcceptor;


            /**
            
 * 使用mina作为服务器进行socket通讯
 * 
 * 需要jar包: mina-core-2.0.16.jar, slf4j-api-1.7.21.jar
 * jar包下载地址 : 
            http://mina.apache.org/downloads-mina.html
             
 *
 
            */
            public
            class
             MinaServer {
    
            public
            static
            void
             main(String[] args) {
        
            try
             {
            
            //
             4步操作
            
            //
             1.新建 NioSocketAcceptor 事例对象
            NioSocketAcceptor acceptor = new NioSocketAcceptor();
            // 2.设置消息处理对象
            acceptor.setHandler(new MyServerHandler());
            // 3.设置消息解码器
            acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory()));
            // acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 3);
            ////设置idle时长
            // 4.绑定端口开启服务
            acceptor.bind(new InetSocketAddress(9999));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

/**
 * 专门处理消息的类,实现网络连接和消息处理的解耦
 */class MyServerHandler extends IoHandlerAdapter {

    /** 异常时候的处理 */
    @Override
    publicvoid exceptionCaught(IoSession session, Throwable cause) throws Exception {
        System.out.println("exceptionCaught");
    }

    /** 收到消息 */
    @Override
    publicvoid messageReceived(IoSession session, Object message) throws Exception {
        System.out.println("messageReceived " + message);
        // session.write("reply " + message); //收到消息就马上把消息回送给客户端    }

    /** 发送消息 */
    @Override
    publicvoid messageSent(IoSession session, Object message) throws Exception {
        System.out.println("messageSent " + message);
    }

    /** 通讯闲置时候的处理 */
    @Override
    publicvoid sessionIdle(IoSession session, IdleStatus status) throws Exception {
        System.out.println("sessionIdle");
    }
}

 

原文：http://www.cnblogs.com/Westfalen/p/6252555.html

内容总结

以上是互联网集市为您收集整理的java socket 多线程通讯 使用mina作为服务端全部内容，希望文章能够帮你解决java socket 多线程通讯 使用mina作为服务端所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1189885.html

来源：【匿名】