0

我用rabbitmq创建了一个连接应用程序,它工作正常,但是当我停止rabbitmq进程时,我的所有请求都丢失了,即使在杀死rabitmq服务后,我的请求也会被保存,并且在重新启动rabitmq服务后,我的所有请求都会返回到他们自己的地方。

这是我的 rabitmq.py:

import pika
import SimilarURLs


data = ''

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


def rabit_mq_start(Parameter):
    channel.queue_declare(queue='req')
    a = (take(datas=Parameter.decode()))
    channel.basic_publish(exchange='',
                          routing_key='req',
                          body=str(a))
    print(" [x] Sent {}".format(a))
    return a


channel.start_consuming()


def take(datas):
    returns = SimilarURLs.start(data=datas)
    return returns

另外,我很抱歉在我的问题中写错了。

4

1 回答 1

2

您需要启用发布者确认(通过对象上的confirm_delivery方法channel)。然后,您的应用程序必须跟踪哪些消息已被确认为已发布,哪些消息尚未发布。您必须自己实施。当 RabbitMQ 停止并重新启动时,您的应用程序可以重新发布未确认的消息。

最好使用异步发布者示例作为指南。如果您使用BlockingConnection,则在确认消息时不会收到异步通知,从而违背了它们的目的。

如果您在尝试自己实施后需要进一步的帮助,我建议您跟进pika-python邮件列表。


注意: RabbitMQ 团队会监控邮件列表rabbitmq-users有时只会在 StackOverflow 上回答问题。

于 2018-12-22T16:16:15.887 回答