Kubernetes 中的全链路跟踪技术-JavaScript中文网-JavaScript教程资源分享门户

在 Kubernetes 中，我们经常需要处理大量的微服务。在这些微服务中，跨越多个服务的业务流程也变得越来越复杂。跟踪这些服务之间的交互、调用和延迟变得很困难。因此，全链路跟踪成为了在 Kubernetes 中处理微服务的必要工具之一。本文将深入探讨在 Kubernetes 中实现全链路跟踪的技术，并提供示例代码，以帮助您更好地理解和应用这些技术。

什么是全链路跟踪？

全链路跟踪是一种跟踪分布式系统中所有行为的方法。跟踪是通过在每一个服务中插入跟踪代码，记录请求和响应之间的时间戳和其他元数据来实现的。全链路跟踪可以使我们深入了解请求从客户端到达时所经历的每一个服务、请求的响应时间以及服务之间的延迟。这些信息可以帮助我们快速定位故障，提高系统的可靠性和可用性。

在 Kubernetes 中，我们可以使用一些流行的全链路跟踪工具，如 Zipkin、Jaeger 和 OpenTelemetry。这些工具提供了 API 和代理来帮助我们捕获和跟踪请求，同时还提供了易于使用的 UI 来查看跟踪数据。下面我们将对这些工具和它们在 Kubernetes 中的使用进行介绍。

Zipkin

Zipkin 是一个开源的分布式跟踪系统，可以帮助我们跨多个进程和服务进行跟踪。在 Kubernetes 中，我们可以通过部署 Zipkin 的服务实例，并使用 Kubernetes 的 Service 来作为代理将 Zipkin 和我们的应用程序连接起来。然后，在我们的应用程序代码中插入 Zipkin 跟踪代码即可开始跟踪我们的请求。

下面是一个基于 Spring Boot 的示例应用程序，展示了如何使用 Zipkin：

// javascriptcn.com 代码示例
@SpringBootApplication
public class ZipkinApplication {

    public static void main(String[] args) {
        SpringApplication.run(ZipkinApplication.class, args);
    }

    @Autowired
    private RestTemplate restTemplate;

    private final Logger logger = LoggerFactory.getLogger(ZipkinApplication.class);

    @Bean
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }

    @Bean
    public Sampler defaultSampler() {
        return Sampler.ALWAYS_SAMPLE;
    }

    @RequestMapping("/home")
    public String home() {
        logger.info("服务1被调用");
        String result = restTemplate.getForObject("http://localhost:8082/hello2", String.class);
        return "服务1调用服务2结果: " + result;
    }
}

Zipkin 的部署非常简单，可以使用 Helm Chart 进行部署：

helm repo add stable https://charts.helm.sh/stable
helm install stable/zipkin --name zipkin

Jaeger

Jaeger 是一个开源的分布式跟踪系统，它可以帮助我们收集、聚合和可视化跨多个服务的请求跟踪数据。Jaeger 支持多种语言和框架，并提供用于展示跟踪数据的 UI。在 Kubernetes 中，我们可以通过部署 Jaeger 的服务实例，并与我们的应用程序连接起来，来实现跨服务的全链路跟踪。

下面是一个基于 Spring Cloud 的示例应用程序，展示了如何使用 Jaeger：

// javascriptcn.com 代码示例
@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class JaegerApplication {

    public static void main(String[] args) {
        SpringApplication.run(JaegerApplication.class, args);
    }

    @Autowired
    private SenderService senderService;

    private final Logger logger = LoggerFactory.getLogger(JaegerApplication.class);

    @Bean
    public io.opentracing.Tracer jaegerTracer() {
        return new Configuration("sender-service").getTracer();
    }

    @RequestMapping("/send")
    public String send() {
        logger.info("发送服务被调用");
        return senderService.sendMessage("Jaeger示例");
    }
}

Jaeger 的部署也非常简单，可以使用 Helm Chart 进行部署：

helm repo add jaegertracing https://jaegertracing.github.io/helm-charts
helm install jaegertracing/jaeger-operator --name jaeger-operator --namespace observability
helm install jaegertracing/jaeger --name jaeger --namespace observability

OpenTelemetry

OpenTelemetry 是一个开放标准的全链路跟踪规范，它提供了一组 API 和工具，可以帮助我们贯穿多个服务跟踪请求。OpenTelemetry 支持多种语言和框架，并提供了用于展示跟踪数据的 UI。在 Kubernetes 中，我们可以使用 OpenTelemetry 来捕获跟踪数据，并将数据发送到 Zipkin 或 Jaeger 等跟踪系统进行分析。OpenTelemetry 可以通过 Kubernetes 的 Sidecar 容器与我们的应用程序连接起来。

下面是一个基于 Node.js 的示例应用程序，展示了如何使用 OpenTelemetry：

// javascriptcn.com 代码示例
const express = require('express')
const app = express()

const port = process.env.PORT || 3000

// Initialize tracing
const opentelemetry = require('@opentelemetry/api')
const { NodeTracerProvider } = require('@opentelemetry/node')
const { registerInstrumentations } = require('@opentelemetry/instrumentation')
const { ExpressInstrumentation } = require('@opentelemetry/instrumentation-express')
const { HttpInstrumentation } = require('@opentelemetry/instrumentation-http')
const { JaegerExporter } = require('@opentelemetry/exporter-jaeger')

const tracerProvider = new NodeTracerProvider({
  serviceName: 'example-app',
})

const exporter = new JaegerExporter({
  serviceName: 'example-app',
  host: 'localhost',
  port: 6832
})

tracerProvider.addSpanProcessor(new SimpleSpanProcessor(exporter))

opentelemetry.trace.setGlobalTracerProvider(tracerProvider)

registerInstrumentations({
  instrumentations: [
    new ExpressInstrumentation({
      // ... ExpressInstrumentation config goes here ...
    }),
    new HttpInstrumentation(),
  ]
})

app.get('/', (req, res) => {
  const span = opentelemetry.trace.getTracer('example').startSpan('handleRequest')
  span.setAttribute('key', 'value')
  console.log('Hello world received a request.')
  span.end()
  res.send('Hello World!')
})

app.listen(port, () => {
})

OpenTelemetry 的部署可以通过 Helm Chart 进行部署：

helm repo add open-telemetry https://open-telemetry.github.io/opentelemetry-helm-charts
helm repo update
helm install otel-opentelemetry-collector open-telemetry/opentelemetry-collector --create-namespace --namespace otel

总结

在这篇文章中，我们介绍了全链路跟踪在 Kubernetes 中的应用和实现。我们了解了一些流行的跟踪工具，如 Zipkin、Jaeger 和 OpenTelemetry，并详细解释了它们的使用方法。通过学习这些技术，您可以完全掌握微服务架构下的全链路跟踪技术，提高系统的稳定性和可靠性。

来源：JavaScript中文网，转载请注明来源本文地址：https://www.javascriptcn.com/post/654248997d4982a6ebbf1b6a