月份: 2020 年 3 月

從中國發改委網站獲悉，停車場充電設施建設協調會7月18日下午召開。會議表示將針對大城市、特大城市存在的停車位資源緊張、社會停車場投資主體多、充電設施企業盈利模式相對單一等問題，進一步推進相關工作。  
  停車場充電設施建設協調會由中國國家發改委基礎產業司副司長鄭劍主持，就2016年第二批城市停車場項目配建充電基礎設施問題，與安徽、江蘇、江西、陝西、浙江、湖北、上海、大連、廈門等地方發展改革委、充電基礎設施服務企業和國家電網公司進行交流座談。   據國家能源局電力司初步統計，截至今年6月底，中國全國已建成公共充電樁8.1萬個，比去年底增長65%；隨車建成私人充電樁超過5萬個，比去年底增長約12%。1-6月全國新能源汽車充電量超過6億kWh，替代燃油約20萬噸，電動汽車的發展對能源結構調整和城市環境提升貢獻明顯。   為新能源汽車的推廣和應用創造良好的環境，國家能源局相關部門加快了推動充電樁政策規劃的落實，組織起草加快居民區充電基礎設施建設的檔。該文件有望7月份出臺，將有效推進居民區和工作場所建樁工作，合理優化公共充電樁佈局，提高公共充電樁利用率。   文章來源：中國發展網

本站聲明:網站內容來源於EnergyTrend https://www.energytrend.com.tw/ev/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※為什麼 USB CONNECTOR 是電子產業重要的元件?

※網頁設計一頭霧水??該從何著手呢? 找到專業技術的網頁設計公司，幫您輕鬆架站!

※想要讓你的商品成為最夯、最多人討論的話題?網頁設計公司讓你強力曝光

※想知道最厲害的台北網頁設計公司推薦、台中網頁設計公司推薦專業設計師”嚨底家”!!

一、問題背景

　　最近離職來到了一家新的公司，原先是在乙方工作，這回到了甲方，在這一個月中，發現目前的業務很大一部分是靠輪詢實現的，例如：通過輪詢判斷數據處於B狀態了，則輪詢到數據后執行某種動作，這個其實是非常浪費的，並且對於數據的實時性也會不怎麼友好，基於以上的情況，在某天開車堵車時候，想到了之前偶然了解過的事件總線（EventBus），對比了公司當前的場景后，覺得事件總線應該是可以滿足需求的（PS:只是我覺得這個有問題，很多人不覺得有問題），那既然想到了，那就想自己是否可以做個事件總線的輪子

二、什麼是事件總線

　　我們知道事件是由一個Publisher跟一個或多個的Subsriber組成，但是在實際的使用過程中，我們會發現，Subsriber必須知道Publisher是誰才可以註冊事件，進而達到目的，那這其實就是一種耦合，為了解決這個問題，就出現了事件總線的模式，事件總線允許不同的模塊之間進行彼此通信而又不需要相互依賴，如下圖所示，通過EventBus，讓Publisher以及Subsriber都只需要對事件源（EventData）進行關注，不用管Publisher是誰，那麼EventBus主要是做了一些什麼事呢？

三、EventBus做了什麼事？

　　1、EventBus實現了對於事件的註冊以及取消註冊的管理

　　2、EventBus內部維護了一份事件源與事件處理程序的對應關係，並且通過這個對應關係在事件發布的時候可以找到對應的處理程序去執行

　　3、EventBus應該要支持默認就註冊事件源與處理程序的關係，而不需要開發人員手動去註冊（這裏可以讓開發人員去控制自動還是手動）

四、具體實現思路

 　　首先在事件總線中，存在註冊、取消註冊以及觸發事件這三種行為，所以我們可以將這三種行為抽象一個接口出來，最終的接口代碼如下：

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

namespace MEventBus.Core
{
    public interface IEventBus
    {
        #region 接口註冊
        void Register<TEventData>(Type handlerType) where TEventData : IEventData;
        void Register(Type eventType, Type handlerType);
        void Register(string eventType, Type handlerType);
        #endregion

        #region 接口取消註冊
        void Unregister<TEventData>(Type handler) where TEventData : IEventData;
        void Unregister(Type eventType, Type handlerType);
        void Unregister(string eventType, Type handlerType);
        #endregion


        void Trigger(string pubKey, IEventData eventData);
        Task TriggerAsync(string pubKey, IEventData eventData);
        Task TriggerAsync<TEventData>(TEventData eventData) where TEventData : IEventData;
        void Trigger<TEventData>(TEventData eventData) where TEventData : IEventData;
    }
}

