香港6合总彩透码主论坛
 ?#19968;?#23494;码
 注册帐号

扫一扫,访问微社区

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

10
回复
394
查看
打印 上一主题 下一主题
[ 复制链接 ]

14

主题

23

帖子

184

积分

Rank: 9Rank: 9Rank: 9

UID
327626
好友
5
蛮牛币
133
威望
0
注册时间
2019-7-19
在线时间
133 小时
最后登录
2019-9-21

马?#29486;?#20876;,结交更多好友,享用更多功能,让你轻松玩转社区。

您需要 登录 才可以下载或查看,没有帐?#29275;?a href="member.php?mod=register" title="注册帐号">注册帐号

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;
        }

    }
}

```


?#33756;?都注释上了没啥好说的, NowTimeSpan => Convert.ToInt64((DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, 0)).TotalSeconds); 这个就是一个只读的写法,每次读取都会读现在的时间与默认的时间差距秒,从而去计算心跳包的秒数
InitMax()就是初始化上限数值   超时次数  超时上限
UpdateHeat()就是更新心跳包的 重新赋值当前与默?#40092;?#38388;的差距秒数,  如果过?#38382;?#38388;不更新不更新当前持有的秒数也不会更新 在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();


        //发送心跳包?#24405;?
        public event Action<T> SendHearEvent;

        //心跳包超时?#24405;?
        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)
        {
            //这里是赋值每过多少秒执行一?#38382;录?
            Checktimer = new System.Timers.Timer(Checkinterval);
            Sendtimer = new System.Timers.Timer(Sendinterval);


            SendHearEvent = sendHearEvent;
            ConnectLostEvent = connectLostEvent;

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

                    CheckHeartBeat();


            };

            //定时执行?#24405;?
            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)
                    {


                        //检查 心跳包超时 如果超时满次数就移除并回调?#24405;?
                        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就是指定要?#22363;蠯GHeartBeat  的

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

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

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



回复

使用道具 举报

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

0

主题

28

帖子

412

积分

Rank: 4

UID
187509
好友
0
蛮牛币
2056
威望
0
注册时间
2017-6-20
在线时间
200 小时
最后登录
2019-9-21
沙发
2019-9-13 11:46:12 只看该作者
开佬帅帅帅 迷妹爱爱爱
回复 支持 反对

使用道具 举报

排名
476
昨日变化

3

主题

328

帖子

2599

积分

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

UID
872
好友
3
蛮牛币
8882
威望
0
注册时间
2013-7-14
在线时间
734 小时
最后登录
2019-9-17
板凳
2019-9-14 20:35:08 只看该作者
一个简易的心跳包 C# Socket
回复 支持 反对

使用道具 举报

排名
34888
昨日变化

0

主题

4

帖子

41

积分

Rank: 1

UID
308258
好友
0
蛮牛币
90
威望
0
注册时间
2018-12-14
在线时间
29 小时
最后登录
2019-9-20
一个简易的心跳包 C# Socket
回复 支持 反对

使用道具 举报

排名
479
昨日变化

2

主题

104

帖子

2401

积分

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

UID
69739
好友
0
蛮牛币
3115
威望
0
注册时间
2015-1-20
在线时间
753 小时
最后登录
2019-9-17
5#
6 天前 只看该作者
一个简易的心跳包 C# Socket
回复 支持 反对

使用道具 举报

排名
144
昨日变化

1

主题

433

帖子

4487

积分

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

UID
39981
好友
2
蛮牛币
9496
威望
0
注册时间
2014-8-15
在线时间
1697 小时
最后登录
2019-9-20

七夕浪漫情人

6#
6 天前 只看该作者
66666666666666
回复

使用道具 举报

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

1

主题

69

帖子

1086

积分

Rank: 6Rank: 6Rank: 6

UID
196658
好友
0
蛮牛币
1457
威望
0
注册时间
2016-12-28
在线时间
534 小时
最后登录
2019-9-21
7#
6 天前 只看该作者
6666666666
回复

使用道具 举报

排名
7938
昨日变化

1

主题

74

帖子

380

积分

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

UID
59843
好友
0
蛮牛币
1760
威望
0
注册时间
2014-12-7
在线时间
149 小时
最后登录
2019-9-19
8#
4 天前 只看该作者
谢谢分享
回复

使用道具 举报

5熟悉之中
667/1000
排名
4696
昨日变化

5

主题

104

帖子

667

积分

Rank: 5Rank: 5

UID
279092
好友
1
蛮牛币
2316
威望
0
注册时间
2018-4-27
在线时间
246 小时
最后登录
2019-9-21
9#
4 天前 只看该作者
谢谢分享
回复

使用道具 举报

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

0

主题

106

帖子

686

积分

Rank: 5Rank: 5

UID
284721
好友
1
蛮牛币
1519
威望
0
注册时间
2018-6-7
在线时间
298 小时
最后登录
2019-9-20
QQ
回复

使用道具 举报

排名
1365
昨日变化

7

主题

261

帖子

1832

积分

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

UID
162659
好友
3
蛮牛币
5012
威望
0
注册时间
2016-8-16
在线时间
670 小时
最后登录
2019-9-21
11#
昨天 16:25 只看该作者
谢谢大佬,
回复

使用道具 举报

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

本版积分规则

香港6合总彩透码主论坛