Skip to main content
Version: 2.4.0

配置详情

Phoenix 配置列表

phoenix-akka配置

配置项描述类型默认值
quantex.phoenix.akka.akka-confactorSystem的配置文件路径String
quantex.phoenix.akka.service-name服务名String服务名
quantex.phoenix.akka.discovery-method集群发现的方式Stringconfig
可选值:config / kubernetes-api
quantex.phoenix.akka.artery-canonical-port远程服务器端口Int2551
quantex.phoenix.akka.artery-canonical-hostname远程服务器地址String127.0.0.1
quantex.phoenix.akka.artery-bind-hostname可绑定的ip地址String0.0.0.0
quantex.phoenix.akka.seed-node集群的初始接触点Listakka:// + 服务名 + @127.0.0.1:2551
quantex.phoenix.akka.method服务发现的方式Stringakka-dns
quantex.phoenix.akka.pod-label-selector服务发现的pod标签Stringapp=%s
quantex.phoenix.akka.management-http-port用于集群管理的端口Int8558
quantex.phoenix.akka.management-http-bind-hostname绑定内部(0.0.0.0:8558)String0.0.0.0
quantex.phoenix.akka.k8sPodDomaink8s服务发现默认集群域名后缀Stringcluster.local

Phoenix-server配置

配置项描述类型默认值
quantex.phoenix.server.nameServer端服务名String
quantex.phoenix.server.packageName聚合根包所在路径String
quantex.phoenix.server.dgc-enableDGC 功能开关Booleantrue
quantex.phoenix.server.entity-aggregate-enable实体聚合根开关Booleantrue
quantex.phoenix.server.transaction-aggregate-enable事务聚合根开关Booleantrue
quantex.phoenix.server.mq.typeMQ 类型Stringkafka
quantex.phoenix.server.mq.addressMQ 服务端地址String
quantex.phoenix.server.mq.groupServer端服务消费组名,对应kafka和rocketmq中的consumergroupStringServer端服务名
quantex.phoenix.server.mq.subscribe[].topic订阅的topicString
quantex.phoenix.server.mq.subscribe[].properties其他配置,比如ReceiverActor调优参数(#ReceiverOptimizedConfig)或者kafkaConsumer的配置,map结构以key,value配置Mapnull
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是否不需要EventStoreBooleanfalse
quantex.phoenix.server.event-store.batch-persist批量持久化 批次大小int200
quantex.phoenix.server.event-store.batch-read分页读取事件, 默认分页大小int100
quantex.phoenix.server.event-store.data-sources[].url数据库 连接urlString
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数据源labelString默认 default
可选值:
default
entity
reliablity
transaction
quantex.phoenix.server.event-store.data-sources[].initial-size初始连接池大小int2
quantex.phoenix.server.event-store.data-sources[].min-idle最小连接池大小int2
quantex.phoenix.server.event-store.data-sources[].max-active最大连接池大小int8
quantex.phoenix.server.license认证license,需要向Phoenix官方申请String
quantex.phoenix.server.default-serializer默认的序列化类型String默认 protostuff
可选值:
protostuff
java
quantex.phoenix.server.performance.batch-processEntityAggregateActor 批量向子Actor发送消息进行处理Int100
quantex.phoenix.server.performance.transaction-retry-strategy重试策略(0: 重试时间会自增的策略 1: 固定重试时间的策略)Int0

Phoenix-client配置

配置项描述类型默认值
quantex.phoenix.client.enabled是否启动Booleantrue
quantex.phoenix.client.nameClient 端服务名String
quantex.phoenix.client.mq.typeMQ 类型Stringkafka
quantex.phoenix.client.mq.groupclient端服务消费组名,对应kafka和rocketmq中的consumergroupStringClient端服务名
quantex.phoenix.client.mq.addressMQ 服务端地址String
quantex.phoenix.server.mq.subscribe[].topic(Client端只需配置一个)订阅的topicString
quantex.phoenix.server.mq.subscribe[].properties其他配置(Client端不用配置),比如ReceiverActor调优参数(#ReceiverOptimizedConfig)或者kafkaConsumer的配置,map结构以key,value配置Mapnull

配置样例

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