博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
JAVA通信系列二:mina入门总结
阅读量:6212 次
发布时间:2019-06-21

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

一、学习资料

Mina入门实例(一) 

Mina入门教程(二)----Spring4 集成Mina 

Apache Mina 入门实例——创建一个MINA时间服务

MINA2.0用户手册中文版——系列文档

mina 心跳机制 

出处:

mina框架详解 

mina编码器详解

Mina系列文章索引(解码解析等,不错)

 

二、代码示例

(1)Mina服务端创建步骤
1.建立监听对象
IoAcceptor acceptor=new NioSocketAcceptor();
2.添加Filter(日志,编解码)
acceptor.getFilterChain().addLast("logger",new LoggingFilter());
acceptor.getFilterChain().addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));

3.添加Handler处理

acceptor.setHandler(new TimeServerHandler());

4.设置回话参数【输入缓存区Buffer大小,多久进入空闲时间】

acceptor.getSessionConfig.setReadBufferSize(2048);
acceptor.getessionConfig.setIdleTime(IdleStatus.BOTH_IDLE,10);

5.绑定端口号,开始监听

acceptor.bind(new InetSocketAddress(PORT));

Handler处理类开发

继承IOHandler类或者实现IoHandler接口
客户端Handler,服务端Handler使用同一个IOHandler继承实现。
public TimeServerHandler extends IoHandlerAdapter
{
@Override
public void exceptionCaught(IoSession session,Throwable cause) throws Exception
{
cause.printStackTrace();
}

@Override

public void messageReceived(IoSession session,Object message) throws Exception
{
String str=message.toString();
if(str.trim().equalsIgnoreCase("quit"))
{
session.close();
return ;
}

Date date=new Date();

session.write(date.toString());
System.out.println("Message written...");
}

@Override

public void sessionIdle(IoSession session,IdleStatus status) throws Exception
{
System.out.println("IDLE"+session.getIdleCount(status));
}
}

exceptionCaught方法:捕获错误,简单地打印了错误的堆栈跟踪和关闭会话。

messageReceived方法:来处理从客户端接收到的数据,这里是将当前时间返回给客户端。根据所使用的协议编解码器,object 这个参数传递的类型有所不同,以及返回的数据时的session.write(Object) 也不同。如果不指定协议的编解码器,你将收到一个类型为IoBuffer 的对象,返回的数据也要求是IoBuffer。

sessionIdle方法:空闲状态时,将定时调用一次会话

还有以下几个方法重写
    @Override
    public void messageSent(IoSession arg0, Object message) throws Exception {
        // TODO Auto-generated method stub
        System.out.println("client发送信息"+message.toString());
    }

    @Override

    public void sessionClosed(IoSession session) throws Exception {
        // TODO Auto-generated method stub
        System.out.println("client与:"+session.getRemoteAddress().toString()+"断开连接");
    }

    @Override

    public void sessionCreated(IoSession session) throws Exception {
        // TODO Auto-generated method stub
        System.out.println("client与:"+session.getRemoteAddress().toString()+"建立连接");
    }

    @Override

    public void sessionOpened(IoSession arg0) throws Exception {
        // TODO Auto-generated method stub
        System.out.println("打开连接");
    }

(2)Mina客户端创建
1.创建客户端连接对象
IoConnector connector=new NioSocketConnector();或者NioSocketConnector connector = new NioSocketConnector();

2.设置过滤器职责链(日志,编解码【多种编解码器】)

connector.getFilterChain().addLast("logger",new LoggingFilter());
connector.getFilterChain().addLast("codec",new ProtocolCodecFilter(new PrefixedStringCodecFactory(Charset.forName("UTF-8"))));
也可以使用
ioAcceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));

3.设置Handler处理

connector.setHandler(new TimeClientHandler());

4.建立Connect连接

ConnectFuture connectFuture=connector.connect(new InetSocketAddress("127.0.0.1",BaseConfig.PORT));
connectFuture.awaitUninterruptibly();

5.获得Session回话

IoSession session=connectFuture.getSession();

6.输入输出操作

以下是接收控制台的输入,获得后发送到服务端
Scanner sc = new Scanner(System.in);

        boolean quit = false;

        while(!quit){

            String str = sc.next();

            if(str.equalsIgnoreCase("quit")){
                quit = true;
            }
            session.write(str);
        }

7.关闭Session和连接器

        if(session!=null){
            if(session.isConnected()){
                session.getCloseFuture().awaitUninterruptibly();
            }
            connector.dispose(true);
        }
IoConnector connector = new NioSocketConnector();
        connector.getFilterChain().addLast( "logger", new LoggingFilter() );
        connector.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new PrefixedStringCodecFactory(Charset.forName("UTF-8"))));
        connector.setHandler(new TimeClientHander());
        ConnectFuture connectFuture = connector.connect(new InetSocketAddress("127.0.0.1",BaseConfig.PORT));
        //等待建立连接
        connectFuture.awaitUninterruptibly();
        System.out.println("连接成功");

        IoSession session = connectFuture.getSession();

        Scanner sc = new Scanner(System.in);

        boolean quit = false;

        while(!quit){

            String str = sc.next();

            if(str.equalsIgnoreCase("quit")){
                quit = true;
            }
            session.write(str);
        }

        //关闭

        if(session!=null){
            if(session.isConnected()){
                session.getCloseFuture().awaitUninterruptibly();
            }
            connector.dispose(true);
        }

三、粘包分包处理

有三种常用方法可以将字节流分离成消息:
使用固定长度的消息。
使用固定长度的标头指出消息内容主体的长度。
使用分隔符;例如很多基于文本的消息在消息的后面追加换行(或者CR LF组合)   ()

参考:

http://www.cnblogs.com/itfly8/p/5844911.html

你可能感兴趣的文章
使用curl命令查看访问url的时间
查看>>
WinForm中跨线程操作控件
查看>>
下MFC中对象、句柄、ID之间的区别.
查看>>
如何构建Win32汇编的编程环境(ONEPROBLEM个人推荐)
查看>>
Flymeos插桩适配教程
查看>>
还在用PS磨皮去皱?看看如何用神经网络高度还原你的年轻容貌!
查看>>
大端模式与小端模式、网络字节顺序与主机字节顺序
查看>>
微信支付申请90%的商户都卡在这儿了,申请微信支付,商户功能设置详细说明...
查看>>
高仿Instagram 页面效果android特效
查看>>
2016 年总结
查看>>
将String转化成Stream,将Stream转换成String
查看>>
java路径Java开发中获得非Web项目的当前项目路径
查看>>
【工具使用系列】关于 MATLAB 遗传算法与直接搜索工具箱,你需要知道的事
查看>>
Kali-linux Arpspoof工具
查看>>
PDF文档页面如何重新排版?
查看>>
基于http协议使用protobuf进行前后端交互
查看>>
bash腳本編程之三 条件判断及算数运算
查看>>
php cookie
查看>>
linux下redis安装
查看>>
弃 Java 而使用 Kotlin 的你后悔了吗?| kotlin将会是最好的开发语言
查看>>