前言

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

公司領導，部門主管，小組組長，組成員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,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},預設未應答 {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，將耦合性再度降低，同時也能讓接收方法更加靈活性，能實現不同級別的職員做出不同的響應！

以上就是c# 使用計時器和觀察者模式實現報警推送需求的詳細內容，更多關於c# 實現報警推送需求的資料請關注我們其它相關文章！