曾經.NET面試過程中經常問的一個問題是，如果程序集A，引用B ，B 引用C，那么C怎么去訪問A中的方法呢。

這個問題初學.net可能一時想不出該咋處理，這涉及到循環引用問題。但有點經驗的可能就簡單了，通過委托的方式，從A中傳遞到C中，然后在C中就可以訪問了。還有通過接口方式也可以。

但是如果項目中有非常多的程序集， A B C D E F G 而且互相都有交叉的訪問關系，任何兩者都有可能訪問，那么如果用接口和委托可能就不是那么方便了。

?

消息模式不僅僅可以完美解決上述問題，還可以使得所有交互都集中處理，使用更方便。

最近開發的一個系統，涉及到諸多數據處理以及控制層，而且之間大都存在循環訪問的問題，如果不用消息模式，系統將變得非常難于維護。

系統有如下幾層：UI層，指令層，數據層，算法層，狀態層。?

UI層需要通知指令層參數變更等。指令層需要通知UI層，發出買入賣出操作并且更改UI顯示。

狀態層狀態改變后，需要通知UI層顯示變更，指令層訪問算法層，指令層執行算法發現滿足條件時，通知狀態層變更。狀態層狀態變更后，通知指令層狀態變更正?；蛘弋惓?。然后進一步后續操作

還有自定義控件需要訪問Form中的方法以及給form發送通知都是通過發送消息的方式來實現的。

?

項目結構以及數據控制流圖如下（數據控制流只標記了部分，實際流更多）

? ??

?

?

消息中心 主要包括兩個靜態方法，一個公共事件，這里負責系統中所有的事件訂閱以及事件觸發的樞紐

