找回密码
 注册帐号

扫一扫,访问微社区

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

24
回复
1498
查看
[ 复制链接 ]

15

主题

25

帖子

218

积分

Rank: 9Rank: 9Rank: 9

UID
327626
好友
6
蛮牛币
87
威望
0
注册时间
2019-7-19
在线时间
164 小时
最后登录
2019-12-1
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四处流浪
427/500
排名
7088
昨日变化

0

主题

28

帖子

427

积分

Rank: 4

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

使用道具 举报

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

3

主题

328

帖子

2607

积分

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

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

使用道具 举报

排名
34890
昨日变化

0

主题

13

帖子

70

积分

Rank: 2Rank: 2

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

使用道具 举报

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

2

主题

104

帖子

2405

积分

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

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

使用道具 举报

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

1

主题

436

帖子

4525

积分

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

UID
39981
好友
2
蛮牛币
10034
威望
0
注册时间
2014-8-15
在线时间
1732 小时
最后登录
2019-12-13

七夕浪漫情人

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

使用道具 举报

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

1

主题

71

帖子

1141

积分

Rank: 6Rank: 6Rank: 6

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

使用道具 举报

排名
7938
昨日变化

1

主题

75

帖子

382

积分

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

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

使用道具 举报

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

5

主题

106

帖子

688

积分

Rank: 5Rank: 5

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

使用道具 举报

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

0

主题

108

帖子

702

积分

Rank: 5Rank: 5

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

使用道具 举报

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

7

主题

278

帖子

1901

积分

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

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

使用道具 举报

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

1

主题

107

帖子

584

积分

Rank: 5Rank: 5

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

使用道具 举报

4四处流浪
308/500
排名
64938
昨日变化

0

主题

169

帖子

308

积分

Rank: 4

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

使用道具 举报

6蛮牛粉丝
1006/1500
排名
5176
昨日变化

1

主题

325

帖子

1006

积分

Rank: 6Rank: 6Rank: 6

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

使用道具 举报

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

0

主题

52

帖子

163

积分

Rank: 3Rank: 3Rank: 3

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

使用道具 举报

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

本版积分规则