我尝试在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"
有什么想法吗?在
谢谢!在
我本周也遇到了同样的问题连接.关闭()永远挂着]。在
我发现运行RBMQ服务器的主机上/(和/tmp和/var)上的磁盘空间使用率为100%,因此显然RBMQ服务器有问题。
当我试图重新启动服务器时('service rabbitmq server restart')我得到了[FAIL],日志没有告诉我任何信息。。。在
我所做的是:
1释放磁盘空间
2手动终止服务器(使用'kill-HUP'),因为“服务停止”命令也失败
三。开始了(服务。。。开始)
现在一切都好了。
顺便说一句,服务器是运行Ubuntu12.04的虚拟机。在
嗯, 阿米尔
相关问题 更多 >
编程相关推荐