一个关于事件溯源Event Sourcing的小荔枝,Golang实现

news/2024/3/28 21:51:58/文章来源:https://blog.csdn.net/weixin_44445507/article/details/129276015

最后更新于2023年3月1日 10:23:13

参考的这个文章:https://martinfowler.com/eaaDev/EventSourcing.html
用C sharp实现的,我改写成Golang了

最简单的例子

func main() {eProc := NewEventProcessor()//refact := Cargo{Name: "Refactoring"}kr := &Ship{Name: "King Roy"}sfo := &Port{Name: "San Francisco", Country: "US"}//la := Port{Name: "Los Angeles", Country: "US"}//yyv := Port{Name: "Vancouver", Country: "Canada"}// Test 1ev := ArrivalEvent{DomainEvent: DomainEvent{Recorded: time.Now(),Occurred: time.Date(2005, time.November, 1, 0, 0, 0, 0, time.Local),},Port: sfo,Ship: kr,}eProc.Process(&ev)jiayulog.Logger.DebugP(sfo)jiayulog.Logger.DebugP(kr.Port)pretty.Log(eProc)
}

这里面的jiayulog是我自己搞了一个log,pretty-print结构体,用fmt.Print来代替就行。
首先main函数,定义了一艘船"King Roy"号,还有几个港口,这个例子里面就用了一个旧金山。
定义了一个到达事件,大概就是King Roy号在2005年到达了旧金山港口,这件事记录于time.Now()这个时刻。
把这个事情扔进事件处理器EventProcessor里面处理一下(更新Ship, Port等实体、记录日志)

// EventLog
type EventLog struct {ls []EventBase
}func (i *EventLog) Add(e EventBase) {i.ls = append(i.ls, e)
}// EventProcessor
type EventProcessor struct {log EventLog
}func NewEventProcessor() *EventProcessor {return &EventProcessor{log: EventLog{ls: make([]EventBase, 0)},}
}func (i *EventProcessor) Process(e EventBase) {e.Process()i.log.Add(e)
}

上面这个是事件处理器+事件日志,eventProcessor.Process方法里,首先让传进来的event调用自己的process方法,然后添加日志;
事件日志很简单,就是一个切片,一直往里面append就可以了,这个可以持久化到数据库里面。

// ArrivalEvent
type ArrivalEvent struct {DomainEventPort *PortShip *Ship
}func (i *ArrivalEvent) Process() {i.Ship.HandleArrival(*i)
}// DepartureEvent
type DepartureEvent struct {DomainEventPort *PortShip *Ship
}func (i *DepartureEvent) Process() {i.Ship.HandleDeparture(*i)
}// DomainEvent
type DomainEvent struct {Recorded time.TimeOccurred time.Time
}type EventBase interface {Process()
}

然后是实现了一个EventBase接口,下面有两种不同的event,到达event+出发event。在各自的Process方法里面调用Ship的处理方法,这里把整个event当做参数传进handle*方法里面i.Ship.HandleDeparture(*i),就很怪,不知道这样写好不好……

var PortAtSea = &Port{Name:    "AT_SEA",Country: "N/A",
}// Entities
type Ship struct {Name   stringPort   *PortCargos []Cargo
}func (i *Ship) HandleArrival(ev ArrivalEvent) {i.Port = ev.Portfor _, c := range i.Cargos {c.HandleArrival(ev)}
}func (i *Ship) HandleDeparture(ev DepartureEvent) {i.Port = PortAtSea
}type Port struct {Name    stringCountry string
}// Cargo
type Cargo struct {Name            string
}

再接着是一些实体类,船、港口、货物。需要注意的是船出发了它就在海上了,port这里就用一个PortAtSea表示没有停靠任何港口。
注意!!!HandleArrivel和HandleDeparture相当于把一个event传递进实体里面了!!!这是设计的思路!!!学吧老哥!!!

深入一点:我们的货物是否经过了加拿大

加拿大是tm挺危险,俺们那边老有人一不小心就自驾到温莎了,毕竟就是过条河的距离,习惯了。

// Cargo
type Cargo struct {Name            stringHasBeenInCanada bool
}func (i *Cargo) HandleArrival(ev ArrivalEvent) {if ev.Port.Country == "Canada" {i.HasBeenInCanada = true}
}

把上面提到的cargo这个实体改一改,做点判断。

func (i *Ship) HandleLoad(ev LoadEvent) {for _, c := range i.Cargos {if c.Name == ev.Cargo.Name {panic("重复的货物我不接,这不是数据结构和算法,不要考虑特殊情况")}}i.Cargos = append(i.Cargos, ev.Cargo)
}func (i *Ship) HandleUnload(ev UnloadEvent) {// Suppose that there must have available cargo at the ship.for index, c := range i.Cargos {if c.Name == ev.Cargo.Name {i.Cargos = append(i.Cargos[1:index], i.Cargos[index+1:]...)break}}
}

Ship也要改一改,加上装卸货的方法。