namespace Common {/// <summary>/// 消息事件參數/// </summary>public class MessageArg : EventArgs{/// <summary>/// 消息類型/// </summary>public EnumMsgtype mstType { set; get; }public string gpCode { set; get; }public string message { set; get; }/// <summary>/// 擴展數據/// </summary>public object ExtendData { set; get; }}public class MessageCenter{ public static MessageCenter Instanse = null;static MessageCenter(){Instanse = new MessageCenter();}public delegate void MessageHandle(Object sender, MessageArg e);/// <summary>/// 消息事件/// </summary>public event MessageHandle OnMessage;/// <summary>/// 發送事件（后續添加的，發現消息模式的諸多便利）/// </summary>/// <param name="gpCode"></param>/// <param name="eventType"></param>/// <param name="extendData"></param>public static void SendEvent(string gpCode,EnumMsgtype eventType, object extendData){if(MessageCenter.Instanse.OnMessage!=null){try{MessageCenter.Instanse.OnMessage(MessageCenter.Instanse, new MessageArg() { mstType = eventType, gpCode = gpCode, ExtendData = extendData });}catch(Exception ex){ShowExceptionMsg(ex, gpCode);}} }/// <summary>/// 提示信息（一開始設計僅僅是想發送消息）/// </summary>/// <param name="mstType"></param>/// <param name="gpCode"></param>/// <param name="message"></param>public static void ShowMessage(EnumMsgtype mstType, string gpCode, string message){if (MessageCenter.Instanse.OnMessage != null){MessageCenter.Instanse.OnMessage(MessageCenter.Instanse, new MessageArg() { mstType = mstType, gpCode = gpCode, message = message });}}/// <summary>/// 發送異常信息/// </summary>/// <param name="ex"></param>/// <param name="gpCode"></param>public static void ShowExceptionMsg(Exception ex, string gpCode){EnumMsgtype msgType;string msg = "";if (ex is ApplicationException){msgType = EnumMsgtype.ImportantInfo;msg = ex.Message;}else{msgType = EnumMsgtype.SysError;msg = ex.ToString();}ShowMessage(msgType, gpCode, msg);}} }

?

?

指令中心 發送通知舉例

MessageCenter.SendEvent(singleStatus.GpCode, EnumMsgtype.ManageBeforeChangeEvent, singleStatus);//觸發操作前事件
MessageCenter.SendEvent(singleStatus.GpCode, EnumMsgtype.ManageChangeEvent, singleStatus);//觸發操作后事件

private void SetGpBuy(PriceTimeModel gpRealTimeData, GpStatusManage gpStatus){//所有需要買的狀態項List<GpStatusBase> lstBuyStatus = gpStatus.AllNeedBuyStatus;//依次進行驗證操作foreach (var singleStatus in lstBuyStatus){//設置狀態的最后一個股票信息singleStatus.LasterOpraPriceItem = gpRealTimeData;//獲取股票算法ManageRuleBase saleRule = ManageRuleBase.GetRule(gpStatus.GpParameterItem.LogicType);saleRule.PriceChange(gpRealTimeData, singleStatus); bool isCanBuy = CheckCanBuy(gpRealTimeData, singleStatus, saleRule);if (isCanBuy){MessageCenter.SendEvent(singleStatus.GpCode, EnumMsgtype.ManageBeforeChangeEvent, singleStatus);//緊急暫停if (IsStopBuy || singleStatus.GpItem.IsStopBuy){MessageCenter.ShowMessage(EnumMsgtype.StatusInfo, singleStatus.GpCode, gpRealTimeData.GetGpcodeAndTimeStr() + singleStatus.ManageTypeName + "緊急暫停，取消買操作");continue;}//的判斷是上面這個事件可能會更改狀態if (singleStatus.CanManage == false || singleStatus.ManageCnt==0){MessageCenter.ShowMessage(EnumMsgtype.StatusInfo, singleStatus.GpCode, gpRealTimeData.GetGpcodeAndTimeStr() + singleStatus.ManageTypeName + "數量不足，取消買操作");continue;}//發出買指令(鎖定價格買)var para = new ManageParameter(){GpCode = singleStatus.GpItem.GpCode,InstructWay = EnumInstruct.Buy,ManagePrice = singleStatus.LockPrice + gpStatus.GpItem.ChangePersontToPrice(0.2f),//加上0.3百分點增加買入成功率 //0322還是更改鎖定價格+0.2fManageCnt = singleStatus.ManageCnt,PriceItem = gpRealTimeData,GpItem = singleStatus.GpItem};//外掛操作if (waiguaOprationer.GpManage(para)){float managePrice = gpRealTimeData.Price + gpStatus.GpItem.ChangePersontToPrice(0.2f);singleStatus.ManagePrice = float.Parse(managePrice.ToString("f2"));singleStatus.ManagePriceItem = gpRealTimeData;//買入，更改狀態 singleStatus.SetGpStatusAfterEvent(EnumOprationStatus.Buyed);lstNeedCheckStatus.Add(singleStatus);//通知 MessageCenter.ShowMessage(EnumMsgtype.StatusInfo, gpStatus.GpCode, gpRealTimeData.GetGpcodeAndTimeStr() + singleStatus.ManageTypeName+ "買入操作成功,待驗證\r\n");//操作變更事件 MessageCenter.SendEvent(singleStatus.GpCode, EnumMsgtype.ManageChangeEvent, singleStatus);}}}}

?

UI接收消息舉例

訂閱消息?MessageCenter.Instanse.OnMessage += Instanse_OnMessage;

對不同的消息類型分別處理

private void Instanse_OnMessage(object sender, MessageArg e){try{if (GpItem != null && e.gpCode == ""){//清空if (e.mstType == EnumMsgtype.ClearDataEvent){this.lstOnePara.ForEach(t =>{t.SingleStatus = null;t.ReinitStepStyle();});}}if (GpItem != null && e.gpCode == GpItem.GpCode){//如果不在Form控制下，那么取消事件注冊！！！var parFrm = FindParentForm();if (parFrm == null){//這里通常是由于導入了參數，導致的額外注冊MessageCenter.Instanse.OnMessage -= Instanse_OnMessage;return;}if (e.mstType == EnumMsgtype.PriceChangeEvent){// }//消息else if (e.mstType == EnumMsgtype.Info || e.mstType == EnumMsgtype.ImportantInfo || e.mstType == EnumMsgtype.StatusInfo){// }else if (e.mstType == EnumMsgtype.ManageBeforeChangeEvent)//操作之前事件 {// }else if (e.mstType == EnumMsgtype.ManageChangeEvent)//操作之后事件 {// }else if (e.mstType == EnumMsgtype.AutoLockChangeEvent)//智能鎖定 {// }else if(e.mstType== EnumMsgtype.MonitStartEvent){// } }}catch(Exception ex){MessageCenter.ShowExceptionMsg(ex, GpItem.GpCode);}}

?

文中的舉例的軟件以及下載地址在我另外一博文中介紹

http://www.cnblogs.com/blackvis/p/5779443.html

?

總結消息模式的幾大優點

1 解決程序集循環訪問的問題

2 程序集解耦，對于少量通信的程序集之間不需要存在引用關系，就可達到互相通訊，亦可減少程序集中的public方法數量。

3 消息以廣播的形式進行發送，使得一處發送，多處重復使用。

4 消息集中處理控制更加靈活。

?

轉載于:https://www.cnblogs.com/blackvis/p/5782288.html

總結

以上是生活随笔為你收集整理的消息模式在实际开发应用中的优势的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。