帮我写一个死信队列代码

好的，以下是一个简单的死信队列代码示例：

import time
import json
import random

# 模拟消息队列
queue = []

# 模拟死信队列
dead_letter_queue = []

# 定义消息处理函数
def process_message(msg):
    # 模拟消息处理过程
    if random.random() < 0.5:
        print("消息处理成功：", msg)
    else:
        print("消息处理失败：", msg)
        # 将消息加入死信队列
        dead_letter_queue.append(msg)

# 定义消息队列消费者函数
def consume():
    while True:
        if queue:
            msg = queue.pop(0)
            process_message(msg)
        else:
            time.sleep(1)

# 定义消息队列生产者函数
def produce():
    for i in range(10):
        msg = {"id": i, "content": f"消息{i}"}
        queue.append(msg)
        print("生产消息：", msg)
        time.sleep(1)

# 启动消费者线程
import threading
t = threading.Thread(target=consume)
t.start()

# 启动生产者线程
t = threading.Thread(target=produce)
t.start()

这个代码实现了一个简单的消息队列，当消息处理失败时，将消息加入死信队列。在实际应用中，可以根据具体需求对死信队列进行处理，比如重新发送消息、记录日志等。