找回密码
 注册帐号

扫一扫,访问微社区

开果 一个简易的心跳包 C# Socket

19
回复
881
查看
[ 复制链接 ]

15

主题

25

帖子

213

积分

Rank: 9Rank: 9Rank: 9

UID
327626
好友
6
蛮牛币
142
威望
0
注册时间
2019-7-19
在线时间
159 小时
最后登录
2019-10-14
2019-9-12 17:24:24 显示全部楼层 阅读模式

马上注册,结交更多好友,享用更多功能,让你轻松玩转社区。

您需要 登录 才可以下载或查看,没有帐号?注册帐号

x
上篇 讲讲  代码 下篇就是讲下示例上面的使用了
先来看看代码吧:
1.KGHeartBeat   单个心跳包的数据类

[C#] 纯文本查看 复制代码
```
using System;



namespace KGSocket.Tool
{
    public class KGHeartBeat
    {

        //保存上一次心跳的时间
        protected long lastHeartTime;

        //超时次数
        public int Lostcount;

        //心跳包最大超时多少次
        public int MaxLostcount;

        //超时多久算一次
        public double MaxLostTime;

        //计算时间差的
        public long NowTimeSpan => Convert.ToInt64((DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, 0)).TotalSeconds);

        /// <summary>
        /// 检查心跳包延时
        /// </summary>
        public virtual void CheckHeat()
        {
            if (Math.Abs(lastHeartTime - this.NowTimeSpan) > MaxLostTime)
            {

                lastHeartTime = this.NowTimeSpan;
                Lostcount++;
            }
        }


        /// <summary>
        /// 更新心跳包
        /// </summary>
        public virtual void UpdateHeat()
        {
            lastHeartTime = this.NowTimeSpan;
            Lostcount = 0;
        }

        public virtual T InitMax<T>(double maxlosttime = 2, int maxlost = 3) where T: KGHeartBeat
        {
            MaxLostTime = maxlosttime;
            MaxLostcount = maxlost;
            //第一次赋值肯定要刷新
            lastHeartTime = this.NowTimeSpan;
            return this as T;
        }

        public virtual void InitMax(double maxlosttime = 2, int maxlost = 3) 
        {
            MaxLostTime = maxlosttime;
            MaxLostcount = maxlost;
            //第一次赋值肯定要刷新
            lastHeartTime = this.NowTimeSpan;
        }

    }
}

```


貌似 都注释上了没啥好说的, NowTimeSpan => Convert.ToInt64((DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, 0)).TotalSeconds); 这个就是一个只读的写法,每次读取都会读现在的时间与默认的时间差距秒,从而去计算心跳包的秒数
InitMax()就是初始化上限数值   超时次数  超时上限
UpdateHeat()就是更新心跳包的 重新赋值当前与默认时间的差距秒数,  如果过段时间不更新不更新当前持有的秒数也不会更新 在CheckHeat()检测超过限定的超时时间MaxLostTime 就是增加一次Lostcount超时次数

2.KGHeartBeatManage<T,R>心跳包的管理类


