rabbitmq中confirm消息没确认怎么设置重试

在 RabbitMQ 中，确认消息的方式有两种：confirm 模式和事务模式。如果你使用的是 confirm 模式，可以设置消息的确认超时时间，如果消息在超时时间内没有被确认，则可以进行重试。

具体来说，可以使用 `channel.confirm_select()` 方法开启 confirm 模式，并使用 `add_on_return_callback()` 方法为未确认的消息设置回调函数。在回调函数中，可以根据需要进行消息的重发或其他操作。

下面是一个简单的示例代码：

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 开启 confirm 模式
channel.confirm_select()

# 设置未确认消息的回调函数
def on_return(channel, method, properties, body):
    print("Message returned: %s" % body)
    # 进行重试或其他操作

channel.add_on_return_callback(on_return)

# 发送消息
channel.basic_publish(exchange='', routing_key='test', body='Hello, world!', mandatory=True)

# 等待消息确认
if not channel.wait_for_confirmation():
    # 消息未被确认，进行重试或其他操作
    pass

connection.close()

在上面的代码中，我们使用 `mandatory=True` 将消息标记为必须路由到队列中，如果无法路由则会返回给生产者。如果消息被返回，则会触发回调函数 `on_return()` 进行处理。在 `wait_for_confirmation()` 方法中等待消息的确认，如果在超时时间内消息未被确认，则会返回 False，此时可以进行重试或其他操作。