欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

C# 基于消息發(fā)布訂閱模型的示例(下)

 更新時(shí)間:2021年03月01日 08:53:22   作者:Hello——尋夢(mèng)者!  
這篇文章主要介紹了C# 基于消息發(fā)布訂閱模型的示例,幫助大家更好的理解和使用c#,感興趣的朋友可以了解下

一 背景

  在上面的一篇文章中我們介紹了一個(gè)完整地基于消息發(fā)布和訂閱的模型,這篇文章我將介紹一種簡(jiǎn)單的基于消息的發(fā)布和訂閱模型,在這個(gè)模型中我們將通過(guò)構(gòu)建一個(gè)Publisher類(lèi)來(lái)完成對(duì)特定的事件和事件訂閱進(jìn)行封裝,這個(gè)是一個(gè)更加輕量級(jí)別的方式,使用這個(gè)的主要目的是降低類(lèi)之間彼此的耦合程度,從而方便代碼的擴(kuò)展和訪問(wèn),最終使代碼結(jié)構(gòu)更加合理。

  我們首先來(lái)看看具體的Publisher類(lèi)的構(gòu)成,后面我們將會(huì)對(duì)這個(gè)類(lèi)做一個(gè)詳細(xì)的講解和分析。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
 
namespace Pangea.Common.Utility
{
    /// <summary>
    /// Publisher/Subscriber pattern
    /// This infrastructure works as an instance.
    /// </summary>
    public sealed class Publisher<EventType> where EventType : IComparable
    {
        private static readonly object _locker = new object();
 
        private static readonly Dictionary<EventType, List<Action<object, object, object, object>>> _eventTypeList = new Dictionary<EventType, List<Action<object, object, object, object>>>();
 
        public static void Attach(EventType key, Action<object, object, object, object> act)
        {
            lock (_locker)
            {
                if (!_eventTypeList.ContainsKey(key))
                    _eventTypeList.Add(key, new List<Action<object, object, object, object>>());
                if (!_eventTypeList[key].Contains(act))
                    _eventTypeList[key].Add(act);
            }
        }
 
        public static void Detach(EventType key)
        {
            lock (_locker)
            {
                if (_eventTypeList.ContainsKey(key))
                {
                    _eventTypeList[key].Clear();
                }
            }
        }
 
        public static void Detach(EventType key, Action<object, object, object, object> act)
        {
            lock (_locker)
            {
                if (_eventTypeList.ContainsKey(key) && _eventTypeList[key].Contains(act))
                {
                    _eventTypeList[key].Remove(act);
                }
            }
        }
 
        public static void Notify(EventType key, object p1, object p2, object p3, object p4)
        {
            lock (_locker)
            {
                if (_eventTypeList.ContainsKey(key))
                {
                    foreach (var act in _eventTypeList[key])
                    {
                        act.Invoke(p1, p2, p3, p4);
                    }
                }
            }
        }
 
        public static void Notify(EventType key, object p1, object p2, object p3)
        {
            Notify(key, p1, p2, p3, null);
        }
 
        public static void Notify(EventType key, object p1, object p2)
        {
            Notify(key, p1, p2, null, null);
        }
 
        public static void Notify(EventType key, object p1)
        {
            Notify(key, p1, null, null, null);
        }
 
        public static void Notify(EventType key)
        {
            Notify(key, null, null, null, null);
        }
    }
}

二 完成分析

  在上面的Publisher類(lèi)中,我們使用了一個(gè)EventType類(lèi)型的泛型參數(shù),這個(gè)參數(shù)由我們自己來(lái)進(jìn)行定義,一般定義為枚舉類(lèi)型用于標(biāo)識(shí)我們唯一的事件類(lèi)型,定義好了泛型參數(shù)后我們定義了一個(gè)_eventTypeList用于定義具體的EventType和對(duì)應(yīng)的處理方法并且將這個(gè)放到一個(gè)靜態(tài)的Dictionary中,當(dāng)然我們?cè)诖a中一個(gè)事件可以對(duì)應(yīng)多個(gè)處理的Action,但是在一般情況下一個(gè)事件只有一個(gè)對(duì)應(yīng)的處理函數(shù),這里也不排除一個(gè)事件對(duì)應(yīng)多個(gè)事件的處理函數(shù),另外這里我們默認(rèn)定義了四個(gè)object類(lèi)型的參數(shù),用于向處理函數(shù)進(jìn)行參數(shù)的傳遞,另外我們的方法都是靜態(tài)的方法并且在訂閱的過(guò)程中加了鎖從而保證了多線程的環(huán)境中保證線程的安全性。

三 使用過(guò)程

  在具體的使用過(guò)程中主要包括三個(gè)重要的步驟:1 定義事件類(lèi)型。2  消息接收方訂閱事件處理(一般在構(gòu)造函數(shù)中調(diào)用Attach方法創(chuàng)建時(shí)間的唯一訂閱)。3  事件發(fā)布方發(fā)布事件(事件的發(fā)送方觸發(fā)時(shí)間并傳遞參數(shù),調(diào)用Notify方式觸發(fā)事件),完成以上三個(gè)步驟就完成了整個(gè)基于消息的發(fā)布訂閱的簡(jiǎn)單處理,這個(gè)Publisher類(lèi)在處理一般的事件方法中都能夠順利實(shí)現(xiàn),最重要的是事件本身簡(jiǎn)單易于理解而且能最大程度上降低模塊間的耦合,所以在使用的時(shí)候還是非常方便的。

以上就是C# 基于消息發(fā)布訂閱模型的示例(下)的詳細(xì)內(nèi)容,更多關(guān)于c# 發(fā)布訂閱模型的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

最新評(píng)論