如何在Rabbit IOLoop中实现定时重复回调函数？

当然可以只用Pika的IOLoop来实现定时重复执行的函数！你已经找到了call_later方法，它确实只会执行一次，但只要稍微调整逻辑，让回调函数在完成自身任务后，再次调用call_later安排下一次执行，就能形成循环啦。

核心思路 #

让你的回调函数在执行完业务逻辑后，主动调用call_later把自己再次加入IOLoop的任务队列，这样就会每隔self.timeout秒重复执行一次。

代码示例 #

可以参考这个修改后的实现：

class YourTaskClass:
    def __init__(self, connection, timeout):
        self._connection = connection
        self.timeout = timeout
        self._is_running = True  # 用来控制任务启停的标志
        
        # 启动第一次定时任务
        self._connection.ioloop.call_later(self.timeout, self.callback)
    
    def callback(self):
        if not self._is_running:
            return  # 如果任务已停止，不再安排下一次执行
        
        # 这里写你需要重复执行的业务逻辑
        print("正在执行定时任务...")
        
        # 安排下一次执行，形成循环
        self._connection.ioloop.call_later(self.timeout, self.callback)
    
    def stop_repeating_task(self):
        # 调用这个方法可以优雅停止定时任务
        self._is_running = False

关键说明 #

• 循环逻辑：每次callback执行完毕后，都会再次调用call_later，从而实现每隔指定秒数重复执行的效果。
• 停止机制：加入_is_running标志位是为了能灵活终止任务——当你调用stop_repeating_task把标志设为False后，下一次callback执行时就不会再安排后续任务，循环自然终止。
• 纯Pika实现：整个过程完全依赖Pika的IOLoop，不需要额外引入其他定时任务库，完全满足你的需求。

内容的提问来源于stack exchange，提问作者Sergei Petrov