消息模式在實際開發應用中的優勢

曾經.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 消息集中處理控制更加靈活。

?