如何在ASP.NET Core中配置MassTransit与Application Insights集成？

问题描述 #

我有多个ASP.NET Core微服务，多数通过基于RabbitMQ的MassTransit实现跨服务通信，但消息传递时Application Insights中无相关数据显示（应用程序地图、事务搜索视图均无内容）。查阅官方文档后发现，文档主要针对直接使用TelemetryClient的控制台应用，而我的项目采用传统依赖注入启动方式，现有配置如下：

services.AddCloudRoleNameInitializer("AgencyService");
services.AddApplicationInsightsTelemetry();

var rabbitSettings = services.GetTransportSettings(Configuration);
services.AddMassTransit(x =>
{
    x.SetKebabCaseEndpointNameFormatter();
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host(rabbitSettings.Host, rabbitSettings.Name, h =>
        {
            h.Username(rabbitSettings.Username);
            h.Password(rabbitSettings.Password);
        });
        cfg.ConfigureEndpoints(context);
    });
});

尝试添加以下配置但未生效：

services.ConfigureTelemetryModule<DependencyTrackingTelemetryModule>((telemetryModule, options) =>
    telemetryModule.IncludeDiagnosticSourceActivities.Add("MassTransit"));

解决方案 #

1. 安装必要NuGet包 #

确保项目中安装MassTransit.ApplicationInsights包，这是MassTransit与Application Insights集成的核心依赖。

2. 修改MassTransit配置，添加Application Insights集成 #

在AddMassTransit的配置委托中，添加Application Insights遥测支持：

services.AddCloudRoleNameInitializer("AgencyService");
services.AddApplicationInsightsTelemetry();

var rabbitSettings = services.GetTransportSettings(Configuration);
services.AddMassTransit(x =>
{
    x.SetKebabCaseEndpointNameFormatter();

    // 注入Application Insights遥测集成
    x.AddApplicationInsightsTelemetry(context);

    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host(rabbitSettings.Host, rabbitSettings.Name, h =>
        {
            h.Username(rabbitSettings.Username);
            h.Password(rabbitSettings.Password);
        });

        cfg.ConfigureEndpoints(context);
    });
});

3. 正确配置DependencyTrackingTelemetryModule #

替换之前的配置代码，使用PostConfigure确保MassTransit的诊断源活动被Application Insights捕获：

services.PostConfigure<DependencyTrackingTelemetryModule>(module =>
{
    if (!module.IncludeDiagnosticSourceActivities.Contains("MassTransit"))
        module.IncludeDiagnosticSourceActivities.Add("MassTransit");
});

4. 验证配置效果 #

• 确认每个微服务都配置了唯一的CloudRoleName，便于在Application Insights中区分不同服务实例。
• 发送测试消息后，查看Application Insights的事务搜索和应用程序地图，验证是否出现消息传递的追踪数据。

关键说明 #

• MassTransit.ApplicationInsights包会自动复用DI容器中的TelemetryClient，无需手动实例化。
• 配置DependencyTrackingTelemetryModule是为了让Application Insights捕获MassTransit的诊断活动，生成完整的分布式追踪链路。

内容的提问来源于stack exchange，提问作者basscinner