　　在以上代碼中發現有些方法是有IEventData約束的，這邊IEventData就是約束入參行為，原則上規定，每次觸發的EventData都需要繼承IEventData，而註冊的行為也是直接跟入參類型相關，具體代碼如下：

using System;
using System.Collections.Generic;
using System.Text;

namespace MEventBus.Core
{
    public interface IEventData
    {
        string Id { get; set; }
        DateTime EventTime { get; set; }
        object EventSource { get; set; }
    }
}

　　接下來我們看下具體的實現代碼

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

namespace MEventBus.Core
{
    public class EventBus : IEventBus
    {
        private static ConcurrentDictionary<string, List<Type>> dicEvent = new ConcurrentDictionary<string, List<Type>>();
        private IResolve _iresolve { get; set; }
        public EventBus(IResolve resolve)
        {
            _iresolve = resolve;
            InitRegister();
        }

        public void InitRegister()
        {
            if (dicEvent.Count > 0)
            {
                return;
            }
            //_iresolve = ioc_container;
            dicEvent = new ConcurrentDictionary<string, List<Type>>();
            //自動掃描類型並且註冊
            foreach (var file in Directory.GetFiles(AppDomain.CurrentDomain.BaseDirectory, "*.dll"))
            {
                var ass = Assembly.LoadFrom(file);
                foreach (var item in ass.GetTypes().Where(p => p.GetInterfaces().Contains(typeof(IEventHandler))))
                {
                    if (item.IsClass)
                    {
                        foreach (var item1 in item.GetInterfaces())
                        {
                            foreach (var item2 in item1.GetGenericArguments())
                            {
                                if (item2.GetInterfaces().Contains(typeof(IEventData)))
                                {
                                    Register(item2, item);
                                }
                            }
                        }
                    }
                }
            }
        }
        //註冊以及取消註冊的時候需要加鎖處理
        private static readonly object obj = new object();

        #region 註冊事件
        public void Register<TEventData>(Type handlerType) where TEventData : IEventData
        {
            //將數據存儲到mapDic
            var dataType = typeof(TEventData).FullName;
            Register(dataType, handlerType);
        }
        public void Register(Type eventType, Type handlerType)
        {
            var dataType = eventType.FullName;
            Register(dataType, handlerType);
        }
        public void Register(string pubKey, Type handlerType)
        {
            lock (obj)
            {
                //將數據存儲到dicEvent
                if (dicEvent.Keys.Contains(pubKey) == false)
                {
                    dicEvent[pubKey] = new List<Type>();
                }
                if (dicEvent[pubKey].Exists(p => p.GetType() == handlerType) == false)
                {
                    //IEventHandler obj = Activator.CreateInstance(handlerType) as IEventHandler;
                    dicEvent[pubKey].Add(handlerType);
                }
            }
        }



        #endregion

        #region 取消事件註冊
        public void Unregister<TEventData>(Type handler) where TEventData : IEventData
        {
            var dataType = typeof(TEventData);
            Unregister(dataType, handler);
        }

        public void Unregister(Type eventType, Type handlerType)
        {
            string _key = eventType.FullName;
            Unregister(_key, handlerType);
        }
        public void Unregister(string eventType, Type handlerType)
        {
            lock (obj)
            {
                if (dicEvent.Keys.Contains(eventType))
                {
                    if (dicEvent[eventType].Exists(p => p.GetType() == handlerType))
                    {
                        dicEvent[eventType].Remove(dicEvent[eventType].Find(p => p.GetType() == handlerType));
                    }
                }
            }
        }
        #endregion

        #region Trigger觸發
        //trigger時候需要記錄到數據庫
        public void Trigger<TEventData>(TEventData eventData) where TEventData : IEventData
        {
            var dataType = eventData.GetType().FullName;
            //獲取當前的EventData綁定的所有Handler
            Notify(dataType, eventData);
        }

        public void Trigger(string pubKey, IEventData eventData)
        {
            //獲取當前的EventData綁定的所有Handler
            Notify(pubKey, eventData);
        }
        public async Task TriggerAsync<TEventData>(TEventData eventData) where TEventData : IEventData
        {
            await Task.Factory.StartNew(new Action(()=> 
            {
                var dataType = eventData.GetType().FullName;
                Notify(dataType, eventData);
            }));
        }
        public async Task TriggerAsync(string pubKey, IEventData eventData)
        {
            await Task.Factory.StartNew(new Action(() =>
            {
                var dataType = eventData.GetType().FullName;
                Notify(pubKey, eventData);
            }));
        }
        //通知每成功執行一個就需要記錄到數據庫
        private void Notify<TEventData>(string eventType, TEventData eventData) where TEventData : IEventData
        {
            //獲取當前的EventData綁定的所有Handler
            var handlerTypes = dicEvent[eventType];
            foreach (var handlerType in handlerTypes)
            {
                var resolveObj = _iresolve.Resolve(handlerType);
                IEventHandler<TEventData> handler = resolveObj as IEventHandler<TEventData>;
                handler.Handle(eventData);

            }
        }
        #endregion
    }
}

