首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >pika发送消息到rabbitmq超时

pika发送消息到rabbitmq超时
EN

Stack Overflow用户
提问于 2014-02-16 20:46:33
回答 2查看 2K关注 0票数 3

当尝试使用pika和rabbitmq从一台笔记本电脑向另一台笔记本电脑发送消息时,我收到此错误。有什么办法解决这个问题吗?

代码语言:javascript
运行
复制
WARNING:pika.adapters.base_connection:Could not connect due to "timeout," retrying in 2 sec
ERROR:pika.adapters.base_connection:Could not connect: timeout
Traceback (most recent call last):
  File "C:/Users/Peter/Desktop/Blimp182-development(1)/Blimp182-development/Blimp182/send.py", line 7, in <module>
    connection = pika.BlockingConnection(parameters)
  File "C:\Python27\lib\site-packages\pika\adapters\base_connection.py", line 61, in __init__
    super(BaseConnection, self).__init__(parameters, on_open_callback)
  File "C:\Python27\lib\site-packages\pika\connection.py", line 513, in __init__
    self._connect()
  File "C:\Python27\lib\site-packages\pika\connection.py", line 804, in _connect
    self._adapter_connect()
  File "C:\Python27\lib\site-packages\pika\adapters\blocking_connection.py", line 138, in _adapter_connect
    super(BlockingConnection, self)._adapter_connect()
  File "C:\Python27\lib\site-packages\pika\adapters\base_connection.py", line 120, in _adapter_connect
    self.params.retry_delay)
pika.exceptions.AMQPConnectionError: 2.0

进程已完成,退出代码为%1

使用的代码如下:

代码语言:javascript
运行
复制
import pika
import logging
logging.basicConfig()
credentials = pika.PlainCredentials('guest','guest')
parameters =    pika.ConnectionParameters('10.43.12.76', 55672, '/', credentials)
connection = pika.BlockingConnection(parameters=parameters)
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')
print " [x] Sent 'Hello World!'"
connection.close()
EN

回答 2

Stack Overflow用户

发布于 2015-04-07 01:32:24

我不确定您使用的是哪个版本的RabbitMQ,但是端口55672在3.0之前的版本中使用过。对于较新的版本,将使用5672。我知道这个问题很久以前就有人问过了,但是3.0是在2012年发布的。这很容易成为超时问题的原因。

票数 0
EN

Stack Overflow用户

发布于 2015-07-28 15:43:49

1)端口号错误(应为5672)

2) "guest“用户不能用于远程连接。如果要使用,则需要在服务器中进行一些额外的配置。有关配置,请参阅:https://www.rabbitmq.com/access-control.html

3)确保端口未被阻塞。打开以下端口。

sudo iptables -I INPUT -p tcp --dport 5672 --syn -j ACCEPT

sudo iptables -I INPUT -p tcp --dport 5673 --syn -j ACCEPT

sudo iptables -I INPUT -p tcp --dport 15672 --syn -j ACCEPT

谢谢,Saravanan S。

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/21811299

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档