应用实时监控服务ARMS：App监控关联前后端Trace

使用ARMS应用监控探针接入

ARMS应用监控探针默认集成了对OpenTelemetry协议的支持，因此无需额外配置，即可实现与RUM Trace关联，但需要确保以下两点：

• 支持的ARMS应用监控探针版本：2.x、3.x、4.x，为了获得更好的使用体验，推荐升级到4.x版本。

• 支持的Web容器和框架：支持Tomcat、Jetty、WebLogic、Undertow等主流Web容器，以及SpringBoot、SpringMVC等框架。支持的完整组件和框架请参见ARMS应用监控支持的Java组件和框架。

ARMS应用监控探针接入操作请参见开始监控Java应用。

使用OpenTelemetry接入

通过OpenTelemetry接入ARMS（可观测链路 OpenTelemetry 版），目前分为两种方式：自动埋点和手动埋点。

• 自动埋点场景下，由于OpenTelemetry已经支持了绝大多数主流框架，因此，无需额外配置，即可实现与RUM Trace的串联。

  说明

  OpenTelemetry支持的Java框架，请参见通过OpenTelemetry上报Java应用数据。

• 手动埋点场景下，需要通过OpenTelemetry SDK提供的扩展机制，实现与RUM Trace的串联，即从前端请求头（traceparent、tracesate）中，解析出Trace上下文，以下是Springboot场景代码示例：

  1. 引入OpenTelemetry的依赖项。

     <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-api</artifactId>
     </dependency>
     <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-sdk-trace</artifactId>
     </dependency>
     <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-extension-annotations</artifactId>
       <version>1.18.0</version>
     </dependency>
     <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-exporter-otlp</artifactId>
     </dependency>
     <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-sdk</artifactId>
     </dependency>
     <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-semconv</artifactId>
       <version>1.30.1-alpha</version>
     </dependency>
     <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-sdk-extension-autoconfigure</artifactId>
       <version>1.34.1</version>
     </dependency>
     <dependency>
       <groupId>io.opentelemetry</groupId>
       <artifactId>opentelemetry-extension-incubator</artifactId>
       <version>1.35.0-alpha</version>
     </dependency>

  2. 在OpenTelemetry初始化时，添加W3C Propagator。

     Resource resource = Resource.getDefault()
             .merge(Resource.create(Attributes.of(
                     ResourceAttributes.SERVICE_NAME, "otel-demo",
                     ResourceAttributes.HOST_NAME, "xxxx"
     )));
     
     SdkTracerProvider sdkTracerProvider = SdkTracerProvider.builder()
             .addSpanProcessor(BatchSpanProcessor.builder(OtlpHttpSpanExporter.builder()
                     .setEndpoint("Your Endpoint")
                     .addHeader("Authentication", "Your Token")
                     .build()).build())
             .setResource(resource)
             .build();
     
     openTelemetry = OpenTelemetrySdk.builder()
             .setTracerProvider(sdkTracerProvider)
             // 这里添加W3C Propagator
             .setPropagators(ContextPropagators.create(
                     TextMapPropagator.composite(W3CTraceContextPropagator.getInstance(), W3CBaggagePropagator.getInstance()))
              ).buildAndRegisterGlobal();
     // 这里需要使用扩展的Tracer
     tracer = ExtendedTracer.create(openTelemetry.getTracer("com.example.tracer", "1.0.0"));

  3. 在业务接口中，添加headers参数，并从请求头中解析Trace上下文，设置parent。

     // Controller中添加请求header参数，用于解析Trace上下文
     @RequestMapping("/test")
     public String test(@RequestHeader Map<String, String> headers) {
         Span span = OpenTelemetrySupport.getTracer()
                 .spanBuilder("/test")
                 // 从headers中解析parent span
                 .setParentFrom(OpenTelemetrySupport.getContextPropagators(), headers)
                 .setSpanKind(SpanKind.SERVER)
                 .startSpan();
         try (Scope scope = span.makeCurrent()) {
             // do something
         } catch (Throwable t) {
             span.setStatus(StatusCode.ERROR, "handle parent span error");
         } finally {
             span.end();
         }
         return "success";
     }

