请问在9-12节中,每隔多长时间才执行一次checkLocalTransaction(Message msg)方法呀?

来源:9-12 分布式事务02-编码实现

宝慕林5249423

2019-08-08

请问在9-12节中,每隔多长时间才执行一次checkLocalTransaction(Message msg)方法呀?
这个时间是在哪里配置的?

写回答

1回答

大目

2019-08-08

您好,默认的回查间隔时间是1分钟。这个时间在RocketMQ broker里面。

可通过:rocketmq-all-4.5.1-bin-release/conf/broker.conf,里面添加

transactionCheckInterval = 时间 去指定,单位是毫秒。

这是RocketMQ本身的知识,不是课程的重点,所以课上没有讲。


如果你对源码感兴趣,代码在:

org.apache.rocketmq.broker.transaction.TransactionalMessageCheckService.run方法,里面的:


long checkInterval = brokerController.getBrokerConfig().getTransactionCheckInterval();

代码地址:https://github.com/apache/rocketmq/blob/rocketmq-all-4.5.1/broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageCheckService.java

1
3
宝慕林5249423
回复
大目
我们都应该感谢您的,因为您教给了我们知识
2019-08-08
共3条回复

Spring Cloud Alibaba微服务从入门到进阶

面向未来微服务:熟练掌握Spring Cloud Alibaba

3085 学习 · 1324 问题

查看课程