RabbitMQ和Python连接不能clos

2024-02-26 10:49:34 发布

您现在位置:Python中文网/ 问答频道 /正文

我尝试在ubuntu13机器上使用RabbitMQ和Python。在

一切似乎都在工作——也就是说,RabbitMQ已经启动并运行。Python有这个库(我使用的是Pika)。代码运行。在

但是在我使用publish并尝试关闭连接之后,它不会关闭。在

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

python和bitrabi不存在问题。在

我的代码:

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"

有什么想法吗?在

谢谢!在


Tags: namepy机器queuejobschannelrabbitmqconnection
1条回答
网友
1楼 · 发布于 2024-02-26 10:49:34

我本周也遇到了同样的问题连接.关闭()永远挂着]。在

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

当我试图重新启动服务器时('service rabbitmq server restart')我得到了[FAIL],日志没有告诉我任何信息。。。在

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

现在一切都好了。
顺便说一句,服务器是运行Ubuntu12.04的虚拟机。在

嗯, 阿米尔

相关问题 更多 >