作者:張鑫
來源:http://dubbo.apache.org/zh-cn/blog/tracing-with-skywalking.html
如何使用 SkyWalking 給 Dubbo 服務做鏈路追蹤?

Apache Skywalking(Incubator)簡介

Apache Skywalking(Incubator) 專門爲微服務架構和雲原生架構系統而設計並且支持分佈式鏈路追蹤的APM系統。Apache Skywalking(Incubator)通過加載探針的方式收集應用調用鏈路信息,並對採集的調用鏈路信息進行分析,生成應用間關係和服務間關係以及服務指標。Apache Skywalking (Incubating)目前支持多種語言,其中包括Java,.Net Core,Node.js和Go語言。

目前Skywalking已經支持從6個可視化維度剖析分佈式系統的運行情況。總覽視圖是應用和組件的全局視圖,其中包括組件和應用數量,應用的告警波動,慢服務列表以及應用吞吐量;拓撲圖從應用依賴關係出發,展現整個應用的拓撲關係;應用視圖則是從單個應用的角度,展現應用的上下游關係,TopN的服務和服務器,JVM的相關信息以及對應的主機信息。服務視圖關注單個服務入口的運行情況以及此服務的上下游依賴關係,依賴度,幫助用戶針對單個服務的優化和監控;調用鏈展現了調用的單次請求經過的所有埋點以及每個埋點的執行時長;告警視圖根據配置閾值針對應用、服務器、服務進行實時告警。

Dubbo與Apache Skywalking(Incubator)

編寫Dubbo示例程序

Dubbo實例程序已上傳到Github倉庫中。方便大家下載使用。

API工程

服務接口:

package org.apache.skywalking.demo.interfaces;
public interface HelloService {
String sayHello(String name);
}

Dubbo服務提供工程

package org.apache.skywalking.demo.provider;
@Service(version = "${demo.service.version}",
application = "${dubbo.application.id}",
protocol = "${dubbo.protocol.id}",
registry = "${dubbo.registry.id}", timeout = 60000)
public class HelloServiceImpl implements HelloService {
public String sayHello(String name) {
LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(1));
return "Hello, " + name;
}
}

Consumer工程

package org.apache.skywalking.demo.consumer;
@RestController
public class ConsumerController {
private static int COUNT = 0;
@Reference(version = "${demo.service.version}",
application = "${dubbo.application.id}",
url = "dubbo://localhost:20880", timeout = 60000)
private HelloService helloService;
@GetMapping("/sayHello/{name}")
public String sayHello(@PathVariable(name = "name") String name) {
if ((COUNT++) % 3 == 0){
throw new RuntimeException();
}
LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(2));
return helloService.sayHello(name);
}
}

部署Apache Skywalking(Incubator)

Apache Skywalking(Incubator)共提供兩種部署模式:單節點模式和集羣模式,以下爲單節點模式部署步驟,集羣模式部署詳情參考文檔。

依賴第三方組件

  1. JDK8+
  2. Elasticsearch 5.x

部署步驟

  1. 下載 Apache Skywalking Collector
  2. 部署ElasticSearch
  • 修改elasticsearch.yml文件,並設置cluster.name設置成CollectorDBCluster。此名稱需要和collector配置文件一致。
  • 修改ES配置network.host值,將network.host的值修改成0.0.0.0。
  • 啓動Elasticsearch
  1. 解壓並啓動Skywalking Collector。運行bin/startup.sh命令即可啓動Skywalking Collector

啓動示例程序

在啓動示例程序之前,執行編譯打包的命令:

./mvnw clean package

啓動服務提供端

java -jar -javaagent:$AGENT_PATH/skywalking-agent.jar -Dskywalking.agent.application_code=dubbo-provider -Dskywalking.collector.servers=localhost:10800 dubbo-provider/target/dubbo-provider.jar

啓動服務消費端

java -jar -javaagent:$AGENT_PATH/skywalking-agent.jar -Dskywalking.agent.application_code=dubbo-consumer -Dskywalking.collector.servers=localhost:10800 dubbo-consumer/target/dubbo-consumer.jar 

訪問消費端提供的服務

curl http://localhost:8080/sayHello/test

Skywalking監控截圖:

首頁

如何使用 SkyWalking 給 Dubbo 服務做鏈路追蹤?

拓撲圖

如何使用 SkyWalking 給 Dubbo 服務做鏈路追蹤?

應用視圖

如何使用 SkyWalking 給 Dubbo 服務做鏈路追蹤?

JVM信息

如何使用 SkyWalking 給 Dubbo 服務做鏈路追蹤?

服務視圖

服務消費端:

如何使用 SkyWalking 給 Dubbo 服務做鏈路追蹤?

服務提供端:

如何使用 SkyWalking 給 Dubbo 服務做鏈路追蹤?

Trace視圖

如何使用 SkyWalking 給 Dubbo 服務做鏈路追蹤?

Span信息:

如何使用 SkyWalking 給 Dubbo 服務做鏈路追蹤?

告警視圖

如何使用 SkyWalking 給 Dubbo 服務做鏈路追蹤?

相關文章