如何設(shè)計(jì)事件流，第 1 部分

事件流在當(dāng)今世界變得越來(lái)越普遍。事件是一條數(shù)據(jù)，它以時(shí)間快照的形式描述了您的業(yè)務(wù)中發(fā)生的重要事件。我們將該數(shù)據(jù)記錄到事件流(通常使用 Apache Kafka 主題)，這為其他應(yīng)用程序和業(yè)務(wù)流程做出相應(yīng)的響應(yīng)和反應(yīng)提供了基礎(chǔ)——也稱為事件驅(qū)動(dòng)架構(gòu) (EDA)。

事件驅(qū)動(dòng)架構(gòu) (EDA) 廣泛依賴于事件。為了在 EDA 方面取得成功，您需要知道如何正確設(shè)計(jì)您的活動(dòng)，因?yàn)檫@不僅會(huì)顯著影響您今天可以做的事情，還會(huì)影響明天的事情。

設(shè)計(jì)活動(dòng)可能具有挑戰(zhàn)性，特別是在考慮消費(fèi)者的不同需求、數(shù)據(jù)格式和延遲要求時(shí)。在這篇文章中，我們將討論構(gòu)建事件時(shí)的主要考慮因素之一：圍繞狀態(tài)進(jìn)行設(shè)計(jì)與圍繞更改進(jìn)行設(shè)計(jì)。

但首先，讓我們看一下事件流的基礎(chǔ)知識(shí)。

什么是事件?

事件代表在特定時(shí)間點(diǎn)發(fā)生的事件。

事件確實(shí)可以代表任何事物，但它幾乎總是代表對(duì)業(yè)務(wù)重要的事物。例如，電子商務(wù)企業(yè)可能會(huì)記錄有關(guān)銷售、訂單、客戶、交貨和庫(kù)存的事件。航空公司可以記錄有關(guān)付款、航班、飛行員、航線、機(jī)場(chǎng)和航班遙測(cè)的事件。

事件流的基礎(chǔ)知識(shí)

事件流(有時(shí)也稱為數(shù)據(jù)流)是一系列事件，發(fā)布到不可變的僅附加日志代理(例如Apache Kafka)。生產(chǎn)者系統(tǒng)將事件寫入流(Kafka 主題)，該流由一個(gè)或多個(gè)消費(fèi)者系統(tǒng)消費(fèi)。一旦記錄了事件，它們就會(huì)被寫入事件流中。

· 事件和事件流都是完全不可變的——一旦發(fā)布，您就無(wú)法更改它們的內(nèi)容，也無(wú)法更改它們?cè)诹髦械捻樞颉＞拖裆钜粯?，你無(wú)法改變過去:)。

· 多個(gè)消費(fèi)者可以根據(jù)自己的選擇使用該事件。

· 事件是持久且可重玩的。與傳統(tǒng)的排隊(duì)系統(tǒng)不同，寫入主題的事件仍然可以根據(jù)您選擇的次數(shù)進(jìn)行處理和使用。

流中的事件日志可用于構(gòu)建系統(tǒng)隨時(shí)間變化的詳細(xì)情況，而不僅僅是當(dāng)前的快照。

設(shè)計(jì)活動(dòng)時(shí)需要考慮幾個(gè)因素。目標(biāo)消費(fèi)者是誰(shuí)?事件是在單個(gè)系統(tǒng)內(nèi)生成以供同一系統(tǒng)內(nèi)部使用嗎?還是與外部消費(fèi)者共享，例如其他系統(tǒng)、團(tuán)隊(duì)和人員?

事件設(shè)計(jì)中最大的問題之一是決定哪些數(shù)據(jù)應(yīng)該出現(xiàn)在事件中，哪些數(shù)據(jù)不應(yīng)該出現(xiàn)。解決這個(gè)問題需要采用與確定服務(wù)邊界和 API 組成相同的思維方法。我們將什么封裝在服務(wù)內(nèi)部，以及我們?cè)敢庀蚋鼜V闊的世界公開什么?

讓我們更深入地了解一下。

內(nèi)部數(shù)據(jù)與外部數(shù)據(jù)

