跳到主要内容
版本：2.2.4

使用说明

Phoenix中提供了可集成于Phoenix Server服务中的EventPublish功能模块，启用该模块可直接在Phoenix服务中运行Event Publish任务，服务部署时可通过配置定义Event Publish任务。

引用依赖​

<dependency>
  <groupId>com.iquantex</groupId>
  <artifactId>phoenix-event-publish-starter</artifactId>
  <version>2.2.4</version>
</dependency>

功能​

  • 可在phoenix服务中开启event-publish能力，扫描event-store中的领域事件，发布到特定的kafka topic。
  • 可在phoenix服务配置中定义event-publish模块的运行参数和定义event-stask与monitor-task,event-stask用于将phoenix处理事件转发至指定的topic，monitor-task可以采集phoenix处理的消息信息，推送给phoenix-amdin进行监控
  • event-publish任务保证读取的event-store领域事件完整性，不出现事件遗漏、丢失。
  • event-publish任务保证相同的聚合根ID的领域事件按照version严格递增的顺序投递到kafka。
  • event-publish任务支持多节点负载均衡和高可用，需要依赖phoenix服务本身的akka集群能力。

使用说明​

phoenix-event-publish功能模块对phoenix服务本身没有代码入侵，要打开event-publish功能模块，仅需要使用quantex.phoenix.event-publish配置。

要开启event-publish功能模块，需要将phoenix服务的quantex.phoenix.event-publsh.enabled配置置为"true"，以下为event-publish通用配置的说明：

配置项描述类型默认值
quantex.phoenix.event-publish.batch-size批量大小int128
quantex.phoenix.event-publish.buffer-queue-size缓存队列大小int64
quantex.phoenix.event-publish.state-table-nameEventPublish状态表名称Stringevent_publish_state
quantex.phoenix.event-publish.fromBegin新建状态或状态不存在时，是否重置读取位置到EventStore最早时间戳booleanfalse

以上配置为event-publish功能模块的通用配置，应用于服务内所有event-publish任务。

Event Publish 任务定义​

event-publish模块完全使用配置定义和声明服务中需要运行的event-publish任务，以下为定义任务的配置说明：

配置名称配置说明可选值默认值备注
quantex.phoenix.event-publish.event-task.enabled是否开启领域事件发布booleantrue
quantex.phoenix.event-publish.event-task.topic领域事件发布的目标topicString无
quantex.phoenix.event-publish.monitor-task.enabled是否开启消息监控上报任务booleantrue
quantex.phoenix.event-publish.monitor-task.broker-server消息监控上报的kafka服务地址String无
quantex.phoenix.event-publish.monitor-task.topic消息监控上报的目标topicString无

使用示例：

quantex:
  phoenix:
    event-publish:
      batch-size: 64
      buffer-queue-size: 64
      from-begin: true
      event-task:
        enabled: true
        topic: bank-account-event-pub
      monitor-task:
        enabled: true
        broker-server: 127.0.0.1:9092
        topic: bank-account-monitor