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

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

Feign 调用链追踪

假设存在 user-service 和 order-service，通过 Feign 远程调用。Agent 会自动捕获上下文传递。

// OrderServiceClient.java
@FeignClient(name = "order-service", url = "http://localhost:8082")
public interface OrderServiceClient {
    @GetMapping("/orders/{userId}")
    List<Order> getOrdersByUserId(@PathVariable 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);
        // 此处调用会触发 Feign 的 Span 创建
        List<Order> orders = orderServiceClient.getOrdersByUserId(id);
        user.setOrders(orders);
        return user;
    }
}

启动后访问接口，SkyWalking UI 将展示完整的调用链路：用户浏览器 -> user-service -> Feign -> order-service。你可以查看每个 Span 的耗时、HTTP 状态码及异常堆栈。

Dubbo 集成示例

Dubbo 在国内企业广泛使用，SkyWalking 对 Dubbo 2.7+ 提供了完整支持。

Provider & Consumer 示例

只需确保 -javaagent 参数正确挂载，无需额外配置。

Provider 端：

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

Consumer 端：

@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);
    }
}

访问接口后，UI 中将显示 Dubbo 接口名、方法名、版本信息及调用耗时。

RocketMQ 集成示例

SkyWalking 支持对 RocketMQ 生产者和消费者的全链路追踪，能够关联消息 Topic 与处理耗时。

生产者与消费者

依赖非必须，Agent 已内置插件。若需手动埋点可引入 apm-toolkit-mq。

生产者：

@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();
        }
    }
}

调用发送接口后，可在 UI 中查看消息流转过程，包括 Topic、Tag、Key 及处理耗时。

ShardingSphere 集成示例

ShardingSphere 提供分库分表功能，SkyWalking 可监控其 SQL 执行详情。

配置数据源

spring:
  shardingsphere:
    datasource:
      names: ds0,ds1
      ds0:
        type: com.zaxxer.hikari.HikariDataSource
        jdbc-url: jdbc:mysql://localhost:3306/db0?useSSL=false&serverTimezone=UTC
        username: root
        password: root
      ds1:
        type: com.zaxxer.hikari.HikariDataSource
        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
            props:
              algorithm-expression: t_order_${order_id % 2}
        key-generators:
          snowflake:
            type: SNOWFLAKE

Controller 示例

@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);
    }
}

调用接口后，UI 的 Database 标签页将记录 SQL 内容、执行耗时、影响行数及所属数据源，支持慢查询分析。

自定义埋点与上下文传递

虽然 Agent 能自动采集大部分数据，但在异步线程或第三方 SDK 场景下，可能需要手动干预。

手动创建 Span

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() {
        String traceId = TraceContext.traceId();
        System.out.println("Current TraceId: " + traceId);
        doHeavyWork();
        return "Custom trace completed with TraceId: " + traceId;
    }

    private void doHeavyWork() throws InterruptedException {
        Thread.sleep(1000);
    }
}

异步线程传递上下文

@GetMapping("/async")
public String asyncTrace() throws InterruptedException, ExecutionException {
    String traceId = TraceContext.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，保持调用链完整性。

SkyWalking UI 功能详解

登录 UI 后，核心功能模块包括：

1. 仪表盘（Dashboard）：展示 TPS、响应时间、成功率及 JVM 资源使用情况。
2. 拓扑图（Topology Map）：自动生成服务间调用关系，支持点击钻取细节。
3. 追踪（Traces）：按服务、端点、状态码筛选具体请求的完整调用链。
4. 性能剖析（Profile）：对慢请求进行 CPU 方法级采样，定位瓶颈。
5. 日志（Logs）：集成 Logback/Log4j2，支持按 TraceId 关联日志。
6. 告警（Alarms）：配置规则（如错误率阈值）触发通知。

高级配置与调优

采样率控制

编辑 agent/config/agent.config，降低采集频率以减少开销：

agent.sample_n_per_3_secs=10

忽略特定端点

不追踪静态资源或健康检查接口：

agent.ignore_suffix=.jpg,.jpeg,.js,.css,.png,.gif,/health,/actuator/**

日志集成

在 logback-spring.xml 中添加 %X{tid} 以输出 TraceId：

<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%X{tid}] [%thread] %-5level %logger{36} - %msg%n</pattern>

性能优化建议

• 调整缓冲区：增大 buffer.channel_size 和 buffer.buffer_size。
• 关闭冗余插件：如未使用 Redis 可禁用相关插件。
• 开启 gRPC 压缩：设置 collector.grpc_compression=true。
• 存储层优化：Elasticsearch 建议使用 SSD，定期清理过期索引。

多语言支持

除了 Java，SkyWalking 还支持 Go、Node.js、Python、.NET、PHP 及 Rust 等语言。跨语言调用时，只要配置了相应的 SDK，TraceId 依然能保持传递，实现全栈可观测性。

总结

Apache SkyWalking 不仅仅是一个链路追踪工具，它涵盖了 Metrics、Tracing、Logging、Profiling、Alerting 五大支柱。无论是 Spring Cloud 微服务、Dubbo RPC、RocketMQ 消息队列还是 ShardingSphere 分库分表，SkyWalking 都能提供透明、精准的性能洞察。对于追求开箱即用、功能全面且生态活跃的团队而言，它是构建分布式系统可观测性的首选方案。

建议在生产环境开启采样策略，统一命名规范，并结合日志系统快速定位问题。定期归档数据并培训团队使用 UI，能显著提升整体排障效率。