// LoadEvent
type LoadEvent struct {DomainEventCargo *CargoShip  *Ship
}func (i *LoadEvent) Process() {i.Ship.HandleLoad(*i)
}// UnloadEvent
type UnloadEvent struct {DomainEventCargo *CargoShip  *Ship
}func (i *UnloadEvent) Process() {i.Ship.HandleUnload(*i)
}

加上装卸货的事件。

func TestCanada(t *testing.T) {eProc := NewEventProcessor()refact := &Cargo{Name: "Refactoring"}kr := &Ship{Name: "King Roy"}sfo := &Port{Name: "San Francisco", Country: "US"}la := &Port{Name: "Los Angeles", Country: "US"}yyv := &Port{Name: "Vancouver", Country: "Canada"}eProc.Process(&LoadEvent{DomainEvent: DomainEvent{Recorded: time.Now(),Occurred: time.Date(2005, time.November, 1, 0, 0, 0, 0, time.Local),},Cargo: refact,Ship:  kr,})eProc.Process(&DepartureEvent{DomainEvent: DomainEvent{Recorded: time.Now(),Occurred: time.Date(2005, time.November, 1, 0, 0, 0, 0, time.Local),},Port: la,Ship: kr,})eProc.Process(&ArrivalEvent{DomainEvent: DomainEvent{Recorded: time.Now(),Occurred: time.Date(2005, time.November, 2, 0, 0, 0, 0, time.Local),},Port: yyv,Ship: kr,})eProc.Process(&DepartureEvent{DomainEvent: DomainEvent{Recorded: time.Now(),Occurred: time.Date(2005, time.November, 3, 0, 0, 0, 0, time.Local),},Port: yyv,Ship: kr,})eProc.Process(&ArrivalEvent{DomainEvent: DomainEvent{Recorded: time.Now(),Occurred: time.Date(2005, time.November, 4, 0, 0, 0, 0, time.Local),},Port: sfo,Ship: kr,})eProc.Process(&UnloadEvent{DomainEvent: DomainEvent{Recorded: time.Now(),Occurred: time.Date(2005, time.November, 4, 0, 0, 0, 0, time.Local),},Cargo: refact,Ship:  kr,})fmt.Println(refact.HasBeenInCanada)
}

整体流程是这样的:先在LA装上货,去温哥华兜一圈,再回旧金山卸货。因为温哥华在加拿大,所以refact.HasBeenInCanada字段为真。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.luyixian.cn/news_show_75690.aspx

如若内容造成侵权/违法违规/事实不符,请联系dt猫网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Databend 开源周报 第 82 期

Databend 是一款现代云数仓。专为弹性和高效设计,为您的大规模分析需求保驾护航。自由且开源。即刻体验云服务:https://app.databend.com 。Whats New探索 Databend 本周新进展,遇到更贴近你心意的 Databend 。Features & Improvements :…

【沐风老师】3dmax一键窗户生成器插件使用方法详解

3dmax一键窗户生成器插件教程 3dMax一键窗户生成器是一个在3dMax中自动创建3D窗户模型的脚本。它有28种风格的窗户样式,可以在Archviz项目中灵活应用,同时为3D艺术家节省大量时间。 【适用版本】 适用3dMax 2018.2及更高版本 【安装方法】 1.解压缩包&…

林心如常驻《向往的生活》,周杰却陷地域黑,做人的差别太大了吧

十年前如果有人提起周杰,就算是不能如雷贯耳,最起码也是妇孺皆知,毕竟那时候他太有名气了。因为拍摄《还珠格格》,让他和林心如等人一起爆红,不过此后的林心如,却很少再有优秀作品问世。 而周杰却不一样&am…

AOP在PowerJob中的使用,缓存锁保证并发安全,知识细节全总结

这是一篇简简单单的文章,需要你简简单单看一眼就好,如果有不明白的地方,欢迎留言讨论。 在之前的文章中出现过一次AOP的使用,就是在运行任务之前,需要判断一下,触发该任务执行的server,是不是数…

AIGC被ChatGPT带火!底层基础算力有望爆发式增长

ChatGPT火爆全球的背后,可以窥见伴随人工智能技术的发展,数字内容的生产方式向着更加高效迈进。ChatGPT属于AIGC的具体应用,而AIGC是技术驱动的数字内容新生产方式。AIGC类产品未来有望成为5G时代新的流量入口,率先受益的有望是AI…

MySQL实战之深入浅出索引(下)

