使用C#的計時器加觀察者模式完成報警推送需求

前言這兩天面試了一個物聯網公司高級研發，面試題是下麵這樣子公司領導，部門主管，小組組長，組成員4級，假如有個疫情預警，先通知組人員（對個人，主要有一個處理就算處理了）如果3分鐘沒處理，就往組長髮簡訊，如果組長3分鐘沒處理就往上級推送。一級一級的。要求單程式併發至少支持1000tps預警事件 ...

前言

這兩天面試了一個物聯網公司高級研發，面試題是下麵這樣子

公司領導，部門主管，小組組長，組成員4級，假如有個疫情預警，先通知組人員（對個人，主要有一個處理就算處理了）如果3分鐘沒處理，就往組長髮簡訊，如果組長3分鐘沒處理就往上級推送。一級一級的。要求單程式併發至少支持1000tps預警事件

說實話上面需求在我做的過往項目里有過類似需求，我也只是依稀記得自己是怎麼做的。類似於使用第三方任務調度框架完成上面的3分鐘超時處理，然後至於分級發送則更簡單了，再不濟就是使用if、else這樣的最原始驗證即可。但是這樣的題目丟到面試題上我是一下就不知所措了。自然最終的結果也不盡人意(我最終提交的代碼就是採用一個事件匯流排實現報警的推送，但是並未對其進行超時分級發送) 這個自然是錯誤的，我其實當時也想過使用Timer，但是內心對Timer就是感覺用性能做代價去換取最終的結果。

解析需求

過了幾天還是覺得要手純擼代碼將上面功能擼出來，不然如何成長呢！
拆分下需求可以得到的消息是有一個事件。這個事件就是報警事件，通過報警事件需要將消息推送給不同職位的工作人員，而且必須遵循崗位從下至上，但凡人員收到報警消息則表示報警通知已完成，其次就是有一個三分鐘需要處理。

通過上面的需求分析可以知道我們必須要定義一個枚舉，記錄職稱高低。

    /// <summary>
    /// 工作級別
    /// </summary>
    public enum JobLevel : int
    {
        公司領導 = 1,
        部門主管 = 2,
        小組組長 = 3,
        組成員 = 4
    }

