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

Maven 依赖

虽然 Agent 能实现无侵入监控，但若需手动埋点或自定义 Span，可引入工具包：

<dependency>
    <groupId>org.apache.skywalking</groupId>
    <artifactId>apm-toolkit-trace</artifactId>
    <version>8.13.0</version>
</dependency>

启动参数配置

在 Spring Boot 启动命令中添加 Agent 参数：

-javaagent:/path/to/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

Feign 调用链追踪

假设 user-service 通过 Feign 调用 order-service：

// 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);
        List<Order> orders = orderServiceClient.getOrdersByUserId(id);
        user.setOrders(orders);
        return user;
    }
}

启动后访问接口，SkyWalking UI 将显示完整的调用链，包含每个 Span 的耗时、HTTP 状态码及跨服务上下文传递情况。

Dubbo 集成示例

Dubbo 是国内广泛使用的高性能 RPC 框架，SkyWalking 支持 Dubbo 2.7+。

配置与启动

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

Provider & Consumer 示例

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 生产者和消费者的全链路追踪。

依赖与配置

Agent 已内置插件，可选引入工具包：

<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) {}
    }
}

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
        sharding-algorithms:
          table-inline:
            type: INLINE
            props:
              algorithm-expression: t_order_$->{order_id % 2}

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.*;

@RestController
public class CustomTraceController {
    @GetMapping("/custom")
    @Trace
    @Tag(key = "custom.tag", value = "custom.value")
    public String customTrace() {
        String traceId = TraceContext.traceId();
        doHeavyWork();
        return "Custom trace completed with TraceId: " + traceId;
    }

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

异步线程上下文传递

@GetMapping("/async")
public String asyncTrace() throws Exception {
    CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
        // 手动激活 Trace 上下文
        TraceContext.putCorrelation("async.context", "true");
        try { Thread.sleep(500); } catch (InterruptedException e) {}
        return "Async task done in TraceId: " + TraceContext.traceId();
    });
    return future.get();
}

SkyWalking UI 功能详解

登录 http://localhost:8080 后可查看以下模块：

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

高级配置技巧

1. 自定义采样率

编辑 agent/config/agent.config，降低采集开销：

agent.sample_n_per_3_secs=10

2. 忽略特定端点

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

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

3. 集成日志框架

在 logback-spring.xml 中添加 TraceId 输出：

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

4. 性能调优

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

与其他监控系统对比

若追求开箱即用、功能全面且 UI 友好，SkyWalking 是首选。

最佳实践总结

1. 生产环境开启采样：避免全量采集造成性能压力。
2. 统一命名规范：服务名、实例名要有意义，便于排查。
3. 结合日志系统：通过 TraceId 快速定位问题日志。
4. 设置告警规则：及时发现异常流量或错误突增。
5. 定期归档数据：避免存储无限增长。
6. 培训团队使用 UI：提升整体排障效率。

Apache SkyWalking 不仅仅是一个链路追踪工具，它是一个完整的可观测性平台。无论是 Spring Cloud 微服务，还是 Dubbo RPC、RocketMQ 消息或 ShardingSphere 分库，它都能提供透明、精准的性能洞察。