版本：2.4.0

配置详情

Phoenix 配置列表

phoenix-akka配置

配置项	描述	类型	默认值
quantex.phoenix.akka.akka-conf	actorSystem的配置文件路径	String	无
quantex.phoenix.akka.service-name	服务名	String	服务名
quantex.phoenix.akka.discovery-method	集群发现的方式	String	config 可选值：config / kubernetes-api
quantex.phoenix.akka.artery-canonical-port	远程服务器端口	Int	2551
quantex.phoenix.akka.artery-canonical-hostname	远程服务器地址	String	127.0.0.1
quantex.phoenix.akka.artery-bind-hostname	可绑定的ip地址	String	0.0.0.0
quantex.phoenix.akka.seed-node	集群的初始接触点	List	akka:// + 服务名 + @127.0.0.1:2551
quantex.phoenix.akka.method	服务发现的方式	String	akka-dns
quantex.phoenix.akka.pod-label-selector	服务发现的pod标签	String	app=%s
quantex.phoenix.akka.management-http-port	用于集群管理的端口	Int	8558
quantex.phoenix.akka.management-http-bind-hostname	绑定内部（0.0.0.0:8558）	String	0.0.0.0
quantex.phoenix.akka.k8sPodDomain	k8s服务发现默认集群域名后缀	String	cluster.local

Phoenix-server配置

配置项	描述	类型	默认值
quantex.phoenix.server.name	Server端服务名	String	无
quantex.phoenix.server.packageName	聚合根包所在路径	String	无
quantex.phoenix.server.dgc-enable	DGC 功能开关	Boolean	true
quantex.phoenix.server.entity-aggregate-enable	实体聚合根开关	Boolean	true
quantex.phoenix.server.transaction-aggregate-enable	事务聚合根开关	Boolean	true
quantex.phoenix.server.mq.type	MQ 类型	String	kafka
quantex.phoenix.server.mq.address	MQ 服务端地址	String	无
quantex.phoenix.server.mq.group	Server端服务消费组名，对应kafka和rocketmq中的consumergroup	String	Server端服务名
quantex.phoenix.server.mq.subscribe[].topic	订阅的topic	String	无
quantex.phoenix.server.mq.subscribe[].properties	其他配置,比如ReceiverActor调优参数(#ReceiverOptimizedConfig)或者kafkaConsumer的配置,map结构以key,value配置	Map	null
quantex.phoenix.server.event-store.driver-class-name	数据库驱动	String	可选值： org.h2.Driver com.mysql.jdbc.Driver oracle.jdbc.OracleDriver
quantex.phoenix.server.event-store.no-eventsotre	是否不需要EventStore	Boolean	false
quantex.phoenix.server.event-store.batch-persist	批量持久化批次大小	int	200
quantex.phoenix.server.event-store.batch-read	分页读取事件, 默认分页大小	int	100
quantex.phoenix.server.event-store.data-sources[].url	数据库连接url	String	无
quantex.phoenix.server.event-store.data-sources[].username	数据库账户	String	无
quantex.phoenix.server.event-store.data-sources[].password	数据库密码	String	无
quantex.phoenix.server.event-store.data-sources[].label	数据源label	String	默认 default 可选值： default entity reliablity transaction
quantex.phoenix.server.event-store.data-sources[].initial-size	初始连接池大小	int	2
quantex.phoenix.server.event-store.data-sources[].min-idle	最小连接池大小	int	2
quantex.phoenix.server.event-store.data-sources[].max-active	最大连接池大小	int	8
quantex.phoenix.server.license	认证license，需要向Phoenix官方申请	String	无
quantex.phoenix.server.default-serializer	默认的序列化类型	String	默认 protostuff 可选值： protostuff java
quantex.phoenix.server.performance.batch-process	EntityAggregateActor 批量向子Actor发送消息进行处理	Int	100
quantex.phoenix.server.performance.transaction-retry-strategy	重试策略(0: 重试时间会自增的策略 1: 固定重试时间的策略)	Int	0

Phoenix-client配置

配置项	描述	类型	默认值
quantex.phoenix.client.enabled	是否启动	Boolean	true
quantex.phoenix.client.name	Client 端服务名	String	无
quantex.phoenix.client.mq.type	MQ 类型	String	kafka
quantex.phoenix.client.mq.group	client端服务消费组名，对应kafka和rocketmq中的consumergroup	String	Client端服务名
quantex.phoenix.client.mq.address	MQ 服务端地址	String	无
quantex.phoenix.server.mq.subscribe[].topic	(Client端只需配置一个)订阅的topic	String	无
quantex.phoenix.server.mq.subscribe[].properties	其他配置(Client端不用配置),比如ReceiverActor调优参数(#ReceiverOptimizedConfig)或者kafkaConsumer的配置,map结构以key,value配置	Map	null

配置样例

quantex:
  phoenix:
    server:
      name: ${spring.application.name}
      package-name: com.iquantex.phoenix
      mq:
        type: kafka
        address: 127.0.0.1:9092
        subscribe:
          - topic: account
            properties:
              transactionReliabilityBatchRetry: 100
      event-store:
        driver-class-name: org.h2.Driver
        data-sources:
          - url: jdbc:h2:file:./data/test;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=FALSE;INIT=CREATE SCHEMA IF NOT EXISTS PUBLIC
            username: sa
            password:
            initial-size: 0
            min-idle: 0
            max-active: 8
    client:
      name: ${spring.application.name}-client
      mq:
        type: kafka
        address: 127.0.0.1:9092
    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

环境配置参考

Phoenix服务在不同的环境中运行需要对Akka进行相应的配置。下面分别介绍下Phoenix服务在本地环境和K8s环境运行时Akka的配置项需要如何配置。

本地单点运行

直接启动即可，不用在 application.yaml 或者 application.properties 中显式配置Akka相关配置。

本地集群运行

添加或修改以下几项配置，保证多个实例的端口不能冲突。

server:
  port: 8080

quantex:
  phoenix:
    akka:
      artery-canonical-port: 2552  # 集群端口
      management-http-port: 8559 # 集群管理的http端口 
      artery-canonical-hostname: 192.168.1.9   # 节点的ip地址
      seed-node: akka://account-server@192.168.1.9:2551,akka://account-server@192.168.1.9:2552  # 集群中seed-node的节点地址,一般会把所有节点都设置, 另外`account-server`要和应用${spring.application.name}的名字相同

K8s集群运行

在 K8s 环境上运行需要对以下配置进行修改

quantex:
  phoenix:
    akka:
      discovery-method: kubernetes-api

自定义Akka配置

如果想要深入自定义Akka相关配置，可在项目Classpath目录下创建akka.conf文件进行配置。然后修改一下配置。

quantex:
  phoenix:
    akka:
      akka-conf: akka.conf

Phoenix 配置列表​

phoenix-akka配置​

Phoenix-server配置​

Phoenix-client配置​

配置样例​

环境配置参考​

本地单点运行​

本地集群运行​

K8s集群运行​

自定义Akka配置​