c# - RabbitMQ 客户端(消费者)的 active 探测

Question

我想知道/获得有关如何为 RabbitMQ 队列消费者设置 active 探测的意见。我不确定如何验证消费者是否仍在处理来自队列的消息。我已经尝试在互联网上搜索一些线索，但找不到任何线索。所以只是在这里问一个问题，看看是否有人有任何想法。

我想确保正常工作的代码块是

                var consumer = new EventingBasicConsumer(channel);
                consumer.Received += (model, ea) =>
                {
                    var body = ea.Body;
                    var message = Encoding.UTF8.GetString(body);
                    Console.WriteLine($"Message Received: {message}");
                };

谢谢。

Answer 1

首先，您需要在应用程序代码中公开一个 HTTP 端点，以检查消费者是否存活。

有很多方法可以测试消费者的活跃度，比如可以查看最后一条消息被消费的时间戳。如果它太旧，您可以通过返回 HTTP 500 错误来声明消费者已死，否则返回 HTTP 200。这取决于您的业务逻辑，您可能想要使用我建议的方法，或者任何其他适合您需要的方法。

拥有 HTTP 端点后，您可以在 Kubernetes list 中定义 active 探测。

livenessProbe:
      httpGet:
        path: /healthz
        port: 8080
        httpHeaders:
        - name: X-Custom-Header
          value: Awesome
      initialDelaySeconds: 3
      periodSeconds: 3

(摘自https://kubernetes.io/docs/tasks/configure-pod-container/configure-liveness-readiness-probes/)