快捷導(dǎo)航

c# 使用計(jì)時(shí)器和觀察者模式實(shí)現(xiàn)報(bào)警推送需求

更新時(shí)間：2020年07月03日 10:07:44 作者：長(zhǎng)沙大鵬

這篇文章主要介紹了c# 使用計(jì)時(shí)器和觀察者模式實(shí)現(xiàn)報(bào)警推送需求，文中示例代碼非常詳細(xì)，幫助大家更好的理解和學(xué)習(xí)，感興趣的朋友可以了解下

前言

這兩天面試了一個(gè)物聯(lián)網(wǎng)公司高級(jí)研發(fā)，面試題是下面這樣子

公司領(lǐng)導(dǎo)，部門(mén)主管，小組組長(zhǎng)，組成員4級(jí)，假如有個(gè) 疫情預(yù)警，先通知組人員（對(duì)個(gè)人，主要有一個(gè)處理就算處理了）如果3分鐘沒(méi)處理，就往組長(zhǎng)發(fā)短信，如果組長(zhǎng)3分鐘沒(méi)處理就往上級(jí)推送。一級(jí)一級(jí)的。要求單程序并發(fā)至少支持1000tps預(yù)警事件

說(shuō)實(shí)話上面需求在我做的過(guò)往項(xiàng)目里有過(guò)類似需求，我也只是依稀記得自己是怎么做的。類似于使用第三方任務(wù)調(diào)度框架完成上面的3分鐘超時(shí)處理，然后至于分級(jí)發(fā)送則更簡(jiǎn)單了，再不濟(jì)就是使用if、else這樣的最原始驗(yàn)證即可。但是這樣的題目丟到面試題上我是一下就不知所措了。自然最終的結(jié)果也不盡人意(我最終提交的代碼就是采用一個(gè)事件總線實(shí)現(xiàn)報(bào)警的推送，但是并未對(duì)其進(jìn)行超時(shí)分級(jí)發(fā)送) 這個(gè)自然是錯(cuò)誤的，我其實(shí)當(dāng)時(shí)也想過(guò)使用Timer，但是內(nèi)心對(duì)Timer就是感覺(jué)用性能做代價(jià)去換取最終的結(jié)果。

解析需求

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

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

  /// <summary>
  /// 工作級(jí)別
  /// </summary>
  public enum JobLevel : int
  {
    公司領(lǐng)導(dǎo) = 1,
    部門(mén)主管 = 2,
    小組組長(zhǎng) = 3,
    組成員 = 4
  }

其次我們至少存在兩個(gè)類，一個(gè)是產(chǎn)生報(bào)警的對(duì)象，這個(gè)對(duì)象有需要通知的報(bào)警信息和報(bào)警信息發(fā)送結(jié)果，當(dāng)然更加少不了我們訂閱了報(bào)警消息的訂閱者。這里想了下，可以采用觀察者設(shè)計(jì)模式進(jìn)行解耦。

  /// <summary>
  /// 發(fā)布者接口
  /// </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>
    /// 發(fā)送報(bào)警消息
    /// </summary>
    void SendNotify();
  
    /// <summary>
    /// 出現(xiàn)警報(bào)
    /// </summary>
    /// <param name="msg">警報(bào)消息</param>
    void CreateJB(string msg);

接下來(lái)就是實(shí)現(xiàn)上面接口了！

/// <summary>
/// 報(bào)警發(fā)布者
/// </summary>
public class Baojing : IPublish
{
    /// <summary>
    /// 訂閱者集合
    /// </summary>
    public List<SubscriberPeopleBase> SubscriberLst { get; set; }
 
    /// <summary>
    /// 報(bào)警消息
    /// </summary>
    public string Msg { get; set; }
 
    /// <summary>
    /// 有無(wú)接收成功
    /// </summary>
    public bool IsSucess { get; set; }
 
    /// <summary>
    /// 消息通知計(jì)數(shù)器
    /// </summary>
    public Timer NotifyTimer { get; set; }
 