[C#] 纯文本查看 复制代码
```
using System;
using System.Collections.Generic;




namespace KGSocket.Tool
{
    public class KGHeartBeatManage<T, R> : IDisposable where R : KGHeartBeat, new()
    {


        //主定时器
        public System.Timers.Timer Checktimer;
        public System.Timers.Timer Sendtimer;

        private readonly object mlock = new object();


        //发送心跳包事件
        public event Action<T> SendHearEvent;

        //心跳包超时事件
        public event Action<T> ConnectLostEvent;

        //每个会话对应一个心跳KGHeartBeat
        private Dictionary<T, R> connectDic = new Dictionary<T, R>();

        public Dictionary<T, R> ConnectDic { get => connectDic; protected set => connectDic = value; }



        public virtual KGHeartBeatManage<T, R> InitTimerEvent(Action<T> sendHearEvent, Action<T> connectLostEvent, double Checkinterval = 1000, double Sendinterval = 1000)
        {
            //这里是赋值每过多少秒执行一次事件
            Checktimer = new System.Timers.Timer(Checkinterval);
            Sendtimer = new System.Timers.Timer(Sendinterval);


            SendHearEvent = sendHearEvent;
            ConnectLostEvent = connectLostEvent;

            //定时执行事件
            Checktimer.Elapsed += (v, f) =>
            {
                //遍历每个会话回调一次检查心跳包

                    CheckHeartBeat();


            };

            //定时执行事件
            Sendtimer.Elapsed += (v, f) =>
            {
                //遍历每个会话回调一次发送心跳包
                lock (mlock)
                {
                    SendHeartBeat();
                }

            };

            return this;
        }

        public virtual KGHeartBeatManage<T, R> StartTimer()
        {
            Checktimer.Start();
            Sendtimer.Start();
            return this;
        }

        public virtual KGHeartBeatManage<T, R> StopTimer()
        {
            Checktimer.Stop();
            Sendtimer.Stop();
            return this;
        }


        /// <summary>
        /// 发送心跳包
        /// </summary>
        public virtual void SendHeartBeat()
        {
            lock (mlock)
            {
                if (ConnectDic.Count > 0&& SendHearEvent!=null)
                {
                    List<T> RemoveList = new List<T>();
                    foreach (KeyValuePair<T, R> item in ConnectDic)
                    {
                        SendHearEvent?.Invoke(item.Key);

                    }
                }
            }
        }

        /// <summary>
        /// 检查心跳包
        /// </summary>
        public virtual void CheckHeartBeat()
        {
            lock (mlock)
            {
                if (ConnectDic.Count > 0)
                {
                    List<T> RemoveList = new List<T>();
                    foreach (KeyValuePair<T, R> item in ConnectDic)
                    {


                        //检查 心跳包超时 如果超时满次数就移除并回调事件
                        item.Value.CheckHeat();
                        if (item.Value.Lostcount >= item.Value.MaxLostcount)
                        {
                            RemoveList.Add(item.Key);

                        }
                        RemoveList.ForEach(remove =>
                        {
                            ConnectLostEvent(remove);
                            ConnectDic.Remove(remove);
                        });
                    }
                }
            }
        }

        /// <summary>
        /// 添加存储新的心跳包
        /// </summary>
        /// <param name="obj"></param>
        /// <param name="heart"></param>
        /// <param name="maxlosttime"></param>
        /// <param name="maxlost"></param>
        public  KGHeartBeatManage<T, R> AddConnectDic(T obj, double maxlosttime = 2, int maxlost = 3)
        {
            R heartBeat= new R().InitMax<R>(maxlosttime,maxlost);

            lock (mlock)
            {
                ConnectDic.Add(obj, heartBeat);
            }

            return this;
        }


        public KGHeartBeatManage<T, R> RemoveConnectDic(T obj)
        {
            lock (mlock)
            {
                ConnectDic.Remove(obj);
            }

            return this;
        }

        /// <summary>
        /// 更新指定会话对应的心跳包
        /// </summary>
        /// <param name="obj"></param>
        public void UpdateOneHeat(T obj)
        {
            lock (mlock)
            {
                ConnectDic[obj].UpdateHeat();
            }
        }

        public void Dispose()
        {
            Checktimer.Dispose();
            Sendtimer.Dispose();
        }

    }
}

```


KGHeartBeatManage<T,R>:IDisposable where R:KGHeartBeat  这里的T就是你们定义的每个会话管理类,R就是指定要继承KGHeartBeat  的

初始化事件 InitTimerEvent(第一个委托就是发送事件,第二个委托就是 每个心跳包如果超时就会回调回来,每隔多少毫秒触发一次检测,每隔多少毫秒发送心跳包)   
然后StartTimer()就可以开始触发了
这边定时器那里加了个每次都会检测ConnectDic字典里面储存的心跳包,如果超过最大上限超时次数就会回调 KGHeartBeatManage里面的第二个委托,告诉他这个连接已经超时,

AddConnectDic(对应的会话管理类,指定超时时间,超时次数)这里会创建出对应的KGHeartBeat数据里存在字典里面,每个会话管理对应一个心跳包数据
RemoveConnectDic(T obj) 这里是移除字典里面 该会话管理对应的心跳包

因为会有多线程触发的问题这里用了lock互斥锁,排队来
游客,如果您要查看本帖隐藏内容请回复



回复

使用道具 举报

4四处流浪
419/500
排名
7088
昨日变化

0

主题

28

帖子

419

积分

Rank: 4

UID
187509
好友
0
蛮牛币
2081
威望
0
注册时间
2017-6-20
在线时间
207 小时
最后登录
2019-10-22
2019-9-13 11:46:12 显示全部楼层
开佬帅帅帅 迷妹爱爱爱
回复 支持 反对

使用道具 举报

7日久生情
2600/5000
排名
476
昨日变化

3

主题

328

帖子

2600

积分

Rank: 7Rank: 7Rank: 7Rank: 7

UID
872
好友
3
蛮牛币
8884
威望
0
注册时间
2013-7-14
在线时间
735 小时
最后登录
2019-10-18
2019-9-14 20:35:08 显示全部楼层
一个简易的心跳包 C# Socket
回复 支持 反对

使用道具 举报

排名
34890
昨日变化

0

主题

4

帖子

44

积分

Rank: 1

UID
308258
好友
0
蛮牛币
105
威望
0
注册时间
2018-12-14
在线时间
32 小时
最后登录
2019-9-25
2019-9-16 08:44:53 显示全部楼层
一个简易的心跳包 C# Socket
回复 支持 反对

使用道具 举报

7日久生情
2403/5000
排名
479
昨日变化

2

主题

104

帖子

2403

积分

Rank: 7Rank: 7Rank: 7Rank: 7

UID
69739
好友
0
蛮牛币
3136
威望
0
注册时间
2015-1-20
在线时间
755 小时
最后登录
2019-10-18
2019-9-16 09:02:22 显示全部楼层
一个简易的心跳包 C# Socket
回复 支持 反对

使用道具 举报

7日久生情
4501/5000
排名
144
昨日变化

1

主题

434

帖子

4501

积分

Rank: 7Rank: 7Rank: 7Rank: 7

UID
39981
好友
2
蛮牛币
9670
威望
0
注册时间
2014-8-15
在线时间
1710 小时
最后登录
2019-10-22

七夕浪漫情人

2019-9-16 10:12:48 显示全部楼层
66666666666666
回复

使用道具 举报

6蛮牛粉丝
1107/1500
排名
3074
昨日变化

1

主题

71

帖子

1107

积分

Rank: 6Rank: 6Rank: 6

UID
196658
好友
0
蛮牛币
1531
威望
0
注册时间
2016-12-28
在线时间
553 小时
最后登录
2019-10-22
2019-9-16 11:16:27 显示全部楼层
6666666666
回复

使用道具 举报

排名
7938
昨日变化

1

主题

74

帖子

380

积分

Rank: 7Rank: 7Rank: 7Rank: 7

UID
59843
好友
0
蛮牛币
1763
威望
0
注册时间
2014-12-7
在线时间
149 小时
最后登录
2019-9-27
2019-9-18 10:25:08 显示全部楼层
谢谢分享
回复

使用道具 举报

5熟悉之中
672/1000
排名
4698
昨日变化

5

主题

105

帖子

672

积分

Rank: 5Rank: 5

UID
279092
好友
1
蛮牛币
2359
威望
0
注册时间
2018-4-27
在线时间
251 小时
最后登录
2019-10-22
2019-9-18 15:24:49 显示全部楼层
谢谢分享
回复

使用道具 举报

5熟悉之中
688/1000
排名
5116
昨日变化

0

主题

107

帖子

688

积分

Rank: 5Rank: 5

UID
284721
好友
1
蛮牛币
1525
威望
0
注册时间
2018-6-7
在线时间
299 小时
最后登录
2019-9-23
QQ
2019-9-19 15:06:41 显示全部楼层
回复

使用道具 举报

7日久生情
1846/5000
排名
1365
昨日变化

7

主题

263

帖子

1846

积分

Rank: 7Rank: 7Rank: 7Rank: 7

UID
162659
好友
4
蛮牛币
5206
威望
0
注册时间
2016-8-16
在线时间
682 小时
最后登录
2019-10-22
2019-9-21 16:25:23 显示全部楼层
谢谢大佬,
回复

使用道具 举报

5熟悉之中
581/1000
排名
4698
昨日变化

1

主题

105

帖子

581

积分

Rank: 5Rank: 5

UID
31200
好友
0
蛮牛币
1047
威望
0
注册时间
2014-6-25
在线时间
163 小时
最后登录
2019-9-29
QQ
2019-9-26 13:48:44 显示全部楼层
一个简易的心跳包 C# Socket
回复 支持 反对

使用道具 举报

3偶尔光临
215/300
排名
64937
昨日变化

0

主题

126

帖子

215

积分

Rank: 3Rank: 3Rank: 3

UID
143972
好友
0
蛮牛币
136
威望
0
注册时间
2016-3-30
在线时间
87 小时
最后登录
2019-10-22
2019-9-30 09:03:49 显示全部楼层
感谢分享~~~~~~~~~~~
回复

使用道具 举报

5熟悉之中
975/1000
排名
5176
昨日变化

1

主题

322

帖子

975

积分

Rank: 5Rank: 5

UID
258102
好友
1
蛮牛币
1425
威望
0
注册时间
2017-12-6
在线时间
374 小时
最后登录
2019-10-18
2019-10-9 15:04:50 显示全部楼层
回复

使用道具 举报

3偶尔光临
158/300
排名
16595
昨日变化

0

主题

48

帖子

158

积分

Rank: 3Rank: 3Rank: 3

UID
126531
好友
0
蛮牛币
1
威望
0
注册时间
2015-10-23
在线时间
69 小时
最后登录
2019-10-10
QQ
2019-10-9 18:40:28 显示全部楼层
支持一下
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 注册帐号

本版积分规则