我用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
另外,我很抱歉在我的问题中写错了。