文件名称:发件箱事件总线:与技术无关的事件总线
文件大小:120KB
文件格式:ZIP
更新时间:2024-03-09 05:22:39
kotlin events microservices outbox Kotlin
发件箱事件总线 基于Kotlin的事件总线,该总线实现了发件箱模式方法来在数据库事务的上下文中发布域级别的事件。 这允许原子地更新数据库并发布事件。 进行检查,以获得对该模式的深入说明。 此解决方案使用轮询发布者将消息推送到事件队列。 你得到什么 该库针对我们要可靠地持久存储数据并将事件发送到消息总线的场景。 概念 EventBusProvider:生产者和消费者使用的主要入口点,允许用户设置kafka。 EventProducer:将事件发送到数据库,该事件将最终发送到消息队列; EventConsumer:提供用户可以订阅的React性事件流的接口; 引擎:用于传播消息的基础消息传递技术; LocalEventStore:存储事件的本地数据库表; 活动结构 该库对事件的内部结构有固定的看法,将来可能会发生变化,但是就目前而言,事件具有以下结构(请参阅EventOutput类)
【文件预览】:
outbox-event-bus-master
----changelog.md(154B)
----gradlew.bat(3KB)
----gradlew(6KB)
----example()
--------consumer()
--------producer()
--------k8s()
--------start.sh(549B)
----.codacy.yml(46B)
----.github()
--------workflows()
----LICENSE(1KB)
----gradle()
--------wrapper()
----src()
--------test()
--------main()
----.gitignore(344B)
----README.md(8KB)
----settings.gradle(37B)
----.gitattributes(263B)
----build.gradle(5KB)