导读:本期聚焦于小伙伴创作的《C#中ActivitySource和OpenTelemetry在异步代码里怎么保证上下文正确传递》,敬请观看详情,探索知识的价值。以下视频、文章将为您系统阐述其核心内容与价值。如果您觉得《C#中ActivitySource和OpenTelemetry在异步代码里怎么保证上下文正确传递》有用,将其分享出去将是对创作者最好的鼓励。

在C#异步编程中,ActivitySource用来创建Activity以描述操作耗时与依赖关系,OpenTelemetry则负责将这些Activity导出为追踪数据。当代码中存在大量await、Task.Run或自定义任务调度时,Activity所依赖的上下文可能会断裂,造成链路不完整。理解两者在异步环境下的传递机制,是构建可靠可观测系统的前提。

C#中ActivitySource和OpenTelemetry在异步代码里怎么保证上下文正确传递

Activity与异步上下文的基础关系

System.Diagnostics.Activity内部通过AsyncLocal存储当前活动实例。AsyncLocal会随着异步方法的await点自动流动到后续延续,因此大多数正常使用await的代码不需要额外处理。

常见断裂场景

  • 使用Task.Run将工作推到线程池,且外部已丢失父上下文
  • 在异步方法中错误使用async void,导致上下文无法传播
  • 通过Parallel或自定义Thread直接执行,绕过AsyncLocal流动

基础用法示例

下面展示一个在异步方法中利用ActivitySource创建并自动传递上下文的例子。

using System.Diagnostics;

public class DemoService
{
    private static readonly ActivitySource _source = new ActivitySource("MyApp.Demo");

    public async Task DoWorkAsync()
    {
        // 创建Activity,当前上下文会自动进入AsyncLocal
        using var activity = _source.StartActivity("DoWork");
        activity?.SetTag("step", "begin");

        // await点之后,Activity上下文仍可用
        await Task.Delay(100);
        await InnerAsync();
    }

    private async Task InnerAsync()
    {
        // 这里能取到父Activity,因为AsyncLocal随await流动
        if (Activity.Current != null)
        {
            Activity.Current.SetTag("inner", "called");
        }
        await Task.Delay(50);
    }
}

OpenTelemetry如何接入

在程序启动时注册OpenTelemetry的Tracing,并添加对ActivitySource的监听,导出的数据就会包含上述异步链路。

using OpenTelemetry;
using OpenTelemetry.Trace;

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddOpenTelemetry()
    .WithTracing(tracer =>
    {
        tracer.AddSource("MyApp.Demo")
              .AddAspNetCoreInstrumentation()
              .AddConsoleExporter();
    });

Task.Run中的上下文处理

如果必须在Task.Run中执行,并且希望保留当前Activity,应在外部捕获后再传入,避免上下文丢失。

public void RunWithContext()
{
    var parent = Activity.Current;
    Task.Run(() =>
    {
        // 手动恢复上下文,再创建子Activity
        using var scope = parent?.AddActivity?();
        using var act = _source.StartActivity("TaskRunWork");
        // 业务逻辑
    });
}

注意async void

应避免在库代码中使用async void,它会导致Activity.Current在触发后无法回到调用方上下文,OpenTelemetry可能记录到孤立跨度。

小结对照表

场景上下文是否连续建议
普通await调用直接StartActivity
Task.Run新任务否(默认)显式传递parent
async void方法易断裂改为async Task

结论

只要遵循await异步模型、避免async void、谨慎使用Task.Run,C#中的ActivitySource与OpenTelemetry就能在异步代码里稳定传递上下文,生成完整的分布式追踪链路。

C#ActivitySourceOpenTelemetry异步上下文分布式追踪修改时间:2026-07-25 04:30:24

免责声明:​ 已尽一切努力确保本网站所含信息的准确性。网站内容多为原创整理与精心编撰,观点力求客观中立。本站旨在免费分享,内容仅供个人学习、研究或参考使用。若引用了第三方作品,版权归原作者所有。如内容涉及您的权益,请联系我们处理。
内容垂直聚焦
专注技术核心技术栏目,确保每篇文章深度聚焦于实用技能。从代码技巧到架构设计,为用户提供无干扰的纯技术知识沉淀,精准满足专业提升需求。
知识结构清晰
覆盖从开发到部署的全链路。AI、前端、编程、数据库、服务器、建站、系统层层递进,构建清晰学习路径,帮助用户系统化掌握开发与运维所需的核心技术。
深度技术解析
拒绝泛泛而谈,深入技术细节与实践难点。无论是数据库优化还是服务器配置,均结合真实场景与代码示例进行剖析,致力于提供可直接应用于工作的解决方案。
专业领域覆盖
精准对应开发生命周期。从前端界面到后端编程,从数据库操作到服务器运维,形成完整闭环,一站式满足全栈工程师和运维人员的技术需求。
即学即用高效
内容强调实操性,步骤清晰、代码完整。用户可根据教程直接复现和应用于自身项目,显著缩短从学习到实践的距离,快速解决开发中的具体问题。
持续更新保障
专注既定技术方向进行长期、稳定的内容输出。确保各栏目技术文章持续更新迭代,紧跟主流技术发展趋势,为用户提供经久不衰的学习价值。