使用SkyWalking接入

完整接入方式请参见Java Agent插件。

SkyWalking目前仅提供了Java Agent接入方式，您只需要按照上述文档接入，即可实现RUM与后端Trace串联。

和RUM侧配置的协议匹配要求：sw8（v3版本）对应SkyWalking 8.x版本探针。

通过OpenTelemetry接入

完整接入方式请参见通过OpenTelemetry上报Go应用数据。

按照文档接入，然后在HTTP请求Handler中，通过request context生成Span，即可实现与RUM Trace串联。

// 初始化tracer
tracer := otel.Tracer(common.TraceInstrumentationName)
// 通过request context生成span
handler := http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
    ctx := req.Context()
    span := trace.SpanFromContext(ctx)
    // do something
    w.Write([]byte("Hello World"))
})

使用SkyWalking接入

完整接入方式请参见通过SkyWalking上报Go应用数据。

按照文档接入，推荐采用skywalking-go接入方式，该方式支持了主流的Web服务框架，如gin、go-restful、http、go-kratos v2、go-micro、go-resty等，无需修改代码即可实现与RUM Trace串联。

如果您希望手动从HTTP请求头中解析出Trace上下文，也可参考以下代码实现：

//Extract context from HTTP request header `sw8`
span, ctx, err := tracer.CreateEntrySpan(r.Context(), "/api/test", func(key string) (string, error) {
		return r.Header.Get(key), nil
})

通过OpenTelemetry接入

完整接入方式请参见通过OpenTelemetry上报Python应用数据。

按照文档接入，然后从HTTP请求头中解析Span上下文，实现与RUM Trace串联，代码示例如下：

// 初始化tracer
trace.set_tracer_provider(TracerProvider())
trace.get_tracer_provider().add_span_processor(BatchSpanProcessor(ConsoleSpanExporter()))

tracer = trace.get_tracer(__name__)

@app.route('/test')
def test():
    headers = dict(request.headers)

    // 从headers中解析trace context
    carrier ={'traceparent': headers['Traceparent'], 'tracestate': headers['Tracestate']}
    ctx = TraceContextTextMapPropagator().extract(carrier=carrier)

    with tracer.start_span("test", context=ctx):
        // do something
        return "success"

使用SkyWalking接入

完整接入方式请参见通过SkyWalking上报Python应用数据。

按照文档接入，然后从HTTP请求头中解析Span上下文，实现与RUM Trace串联，代码示例如下：

from skywalking import config, agent
from skywalking.trace.context import SpanContext, get_context
from skywalking.trace.carrier import CarrierItem

# 配置 SkyWalking，根据需要调整相关参数
config.init(agent_collector_backend_services='<endpoint>',
            agent_authentication='<auth-token>')

agent.start()

# 示例 HTTP 请求处理函数，需要传入 HTTP 请求的 headers
def handle_request(headers):
    # 从请求头 headers 中提取追踪信息
    carrier_items = []
    for item in SpanContext.make_carrier():
        carrier_header = headers.get(item.key.lower())
        if carrier_header:
            carrier_items.append(CarrierItem(item.key, carrier_header))

    carrier = SpanContext.make_carrier(carrier_items)

    # 从 Carrier 中提取追踪上下文
    context = get_context().extract(carrier)
    
    # 创建一个新 Span 来处理请求
    with get_context().new_entry_span(op='operation_name') as span:
        # 在这里处理请求，并在结束时自动提交 Span
        ...

# 模拟接收到的 HTTP 请求 header 包含 sw8
incoming_headers = {
    'sw8': '1-My40LjU=-MTY1MTcwNDI5OTk5OA==-xxxx-xx-x-x==',  # 示例值，实际根据请求填写
    # 其他 header...
}

# 调用函数处理请求
handle_request(incoming_headers)