我一直在尝试使用Kubernetes设置RabbitMQ集群。
经过研究,我偶然发现了以下两个有用的教程:
https://kubernetes.io/docs/tasks/job/coarse-parallel-processing-work-queue/和https://github.com/rabbitmq/rabbitmq-peer-discovery-k8s/tree/master/examples/k8s_statefulsets
第一个使用ReplicationController设置一个简单的RabbitMQ服务,并推送测试消息,而第二个更进一步,并使用RBAC等设置一个StatefulSet。到目前为止,很好。
但是,当我完成第二个教程时,我试图通过运行稍微调整的命令来像第一个教程中那样推送测试消息:
export BROKER_URL=amqp://guest:guest@rabbitmq:5672
/usr/bin/amqp-declare-queue --url=$BROKER_URL -q foo -d
然后抛出错误
logging in to AMQP server: a socket error occurred
起初我以为URL是错误的,但是我通过用
rabbitmq
替换为使用nslookup rabbitmq
feteched的IP地址来验证它(如第一个教程中所示)。有人可以帮我解决我在这里所缺少的吗?
谢谢
最佳答案
我解决了这个问题,看来kubernetes指南已经过时:如果在测试时使用unbutu的较新镜像(例如ubuntu:18.04),它似乎可以工作!
关于kubernetes - 运行Rabbitmq-peer-discovery-k8s会引发套接字错误,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/52193970/