其次我們至少存在兩個類，一個是產生報警的對象，這個對象有需要通知的報警信息和報警信息發送結果，當然更加少不了我們訂閱了報警消息的訂閱者。這裡想了下，可以採用觀察者設計模式進行解耦。

    /// <summary>
    /// 發佈者介面
    /// </summary>
    public interface IPublish
    {
        /// <summary>
        /// 新增訂閱者(觀察者)
        /// </summary>
        /// <param name="subscriber"></param>
        void AddSubscriber(SubscriberPeopleBase subscriber);

        /// <summary>
        /// 移除訂閱者(觀察者)
        /// </summary>
        /// <param name="subscriber"></param>
        void RemoveSubscriber(SubscriberPeopleBase subscriber);

        /// <summary>
        /// 發送報警消息
        /// </summary>
        void SendNotify();
   
        /// <summary>
        /// 出現警報
        /// </summary>
        /// <param name="msg">警報消息</param>
        void CreateJB(string msg);

　　接下來就是實現上面介面了！

/// <summary>
/// 報警發佈者
/// </summary>
public class Baojing : IPublish
{
        /// <summary>
        /// 訂閱者集合
        /// </summary>
        public List<SubscriberPeopleBase> SubscriberLst { get; set; }

        /// <summary>
        /// 報警消息
        /// </summary>
        public string Msg { get; set; }

        /// <summary>
        /// 有無接收成功
        /// </summary>
        public bool IsSucess { get; set; }

        /// <summary>
        /// 消息通知計數器
        /// </summary>
        public Timer NotifyTimer { get; set; }

        /// <summary>
        /// 記錄當前發送消息的崗位
        /// </summary>
        public JobLevel CurrentJobLevel = JobLevel.組成員;

        public void AddSubscriber(SubscriberPeopleBase subscriber)
        {
            if (SubscriberLst == null) SubscriberLst = new  List<SubscriberPeopleBase>();
            SubscriberLst.Add(subscriber);
        }

        public void CreateJB(string msg)
        {
            Msg = msg;
        }

        public void RemoveSubscriber(SubscriberPeopleBase subscriber)
        {
            if (SubscriberLst != null) SubscriberLst.Remove(subscriber);
        }


        /// <summary>
        /// 發送報警消息
        /// </summary>
        public void SendNotify()
        {
            if (SubscriberLst?.Count > 0)
            {
                //迴圈從職位低到高
                SubscriberLst.OrderByDescending(p => (int)p.Title);    
                 //立即執行CheckNotifySendResult，以為3秒為間隔
                NotifyTimer = new Timer(CheckNotifySendResult, null, 0, 3000);               
            }
        }

        public void CheckNotifySendResult(object stat) 
        {
            //先要停止定時器，防止併發
            NotifyTimer.Change(-1, 3000);
            //第一次發給職位最小 枚舉最大的組成員
            SubscriberPeopleBase subscriberPeople = SubscriberLst.Find(p => 
             (((int)CurrentJobLevel + 1) - (int)p.Title) == 1);
            if (subscriberPeople == null) return; //已經是最小的
            if (!IsSucess)
            {
                IsSucess = subscriberPeople.ReceiveData(this);
                if (!IsSucess)
                {
                    CurrentJobLevel = CurrentJobLevel!= JobLevel.公司領導?(JobLevel)((int)CurrentJobLevel) - 1: JobLevel.公司領導;
                    NotifyTimer.Change(3000, 3000);
                }
            }
            else
            {
                Console.WriteLine($"停止計數器 {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
                NotifyTimer.Dispose();
            }
        }
    }

　　還需要有訂閱者，訂閱者使用抽象類方式降低耦合性(其實還是要用事件匯流排，將耦合性和擴展性提高一個檔次)

  /// <summary>
    /// 訂閱者
    /// 其實這裡還不夠完善，理論上後續如果每個職位的訂閱者對報警消息的處理不同則在下麵的接收消息里會存在一些冗餘代碼，
    /// 理想情況是不同級別應該有不同的實現，這樣可以足夠抽象，後續擴展也更加方便
    /// </summary>
    public abstract class SubscriberPeopleBase
    {
        /// <summary>
        /// 工作職位(級別)
        /// </summary>
        public JobLevel Title { get; set; }

        public SubscriberPeopleBase(JobLevel title)
        {
            Title = title;
        }

        public virtual bool ReceiveData(Baojing baojing)
        {
            if (Title == JobLevel.公司領導)
            {
                Console.WriteLine($"出現報警信息:{baojing.Msg},當前訂閱者:{Title.ToString()} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
                return true;
            }
            else
            {
                Console.WriteLine($"出現報警信息:{baojing.Msg},當前訂閱者:{Title.ToString()},預設未應答  {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
                return false;
            }
        }
    }

　　再加個子類，重寫下接收警報的方法

 public class SubscriberPeople : SubscriberPeopleBase
 {
        public SubscriberPeople(JobLevel title) : base(title) { }
        public override bool ReceiveData(Baojing baojing)
        {           
            if (Title == JobLevel.公司領導)
            {
                Console.WriteLine($"出現最新報警信息:{baojing.Msg},當前訂閱者:{Title.ToString()} 已成功應答 {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
                return true;
            }
            else
            {
                Console.WriteLine($"出現報警信息:{baojing.Msg},當前訂閱者:{Title.ToString()},預設未應答 {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
                return false;
            }
        }
 }

　　最終我的main方法是這樣

  static void Main(string[] args)
  {
            IPublish publish = new Baojing();
            publish.AddSubscriber(new SubscriberPeople(JobLevel.組成員));
            publish.AddSubscriber(new SubscriberPeople(JobLevel.公司領導));
            publish.AddSubscriber(new SubscriberPeople(JobLevel.部門主管));
            publish.AddSubscriber(new SubscriberPeople(JobLevel.小組組長));
            publish.CreateJB("主機溫度過高!");
            publish.SendNotify();
            Console.ReadLine();
   }

　　調試的效果如下:

明天還是完善下，將使用EventBus，將耦合性再度降低，同時也能讓接收方法更加靈活性，能實現不同級別的職員做出不同的響應！