Redmi Buds 4開箱簡評：才199還有降噪 可以無腦入
在上個月舉辦的Redmi Note11T Pro系列新機發(fā)布會上，除了兩款手機新品之外，Redmi還帶來了兩款TWS真無線藍牙耳機產(chǎn)品，Redmi Buds 4和Redmi Buds 4 Pro，此前我們在Redmi Note11T
在當(dāng)今微服務(wù)和分布式系統(tǒng)盛行的背景下，事件驅(qū)動架構(gòu)（Event-Driven Architecture，EDA）扮演著一個至關(guān)重要的角色，此架構(gòu)的設(shè)計使得服務(wù)間可以通過事件進行同步或異步通信，替代了傳統(tǒng)的直接接口調(diào)用。基于事件的交互方式，促進了服務(wù)之間的松耦合，提高系統(tǒng)的可擴展性。
發(fā)布-訂閱模式是實現(xiàn)事件驅(qū)動架構(gòu)的模式之一，它允許系統(tǒng)的不同組件或服務(wù)發(fā)布事件，而其他組件或服務(wù)可以訂閱這些事件并根據(jù)事件內(nèi)容進行響應(yīng)。相信大部分開發(fā)者都接觸過這一模式，常見的技術(shù)實現(xiàn)有消息隊列（MQ）和 Redis 發(fā)布/訂閱（PUB/SUB）功能等。
在 Go 語言中，我們可以利用其強大的 channel 和并發(fā)機制來實現(xiàn)發(fā)布-訂閱模式。本文將深入探討如何在 Go 中實現(xiàn)一個簡單的事件總線，這是發(fā)布-訂閱模式的具體實現(xiàn)。
準(zhǔn)備好了嗎？準(zhǔn)備一杯你最喜歡的咖啡或茶，隨著本文一探究竟吧。
事件總線是發(fā)布-訂閱模式的具體實現(xiàn)，它作為發(fā)布者和訂閱者的中間件，管理著事件傳遞與分發(fā)，確保事件從發(fā)布者順利地傳達到訂閱者。
圖片
事件總線的優(yōu)勢主要包括：
接下來將介紹如何在 Go 語言中實現(xiàn)一個簡單的事件總線，它包含以下關(guān)鍵功能：
項目源碼地址：https://github.com/chenmingyong0423/go-eventbus
type Event struct { Payload any}Event 是一個封裝事件的結(jié)構(gòu)體，其中 Payload 為事件的上下文信息，類型是 any。
type ( EventChan chan Event)type EventBus struct { mu sync.RWMutex subscribers map[string][]EventChan}func NewEventBus() *EventBus { return &EventBus{ subscribers: make(map[string][]EventChan), }}EventChan 是一個類型別名，定義為傳遞 Event 結(jié)構(gòu)體的通道 chan Event。
EventBus 為事件總線的定義，它包含兩個屬性：
NewEventBus 函數(shù)用于創(chuàng)建一個新的 EventBus 事件總線。
事件總線實現(xiàn)了三個方法，分別為發(fā)布事件（Publish）和訂閱事件（Subscribe）以及取消訂閱事件（Unsubscribe）。
func (eb *EventBus) Publish(topic string, event Event) { eb.mu.RLock() defer eb.mu.RUnlock() // 復(fù)制一個新的訂閱者列表，避免在發(fā)布事件時修改訂閱者列表 subscribers := append([]EventChan{}, eb.subscribers[topic]...) gofunc() { for _, subscriber := range subscribers { subscriber <- event } }()}Publish 方法用于發(fā)布事件。該方法接收兩個參數(shù)：topic（主題）和 event （封裝事件的對象）。
在 Publish 方法的實現(xiàn)中，首先通過 mu 屬性獲取讀鎖，以確保接下來的 subscribers 寫操作是協(xié)程安全的。然后復(fù)制一份當(dāng)前主題的訂閱者列表 subscribers。接下來開啟一個新 goroutine，在這個 goroutine 中遍歷復(fù)制的訂閱者列表，將事件通過通道發(fā)送給所有訂閱者。完成這些操作后，釋放讀鎖。
為什么會復(fù)制一個新的訂閱者列表？
答：復(fù)制訂閱者列表是為了在發(fā)送事件時保持?jǐn)?shù)據(jù)的一致性和穩(wěn)定性。由于向通道發(fā)送數(shù)據(jù)的操作是在一個新的 goroutine 中進行的，在發(fā)送數(shù)據(jù)時，讀鎖已經(jīng)被釋放，原來的訂閱者列表可能會由于添加或刪除訂閱者而發(fā)生變化。如果直接使用原來的訂閱者列表，可能會發(fā)生預(yù)料之外的錯誤（如向一個已經(jīng)關(guān)閉的通道發(fā)送數(shù)據(jù)會產(chǎn)生 panic）。
func (eb *EventBus) Subscribe(topic string) EventChan { eb.mu.Lock() defer eb.mu.Unlock() ch := make(EventChan) eb.subscribers[topic] = append(eb.subscribers[topic], ch) return ch}Subscribe 方法用于訂閱特定主題的事件。該方法有接收一個 topic 參數(shù)，表示希望訂閱的主題。通過此方法，可以獲得一個 EventChan 通道，用于接收該主題的事件。
在 Subscribe 方法的實現(xiàn)中，首先通過 mu 屬性獲取寫鎖，以保證接下來的 subscribers 讀寫操作是協(xié)程安全的；接著創(chuàng)建一個新的 EventChan 通道 ch，將其添加到相應(yīng)主題的訂閱者切片中。完成這些操作后，釋放寫鎖。
func (eb *EventBus) Unsubscribe(topic string, ch EventChan) { eb.mu.Lock() defer eb.mu.Unlock() if subscribers, ok := eb.subscribers[topic]; ok { for i, subscriber := range subscribers { if ch == subscriber { eb.subscribers[topic] = append(subscribers[:i], subscribers[i+1:]...) close(ch) // 清空通道 forrange ch { } return } } }}Unsubscribe 方法用于取消訂閱事件。該方法接收兩個參數(shù)：topic（已訂閱的主題）和 ch（被頒發(fā)的通道）。
在 Unsubscribe 方法里，首先通過 mu 屬性獲取寫鎖，以保證接下來的 subscribers 讀寫操作是協(xié)程安全的；然后檢查 topic 主題是否存在對應(yīng)的訂閱者。如果存在，遍歷該主題的訂閱者切片，找到與 ch 相匹配的通道，將其從訂閱者切片里移除并關(guān)閉該通道。然后清空通道。完成這些操作后，釋放寫鎖。
// https://github.com/chenmingyong0423/blog/blob/master/tutorial-code/go/eventbus/main.gopackage mainimport ( "fmt" "time" "github.com/chenmingyong0423/go-eventbus")func main() { eventBus := eventbus.NewEventBus() // 訂閱 post 主題事件 subscribe := eventBus.Subscribe("post") gofunc() { for event := range subscribe { fmt.Println(event.Payload) } }() eventBus.Publish("post", eventbus.Event{Payload: map[string]any{ "postId": 1, "title": "Go 事件驅(qū)動編程：實現(xiàn)一個簡單的事件總線", "author": "陳明勇", }}) // 不存在訂閱者的 topic eventBus.Publish("pay", eventbus.Event{Payload: "pay"}) time.Sleep(time.Second * 2) // 取消訂閱 post 主題事件 eventBus.Unsubscribe("post", subscribe)}本文實現(xiàn)的事件總線較為簡單，如果要增強時間總線的靈活性，可靠性和易用性等方面，我們可以考慮擴展它，以下是一些建議：
本文深入探討了在 Go 語言中實現(xiàn)簡單事件總線的過程。通過利用 Go 語言的強大特性，如 channel 和并發(fā)機制，我們可以輕松地實現(xiàn)發(fā)布-訂閱模式。
文章從事件總線的優(yōu)勢開始，介紹了其解耦、異步處理、可擴展性和錯誤隔離等特點。然后詳細(xì)解釋了如何定義事件數(shù)據(jù)結(jié)構(gòu)和事件總線結(jié)構(gòu)，并實現(xiàn)了發(fā)布、訂閱和取消訂閱事件的方法。最后，提出了一些可能的擴展方向，如事件持久化、通配符訂閱、負(fù)載均衡和插件支持，以增強事件總線的靈活性和功能性。
通過閱讀本文，你可以學(xué)會在 Go 語言中實現(xiàn)一個簡單但功能強大的事件總線，并根據(jù)可能的需求進行擴展。
★項目源碼地址：https://github.com/chenmingyong0423/go-eventbus
本文鏈接：http://www.tebozhan.com/showinfo-26-88374-0.htmlGo 事件驅(qū)動編程：實現(xiàn)一個簡單的事件總線
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
上一篇： 要不要升級？Java 21強大的新特性，代碼量減半
下一篇： 剖析 Figma 圖形對象的基本屬性
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請聯(lián)系：2376512515@qq.com 津ICP備18001702號
津公網(wǎng)安備 12010102000574號