Mina 断线重连

定义：这里讨论的Mina 断线重连是指使用mina作为客户端软件，连接其他提供Socket通讯服务的服务器端。Socket服务器可以是Mina提供的服务器，也可以是C++提供的服务器。

一、断线重连的方式；

1. 在创建Mina客户端时增加一个监听器，或者增加一个拦截器，当检测到Session关闭时，自动进行重连。

2. 在第1种方式的基础上，增加客户端的读写通道空闲检查，当发生Session关闭或者读写空闲时，进行重连。

第一种方式比较传统，优点是简单方便，适合网络稳定、数据量不大（1M带宽以下）的环境；不过缺点是不能对系统级的连接断开阻塞进行捕获。

第二种方式更加精细，基本上能捕获到应用、网络、系统级的断连。

二、重连目的：

在使用Mina做为客户端时，往往因为网络、服务器、应用程序出现问题而导致连接断开，而自动重连，就是解决连接断开的唯一方式。如果网线断开、服务器宕机、应用程序挂了，都是断线的原因，这个时候，通过增加一个监听器或者拦截器，就能实现重连。但是生产环境中，断线的原因可能更复杂：网络不稳定、延时、服务器负载高、服务器或者应用程序的发送或者接收缓冲区满等等问题都可能导致数据传输过程出现类似于断线的情况，这个时候，光检测Session关闭是远远不够的，这个时候就需要一种重连机制，比如读写空闲超过30秒，就进行重连。对于数据不间断、实时性高、数据量大的应用场景，更是实用。

三、实例：

第一种：监听器方式

创建一个监听器实现mina的IoServiceListener接口，里面的方法可以不用写实现

Java代码  

  1. <span style="font-family: ‘Microsoft YaHei‘,微软雅黑,SimHei,tahoma,arial,helvetica,sans-serif;">import org.apache.mina.core.service.IoService;
  2. import org.apache.mina.core.service.IoServiceListener;
  3. import org.apache.mina.core.session.IdleStatus;
  4. import org.apache.mina.core.session.IoSession;
  5. public class IoListener implements IoServiceListener{
  6. @Override
  7. public void serviceActivated(IoService arg0) throws Exception {
  8. // TODO Auto-generated method stub
  9. }
  10. @Override
  11. public void serviceDeactivated(IoService arg0) throws Exception {
  12. // TODO Auto-generated method stub
  13. }
  14. @Override
  15. public void serviceIdle(IoService arg0, IdleStatus arg1) throws Exception {
  16. // TODO Auto-generated method stub
  17. }
  18. @Override
  19. public void sessionCreated(IoSession arg0) throws Exception {
  20. // TODO Auto-generated method stub
  21. }
  22. @Override
  23. public void sessionDestroyed(IoSession arg0) throws Exception {
  24. // TODO Auto-generated method stub
  25. }
  26. }</span>

再创建客户端时加入监听

