Seata 配置中心

女爷i 2022-11-21 09:47 202阅读 0赞

# 配置中心配置文件 #

配置中心读取配置的流程

1.  选择配置文件, 例如registry.conf
2.  根据配置文件的文件类型选择基础配置
3.  通过基础配置进行驱动， 加载核心配置

seata 在加载核心配置的时候， 会放到本地的 ConcurrentHashMap 缓存。 取值时可以分为三个级别:

1.  优先从缓存中获取
2.  从 System.getProperty 获取
3.  从配置中心获取  
    如果取到值会存放到缓存中

## 选择配置文件 ##

配置中心配置文件默认是: registry.conf , 可以通过系统属性(System.getProperty),环境变量(System.getenv)指定配置中心配置文件

配置的属性优先获取系统属性值，如果不存在在获取环境变量的配置，如果还没有就获取默认值

<table> 
 <thead> 
  <tr> 
   <th>系统属性方式</th> 
   <th>环境变量方式</th> 
   <th>默认值</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>seata.config.name</td> 
   <td>SEATA_CONFIG_NAME</td> 
   <td>registry</td> 
  </tr> 
  <tr> 
   <td>seataEnv</td> 
   <td>SEATA_ENV</td> 
   <td>空值</td> 
  </tr> 
 </tbody> 
</table>

默认配置: registry.conf  
通过JVM参数: -DseataEnv=test 指定的配置文件: registry-test.conf

配置中心的配置可以放在很多个地方，例如下图的文件，zk,etcd等。 选择配置中心的形式后，就需要根据选择的类型做参数配置。每种配置中心需要的参数都不一样， 例如文件配置中心只需要： 文件类型=文件，文件名=file.conf 。 而zookeeper就需要指定服务器地址，会话超时时间，连接超时时间 等  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L216NDEzOA_size_16_color_FFFFFF_t_70_pic_center]

## 基础配置 ##

文件配置中心的基础配置:

<table> 
 <thead> 
  <tr> 
   <th>配置类型</th> 
   <th>配置名称</th> 
   <th>含义</th> 
   <th>必须</th> 
   <th>类型</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>通用</td> 
   <td>conf.type</td> 
   <td>配置中心的文件类型 ,nacos,consul,apollo,zk,etcd3,file 其中之一</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>nacos</td> 
   <td>config.nacos.serverAddr</td> 
   <td>服务器地址, 例如: localhost</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>nacos</td> 
   <td>config.nacos.namespace</td> 
   <td>命名空间，例如: public</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>nacos</td> 
   <td>config.nacos.group</td> 
   <td>核心配置文件名称</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>nacos</td> 
   <td>config.nacos.cluster</td> 
   <td>集群名称, 例如: default</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>nacos</td> 
   <td>config.nacos.username</td> 
   <td>用户名</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>nacos</td> 
   <td>config.nacos.password</td> 
   <td>密码</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>consul</td> 
   <td>config.consul.serverAddr</td> 
   <td>服务器地址, 例如:127.0.0.1:8500</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>apollo</td> 
   <td>config.apollo.appId</td> 
   <td>app名称,例如: seata-server</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>apollo</td> 
   <td>config.apollo.apolloMeta</td> 
   <td>元数据，例如: http://localhost:8801</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>apollo</td> 
   <td>config.apollo.namespace</td> 
   <td>命名空间，例如: application</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>zookeeper</td> 
   <td>config.zk.serverAddr</td> 
   <td>服务器地址,例如: 127.0.0.1:2181</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>zookeeper</td> 
   <td>config.zk.sessionTimeout</td> 
   <td>会话超时时间, 单位: 毫秒</td> 
   <td>是</td> 
   <td>int</td> 
  </tr> 
  <tr> 
   <td>zookeeper</td> 
   <td>config.zk.connectTimeout</td> 
   <td>连接超时时间, 单位: 毫秒</td> 
   <td>是</td> 
   <td>int</td> 
  </tr> 
  <tr> 
   <td>zookeeper</td> 
   <td>config.zk.username</td> 
   <td>用户名</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>zookeeper</td> 
   <td>config.zk.password</td> 
   <td>密码</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>etcd</td> 
   <td>config.etcd3.serverAddr</td> 
   <td>服务器地址, 例如: http://localhost:2379</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
  <tr> 
   <td>file</td> 
   <td>config.file.name</td> 
   <td>核心配置文件名称,例如: file.conf</td> 
   <td>是</td> 
   <td>string</td> 
  </tr> 
 </tbody> 
