前言
這兩天面試了一個物聯網公司高級研發，面試題是下面這樣子
公司領導，部門主管，小組組長，組成員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，將耦合性再度降低，同時也能讓接收方法更加靈活性，能實作不同級別的職員做出不同的回應！
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/71358.html
標籤：C#
上一篇：C# 泛型
下一篇：C# 委托