c# 使用计时器和观察者模式实现报警推送需求

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

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