配置详情
Phoenix 配置列表
phoenix-akka配置
| 配置项 | 描述 | 类型 | 默认值 |
|---|---|---|---|
| quantex.phoenix.akka.akka-conf | actorSystem的配置文件路径 | String | 无 |
| quantex.phoenix.akka.akka-parallelism-min | actorSystem的线程池配置最小并发数 | Int | 1 |
| quantex.phoenix.akka.akka-parallelism-factor | actorSystem的线程池配置线程比，即一个核配多少个线程； | Double | 3 |
| quantex.phoenix.akka.akka-parallelism-max | actorSystem的线程池配置最大并发数 | Int | 128 |
| quantex.phoenix.akka.service-name | 服务名 | String | 服务名 |
| quantex.phoenix.akka.discovery-method | 集群发现的方式 | String | config 可选值：config / kubernetes-api |
| quantex.phoenix.akka.cinnamon-application | 服务名 | String | 服务名 |
| quantex.phoenix.akka.provider | 运行模式 | String | cluster 可选值：local / cluster / remote |
| quantex.phoenix.akka.artery-enable | remote.artery 开关 | String | on 可选值：on / off |
| quantex.phoenix.akka.artery-transport | 传输方式 | String | tcp 可选值：tcp / tls-tcp / aeron-udp |
| 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.executor | 线程池类型 | akka executor | thread-pool-executor |
| quantex.phoenix.akka.fixedPoolSize | 固定线程池中线程数量 默认值设为 500 | int | 500 |
| quantex.phoenix.akka.k8sPodDomain | k8s服务发现默认集群域名后缀 | String | cluster.local |
Phoenix-server配置
| 配置项 | 描述 | 类型 | 默认值 |
|---|---|---|---|
| quantex.phoenix.server.name | Server端服务名 | String | 无 |
| quantex.phoenix.server.packageName | 聚合根包所在路径 | String | 无 |
| 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.subscribes-topic | Server端订阅的 topic | String | 无 |
| quantex.phoenix.server.mq.use-kerberos | 是否开启 kerberos 认证 | Boolean | false |
| quantex.phoenix.server.mq.jaas-conf-path | jaas配置文件路径 | String | 无 |
| quantex.phoenix.server.mq.krb5-conf-path | krb5配置文件路径 | String | 无 |
| quantex.phoenix.server.mq.krb-service-name | krb服务名 | String | 无 |
| quantex.phoenix.server.event-store.driver-class-name | 数据库驱动 | String | 可选值： org.h2.Driver com.mysql.jdbc.Driver oracle.jdbc.OracleDriver |
| quantex.phoenix.server.event-store.initial-size | 初始连接池大小 | int | 2 |
| quantex.phoenix.server.event-store.min-idle | 最小连接池大小 | int | 2 |
| quantex.phoenix.server.event-store.max-active | 最大连接池大小 | int | 8 |
| 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.license | 认证license，需要向Phoenix官方申请 | String | 无 |
| quantex.phoenix.server.performance.transaction-reliability-maxAge | 全局SimpleLeastOneDeliveryStrategy 在途事务最大年龄 | int | 5 |
| quantex.phoenix.server.performance.transaction-reliability-retry-time-interval-ms | 全局SimpleLeastOneDeliveryStrategy 消息重试投递等待间隔基数 | int | 5000 |
| quantex.phoenix.server.performance.transaction-reliability-batch-retry | 全局SimpleLeastOneDeliveryStrategy批量重试大小 批量重试批次大小 | Int | 100 |
| quantex.phoenix.server.performance.limit-max-live-things | 全局CountLimitHandler 最大存活事情 | Int | 5000 |
| quantex.phoenix.server.performance.limit-max-remove-timeout-ms | 全局CountLimitHandler 最大移除超时时间 | Int | 100000 |
| quantex.phoenix.server.performance.batch-process | EntityAggregateActor 批量向子Actor发送消息进行处理 | Int | 100 |
| quantex.phoenix.server.performance.batch-persist | 消息持久化 批次大小 | Int | 200 |
| quantex.phoenix.server.performance.event-sourcing-read-batch-size | Event Sourcing 事件读取的分页大小 | Int | 1000 |
Phoenix-client配置
| 配置项 | 描述 | 类型 | 默认值 |
|---|---|---|---|
| quantex.phoenix.client.name | Client 端服务名 | String | 无 |
| quantex.phoenix.client.maxRetryNum | 最大重试次数（默认重试3次），如果设置为MAX_VALUE则表示关闭重试逻辑 | int | 2 |
| quantex.phoenix.client.retryInterval | 重试间隔（单位毫秒,默认10s） | long | 1000000000 |
| 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.client.mq.subscribe-topic | Server端订阅的 topic | String | Client端服务名 |
| quantex.phoenix.client.mq.use-kerberos | 是否开启 kerberos 认证 | Boolean | false |
| quantex.phoenix.client.mq.jaas-conf-path | jaas配置文件路径 | String | 无 |
| quantex.phoenix.client.mq.krb5-conf-path | krb5配置文件路径 | String | 无 |
| quantex.phoenix.client.mq.krb-service-name | krb服务名 | String | 无 |
Phoenix-admin配置
该配置表示Phoenix应用接入Phoenix-admin所需要的配置
| 配置项 | 描述 | 类型 | 默认值 |
|---|---|---|---|
| eureka.client.enabled | 是否启用eureka客户端 | Boolean | true |
| eureka.client.serviceUrl.defaultZone | eureka server地址 | String | 无 |
| eureka.client.fetch-registry | 从eureka server同步注册信息 | Boolean | true |
| eureka.client.register-with-eureka | 注册自身信息到eureka server | Boolean | true |
| eureka.instance.prefer-ip-address | 是否优先使用ip注册 | Boolean | false |
| eureka.instance.appname | 注册的服务名 | String | UNKNOWN |
| eureka.instance.metadata-map.phoenixEnabled | 是否接入Phoenix-admin监控 | String | 无 |
| eureka.instance.metadata-map.servletPath | 服务的http请求路径 | String | 无 |
配置样例
quantex:
phoenix:
server:
name: ${spring.application.name}
mq:
type: kafka
address: embedded
subscribe-topic: account-server
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:
enabled: true
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
# eureka config
service-center:
url: localhost:7070
eureka:
client:
enabled: false
serviceUrl:
defaultZone: http://${service-center.url}/eureka/
fetch-registry: true
register-with-eureka: true
instance:
prefer-ip-address: true
appname: ${spring.application.name}
metadata-map:
phoenixEnabled: true
环境配置参考
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
artery-enable: off
自定义akka配置
如果想要深入自定义akka相关配置，可在项目classpath目录下创建akka.conf文件进行配置。然后修改一下配置。
quantex:
phoenix:
akka:
akka-conf: akka.conf