    /// <summary>
    /// 記錄當(dāng)前發(fā)送消息的崗位
    /// </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>
    /// 發(fā)送報(bào)警消息
    /// </summary>
    public void SendNotify()
    {
      if (SubscriberLst?.Count > 0)
      {
        //循環(huán)從職位低到高
        SubscriberLst.OrderByDescending(p => (int)p.Title);  
         //立即執(zhí)行CheckNotifySendResult，以為3秒為間隔
        NotifyTimer = new Timer(CheckNotifySendResult, null, 0, 3000);       
      }
    }
 
    public void CheckNotifySendResult(object stat)
    {
      //先要停止定時(shí)器，防止并發(fā)
      NotifyTimer.Change(-1, 3000);
      //第一次發(fā)給職位最小 枚舉最大的組成員
      SubscriberPeopleBase subscriberPeople = SubscriberLst.Find(p =>
       (((int)CurrentJobLevel + 1) - (int)p.Title) == 1);
      if (subscriberPeople == null) return; //已經(jīng)是最小的
      if (!IsSucess)
      {
        IsSucess = subscriberPeople.ReceiveData(this);
        if (!IsSucess)
        {
          CurrentJobLevel = CurrentJobLevel!= JobLevel.公司領(lǐng)導(dǎo)?(JobLevel)((int)CurrentJobLevel) - 1: JobLevel.公司領(lǐng)導(dǎo);
          NotifyTimer.Change(3000, 3000);
        }
      }
      else
      {
        Console.WriteLine($"停止計(jì)數(shù)器 {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
        NotifyTimer.Dispose();
      }
    }
  }

還需要有訂閱者，訂閱者使用抽象類方式降低耦合性(其實(shí)還是要用事件總線，將耦合性和擴(kuò)展性提高一個(gè)檔次)

 /// <summary>
  /// 訂閱者
  /// 其實(shí)這里還不夠完善，理論上后續(xù)如果每個(gè)職位的訂閱者對(duì)報(bào)警消息的處理不同則在下面的接收消息里會(huì)存在一些冗余代碼，
  /// 理想情況是不同級(jí)別應(yīng)該有不同的實(shí)現(xiàn)，這樣可以足夠抽象，后續(xù)擴(kuò)展也更加方便
  /// </summary>
  public abstract class SubscriberPeopleBase
  {
    /// <summary>
    /// 工作職位(級(jí)別)
    /// </summary>
    public JobLevel Title { get; set; }
 
    public SubscriberPeopleBase(JobLevel title)
    {
      Title = title;
    }
 
    public virtual bool ReceiveData(Baojing baojing)
    {
      if (Title == JobLevel.公司領(lǐng)導(dǎo))
      {
        Console.WriteLine($"出現(xiàn)報(bào)警信息:{baojing.Msg},當(dāng)前訂閱者:{Title.ToString()} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
        return true;
      }
      else
      {
        Console.WriteLine($"出現(xiàn)報(bào)警信息:{baojing.Msg},當(dāng)前訂閱者:{Title.ToString()},默認(rèn)未應(yīng)答 {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
        return false;
      }
    }
  }

再加個(gè)子類，重寫(xiě)下接收警報(bào)的方法

public class SubscriberPeople : SubscriberPeopleBase
 {
    public SubscriberPeople(JobLevel title) : base(title) { }
    public override bool ReceiveData(Baojing baojing)
    {     
      if (Title == JobLevel.公司領(lǐng)導(dǎo))
      {
        Console.WriteLine($"出現(xiàn)最新報(bào)警信息:{baojing.Msg},當(dāng)前訂閱者:{Title.ToString()} 已成功應(yīng)答 {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
        return true;
      }
      else
      {
        Console.WriteLine($"出現(xiàn)報(bào)警信息:{baojing.Msg},當(dāng)前訂閱者:{Title.ToString()},默認(rèn)未應(yīng)答 {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.公司領(lǐng)導(dǎo)));
      publish.AddSubscriber(new SubscriberPeople(JobLevel.部門(mén)主管));
      publish.AddSubscriber(new SubscriberPeople(JobLevel.小組組長(zhǎng)));
      publish.CreateJB("主機(jī)溫度過(guò)高!");
      publish.SendNotify();
      Console.ReadLine();
  }

調(diào)試的效果如下: