幸福框架：發布訂閱模式 之 同步訂閱、異步訂閱和離線訂閱

背景

事件驅動解除了發布者和訂閱者之間的耦合，在UI層面，我明經常采用這種編程理念。服務器端最近也開始流行起來了，我也一直小范圍的在采用。今天就跟大家分享一下我寫的一個小框架。

框架原理

一張圖片勝過前言萬語。

代碼示例

下載地址：http://yunpan.cn/Q5SUcWdiA2mmk。

項目結構

關鍵代碼

TestEvent.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using Happy.Event;
using Happy.Event.Offline;

namespace Happy.Event.Demo.Simple
{
    [TestEventInterceptor1Attibute(1)]
    [TestEventInterceptor2Attibute(2)]
    [Persistable(3)]
    internal sealed class TestEvent : IEvent
    {
    }
}

Program.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading;

using Microsoft.Practices.ServiceLocation;
using Microsoft.Practices.Unity;

using Happy.Event;
using Happy.Event.Offline;

namespace Happy.Event.Demo.Simple
{
    class Program
    {
        static readonly string _QueueName = "Happy.Event.Demo.Simple";

        static void Main(string[] args)
        {
            InitUnity();

            var writeQueue = OfflineEventQueueFactory.CreateMSMQOfflineEventQueue(_QueueName);
            EventPublisher.Current.AddService(writeQueue);

            EventPublisher.Current.Publish(new TestEvent());

            new Thread(() =>
            {
                var readQueue = OfflineEventQueueFactory.CreateMSMQOfflineEventQueue(_QueueName);
                var offlineEventProcessor = new OfflineEventProcessor(readQueue);

                offlineEventProcessor.Start();
            })
            .Start();

            Console.ReadLine();
        }

        static void InitUnity()
        {
            var container = new UnityContainer();

            ServiceLocator.SetLocatorProvider(() => new UnityServiceLocator(container));

            container.RegisterType<ISyncEventSubscriber<TestEvent>, TestSyncEventSubscriber1>("TestSyncEventSubscriber1");
            container.RegisterType<ISyncEventSubscriber<TestEvent>, TestSyncEventSubscriber2>("TestSyncEventSubscriber2");
            container.RegisterType<IAsyncEventSubscriber<TestEvent>, TestAsyncEventSubscriber1>("TestAsyncEventSubscriber1");
            container.RegisterType<IAsyncEventSubscriber<TestEvent>, TestAsyncEventSubscriber2>("TestAsyncEventSubscriber2");
            container.RegisterType<IOfflineEventSubscriber<TestEvent>, TestOfflineEventSubscriber1>("TestOfflineEventSubscriber1");
            container.RegisterType<IOfflineEventSubscriber<TestEvent>, TestOfflineEventSubscriber2>("TestOfflineEventSubscriber2");
        }
    }
}

執行結果

備注

基於事件的編程，我在真實項目中有過實戰的，這個框架目前還沒在項目中使用。研發先行。