.NET Core控制台使用Prometheus Pushgateway采集MassTransit指标

云原生阿岚

2026-10-17

问题原因及解决方法

造成控制台应用无法采集MassTransit相关指标的核心原因是控制台应用和ASP.NET Core的初始化逻辑存在差异，缺少必要的启动配置，按照以下步骤调整即可：

1. 确认依赖包安装正确

需要确保项目中已安装版本匹配的依赖包：

MassTransit.Prometheus（需和MassTransit主包版本一致）
prometheus-net
prometheus-net.Pushgateway

2. 显式启动MassTransit总线

ASP.NET Core会自动完成IBusControl的启动，但是控制台应用需要手动触发总线启动，否则指标收集中间件不会加载。在服务容器构建完成后添加启动逻辑：

var serviceProvider = services.BuildServiceProvider();
var busControl = serviceProvider.GetRequiredService<IBusControl>();
// 启动总线，初始化所有中间件、端点和指标收集器
await busControl.StartAsync(CancellationToken.None);

// 你的业务逻辑运行区域

// 应用退出前停止总线
await busControl.StopAsync(CancellationToken.None);

3. 显式指定MetricPusher使用的注册表

MassTransit的Prometheus集成默认将指标写入prometheus-net的全局默认注册表Metrics.DefaultRegistry，初始化MetricPusher时可以显式指定注册表避免配置偏差：

var pusher = new MetricPusher(new MetricPusherOptions
{
    Endpoint = "https://pushgateway.example.org:9091/metrics",
    Job = "some_job",
    // 显式指定和MassTransit共用同一注册表，确保指标能被采集到
    Registry = Metrics.DefaultRegistry
});
pusher.Start();

4. 低版本MassTransit额外配置

如果使用的是低于7.3版本的MassTransit，需要在AddMassTransit之前手动注册Prometheus指标服务：

services.AddPrometheusMetrics();

services.AddMassTransit(x =>
{
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.UsePrometheusMetrics(serviceName: "order_service");
    });
});