0

我正在寻找一种解决方案,它将使用 RPC 模式,其中“工作人员”将在 Kubernetes 服务器(Azure Kubernetes 服务)上的 pod 中运行。

然后,我想通过使用 KEDA 提供的自动缩放功能,让这些 Pod 根据队列长度向上/向下缩放。

我已成功运行此程序,但注意到当 pod 数量缩减(当队列中的项目数量减少时)时,我最终会获得大量正在运行的连接。当我查看这些连接的客户端时,我注意到除了我的“Pika Python 客户端库/Python 3.7.11”客户端连接(当 Pod 数量减少时,它似乎确实减少了)我还有许多连接客户端为“https://github.com/streadway/amqp”。这似乎是 RabbitMQ 的 Go 客户端库。

我的理解是 KEDA 是用 Go 编写的,但是我对这些连接的关系以及如何关闭它们以避免列表继续增长有点迷茫。

有人对我如何关闭这些连接有任何建议吗?

4

0 回答 0