1.前言 在上一篇文章中,我们介绍了InnoDB索引的数据结构模型,今天我们再继续聊一下跟MySQL索引有关的概念。 在介绍之前,我们先看一个问题: 表初始化语句 mysql> create table T ( ID int primary key, k int NOT NULL DEFA…

03、SVN 建立版本库

SVN 建立版本库1 版本库2 版本库的建立步骤2.1 创建版本库的根目录2.2 创建子目录2.3 通过命令创建版本库2.4 生成目的介绍1 版本库 Subversion 是将文件数据信息保存到版本库中进行管理的Subversion 允许用户对版本库目录进行定制 2 版本库的建立步骤 2.1 创建版本库的根目…

RK3568平台开发系列讲解(驱动基础篇)Makefile 详解

🚀返回专栏总目录 文章目录 一、Makefile是什么二、Makefile 详解三、Makefile 语法沉淀、分享、成长,让自己和他人都能有所收获!😄 📢本篇将详细介绍Makefile。 一、Makefile是什么 如果只编译一个hello.c文件,非常简单,所以直接执行下面的指令非常方便: gcc hel…

Java List去重 Lis集合去重 List去重效率对比 List去重复元素效率对比 List去重效率

Java List去重 Lis集合去重 List去重效率对比 List去重复元素效率对比 List去重效率 --- List 去重复元素的几种办法 一、概述 面试的时候,有个常见的问题:“List集合如何去除重复元素”。 常见的回答是:“set集合,for循环对比&a…

KingbaseES V8R3 表加密

前言 透明加密是指将数据库page加密后写入磁盘,当需要读取对应page时进行加密读取。此过程对于用户是透明, 用户无需干预。 该文档进行数据库V8R3版本测试透明加密功能,需要说明,该版本发布时间早于V8R6,所以只能进行表…

SQLite安装及常用语句

SQLite简介SQLite 是一个软件库,实现了自给自足的、无服务器的、零配置的、事务性的 SQL 数据库引擎。SQLite 是在世界上最广泛部署的 SQL 数据库引擎。SQLite 源代码不受版权限制。SQLite安装官网下载 SQLite Download Page新建一个sqlite文件夹,将下载…

【Servlet篇2】创建一个web项目

在上一篇文章当中,已经提到了什么是Maven,以及如何使用maven从中央仓库下载jar包。【Tomcat与Servlet篇1】认识Tomcat与Maven_革凡成圣211的博客-CSDN博客Tomcat,mavenhttps://blog.csdn.net/weixin_56738054/article/details/129228140?spm…

2023年java春招面试题及答案

2023年java春招面试题1、下面有关jdbc statement的说法错误的是?2、下面有关JVM内存,说法错误的是?3、下面有关servlet service描述错误的是?4、下面有关servlet和cgi的描述,说法错误的是?5、下面有关SPRIN…

LeetCode 1237. Find Positive Integer Solution for a Given Equation【双指针,二分,交互】

本文属于「征服LeetCode」系列文章之一,这一系列正式开始于2021/08/12。由于LeetCode上部分题目有锁,本系列将至少持续到刷完所有无锁题之日为止;由于LeetCode还在不断地创建新题,本系列的终止日期可能是永远。在这一系列刷题文章…

开发场景中前端交付的对于后端数据的获取功能书写+页面简繁体转换+页面链接跳转新页面

1,开发场景中前端交付对于后端数据的获取功能书写 首先,我们明确基本逻辑概念,前端获取数据本质是利用ajax中的api接口来获取变量,再将其导入我们的data; 明确基本概念开发就可以进行ajax的定义 下文中e变量是获取前端…

全志T3+FPGA国产核心板——Pango Design Suite的FPGA程序加载固化

本文主要基于紫光同创Pango Design Suite(PDS)开发软件,演示FPGA程序的加载、固化,以及程序编译等方法。适用的开发环境为Windows 7/10 64bit。 测试板卡为全志T3+Logos FPGA核心板,它是一款基于全志科技T3四核ARM Cortex-A7处理器 + 紫光同创Logos PGL25G/PGL50G FPGA设计…

【观察】连续八年霸榜云数据库“领导者”,揭秘亚马逊云科技背后的“统治力”...

日前,全球市场分析机构 Gartner发布《2022 云数据库管理系统魔力象限》报告。其中,在Gartner本次魔力象限报告评估的20家供应商中,亚马逊云科技在纵轴“执行能力”和横轴“愿景完整性”两个维度分别处于最高、最右位置,这也是亚马…

ANTLR的IDE——ANTLRWorks2的安装及基本使用

1. ANTLRWorks2的简单介绍 ① ANTLR官网对ANTLRWorks2的介绍 ANTLRWorks 2.此IDE是ANTLR v3 / v4语法以及StringTemplate模板的复杂编辑器。 它可以运行ANTLR工具来生成识别器,并可以运行TestRig(在命令行上运行)来测试语法。 要将ANTLR生成…

Java内置队列和高性能队列Disruptor

一、队列简介 队列是一种特殊的线性表,遵循先入先出、后入后出(FIFO)的基本原则,一般来说,它只允许在表的前端进行删除操作,而在表的后端进行插入操作,但是java的某些队列运行在任何地方插入删…

EEGLAB处理运动想象脑电数据

最近在看论文时,经常看到作者处理数据的过程,之前都是一代而过,知道怎么处理就可以了,一直没有实践,最近需要一些特殊的数据,需要自己处理出来,这里尝试着自己用MATLAB处理数据,记录…