　　代碼說明：

　　1、如上的EventBus是繼承了IEventBus后的具體實現，小夥伴可能看到在構造函數里，有一個接口參數IResolve，這個主要是為了將解析的過程進行解耦，由於在一些WebApi的項目中，更加多的是使用IOC的機制進行對象的創建，那基於IResolve就可以實現不同的對象創建方式（內置的是通過反射實現）

　　2、InitRegister方法通過遍歷當前目錄下的dll文件，去尋找所有實現了IEventHandler<IEventData>接口的信息，並且自動註冊到EventBus中，所以在實際使用過程中，應該是沒有機會去適用register註冊的

　　3、觸發機制實現了同步以及異步的調用，這個從方法命名中就可以看出來

五、程序Demo

　　TestHandler2(繼承IEventHandler)

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using System.Windows.Forms;
using MEventBus.Core;

namespace MEventBusHandler.Test
{
    public class TestHandler2 : IEventHandler<TestEventData>
    {
        public void Handle(TestEventData eventData)
        {
            Thread.Sleep(2000);
            MessageBox.Show(eventData.EventTime.ToString());
        }
    }
}

　　TestEventData（繼承EventData，EventData是繼承了IEventData的代碼）

using MEventBus.Core;
using System;
using System.Collections.Generic;
using System.Text;

namespace MEventBusHandler.Test
{
    public class TestEventData : EventData
    { }
}

　　調用代碼

using MEventBus.Core;
using MEventBusHandler.Test;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace MEventBus.Test
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
            TestHandler.OnOut += TestHandler_OnOut;
        }

        private void TestHandler_OnOut(object sender, EventArgs e)
        {
            MessageBox.Show("Hello World");
        }

        private void button1_Click(object sender, EventArgs e)
        {
            var task = new MEventBus.Core.EventBus(new ReflectResolve()).TriggerAsync(new TestEventData());
            task.ContinueWith((obj) => {
                MessageBox.Show("事情全部做完");
            });
        }

        private void button2_Click(object sender, EventArgs e)
        {
           new EventBus(new ReflectResolve()).Trigger(new TestEventData());
        }
    }


}

　　執行結果

 我在真正的Demo中，其實是註冊了2個handler，可以在後續公布的項目地址里看到

六、總結

　　從有這個想法開始，到最終實現這個事件總線，大概總共花了2，3天的時間（PS：晚上回家獨自默默幹活），目前只能說是有一個初步可以使用的版本，並且還存在着一些問題：

　　1、在.NetFrameWork下（目前公司還不想升級到.NetCore，吐血。。），如果使用AutoFac創建EventBus（單例模式下），如果Handler也使用AutoFac進行創建，會出現要麼對象創建失敗，要麼handler里的對象與調用方的對象不是同一個實例，為了解決這個問題，我讓EventBus不再是單例模式，將dicEvent變成了靜態，暫時表面解決

　　2、未考慮跨進程的實現（感覺用savorboard大佬的就可以了）

　　3、目前這個東西在一個小的新項目里使用，暫時在測試環境還算沒啥問題，各位小夥伴如果有類似需求，可以做個參考

　　由於個人原因，在測試上可能會有所不夠，如果有什麼bug的話，還請站內信告知，感謝（ps:文字表達弱雞，技術渣渣，各位多多包涵）

　　最後：附上項目地址：

作者： Mango

出處： 

關於自己：專註.Net桌面開發以及Web後台開發，對.NetCore、微服務、DevOps，K8S等感興趣，最近到了個甲方公司準備休養一段時間

本文版權歸作者和博客園共有，歡迎轉載，但未經作者同意必須保留此段聲明，且在文章頁面明顯位置給出原文鏈接，如有問題， 可站內信告知.

本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理【其他文章推薦】

※為什麼 USB CONNECTOR 是電子產業重要的元件?

※網頁設計一頭霧水??該從何著手呢? 找到專業技術的網頁設計公司，幫您輕鬆架站!

※想要讓你的商品成為最夯、最多人討論的話題?網頁設計公司讓你強力曝光

※想知道最厲害的台北網頁設計公司推薦、台中網頁設計公司推薦專業設計師”嚨底家”!!