我有一个kubernetes集群正在运行 . 在这里我有一个作为pod运行的python应用程序 .

这个应用程序正在与 rabbitmq 交谈,这也是同一群集的其中一个 . 因此整个连接使用内部IP完成 .

问题是我有一个rabbitmq服务,所以我提供服务IP连接 . 它看起来像这样(与鼠兔)

credentials = pika.PlainCredentials(rabbituser, rabbitpass)
connection = pika.BlockingConnection(pika.ConnectionParameters(host=QHost, port=80, credentials=credentials))
channel = connection.channel()

正如您所看到的那样,我想要的连接是在k8s服务中打开的端口80 .

现在它应该将它重定向到相应的pod,这是rabbitmq,但它正在尝试连接到端口 5672

这意味着,错误是因为它试图连接到 service-ip:5672 ,而不是那里 .

我希望它将请求转发到指向服务的rabbit mq pod .

我希望我已经解释了主要内容 .

请询问是否需要更多详细信息 . 谢谢