技术专家谈论：定时任务 VS 死信队列：如何巧妙完成关闭超时订单的功能

2023-11-06 20:03:41

定时任务 vs 死信队列：功能对比

定时任务和死信队列都是处理异步任务的常用方法，但它们在功能上存在着一些差异。

定时任务：定时任务允许您在指定的时间间隔内执行某个任务。任务可以是一段代码、一个脚本或任何其他可执行文件。定时任务通常用于在特定时间点或周期性地执行任务。例如，您可以使用定时任务来每天早上 8 点发送一封电子邮件提醒或每小时检查一次数据库中的新数据。
死信队列：死信队列是一个特殊的队列，用于存储无法成功处理的消息。这些消息通常称为“死信”，因为它们无法再被正常处理。死信队列可以用来存储各种类型的消息，例如错误日志、处理失败的订单或无效的电子邮件地址。当消息进入死信队列后，可以进行进一步的处理，例如人工审查、重新发送或丢弃。

定时任务 vs 死信队列：优缺点比较

特征	定时任务	死信队列
可靠性	相对可靠	非常可靠
延迟	可能存在延迟	延迟较小
可扩展性	可扩展性较差	可扩展性较好
适用场景	适合处理定期任务或需要在特定时间点执行的任务	适合处理失败的消息或需要进行进一步处理的消息

使用死信队列完成关闭超时订单功能

现在，让我们来看一个具体的例子，如何使用死信队列来完成关闭超时订单的功能。

创建一个死信队列。可以使用诸如 RabbitMQ、Kafka 或 ActiveMQ 等消息队列系统来创建死信队列。
将订单信息发送到死信队列。当订单超时后，可以将订单信息发送到死信队列。
创建一个消费者来处理死信队列中的消息。消费者可以是一个独立的程序或应用程序，负责从死信队列中获取消息并进行处理。
在消费者中处理订单信息。消费者可以根据订单信息来执行相应的操作，例如关闭订单、发送电子邮件通知或将订单信息存储到数据库中。

代码重构示例

# 使用定时任务来完成关闭超时订单的功能
import time

def close_expired_orders():
    # 获取所有超时订单
    expired_orders = get_expired_orders()

    # 关闭超时订单
    for order in expired_orders:
        close_order(order)

# 启动定时任务，每小时执行一次
scheduler = BlockingScheduler()
scheduler.add_job(close_expired_orders, 'interval', hours=1)
scheduler.start()

# 使用死信队列来完成关闭超时订单的功能
import pika

# 创建一个死信队列
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='dead_letter_queue', durable=True)

# 将订单信息发送到死信队列
def send_order_to_dead_letter_queue(order):
    channel.basic_publish(exchange='',
                          routing_key='dead_letter_queue',
                          body=json.dumps(order))

# 创建一个消费者来处理死信队列中的消息
def consume_dead_letter_queue():
    channel.basic_consume(callback,
                          queue='dead_letter_queue',
                          no_ack=True)
    channel.start_consuming()

# 处理死信队列中的消息
def callback(ch, method, properties, body):
    order = json.loads(body)
    close_order(order)

# 启动消费者
consume_dead_letter_queue()