K8S、RabbitMQ和对等发现

如果values.yaml默认为1个副本(您的清单文件不覆盖此设置),我想知道使用Rabbit Peer发现插件的原因是什么?

我试图根据您的 github issue #但我有点失败。以下是我的观察结果:

1. 如果要使用自定义值安装rabbitmq图表,请 rabbitmq-dev-default-0 POD卡在CrashLoopBackoff状态。 对于我来说,很难进一步排除故障,因为这个rabbitmq helm图表使用的bitnami的rabbitmq映像容器是用非根帐户发货的。
2. 另一方面,如果rabbitmq图表以最简单的形式安装在我的kubernetes集群(v1.13.2)上:

舵安装稳定/rabbitmq

我观察到类似的问题。我的意思是rabbitmq服务器能够在所有集群节点(包括master)的虚拟机重启后存活下来,但我无法从外部连接到它:

在VM重新启动后,我的python mqclient出现以下错误:

socket.gaierror: [Errno -2] Name or service not known

这里没有什么评论:

是的,我按照“舵机状态”命令的指示进行了端口转发:

准备就绪探测器工作正常:

curl -sS -f --user user:<my_pwd> 127.0.0.1:15672/api/healthchecks/node
{"status":"ok"}

rabbitmqctl到rabbitmq从容器内部的服务器连接也可以正常工作:

kubectl exec rabbitmq-dev-default-0 -- rabbitmqctl list_queues
warning: the VM is running with native name encoding of latin1 which may cause Elixir to malfunction as it expects utf8. Please ensure your locale is set to UTF-8 (which can be verified by running "locale" in your shell)
Timeout: 60.0 seconds ...
Listing queues for vhost / ...
name    messages
hello   11

从我使用kubectl port forward to pod而不是service的那一刻起,到rabbitmq服务器的连接就恢复了:

kubectl port-forward --namespace default pod/rabbitmq-dev-default-0 5672:5672

$ python send.py
 [x] Sent 'Hello World!'

所以我真的让兔子跑了。结果发现我的问题是K8S对等机发现无法通过默认端口443连接,我不得不使用外部端口6443,因为 kubernetes.default.svc.cluster.local 解析到公共端口,找不到内部端口,所以是的,我们的配置也混乱了。

我花了一段时间才意识到,当我用 helm install . -f server-values.yaml .

rabbitmq:
  configuration: |-
    ## Clustering
    cluster_formation.peer_discovery_backend  = rabbit_peer_discovery_k8s
    cluster_formation.k8s.host = kubernetes.default.svc.cluster.local
    cluster_formation.k8s.port = 6443
    cluster_formation.node_cleanup.interval = 10
    cluster_formation.node_cleanup.only_log_warning = true
    cluster_partition_handling = autoheal
    # queue master locator
    queue_master_locator=min-masters
    # enable guest user
    loopback_users.guest = false

我不得不加上 cluster_formation.k8s.port = 6443 到主要 values.yaml 文件而不是我自己的。一旦在 价值观 兔子马上就跑了。