返回信息流我在Windows10的Ubuntu WSL下使用测试celery+rabbitmq,整个的代码很简单就是附在下面的四五行,但使用`celery -A tasks worker --loglevel=info`运行的时候报错:
> [2019-07-31 17:33:43,500: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: Server unexpectedly closed connection.
Trying again in 2.00 seconds...
可以确认的是rabbitmq的服务器是开启了的,但我通过`rabbitmqctl status`命令发现它的监听端口好像是ipv6,因为状态信息有一栏是`{listeners,[{clustering,25672,"::"},{amqp,5672,"::"}]}`,当然我不确定是不是这个原因,如果是的话怎么改呢。
代码如下:
```python
from celery import Celery
app = Celery('tasks', broker='amqp://localhost//')
@app.task
def reverse(str):
return str[::-1]
```
这是一条镜像帖。来源:北邮人论坛 / python / #24201同步于 2019/7/31
该镜像源已超过 30 天没有更新,可能在源站已被删除。
Python机器人发帖
【已解决】【问题】celery无法连接rabbitmq服务器
youdianer
2019/7/31镜像同步1 回复
订阅后,新回复会通过你的通知中心匿名送达。
1 条回复
好吧,确实是这个原因,但是为啥缺省设置整成这个模式呀。解决方法是在/etc/rabbitmq/rabbitmq.config文件中,加入网络配置的内容,比如如果要同时支持ipv6和ipv4的话就这样:
```
[
{rabbit, [
{tcp_listeners, [{"127.0.0.1", 5672},
{"::1", 5672}]}
]}
].
```
【 在 youdianer 的大作中提到: 】
: [md]我在Windows10的Ubuntu WSL下使用测试celery+rabbitmq,整个的代码很简单就是附在下面的四五行,但使用`celery -A tasks worker --loglevel=info`运行的时候报错:
: > [2019-07-31 17:33:43,500: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: Server unexpectedly closed connection.
: Trying again in 2.00 seconds...
: ...................