Я экспериментировал с настройкой кластера RabbitMQ с Kubernetes.
Проведя некоторые исследования, я наткнулся на следующие 2 полезных урока:
https://kubernetes.io/docs/tasks/job/coarse-parallel-processing-work-queue/ и https://github.com/rabbitmq/rabbitmq-peer-discovery-k8s/tree/master/examples/k8s_statefulsets
Первый настраивает простую службу RabbitMQ с ReplicationController и проталкивает тестовое сообщение, а второй идет немного дальше и настраивает StatefulSet с RBAC и т. Д. Пока все хорошо.
Однако, когда я заканчиваю второй урок, я пытаюсь протолкнуть тестовое сообщение, как в первом уроке, выполнив слегка скорректированные команды:
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 на IP-адрес, полученный с помощью nslookup rabbitmq (как показано в первом уроке).
Может кто-нибудь помочь с тем, что мне здесь не хватает?
Спасибо