队列大小的指标答案

【问题标题】：Metric for queue size队列大小的指标
【发布时间】：2019-03-27 21:38:40
【问题描述】：

将 spring 流与 rabbitmq binder 一起使用。我们希望有一个衡量我们队列大小的指标。实现队列大小指标的最佳方法是什么？

我已尝试使用注释 @EnableIntegrationManagement...但我没有看到我们的输出通道计数器指标

【问题讨论】：

【解决方案1】：

如果您指的是 RabbitMQ 代理上的队列大小，则客户端应用程序中没有任何东西提供开箱即用的功能。您为什么希望 @EnableIntegrationManagement 提供帮助，尤其是在输出通道方面？

您可以针对 RabbitMQ 管理插件调用 REST API，也可以使用 RabbitAdmin 并调用 getQueueProperties(queueName)。

【讨论】：

我将如何获得一个 rabbitadmin bean？当我点击我们应用程序的 bean 执行器时，我可以看到一个 rabbitadmin bean，但是当我尝试让 spring 自动装配它时，我得到一个未找到的异常。
IIRC，您必须将其自动连接为AmqpAdmin。
是的，使用 AmqpAdmin 修复了自动装配。现在我得到“连接被拒绝（连接被拒绝）”。我们在 PCF 上运行，所有的连接魔法都发生在我们身上。希望 RabbitAdmin 将全部设置
用这个修复它：'@Configuration public class RabbitmqConfig extends AbstractCloudConfig { @Bean public ConnectionFactory rbc() { return connectionFactory().rabbitConnectionFactory(); } }'