幸福框架：使用 “離線事件” 處理 “長事務”

背景

事件有兩種使用方式：一、作為傳統的監聽者模式以達到程序結構的解耦；二、作為消息機制以達到時間和空間上的解耦，如發送到遠程服務器、持久化到隊列等待。今天介紹如何使用“離線事件”處理“長事務”，這就需要把事件當做消息對待。

我理解的長事務是“執行時間長的任務，具體多少沒有標准”，如果希望在一個數據庫事務中完成這些長事務是不現實的，之前我的做法是換成存儲過程以降低事務的執行時間，以后我會采用“離線事件”。

離線事件：事件的一部分是同步執行，另外一部分會被異步的離線的在另外一台機器執行。

簡單示例

下載地址：OfflineEventStudy。

項目結構

1. Common：類庫，包含了事件和事件監聽者（同步事件監聽者和離線事件監聽者）。
2. Console：離線事件執行程序，定時從隊列取事件並執行離線事件監聽者。
3. Web：事件生成程序，發布事件並執行同步事件監聽者。

Common中的代碼

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

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

namespace OfflineEventStudy.Common
{
    [Persistable(1)]
    public sealed class TestEvent : IEvent
    {
        public const string FilePath = @"E:\log.txt";

        public string Info { get; set; }
    }
}

注意：Persistable特性會導致此事件支持離線訂閱。

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

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

namespace OfflineEventStudy.Common
{
    public sealed class TestEventSubscriber : ISyncEventSubscriber<TestEvent>, IOfflineEventSubscriber<TestEvent>
    {
        void ISyncEventSubscriber<TestEvent>.Handle(TestEvent @event)
        {
            File.WriteAllText(TestEvent.FilePath, @event.Info + "：任務正在執行中！");
        }

        void IOfflineEventSubscriber<TestEvent>.Handle(TestEvent @event)
        {
            Thread.Sleep(5000);

            File.WriteAllText(TestEvent.FilePath, @event.Info + "：任務完成！");
        }
    }
}

注意：同步接口會在Web中執行，離線接口會在Console中執行。

Console中的代碼

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

using Happy.Event;
using Happy.Event.Offline;
using Happy.Bootstrap;
using Happy.Infrastructure.Unity;

namespace OfflineEventStudy.Console
{
    class Program
    {
        static void Main(string[] args)
        {
            /****************************************啟動過程配置****************************************/

            BootstrapService
             .Current
             .IntegrateWithUnity() //使用Unity作為Ioc容器。
             .UseRegisterServiceByConventionPlug() //使用按照約定注冊服務插件，會自動幫你執行注冊。
                .UseEventSubscriberRegister() //注冊所有的EventListener。
                .Done() //完成配置。
             .Start(); //啟動。

            /****************************************啟動過程配置****************************************/

            var processor = new OfflineEventProcessor(OfflineEventQueueFactory.CreateMSMQOfflineEventQueue("OfflineEventStudy"));

            ThreadPool.QueueUserWorkItem((state) =>
            {
                processor.Start();
            }, null);

            System.Console.WriteLine("正在監聽任務");
            System.Console.Read();
        }
    }
}

注意：這里會不斷的從隊列取事件並執行。

Web中的代碼

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.IO;

using Happy.Event;
using OfflineEventStudy.Common;

namespace OfflineEventStudy.Web
{
    public partial class Default : System.Web.UI.Page
    {
        protected void Page_Load(object sender, EventArgs e)
        {
            if (this.IsPostBack)
            {
                return;
            }

            this.Display();
        }

        protected void Button1_Click(object sender, EventArgs e)
        {
            EventPublisher.Current.Publish(new TestEvent { Info = "測試事件" });

            this.Display();
        }

        protected void Button2_Click(object sender, EventArgs e)
        {
            this.Display();
        }

        private void Display()
        {
            if (!File.Exists(TestEvent.FilePath))
            {
                return;
            }

            this.Label1.Text = File.ReadAllText(TestEvent.FilePath);
        }
    }
}

運行效果

備注

因為事件的一部分是離線執行的，所以不能保證實時一致性，關於最終一致性的問題這里不好多說，有興趣的朋友可以找http://www.cnblogs.com/netfocus/聊聊，netfocus最新力作enode完全放棄實時一致性，換來的是高並發。