</table>

## 核心配置 ##

<table> 
 <thead> 
  <tr> 
   <th>配置名称</th> 
   <th>类型</th> 
   <th>默认值</th> 
   <th>必须</th> 
   <th>含义</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>transport.type</td> 
   <td>string</td> 
   <td>TCP</td> 
   <td>是</td> 
   <td>worker线程的名称</td> 
  </tr> 
  <tr> 
   <td>transport.server</td> 
   <td>string</td> 
   <td>NIO</td> 
   <td>是</td> 
   <td>传输方式, 取值范围: NIO,NATIVE</td> 
  </tr> 
  <tr> 
   <td>transport.heartbeat</td> 
   <td>boolean</td> 
   <td>true</td> 
   <td>是</td> 
   <td>是否启用心跳检查</td> 
  </tr> 
  <tr> 
   <td>transport.enableClientBatchSendRequest</td> 
   <td>boolean</td> 
   <td>true</td> 
   <td>是</td> 
   <td>是否启用客户端批量发送请求</td> 
  </tr> 
  <tr> 
   <td>transport.threadFactory.bossThreadPrefix</td> 
   <td>string</td> 
   <td>NettyBoss</td> 
   <td>否</td> 
   <td>boss线程的名称</td> 
  </tr> 
  <tr> 
   <td>transport.threadFactory.workerThreadPrefix</td> 
   <td>string</td> 
   <td>NettyServerNIOWorker</td> 
   <td>是</td> 
   <td>worker线程的名称</td> 
  </tr> 
  <tr> 
   <td>transport.threadFactory.serverExecutorThreadPrefix</td> 
   <td>string</td> 
   <td>无</td> 
   <td>是</td> 
   <td>服务执行器线程前缀， 目前版本无意义</td> 
  </tr> 
  <tr> 
   <td>transport.threadFactory.clientWorkerThreadPrefix</td> 
   <td>string</td> 
   <td>NettyClientWorkerThread</td> 
   <td>否</td> 
   <td>服务执行器线程前缀</td> 
  </tr> 
  <tr> 
   <td>transport.threadFactory.clientSelectorThreadPrefix</td> 
   <td>string</td> 
   <td>NettyClientSelector</td> 
   <td>否</td> 
   <td>客户端选择器的线程前缀</td> 
  </tr> 
  <tr> 
   <td>transport.threadFactory.clientSelectorThreadSize</td> 
   <td>int</td> 
   <td>1</td> 
   <td>否</td> 
   <td>客户端选择器的线程大小</td> 
  </tr> 
  <tr> 
   <td>transport.threadFactory.shareBossWorker</td> 
   <td>boolean</td> 
   <td>无</td> 
   <td>是</td> 
   <td>是否共享boss和worker的线程池，目前版本无意义</td> 
  </tr> 
  <tr> 
   <td>transport.threadFactory.shutdown.wait</td> 
   <td>int</td> 
   <td>3</td> 
   <td>否</td> 
   <td>应用关闭时调用，配置中心关闭后，等待的时间</td> 
  </tr> 
  <tr> 
   <td>transport.threadFactory.bossThreadSize</td> 
   <td>int</td> 
   <td>1</td> 
   <td>是</td> 
   <td>boss线程池的数量</td> 
  </tr> 
  <tr> 
   <td>transport.threadFactory.workerThreadSize</td> 
   <td>string/int</td> 
   <td>CPU核数*2</td> 
   <td>否</td> 
   <td>为空或者是default是一样的， 也可以指定数字</td> 
  </tr> 
  <tr> 
   <td>transport.serialization</td> 
   <td>string</td> 
   <td>SEATA</td> 
   <td>是</td> 
   <td>序列化的方式: 可选值: SEATA,PROTOBUF,KRYO,FST.(1.3.0还未支持HESSIAN, 下个版本会修复)</td> 
  </tr> 
  <tr> 
   <td>transport.compressor</td> 
   <td>string</td> 
   <td>NONE</td> 
   <td>是</td> 
   <td>压缩方式: NONE,GZIP,ZIP,SEVENZ,BZIP2,LZ4</td> 
  </tr> 
  <tr> 
   <td>transport.threadFactory.bossThreadSize</td> 
   <td>int</td> 
   <td>1</td> 
   <td>是</td> 
   <td>boss线程池的数量</td> 
  </tr> 
  <tr> 
   <td>service.vgroupMapping.my_test_tx_group</td> 
   <td>string</td> 
   <td>无</td> 
   <td>是</td> 
   <td>传输服务组的映射, 创建GlobalTransactionScanner时指定分组名称，例如指定分组名称为<code>my_test_tx_group</code></td> 
  </tr> 
  <tr> 
   <td>service.default.grouplist</td> 
   <td>string</td> 
   <td>无</td> 
   <td>是</td> 
   <td>服务默认组</td> 
  </tr> 
  <tr> 
   <td>service.enableDegrade</td> 
   <td>string</td> 
   <td>无</td> 
   <td>是</td> 
   <td>当前版本不支持</td> 
  </tr> 
  <tr> 
   <td>service.disableGlobalTransaction</td> 
   <td>string</td> 
   <td>false</td> 
   <td>否</td> 
   <td>是否禁用全局事物</td> 
  </tr> 
  <tr> 
   <td>client.rm.asyncCommitBufferLimit</td> 
   <td>int</td> 
   <td>10000</td> 
   <td>是</td> 
   <td>二阶段异步提交的缓冲区大小</td> 
  </tr> 
  <tr> 
   <td>client.rm.lock.retryPolicyBranchRollbackOnConflict</td> 
   <td>boolean</td> 
   <td>true</td> 
   <td>否</td> 
   <td>冲突时的回滚策略，设置为false时，如果发生了回滚冲突会进行重试重试</td> 
  </tr> 
  <tr> 
   <td>client.rm.lock.retryInterval</td> 
   <td>int</td> 
   <td>10</td> 
   <td>否</td> 
   <td>重试间隔的毫秒数</td> 
  </tr> 
  <tr> 
   <td>client.rm.lock.retryTimes</td> 
   <td>int</td> 
   <td>30</td> 
   <td>否</td> 
   <td>重试最大次数</td> 
  </tr> 
  <tr> 
   <td>client.rm.reportRetryCount</td> 
   <td>int</td> 
   <td>10</td> 
   <td>否</td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>client.rm.tableMetaCheckEnable</td> 
   <td>boolean</td> 
   <td>false</td> 
   <td>是</td> 
   <td>是否启用表的元数据检查,如果开启，则会开启一个定时器，每60秒执行一次，更新表元数据缓存Map的所有表的结构</td> 
  </tr> 
  <tr> 
   <td>client.rm.sqlParserType</td> 
   <td>string</td> 
   <td>druid</td> 
   <td>是</td> 
   <td>SQL解析器类型, (1.4.0的属性)</td> 
  </tr> 
  <tr> 
   <td>client.rm.reportSuccessEnable</td> 
   <td>boolean</td> 
   <td>false</td> 
   <td>否</td> 
   <td>saga 模式是否报告成功状态</td> 
  </tr> 
  <tr> 
   <td>client.rm.sagaBranchRegisterEnable</td> 
   <td>boolean</td> 
   <td>false</td> 
   <td>否</td> 
   <td>saga模式是否启用分支注册(1.4.0)</td> 
  </tr> 
  <tr> 
   <td>client.tm.commitRetryCount</td> 
   <td>int</td> 
   <td>false</td> 
   <td>否</td> 
   <td>全局事物提交的最大重试次数</td> 
  </tr> 
  <tr> 
   <td>client.tm.rollbackRetryCount</td> 
   <td>int</td> 
   <td>false</td> 
   <td>否</td> 
   <td>全局事物回滚的最大重试次数</td> 
  </tr> 
  <tr> 
   <td>client.undo.dataValidation</td> 
   <td>boolean</td> 
   <td>true</td> 
   <td>否</td> 
   <td>二阶段回滚时，是否验证后置镜像与当前数据的一致性（避免脏写，一定要开启）</td> 
  </tr> 
  <tr> 
   <td>client.undo.logSerialization</td> 
   <td>string</td> 
   <td>jackson</td> 
   <td>否</td> 
   <td>回滚日志序列化方式</td> 
  </tr> 
  <tr> 
   <td>client.undo.logTable</td> 
   <td>string</td> 
   <td>undo_log</td> 
   <td>否</td> 
   <td>回滚日志的表名称</td> 
  </tr> 
  <tr> 
   <td>client.log.exceptionRate</td> 
   <td>int</td> 
   <td>100</td> 
   <td>否</td> 
   <td>随机打印调用栈的最大比例</td> 
  </tr> 
 </tbody> 
</table>

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L216NDEzOA_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/15ef8d4b4e834b129ca7f0020bf52b66.png