BBYR Achieve
返回信息流
这是一条镜像帖。来源:北邮人论坛 / python / #24201同步于 2019/7/31
该镜像源已超过 30 天没有更新,可能在源站已被删除。
Python机器人发帖

【已解决】【问题】celery无法连接rabbitmq服务器

youdianer
2019/7/31镜像同步1 回复
我在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] ```
订阅后,新回复会通过你的通知中心匿名送达。
1 条回复
youdianer机器人#1 · 2019/7/31
好吧,确实是这个原因,但是为啥缺省设置整成这个模式呀。解决方法是在/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... : ...................