///

/// 检查一个Socket是否可连接

///

///

///

private bool IsConnected(Socket socket)

{

if (socket == null || socket.Connected == false)

{

return false;

}

bool blockingState = socket.Blocking;

try

{

byte[] tmp = new byte[];

socket.Blocking = false;

socket.Send(tmp, , );

return true;

}

catch (SocketException e)

{

// 产生 10035 == WSAEWOULDBLOCK 错误，说明被阻止了，但是还是连接的

if (e.NativeErrorCode.Equals())

{

return true;

}

else

{

return false;

}

}

finally

{

socket.Blocking = blockingState; // 恢复状态

}

}

上面的代码来自互联网

原理就是在外面加个timer/task/thread，每隔一段时间，做心跳检查。如果发送信息失败表示无法连接，那么我们就可以重连了。

///

/// 轮询检查Socket连接

///

private void PollingCheckSocket()

{

_pollingCheckSocketTimer = new System.Threading.Timer((obj) =>

{

if (!_run)//控制timer暂停、恢复用的

{

return;

}

foreach (var hub in _hubs)

{

//为null或断开连接时，重连

var connected = this.IsConnected(hub.Socket);

if (!connected)

{

_socketService.Close(hub.Socket);

hub.Socket = _socketService.Get(hub);

}

}

}, null, , );//表示10秒后开始检查，然后每15秒检查一次

}

我是将socket作为hub的一个属性。这里是遍历所有hub，逐一检查每个hub的socket是否断开。如果断开了，先关闭旧的socket，再重连。需要说明的是，这里的重连是新建一个socket连接，旧的socket连接是无法再次连接的。以下是socket辅助类：

public class SocketService

{

private Logger _logger = LogManager.GetCurrentClassLogger();

///

/// 获取socket

///

///

///

public Socket Get(HubModel model)

{

try

{

// 将IP地址字符串转换为IPAddress对象

IPAddress ip = IPAddress.Parse(model.IP);

// 创建终结点EndPoint

IPEndPoint endPoint = new IPEndPoint(ip, model.Port);

// 创建Socket并连接到服务器

Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

// 连接到服务器

socket.Connect(endPoint);

return socket;

}

catch (System.Exception ex)

{

_logger.Error(string.Format("获取socket异常,message:{0},stacktrace:{1}", ex.Message, ex.StackTrace));

}

return null;

}

///

/// 关闭socket

///

///

public void Close(Socket socket)

{

if (socket != null)

{

socket.Close();

socket = null;

}

}

}

}

初探和实现websocket心跳重连

心跳重连缘由 在使用websocket过程中,可能会出现网络断开的情况,比如信号不好,或者网络临时性关闭,这时候websocket的连接已经断开, 而浏览器不会执行websocket 的 onclos ...

web socket 心跳包的实现方案

web socket 心跳包的实现方案05/30/2010 现在网络环境错综复杂,socket心跳包是获得健康强壮的连接的有效解决方案,今天,我们就在web socket中实现心跳包方案,是的,尽管我 ...

初探和实现websocket心跳重连(npm: websocket-heartbeat-js)

提示:文章最下方有仓库地址 心跳重连缘由 websocket是前后端交互的长连接,前后端也都可能因为一些情况导致连接失效并且相互之间没有反馈提醒.因此为了保证连接的可持续性和稳定性,websocket ...

【简记】前端对接WebSocket与心跳重连

前言 最近又在忙着开发别的模块,其中包含了即时通讯这一块,上一次做即时通讯时还是去年年底,一时间代码都在自己的笔记本里,还没带--这里就记录一下前端对接WebSocket的实现,包含心跳重连,简记之. ...

websocket心跳重连 websocket-heartbeat-js

初探和实现websocket心跳重连(npm: websocket-heartbeat-js) 心跳重连缘由 websocket是前后端交互的长连接,前后端也都可能因为一些情况导致连接失效并且相互之间 ...

161114、websocket实现心跳重连

心跳重连缘由 在使用websocket过程中,可能会出现网络断开的情况,比如信号不好,或者网络临时性关闭,这时候websocket的连接已经断开, 而浏览器不会执行websocket 的 onclos ...

websocket 心跳重连

websocket 的基本使用: var ws = new WebSocket(url); ws.onclose = function () { //something reconnect(); // ...

[转] Socket心跳包异常检测的C语言实现，服务器与客户端代码案例

转载自:zxh2075的专栏 在Socket心跳机制中,心跳包可以由服务器发送给客户端,也可以由客户端发送给服务器,不过比较起来,前者开销可能较大.本文实现的是由客户端给服务器发送心跳包,服务器不必返 ...

socket心跳包机制实践与理解

实现Socket心跳包主要分为两大类,第一采用tcp自带的KeepAlive,第二是自定义心跳包,恰巧我在产品VICA中都使用过,下面就这两种心跳包机制谈谈个人的理解与感受. 首先第一种KeepAli ...

随机推荐

在excel worksheet中添加button 和对Excel workbook做权限控制相关的新知识

添加button在worksheet中 1. Shapes Object (Excel) Reference:http://technet.microsoft.com/zh-cn/library/ff ...

【zz】Matlab 二值图像形态学函数 bwmorph