所有(或至少絕大多數(shù))服務(wù)都包含數(shù)據(jù)——已提供、創(chuàng)建、計(jì)算、處理或計(jì)算的數(shù)據(jù)。其中一些數(shù)據(jù)是私有的，一些是公共的，一些表示作為業(yè)務(wù)流程一部分的中間表單，一些表示需要與其他系統(tǒng)共享的數(shù)據(jù)。

無(wú)論如何，您可以將服務(wù)的數(shù)據(jù)需求分為兩個(gè)陣營(yíng)：

· 內(nèi)部數(shù)據(jù)由應(yīng)用程序或服務(wù)內(nèi)部的數(shù)據(jù)模型和數(shù)據(jù)結(jié)構(gòu)組成。此數(shù)據(jù)是您的系統(tǒng)私有的。但它還包括您可能想要在邊界之外共享的數(shù)據(jù)。

· 外部的數(shù)據(jù)是我們與其他系統(tǒng)共享的數(shù)據(jù)。它是為其他團(tuán)隊(duì)、系統(tǒng)和人員的發(fā)現(xiàn)、消費(fèi)和使用而明確建模的。

內(nèi)部數(shù)據(jù)的兩個(gè)示例：數(shù)據(jù)庫(kù)支持的系統(tǒng)和事件源系統(tǒng)

服務(wù)可以將其數(shù)據(jù)存儲(chǔ)在關(guān)系數(shù)據(jù)庫(kù)、鍵值存儲(chǔ)、文檔數(shù)據(jù)庫(kù)中，甚至存儲(chǔ)在一組事件流中(例如在事件溯源系統(tǒng)中)。內(nèi)部數(shù)據(jù)是私有的，專門供系統(tǒng)內(nèi)部使用。它是根據(jù)其服務(wù)的需求進(jìn)行建模的。它不適合其他系統(tǒng)和團(tuán)隊(duì)使用，也不向更廣闊的世界開放。它保持封裝并與服務(wù)內(nèi)部工作的需求緊密耦合。

內(nèi)部(內(nèi)部數(shù)據(jù))和外部(外部數(shù)據(jù))世界的高級(jí)視圖

相反，外部的數(shù)據(jù)是我們與其他系統(tǒng)共享的數(shù)據(jù)。它是為其他團(tuán)隊(duì)、系統(tǒng)和人員的發(fā)現(xiàn)、消費(fèi)和使用而明確建模的。創(chuàng)建外部模型需要與下游消費(fèi)者進(jìn)行協(xié)商，還需要考慮狀態(tài)、變更、非規(guī)范化、安全性、性能和成本——當(dāng)我們研究事件設(shè)計(jì)的四個(gè)主要因素時(shí)，我們將涵蓋所有內(nèi)容。

內(nèi)部/外部數(shù)據(jù)是思考數(shù)據(jù)用途以及誰(shuí)應(yīng)該能夠訪問和使用數(shù)據(jù)的有用方法。正如我們必須考慮通過 REST API 向其他服務(wù)公開哪些數(shù)據(jù)一樣，我們還必須考慮使用事件向其他服務(wù)公開哪些數(shù)據(jù)。

還有一個(gè)與 REST API 類似的地方值得探索。當(dāng)您成功發(fā)出 REST 請(qǐng)求(例如 GET)時(shí)，您將收到包含鍵和值的數(shù)據(jù)負(fù)載。然后，您必須解析該數(shù)據(jù)以獲得對(duì)您的服務(wù)的意義。但我們并不期望每個(gè)使用 REST API 的人或服務(wù)都能自己弄清楚這些數(shù)據(jù)的含義。不，我們(通常)為他們提供文檔和他們應(yīng)該期望的數(shù)據(jù)的模式，以便他們可以輕松使用它 - 事件也不例外。

模式對(duì)于創(chuàng)建可重用、可發(fā)現(xiàn)且無(wú)錯(cuò)誤的事件流至關(guān)重要。它們提供基礎(chǔ)和結(jié)構(gòu)，并賦予事件隨時(shí)間演變和變化的能力。讓我們更深入地了解一下。