找回密碼
 注冊帳號

掃一掃,訪問微社區

開果 一個簡易的心跳包 C# Socket

24
回復
1453
查看
打印 上一主題 下一主題
[ 復制鏈接 ]

15

主題

25

帖子

218

積分

Rank: 9Rank: 9Rank: 9

UID
327626
好友
6
蠻牛幣
87
威望
0
注冊時間
2019-7-19
在線時間
164 小時
最后登錄
2019-12-1

馬上注冊,結交更多好友,享用更多功能,讓你輕松玩轉社區。

您需要 登錄 才可以下載或查看,沒有帳號?注冊帳號

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
蠻牛幣
8896
威望
0
注冊時間
2013-7-14
在線時間
742 小時
最后登錄
2019-12-9
板凳
2019-9-14 20:35:08 只看該作者
一個簡易的心跳包 C# Socket
回復 支持 反對

使用道具 舉報

排名
34890
昨日變化

0

主題

11

帖子

65

積分

Rank: 2Rank: 2

UID
308258
好友
0
蠻牛幣
162
威望
0
注冊時間
2018-12-14
在線時間
46 小時
最后登錄
2019-12-6
地板
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
5#
2019-9-16 09:02:22 只看該作者
一個簡易的心跳包 C# Socket
回復 支持 反對

使用道具 舉報

7日久生情
4523/5000
排名
144
昨日變化

1

主題

436

帖子

4523

積分

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

UID
39981
好友
2
蠻牛幣
9986
威望
0
注冊時間
2014-8-15
在線時間
1730 小時
最后登錄
2019-12-9

七夕浪漫情人

6#
2019-9-16 10:12:48 只看該作者
66666666666666
回復

使用道具 舉報

6蠻牛粉絲
1138/1500
排名
3074
昨日變化

1

主題

71

帖子

1138

積分

Rank: 6Rank: 6Rank: 6

UID
196658
好友
0
蠻牛幣
1665
威望
0
注冊時間
2016-12-28
在線時間
584 小時
最后登錄
2019-12-9
7#
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
8#
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
9#
2019-9-18 15:24:49 只看該作者
謝謝分享
回復

使用道具 舉報

5熟悉之中
701/1000
排名
5116
昨日變化

0

主題

108

帖子

701

積分

Rank: 5Rank: 5

UID
284721
好友
1
蠻牛幣
1596
威望
0
注冊時間
2018-6-7
在線時間
311 小時
最后登錄
2019-12-7
QQ
10#
2019-9-19 15:06:41 只看該作者
回復

使用道具 舉報

7日久生情
1896/5000
排名
1365
昨日變化

7

主題

277

帖子

1896

積分

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

UID
162659
好友
4
蠻牛幣
5534
威望
0
注冊時間
2016-8-16
在線時間
718 小時
最后登錄
2019-12-9
11#
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
12#
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
13#
2019-9-30 09:03:49 只看該作者
感謝分享~~~~~~~~~~~
回復

使用道具 舉報

6蠻牛粉絲
1003/1500
排名
5176
昨日變化

1

主題

325

帖子

1003

積分

Rank: 6Rank: 6Rank: 6

UID
258102
好友
1
蠻牛幣
1503
威望
0
注冊時間
2017-12-6
在線時間
399 小時
最后登錄
2019-12-9
14#
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
15#
2019-10-9 18:40:28 只看該作者
支持一下
回復

使用道具 舉報

您需要登錄后才可以回帖 登錄 | 注冊帳號

本版積分規則

法甲球队主场名称