SkyWalking 全链路监控实战：Spring Cloud、Dubbo、RocketMQ 集成指南

Dubbo 集成

Dubbo 2.7+ 版本支持完整，同样依赖 Agent 自动捕获。

@Service(version = "1.0.0")
public class UserServiceImpl implements UserService {
    @Override
    public String sayHello(String name) {
        return "Hello, " + name;
    }
}

// Consumer 端
@Reference(version = "1.0.0")
private UserService userService;

RocketMQ 集成

支持生产者和消费者的全链路追踪，确保消息流转可见。

@Component
@RocketMQMessageListener(topic = "TestTopic", consumerGroup = "test-group")
public class TestConsumer implements RocketMQListener<String> {
    @Override
    public void onMessage(String message) {
        // 消费逻辑会被记录为独立 Span
        System.out.println("Received: " + message);
    }
}

ShardingSphere 集成

可监控分库分表后的 SQL 执行情况，包括慢查询分析。

spring:
  shardingsphere:
    rules:
      sharding:
        tables:
          t_order:
            actual-data-nodes: ds$->{0..1}.t_order_$->{0..1}

高级功能与优化

自定义埋点与异步传递

对于 Agent 无法覆盖的场景（如异步线程），可使用 Toolkit 手动创建 Span 并传递上下文。

import org.apache.skywalking.apm.toolkit.trace.*;

@GetMapping("/async")
public String asyncTrace() throws Exception {
    CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
        // 激活当前 Trace 上下文
        TraceContext.putCorrelation("async.context", "true");
        return "Task done";
    });
    return future.get();
}

性能调优建议

• 采样率调整：编辑 agent/config/agent.config，设置 agent.sample_n_per_3_secs=10 降低开销。
• 忽略特定接口：配置 agent.ignore_suffix 排除健康检查或静态资源。
• 存储优化：Elasticsearch 建议使用 SSD，定期清理过期索引。

UI 功能解析

登录 SkyWalking UI 后，重点关注以下模块：

1. 拓扑图：自动生成服务间调用关系，点击可钻取详情。
2. 追踪（Traces）：查看具体请求的完整调用链，支持按耗时筛选。
3. 性能剖析（Profile）：对慢请求进行 CPU 方法级采样，定位瓶颈。
4. 告警（Alarms）：配置错误率阈值，触发邮件或 Webhook 通知。

最佳实践总结

1. 生产环境开启采样：避免全量采集影响系统性能。
2. 统一命名规范：服务名、实例名需具备业务含义。
3. 日志关联：在 Logback 中输出 TraceId，便于快速定位问题。
4. 定期归档：避免存储无限增长，制定数据保留策略。

SkyWalking 不仅是一个追踪工具，更是涵盖 Metrics、Tracing、Logging 的可观测性平台。合理配置后，它能显著提升分布式系统的排查效率与稳定性。