@TxTransaction annotation详解
- 该注解为分布式事务的切面(AOP point),如果业务方的service服务需要参与分布式事务,则需要加上此注解。
TxTransactionBootstrap 详解:
<context:component-scan base-package="org.dromara.raincat.*"/>
<aop:aspectj-autoproxy expose-proxy="true"/>
<bean id="txTransactionBootstrap" class="org.dromara.raincat.core.bootstrap.TxTransactionBootstrap">
<property name="txManagerUrl" value="http://localhost:8761"/>
<property name="serializer" value="kryo"/>
<property name="nettySerializer" value="kryo"/>
<property name="bufferSize" value="4096"/>
<property name="nettyThreadMax" value="16"/>
<property name="refreshInterval" value="30"/>
<property name="delayTime" value="30"/>
<property name="heartTime" value="10"/>
<property name="compensation" value="true"/>
<property name="recoverDelayTime" value="60"/>
<property name="retryMax" value="3"/>
<property name="compensationRecoverTime" value="60"/>
<property name="compensationCacheType" value="db"/>
<property name="txDbConfig">
<bean class="org.dromara.raincat.common.config.TxDbConfig">
<property name="url"
value="jdbc:mysql://192.168.1.98:3306/tx?useUnicode=true&characterEncoding=utf8"/>
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="username" value="root"/>
<property name="password" value="123456"/>
</bean>
</property>
</bean>
txManagerUrl:填写你启动的txManager的ip端口,注意添加http://前缀。
serializer :事务日志序列化方式,这里我推荐使用是kroy。当然也支持hessian,protostuff,jdk。在我们测试中表现为:kroy>hessian>protostuff>jdk。
nettySerializer: 与txManager通信对象的序列化方法,注意与txManager中的序列化方式配置一样。
bufferSize: disruptor的bufferSize,当高并发的时候,可以调大。注意是 2n次方。
nettyThreadMax : netty客户端工作线程数量。
refreshInterval: 拉取txmanager配置信息间隔时间,单位秒。
delayTime : 客户端与txmanager通信最大延迟时间。
heartTime : 与txmanager保持心跳时间间隔,单位秒。
compensation: 是否需要补偿,一般情况下不需要,极端情况下设置为true。
recoverDelayTime:事务恢复延迟时间,只有当 compensation:为ture才有用。
compensationRecoverTime: 补偿间隔时间 只有当 compensation:为ture才有用。
retryMax : 事务补偿最大重试次数。
compensationCacheType:使用何种方式存储日志,支持的有db,redis,mongo,zookeeper等。
接下来是最重要的事务日志的存储 在我们的压测中,推荐使用mongo。表现为 mongodb>redis集群>mysql>zookeeper
如果你采用mongodb存储日志,配置如下(url可以配置成mongdb集群的url)
<property name="compensationCacheType" value="mongodb"/>
<property name="txMongoConfig">
<bean class="org.dromara.raincat.common.config.TxMongoConfig">
<property name="mongoDbUrl" value="192.168.1.68:27017"/>
<property name="mongoDbName" value="happylife"/>
<property name="mongoUserName" value="xiaoyu"/>
<property name="mongoUserPwd" value="123456"/>
</bean>
</property>
如果你采用redis存储日志,配置如下:
- redis单节点
<property name="compensationCacheType" value="redis" />
<property name="txRedisConfig">
<bean class="org.dromara.raincat.common.config.TxRedisConfig">
<property name="hostName"
value="192.168.1.68"/>
<property name="port" value="6379"/>
<property name="password" value=""/>
</bean>
</property>
- redis哨兵模式集群:
<property name="compensationCacheType" value="redis"/>
<property name="txRedisConfig">
<bean class="org.dromara.hmily.common.config.TxRedisConfig">
<property name="masterName" value="aaa"/>
<property name="sentinel" value="true"/>
<property name="sentinelUrl" value="192.168.1.91:26379;192.168.1.92:26379;192.168.1.93:26379"/>
<property name="password" value="123456"/>
</bean>
</property>
- redis集群:
<property name="compensationCacheType" value="redis"/>
<property name="txRedisConfig">
<bean class="org.dromara.hmily.common.config.TxRedisConfig">
<property name="cluster" value="true"/>
<property name="clusterUrl" value="192.168.1.91:26379;192.168.1.92:26379;192.168.1.93:26379"/>
<property name="password" value="123456"/>
</bean>
</property>
- 如果你采用zookeeper存储日志,配置如下:
<property name="compensationCacheType" value="zookeeper"/>
<property name="txZookeeperConfig">
<bean class="org.dromara.hmily.common.config.TxZookeeperConfig">
<property name="host" value="192.168.1.73:2181"/>
<property name="sessionTimeOut" value="100000"/>
<property name="rootPath" value="/tcc"/>
</bean>
</property>