Java代码  

  1. <span style="font-family: ‘Microsoft YaHei‘,微软雅黑,SimHei,tahoma,arial,helvetica,sans-serif;">        NioSocketConnector connector = new NioSocketConnector();  //创建连接客户端
  2. connector.setConnectTimeoutMillis(30000); //设置连接超时
  3. connector.getSessionConfig().setReceiveBufferSize(10240);   // 设置接收缓冲区的大小
  4. connector.getSessionConfig().setSendBufferSize(10240);// 设置输出缓冲区的大小
  5. //      加入解码器
  6. TextLineCodecFactory factory = new TextLineCodecFactory(Charset.forName("GBK"), LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue());
  7. factory.setDecoderMaxLineLength(10240);
  8. factory.setEncoderMaxLineLength(10240);
  9. connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(factory));
  10. connector.setDefaultRemoteAddress(new InetSocketAddress(host, port));// 设置默认访问地址
  11. //添加处理器
  12. connector.setHandler(new IoHandler());
  13. // 添加重连监听
  14. connector.addListener(new IoListener() {
  15. @Override
  16. public void sessionDestroyed(IoSession arg0) throws Exception {
  17. for (;;) {
  18. try {
  19. Thread.sleep(3000);
  20. ConnectFuture future = connector.connect();
  21. future.awaitUninterruptibly();// 等待连接创建成功
  22. session = future.getSession();// 获取会话
  23. if (session.isConnected()) {
  24. logger.info("断线重连[" + connector.getDefaultRemoteAddress().getHostName() + ":" + connector.getDefaultRemoteAddress().getPort() + "]成功");
  25. break;
  26. }
  27. } catch (Exception ex) {
  28. logger.info("重连服务器登录失败,3秒再连接一次:" + ex.getMessage());
  29. }
  30. }
  31. }
  32. });
  33. for (;;) {
  34. try {
  35. ConnectFuture future = connector.connect();
  36. future.awaitUninterruptibly(); // 等待连接创建成功
  37. session = future.getSession(); // 获取会话
  38. logger.info("连接服务端" + host + ":" + port + "[成功]" + ",,时间:" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
  39. break;
  40. } catch (RuntimeIoException e) {
  41. logger.error("连接服务端" + host + ":" + port + "失败" + ",,时间:" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + ", 连接MSG异常,请检查MSG端口、IP是否正确,MSG服务是否启动,异常内容:" + e.getMessage(), e);
  42. Thread.sleep(5000);// 连接失败后,重连间隔5s
  43. }
  44. }
  45. </span>

第一种：拦截器方式

Java代码  

  1. <span style="font-family: ‘Microsoft YaHei‘,微软雅黑,SimHei,tahoma,arial,helvetica,sans-serif;">        connector = new NioSocketConnector();  //创建连接客户端
  2. connector.setConnectTimeoutMillis(30000); //设置连接超时
  3. //      断线重连回调拦截器
  4. connector.getFilterChain().addFirst("reconnection", new IoFilterAdapter() {
  5. @Override
  6. public void sessionClosed(NextFilter nextFilter, IoSession ioSession) throws Exception {
  7. for(;;){
  8. try{
  9. Thread.sleep(3000);
  10. ConnectFuture future = connector.connect();
  11. future.awaitUninterruptibly();// 等待连接创建成功
  12. session = future.getSession();// 获取会话
  13. if(session.isConnected()){
  14. logger.info("断线重连["+ connector.getDefaultRemoteAddress().getHostName() +":"+ connector.getDefaultRemoteAddress().getPort()+"]成功");
  15. break;
  16. }
  17. }catch(Exception ex){
  18. logger.info("重连服务器登录失败,3秒再连接一次:" + ex.getMessage());
  19. }
  20. }
  21. }
  22. });
  23. TextLineCodecFactory factory = new TextLineCodecFactory(Charset.forName(encoding), LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue());
  24. factory.setDecoderMaxLineLength(10240);
  25. factory.setEncoderMaxLineLength(10240);
  26. //加入解码器
  27. connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(factory));
  28. //添加处理器
  29. connector.setHandler(new IoHandler());
  30. connector.getSessionConfig().setReceiveBufferSize(10240);   // 设置接收缓冲区的大小
  31. connector.getSessionConfig().setSendBufferSize(10240);          // 设置输出缓冲区的大小
  32. connector.setDefaultRemoteAddress(new InetSocketAddress(host, port));// 设置默认访问地址
  33. for (;;) {
  34. try {
  35. ConnectFuture future = connector.connect();
  36. // 等待连接创建成功
  37. future.awaitUninterruptibly();
  38. // 获取会话
  39. session = future.getSession();
  40. logger.error("连接服务端" + host + ":" + port + "[成功]" + ",,时间:" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
  41. break;
  42. } catch (RuntimeIoException e) {
  43. logger.error("连接服务端" + host + ":" + port + "失败" + ",,时间:" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + ", 连接MSG异常,请检查MSG端口、IP是否正确,MSG服务是否启动,异常内容:" + e.getMessage(), e);
  44. Thread.sleep(5000);// 连接失败后,重连间隔5s
  45. }
  46. }</span>

第二种：加入空闲检测机制

空闲检测机制需要在创建客户端时，加入空闲超时，然后在处理器handler端的sessionIdle方法中加入一个预关闭连接的方法。让Session关闭传递到监听器或者拦截器的sessionClose方法中实现重连。

以拦截器方式为例，在创建客户端时，加入读写通道空闲检查超时机制。

Java代码  

  1. <span style="font-family: ‘Microsoft YaHei‘,微软雅黑,SimHei,tahoma,arial,helvetica,sans-serif;">        connector = new NioSocketConnector();  //创建连接客户端
  2. connector.setConnectTimeoutMillis(30000); //设置连接超时
  3. //      断线重连回调拦截器
  4. connector.getFilterChain().addFirst("reconnection", new IoFilterAdapter() {
  5. @Override
  6. public void sessionClosed(NextFilter nextFilter, IoSession ioSession) throws Exception {
  7. for(;;){
  8. try{
  9. Thread.sleep(3000);
  10. ConnectFuture future = connector.connect();
  11. future.awaitUninterruptibly();// 等待连接创建成功
  12. session = future.getSession();// 获取会话
  13. if(session.isConnected()){
  14. logger.info("断线重连["+ connector.getDefaultRemoteAddress().getHostName() +":"+ connector.getDefaultRemoteAddress().getPort()+"]成功");
  15. break;
  16. }
  17. }catch(Exception ex){
  18. logger.info("重连服务器登录失败,3秒再连接一次:" + ex.getMessage());
  19. }
  20. }
  21. }
  22. });
  23. connector.getFilterChain().addLast("mdc", new MdcInjectionFilter());
  24. TextLineCodecFactory factory = new TextLineCodecFactory(Charset.forName(encoding), LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue());
  25. factory.setDecoderMaxLineLength(10240);
  26. factory.setEncoderMaxLineLength(10240);
  27. //加入解码器
  28. connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(factory));
  29. connector.getSessionConfig().setReceiveBufferSize(10240);   // 设置接收缓冲区的大小
  30. connector.getSessionConfig().setSendBufferSize(10240);// 设置输出缓冲区的大小
  31. connector.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 30000);  //读写都空闲时间:30秒
  32. connector.getSessionConfig().setIdleTime(IdleStatus.READER_IDLE, 40000);//读(接收通道)空闲时间:40秒
  33. connector.getSessionConfig().setIdleTime(IdleStatus.WRITER_IDLE, 50000);//写(发送通道)空闲时间:50秒
  34. //添加处理器
  35. connector.setHandler(new IoHandler());
  36. connector.setDefaultRemoteAddress(new InetSocketAddress(host, port));// 设置默认访问地址
  37. for (;;) {
  38. try {
  39. ConnectFuture future = connector.connect();
  40. // 等待连接创建成功
  41. future.awaitUninterruptibly();
  42. // 获取会话
  43. session = future.getSession();
  44. logger.error("连接服务端" + host + ":" + port + "[成功]" + ",,时间:" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
  45. break;
  46. } catch (RuntimeIoException e) {
  47. System.out.println("连接服务端" + host + ":" + port + "失败" + ",,时间:" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + ", 连接MSG异常,请检查MSG端口、IP是否正确,MSG服务是否启动,异常内容:" + e.getMessage());
  48. logger.error("连接服务端" + host + ":" + port + "失败" + ",,时间:" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + ", 连接MSG异常,请检查MSG端口、IP是否正确,MSG服务是否启动,异常内容:" + e.getMessage(), e);
  49. Thread.sleep(5000);// 连接失败后,重连10次,间隔30s
  50. }
  51. }</span>

然后在数据处理器IoHandler中sessionIdle方法中加入Session会话关闭的代码，这样session关闭就能传递到拦截器或者监听器中，然后实现重连。

Java代码  

  1. <span style="font-family: ‘Microsoft YaHei‘,微软雅黑,SimHei,tahoma,arial,helvetica,sans-serif;">import org.apache.mina.core.service.IoHandlerAdapter;
  2. import org.apache.mina.core.session.IdleStatus;
  3. import org.apache.mina.core.session.IoSession;
  4. public class IoHandler extends IoHandlerAdapter {
  5. //部分代码忽略...
  6. @Override
  7. public void sessionIdle(IoSession session, IdleStatus status) throws Exception {
  8. logger.info("-客户端与服务端连接[空闲] - " + status.toString());
  9. if(session != null){
  10. session.close(true);
  11. }
  12. }
  13. //部分代码忽略...
  14. }</span>

总结-最佳实践：

以上两种方式我个人认为最好是使用第二种。在实际的生产环境，对于数据量比较少的情况下，需要加一个线程专门发送心跳信息，然后在服务器端进行回应心跳，这样就保证读写通道不出现空闲。如果数据量比较大，大到24小时都有数据，那么就不需要心跳线程，可以直接在IoHandler处理器端中messageReceived方法中定时发送心跳到服务器。由于读写监控还可以处理服务器、网络、应用等等方面的不确定因素，所以建议使用第二种方式。

时间： 2024-09-29 15:38:55

Mina 断线重连的相关文章

Mina.Net实现的断线重连

using Mina.Filter.Codec; using Mina.Filter.Codec.TextLine; using System; using System.Collections.Generic; using System.Linq; using System.Net; using System.Text; using Mina.Core.Session; using System.Threading; namespace MinaDemo { class TCPMessageD

socket 断线重连

send发送数据时,发送失败,进行如下重连处理: if(send(sockfd, serbuf, readlen, 0) < 0)//serbuf中有数据可以发送才会执行这条语句 { printf("serial to tcp send msg error: %s(errno: %d)\n", strerror(errno), errno);//服务端断掉,则发送失败. //exit(0); //断线重连 sleep(3); close(sockfd); sockfd = soc

关于socket tcp 断线重连

这个问题困扰过我几次,都没有来得及研究,今天研究一下. 首先写一个最简易的socket tcp程序,连接成功后再关闭服务器然后再用客户端各种操作看是什么情况 测试表明 (1)客户端已经连接,当服务端关闭程序时,客户端调用send函数发送失败,WSAGetLastError() 返回10054(远程主机强迫关闭了一个现有的连接) (2)客户端已经连接,当客户端关闭程序时,服务端调用recv函数接收失败,WSAGetLastError() 返回10054(远程主机强迫关闭了一个现有的连接) ,这时对

【c#源码】基于TCP通信的客户端断线重连

源码下载 在CS程序中,断线重连应该是一个常见的功能. 此处的断线重连主要指的是服务器端因为某种故障,服务器端程序或者系统进行了重新启动,客户端能够自动探测到服务器端掉线,并尝试重新进行连接 本程序基于来自英国的开源c#通信框架的networkcomms(2.3.1版本) 先看一下效果 初始状态: 当服务器端程序关闭后,客户端会自动探测到,并在客户端显示相关信息 然后,我们设定为每隔5秒重连一次,可以自定义设置重连的次数,比如说重连50次,如果还没有重连成功,则放弃重连 然后我们重新启动服务器端

房卡麻将分析系列之&quot;断线重连&quot;

"房卡"麻将研发技巧,尽在"红孩儿的游戏开发之路",欢迎关注公众号! 房卡麻将分析系列之"断线重连" 大家好,我是红孩儿,"房卡"麻将分析系列继续进行中. 在进行游戏的过程中,人们往往会遇到"断线"情况,比如坐公车,地铁下班路上玩一局,下车转站时往往先关机,过一会儿再上线继续完,如果没有自动"断线重连",则对于牌局的体验感影响会非常大,在"房卡"麻将中加入"

nodejs使用MYSQL连接池，断线重连

两种方式解决1.你可以配置mysql的连接池 var mysql = require('mysql'); var pool = mysql.createPool({ host: 'localhost', user: 'nodejs', password: 'nodejs', database: 'nodejs', port: 3306 }); var selectSQL = 'select * from t_user limit 10'; pool.getConnection(function

基于TCP通信的客户端断线重连

转载:http://www.cnblogs.com/networkcomms/p/4304362.html 源码下载 在CS程序中,断线重连应该是一个常见的功能. 此处的断线重连主要指的是服务器端因为某种故障,服务器端程序或者系统进行了重新启动,客户端能够自动探测到服务器端掉线,并尝试重新进行连接 本程序基于来自英国的开源c#通信框架的networkcomms(2.3.1版本) 先看一下效果 初始状态: 当服务器端程序关闭后,客户端会自动探测到,并在客户端显示相关信息 然后,我们设定为每隔5秒重

UniDAC 断线重连方法

KBM服务端的 UniConnection 要实现断线重连(连接 MSSQLServer), 需要以下几个步骤: 一.修改单元文件:kbmMWUniDAC.pas procedure TkbmMWUNIDACConnection.InternalOpenConnection(ConnectionPool:TkbmMWCustomConnectionPool); begin // Create new database connection using template. with TkbmMWU

通过任务计划程序实现上网卡断线重拨

由于工作中需要做一些服务器维护,为方便维护,在服务器上安装了一个4G无线上网卡.但是由于网络不稳定,经常在使用一两天后就断开,无法远程连接,甚是苦恼.在网上找了挺久也没有发现什么好的解决办法. 正好今天网络搜索发现了一个帖子<待机唤醒后自动连接宽带>,和我要解决的问题有异曲同工的感觉,于是便试了一试,果然好用,赶紧分享给大家. 1.首先新建文本文件,写入以下vbs代码,并保存为vbs文件: createobject("wscript.shell").run"ras