gpt4 book ai didi

python - RabbitMQ 和 Python - 连接无法关闭

转载 作者:太空宇宙 更新时间:2023-11-03 16:59:56 25 4
gpt4 key购买 nike

我正在尝试在 Ubuntu 13 机器上使用 RabbitMQ 和 Python。

一切似乎都正常 - 即,RabbitMQ 已启动并正在运行。 Python 有库(我正在使用 Pika)。代码运行。

但在我使用发布并尝试关闭连接后 - 它不会关闭。

在我尝试 py-amqplib 之后,我得到了相同的结果。似乎已创建队列,但未发送消息,因此发布不会阻塞。只有 connection.close() block 。

我认为问题出在 RabbitMQ 而不是 python 库。

我的代码:

import pika

JOBS_QUEUE_NAME = "my.queue"

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

channel.queue_declare(queue=JOBS_QUEUE_NAME)

channel.basic_publish(exchange='',
routing_key=JOBS_QUEUE_NAME,
body='Hello World!')
print "closing"
connection.close()
print "closed"

有什么想法吗?

谢谢!

最佳答案

这周我遇到了同样的问题 [connection.close() 永远挂起]。

我发现运行 RBMQ 服务器的主机上/(以及/tmp 和/var)上的磁盘空间使用率为 100%,因此显然 RBMQ 服务器有问题。

当我尝试重新启动服务器('service rabbitmq-server restart')时,我得到了 [FAIL] 并且日志什么也没告诉我......

我所做的是:
1.释放磁盘空间
2. 手动终止服务器(使用“kill -HUP”),因为“服务停止”命令也失败了
3.启动它(服务...启动)

现在一切都很好。
顺便说一句,服务器是运行 Ubuntu 12.04 的虚拟机。

喂,阿米尔

关于python - RabbitMQ 和 Python - 连接无法关闭,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18723976/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com