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

来源:https://www.cnblogs.com/hunanzp/archive/2020/02/22/12343863.html
-Advertisement-
Play Games

前言 這兩天面試了一個物聯網公司高級研發，面試題是下麵這樣子 公司領導，部門主管，小組組長，組成員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，將耦合性再度降低，同時也能讓接收方法更加靈活性，能實現不同級別的職員做出不同的響應！

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Python原來這麼好學-2.1節: 選擇PyCharm作為開發工具
    Pycharm分為商業版和社區版，商業版是收費的，社區版面向的是python社區的學習人員，其提供的功能與商業版並無太大區別。通常來說，使用社區版即可滿足絕大部分程式員的開發需求。 ...
  • 同一伺服器下發佈兩個不同網站（war包）的方法（這裡採用的是二級功能變數名稱的方法）
    這裡是在阿裡雲伺服器的上部署 在本地測試好之後，打包，然後發到伺服器上的tomcat的webapp目錄上（這個可能會有個bug，先啟動下伺服器，然後關掉，再啟動，那個war包對應的文件才會出來） 這裡指的是第二個項目，也就是說本身有個項目已經在上面跑了，第二個也直接放到webapp文件夾下即可 然後 ...
  • 【Pyecharts可視化分享】杭州步行熱門路線等～
    前言 本文包括內容如下： 杭州步行熱門路線 漸變效果散點圖 均是Echarts官方提供等示例，本文將會通過Pyecharts來進行實現。 杭州步行熱門路線 因為代碼中需要調用百度地圖，所以開始之前你需要去百度申請一個開發者AK： "百度地圖開放平臺" 。 數據源： "https://echarts. ...
  • Windows玩轉Kubernetes系列4-搭建K8S Dashboard
    下載官方yaml文件 最新的配置文件v2.0.0 beta8版本recommended.yaml， "UI地址" 原文件： 修改為： 原文件內容 修改為： 下載鏡像和啟動 在master節點執行 執行 查看pod和service狀態 如果發現 kubernetes dashboard crashlo ...
  • php面試筆記（5）-php基礎知識-自定義函數及內部函數考點
    本文是根據慕課網Jason老師的課程進行的PHP面試知識點總結和升華，如有侵權請聯繫我進行刪除，email：[email protected] 在面試中，考官往往喜歡基礎扎實的面試者，而函數相關的考點，往往是大家容易忽視的一個點，今天冷月就來幫各位小伙伴們梳理一下，在面試中函數相關的註意點。 回顧真 ...
  • 封裝的Redis隊列
    封裝的Redis隊列 MyRedisQueue.py 接收端 發送端 ...
  • Python學習零基礎＜入門必學＞
    1. 註釋註釋 是任何存在於 # 號右側的文字，其主要用作寫給程式讀者看的筆記。 2. 字面常量一個字面常量（Literal Constants）的例子是諸如 5、1.23 這樣的數字，或者是如 這是一串文本 或 This is a string 這樣的文本。 ＆每天都有程式員定時講解Python技 ...
  • Asp.net Core MVC（三）UseMvc設置路由
    在家辦公，下班繼續看點東西，不廢話，繼續看MVC的路由。 asp.net核心mvc的路由是建立在asp.net核心的路由之上的。通過終結點載入路由中間件的配置方式在此不細說了，（DOTNET Core MVC（二）已經說明）。在看一下其他的載入方式： app.UseMvc(routes => { / ...
一周排行
    -Advertisement-
    Play Games
  • Dapr Outbox 執行流程
    Dapr Outbox 是1.12中的功能。 本文只介紹Dapr Outbox 執行流程，Dapr Outbox基本用法請閱讀官方文檔 。本文中appID=order-processor，topic=orders 本文前提知識：熟悉Dapr狀態管理、Dapr發佈訂閱和Outbox 模式。 Outbo ...
  • Advanced .Net Debugging 7：托管堆與垃圾收集
    引言 在前幾章我們深度講解了單元測試和集成測試的基礎知識，這一章我們來講解一下代碼覆蓋率,代碼覆蓋率是單元測試運行的度量值,覆蓋率通常以百分比表示，用於衡量代碼被測試覆蓋的程度，幫助開發人員評估測試用例的質量和代碼的健壯性。常見的覆蓋率包括語句覆蓋率（Line Coverage）、分支覆蓋率（Bra ...
  • C#S7.NET實現西門子PLCDB塊數據採集的完整步驟
    前言 本文介紹瞭如何使用S7.NET庫實現對西門子PLC DB塊數據的讀寫，記錄了使用電腦模擬，模擬PLC，自至完成測試的詳細流程，並重點介紹了在這個過程中的易錯點，供參考。 用到的軟體： 1.Windows環境下鏈路層網路訪問的行業標準工具（WinPcap_4_1_3.exe）下載鏈接：http ...
  • WPF控制項：密碼框綁定MVVM
    從依賴倒置原則（Dependency Inversion Principle, DIP）到控制反轉（Inversion of Control, IoC）再到依賴註入（Dependency Injection, DI）的演進過程，我們可以理解為一種逐步抽象和解耦的設計思想。這種思想在C#等面向對象的編 ...
  • Python中的私有屬性與私有方法
    關於Python中的私有屬性和私有方法 Python對於類的成員沒有嚴格的訪問控制限制，這與其他面相對對象語言有區別。關於私有屬性和私有方法，有如下要點： 1、通常我們約定，兩個下劃線開頭的屬性是私有的（private）。其他為公共的（public）； 2、類內部可以訪問私有屬性（方法）； 3、類外 ...
  • C++ 訪問說明符詳解：封裝數據，控制訪問，提升安全性
    C++ 訪問說明符 訪問說明符是 C++ 中控制類成員（屬性和方法）可訪問性的關鍵字。它們用於封裝類數據並保護其免受意外修改或濫用。 三種訪問說明符： public：允許從類外部的任何地方訪問成員。 private：僅允許在類內部訪問成員。 protected：允許在類內部及其派生類中訪問成員。 示 ...
  • static_cast與dynamic_cast到底是什麼？
    寫這個隨筆說一下C++的static_cast和dynamic_cast用在子類與父類的指針轉換時的一些事宜。首先，【static_cast，dynamic_cast】【父類指針，子類指針】，兩兩一組，共有4種組合：用 static_cast 父類轉子類、用 static_cast 子類轉父類、使用 ...
  • C語言數據結構：雙向鏈表的增刪操作
    /******************************************************************************************************** * * * 設計雙向鏈表的介面 * * * * Copyright (c) 2023-2 ...
  • @ComponentScan註解的實現，Spring掃描包的過程
    相信接觸過spring做開發的小伙伴們一定使用過@ComponentScan註解 @ComponentScan("com.wangm.lifecycle") public class AppConfig { } @ComponentScan指定basePackage，將包下的類按照一定規則註冊成Be ...
  • opensips開啟python支持
    操作系統 ：CentOS 7.6_x64 opensips版本： 2.4.9 python版本：2.7.5 python作為腳本語言，使用起來很方便，查了下opensips的文檔，支持使用python腳本寫邏輯代碼。今天整理下CentOS7環境下opensips2.4.9的python模塊筆記及使用 ...
所有分類