wal listener:PostgreSQL WAL侦听器 源码

WAL侦听器 一种帮助实现事件驱动的体系结构的服务。 为了保持系统中数据的一致性,我们将使用事务消息传递-在具有域模型更改的单个事务中发布事件。 该服务允许您使用其逻辑解码功能订阅PostgreSQL数据库中的更改,并将其发布到NATS Streaming服务器。 工作逻辑 为了在PostgreSQL数据库中接收有关数据更改的事件,我们使用标准的逻辑解码模块( pgoutput )该模块将从WAL读取的更改转换为逻辑复制协议。 而且我们已经消耗了所有这些信息。 然后,我们仅过滤出所需的事件并将其发布到队列中 活动发布 NATS流被用作消息代理。 服务发布以下结构。 用于订阅以接收消息的主