请问在9-12节中,每隔多长时间才执行一次checkLocalTransaction(Message msg)方法呀?
来源:9-12 分布式事务02-编码实现

宝慕林5249423
2019-08-08
请问在9-12节中,每隔多长时间才执行一次checkLocalTransaction(Message msg)方法呀?
这个时间是在哪里配置的?
写回答
1回答
-
您好,默认的回查间隔时间是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();
132019-08-08
相似问题