服务器 Gind.cn
  1. 服务器 Gind.cn
  3. rabbitmq服务器不接收来自python客户端的消息
Intereting Posts
我想将使用Inotify抓取的事件或日志保存到文件中 1U机箱中CPU风扇/散热器的最佳定位 Debian的包装：如何防止“试图覆盖”的错误 Ubuntu 12.04 LTS定期失去与NTP服务器的同步 MaxMind GeoIP CSV到.dat 每次运行时，ISPmanager srvmon都会重新启动MariaDb auditctl缓冲区设置 – 这个有多大？ SQL Server – 以另一个域用户身份连接 与QEmu的第2层桥接networking问题 Azure Active Directory的Windows 10不提供电子邮件login选项 如何在CentOS 6中向外打开Apache2 ipmi – 无法ping或远程连接 如何使用Apache 2.2在CentOS / Red Hat 6上获得mod_proxy_fcgi？ 可以在我的桌面上运行程序，而它位于远程服务器上？ 我怎样才能configuration我的星号与meetme一起工作

rabbitmq服务器不接收来自python客户端的消息

我正在尝试发布一个消息给rabbitmq。 这工作在生产环境env与相同的代码，所以我怀疑这是一个configuration问题。 

rbqueue = RabbitMQClientQueue('cn-dip-v3', host = rabbitmq_config['host'], username = rabbitmq_config['user'], password = rabbitmq_config['password']) channel = rbqueue.connection.channel() args = {"x-max-priority": 10} channel.queue_declare(queue='cn-dip-v3', durable=True, arguments=args) result = channel.queue_declare(exclusive=True) callback_queue = result.method.queue msgBody = json.dumps({"ohad":123}) # may happen that sendResponseToDal is True but there is no sendResponseToDal method on server side data = {"body":msgBody,"queue_response" : False} if responseHandler: data["queue_response"] = True corrID = str(uuid.uuid4()) channel.basic_publish(exchange='',routing_key='cn-dip-v3',properties=pika.BasicProperties(priority = 10, reply_to = callback_queue,correlation_id = corrID,),body=json.dumps(data))

queue_declare作品。 如果我删除它并运行相同的行队列被定义。 我在pipe理小组中看到了这一点，奇怪的是，在55672港口而不是15672。

在这里输入图像说明

原来的答案是，这是一个旧的安装。 2.8.4在生产阶段vs 3。

安装最新的兔子解决了它。 这里是我使用的安装脚本： 

 vim install_latest_rabbit.sh #!/bin/sh cat <<EOF > /etc/apt/sources.list.d/rabbitmq.list deb http://www.rabbitmq.com/debian/ testing main EOF curl https://www.rabbitmq.com/rabbitmq-signing-key-public.asc -o /tmp/rabbitmq-signing-key-public.asc apt-key add /tmp/rabbitmq-signing-key-public.asc rm /tmp/rabbitmq-signing-key-public.asc apt-get -qy update apt-get -qy install rabbitmq-server sudo rabbitmqctl add_user guest guest sudo rabbitmqctl set_user_tags guest administrator sudo rabbitmqctl set_permissions -p / guest ".*" ".*" ".*" sudo sh install_latest_rabbit.sh