Apache SkyWalking 是一款开源的 APM 系统，提供全链路追踪与性能监控。本文详细讲解其在微服务架构中的集成方案，涵盖 Spring Cloud、Dubbo、RocketMQ 和 ShardingSphere 等主流中间件。内容包括环境搭建、Agent 配置、代码示例及 UI 功能解析。通过无侵入探针自动采集数据，支持多语言和多协议，具备拓扑图展示、慢 SQL 分析、日志关联及告警能力。文章还提供了采样率调整、插件优化等高级配置技巧，帮助开发者构建完整的可观测性体系，提升分布式系统的排查效率。
在微服务架构盛行的今天，系统之间的调用关系变得异常复杂。一次用户请求可能经过多个服务节点、消息队列、数据库分片、缓存中间件等组件，任何一个环节出现问题都可能导致整个链路失败或性能下降。传统的日志分析和单点监控已经无法满足现代分布式系统的可观测性需求。
Apache SkyWalking 作为一款开源的 APM（Application Performance Management）系统，应运而生，并迅速成为业界最受欢迎的全链路追踪与性能监控解决方案之一。
在众多 APM 工具中（如 Zipkin、Pinpoint、Jaeger），SkyWalking 凭借以下优势脱颖而出：
官方地址：https://skywalking.apache.org/
SkyWalking 采用模块化设计，主要由以下几个核心组件构成：
前往官网下载最新版本（建议使用 9.x 版本）： https://skywalking.apache.org/downloads/
解压后目录结构如下：
apache-skywalking-apm-x.x.x
├── agent/ # 探针目录
├── config/ # OAP 配置文件
├── oap-libs/ # OAP 依赖库
├── webapp/ # UI 应用
├── bin/ # 启动脚本
└── ...
进入 bin 目录：
# Linux/Mac
./oapService.sh
./webappService.sh
# Windows
oapService.bat
webappService.bat
默认 UI 地址：http://localhost:8080
Spring Cloud 是目前最流行的微服务框架之一，SkyWalking 对其支持非常完善，包括 Feign、RestTemplate、Gateway、Eureka、Nacos 等组件。
虽然 SkyWalking 使用 Java Agent 实现无侵入监控，但如果你想手动埋点或自定义 Span，可以引入：
<dependency>
<groupId>org.apache.skywalking</groupId>
<artifactId>apm-toolkit-trace</artifactId>
<version>8.13.0</version>
</dependency>
在你的 Spring Boot 应用启动命令中添加：
-javaagent:/path/to/skywalking-agent/skywalking-agent.jar \
-Dskywalking.agent.service_name=your-service-name \
-Dskywalking.collector.backend_service=localhost:11800
例如：
java -javaagent:/opt/skywalking/agent/skywalking-agent.jar \
-Dskywalking.agent.service_name=user-service \
-Dskywalking.collector.backend_service=127.0.0.1:11800 \
-jar user-service.jar
假设你有两个服务：user-service 和 order-service，通过 Feign 远程调用。
// OrderServiceClient.java
@FeignClient(name = "order-service", url = "http://localhost:8082")
public interface OrderServiceClient {
@GetMapping("/orders/{userId}")
List<Order> getOrdersByUserId(@PathVariable("userId") Long userId);
}
// UserController.java
@RestController
@RequestMapping("/users")
public class UserController {
@Autowired
private OrderServiceClient orderServiceClient;
@GetMapping("/{id}")
public User getUserWithOrders(@PathVariable Long id) {
User user = userService.findById(id);
List<Order> orders = orderServiceClient.getOrdersByUserId(id);
user.setOrders(orders);
return user;
}
}
✅ 启动后访问 http://localhost:8081/users/1，你将在 SkyWalking UI 中看到完整的调用链。
你可以在 UI 中查看：
Dubbo 是阿里巴巴开源的高性能 RPC 框架，在国内企业广泛使用。SkyWalking 提供了对 Dubbo 2.7+ 的完整支持。
只需确保 -javaagent 参数正确挂载即可，无需额外配置。
// UserServiceImpl.java
@Service(version = "1.0.0")
public class UserServiceImpl implements UserService {
@Override
public String sayHello(String name) {
return "Hello, " + name + " from Dubbo Provider!";
}
}
// UserController.java
@RestController
public class UserController {
@Reference(version = "1.0.0")
private UserService userService;
@GetMapping("/hello/{name}")
public String hello(@PathVariable String name) {
return userService.sayHello(name);
}
}
✅ 访问 http://localhost:8083/hello/Alice，SkyWalking 将自动捕获 Dubbo 调用链。
你可以在 UI 中看到：
RocketMQ 是阿里开源的分布式消息中间件，SkyWalking 支持对其生产者和消费者的全链路追踪。
<dependency>
<groupId>org.apache.skywalking</groupId>
<artifactId>apm-toolkit-mq</artifactId>
<version>8.13.0</version>
</dependency>
@RestController
public class MessageController {
@Autowired
private RocketMQTemplate rocketMQTemplate;
@GetMapping("/send/{msg}")
public String sendMessage(@PathVariable String msg) {
Message<String> message = MessageBuilder.withPayload(msg).build();
rocketMQTemplate.send("TestTopic", message);
return "Message sent: " + msg;
}
}
@Component
@RocketMQMessageListener(topic = "TestTopic", consumerGroup = "test-group")
public class TestConsumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
System.out.println("Received message: " + message);
// 模拟业务处理耗时
try {
Thread.sleep(500);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
}
✅ 调用 http://localhost:8084/send/HelloRocketMQ，SkyWalking 将追踪完整的消息流转过程。
你可以在 UI 中看到：
ShardingSphere 是一套开源的分布式数据库中间件，提供分库分表、读写分离、数据加密等功能。SkyWalking 支持对其 SQL 执行的监控与追踪。
spring:
shardingsphere:
datasource:
names: ds0,ds1
ds0:
type: com.zaxxer.hikari.HikariDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
jdbc-url: jdbc:mysql://localhost:3306/db0?useSSL=false&serverTimezone=UTC
username: root
password: root
ds1:
type: com.zaxxer.hikari.HikariDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
jdbc-url: jdbc:mysql://localhost:3306/db1?useSSL=false&serverTimezone=UTC
username: root
password: root
rules:
sharding:
tables:
t_order:
actual-data-nodes: ds${0..1}.t_order_${0..1}
table-strategy:
standard:
sharding-column: order_id
sharding-algorithm-name: table-inline
key-generate-strategy:
column: order_id
key-generator-name: snowflake
sharding-algorithms:
table-inline:
type: INLINE
@RestController
@RequestMapping("/orders")
public class OrderController {
@Autowired
private OrderRepository orderRepository;
@PostMapping
public Order createOrder(@RequestBody Order order) {
return orderRepository.save(order);
}
@GetMapping("/{id}")
public Order getOrder(@PathVariable Long id) {
return orderRepository.findById(id).orElse(null);
}
}
✅ 调用创建订单接口，SkyWalking 将自动记录：
你可以在 UI 的 'Database' 标签页中看到所有 SQL 执行情况，包括慢查询分析。
虽然 SkyWalking Agent 能自动采集大部分数据，但在某些场景下（如异步线程、自定义任务、第三方 SDK），你可能需要手动埋点。
import org.apache.skywalking.apm.toolkit.trace.TraceContext;
import org.apache.skywalking.apm.toolkit.trace.Trace;
import org.apache.skywalking.apm.toolkit.trace.Tag;
@RestController
public class CustomTraceController {
@GetMapping("/custom")
@Trace
@Tag(key = "custom.tag", value = "custom.value")
public String customTrace() {
// 获取当前 TraceId
String traceId = TraceContext.traceId();
System.out.println("Current TraceId: " + traceId);
// 模拟业务逻辑
doHeavyWork();
return "Custom trace completed with TraceId: " + traceId;
}
private void doHeavyWork() {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
}
@GetMapping("/async")
public String asyncTrace() throws InterruptedException, ExecutionException {
String traceId = TraceContext.traceId();
System.out.println("Main thread TraceId: " + traceId);
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
// 手动激活 Trace 上下文
TraceContext.putCorrelation("async.context", "true");
try {
Thread.sleep(500);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
return "Async task done in TraceId: " + TraceContext.traceId();
});
return future.get();
}
✅ 上述代码中，异步线程中的操作仍会关联到原始 TraceId，确保调用链完整。
登录 http://localhost:8080 后，你将看到以下核心功能模块：
展示全局性能指标：TPS、响应时间、成功率、JVM 内存/CPU 使用率等。
自动生成服务间调用关系图，支持点击钻取。
查看具体某次请求的完整调用链，支持按服务、端点、状态码、耗时筛选。
对慢请求进行 CPU 方法级采样，定位性能瓶颈。
集成 Logback/Log4j2，支持按 TraceId 关联日志。
配置规则，如'5 分钟内错误率 > 5%'触发邮件/Webhook 告警。
编辑 agent/config/agent.config：
# 默认采样率 100%，可调整为 10% 降低开销
agent.sample_n_per_3_secs=10
# 不追踪健康检查接口
agent.ignore_suffix=.jpg,.jpeg,.js,.css,.png,.gif,/health,/actuator/**
-Dskywalking.agent.instance_name=${HOSTNAME}
在 logback-spring.xml 中添加：
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%X{tid}] [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
其中 %X{tid} 会输出 SkyWalking TraceId，便于日志关联。
除了 Java，SkyWalking 还支持：
go2sky SDKskywalking-backend-jsskywalking-pythonSkyAPM-dotnetskywalking-php-sdk跨语言调用也能保持 TraceId 传递，实现全栈可观测性。
官方多语言 SDK 文档：https://skywalking.apache.org/docs/
SkyWalking Agent 默认性能损耗 < 10%，但在高并发场景下仍需优化：
# agent.config
buffer.channel_size=5
buffer.buffer_size=1000
# 禁用 Redis 插件（如未使用）
plugin.redis.trace_redis_parameters=false
collector.grpc_compression=true
| 特性 | SkyWalking | Zipkin | Pinpoint | Jaeger |
|---|---|---|---|---|
| 无侵入探针 | ✅ | ❌（需手动埋点） | ✅ | ❌ |
| UI 功能丰富度 | ⭐⭐⭐⭐⭐ | ⭐⭐ | ⭐⭐⭐⭐ | ⭐⭐⭐ |
| 多语言支持 | ✅ | ✅ | ❌（仅 Java） | ✅ |
| 拓扑图 | ✅ | ❌ | ✅ | ❌ |
| 日志集成 | ✅ | ❌ | ❌ | ❌ |
| 社区活跃度 | ⭐⭐⭐⭐⭐ | ⭐⭐⭐ | ⭐⭐ | ⭐⭐⭐⭐ |
结论：如果你追求开箱即用、功能全面、UI 友好、生态活跃，SkyWalking 是首选。
SkyWalking 支持自定义插件扩展，适用于私有协议或未支持的框架。
基本步骤：
ClassEnhancePluginDefineInstanceMethodsAroundInterceptoragent/plugins/官方插件开发指南：https://skywalking.apache.org/docs/skywalking-java/latest/en/setup/service-agent/java-agent/readme/
Apache SkyWalking 不仅仅是一个'链路追踪工具'，它是一个完整的可观测性平台，涵盖 Metrics、Tracing、Logging、Profiling、Alerting 五大支柱。
无论你是使用 Spring Cloud 构建微服务，还是 Dubbo 实现高性能 RPC，或是 RocketMQ 处理异步消息、ShardingSphere 管理海量数据，SkyWalking 都能为你提供透明、精准、实时的性能洞察。
不要再让'黑盒'困扰你的系统，从今天开始，给你的应用装上'天眼' —— Apache SkyWalking！
📌 本文所有示例代码均可在本地搭建环境运行，建议配合官方文档进行深入学习。 📘 官方文档：https://skywalking.apache.org/docs/ 🧑💻 社区论坛：https://github.com/apache/skywalking/discussions 🐦 Twitter 更新：https://twitter.com/ASFSkyWalking
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具，Keycode 信息在线工具，online
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。 在线工具，Escape 与 Native 编解码在线工具，online
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具，JavaScript / HTML 格式化在线工具，online
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。 在线工具，JavaScript 压缩与混淆在线工具，online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具，Base64 文件转换器在线工具，online