Spring Cloud 學(xué)習(xí)(32) --- APM(二) SkyWalking

SkyWalking 是有個(gè)完整的 APM 系統(tǒng)，被用于追蹤、監(jiān)控、診斷分布式系統(tǒng)。

SkyWalking 整體由 4 個(gè)部分組成：collector、agent、web、storage。
應(yīng)用級(jí)別的接入，可以使用 SDK 形式接入，也可以使用非侵入式的 Agent 形式接入。agent 將數(shù)據(jù)轉(zhuǎn)化為 SkyWalking Trace 數(shù)據(jù)協(xié)議，通過 HTTP、gRPC 發(fā)送到 collector，collector 對(duì)收集到的數(shù)據(jù)進(jìn)行分析、整合，最后存儲(chǔ)到 es 或 H2 中，一般情況下，H2 用于測(cè)試。

SkyWalking 特性

SkyWalking 主要功能

  • 分布式只追蹤、上下文傳輸
  • 應(yīng)用、實(shí)例、服務(wù)性能指標(biāo)分析
  • 根源分析
  • 應(yīng)用拓?fù)浞治?/li>
  • 應(yīng)用于服務(wù)依賴分析
  • 慢服務(wù)檢測(cè)
  • 性能優(yōu)化

SkyWalking 主要特性

  • 多語(yǔ)言探針、類庫(kù)
  1. Java 自動(dòng)探針，追蹤、監(jiān)控程序時(shí)，無需修改源碼
  2. 社區(qū)提供多語(yǔ)言探針：.NET、Node.js
  • 多種后端存儲(chǔ)：Elasticsearch、H2 等
  1. 支持 OpenTrancing：Java 自動(dòng)探針和 OpenTracing API 協(xié)同工作
  • 輕量級(jí)、完善的后臺(tái)聚合和分析功能
  • 現(xiàn)代化 Web UI
  • 日志集成
  • 應(yīng)用、實(shí)例、服務(wù)的告警
  • 支持接受其他跟蹤器數(shù)據(jù)格式
  1. Zipkin JSON、Thrift、Protobuf v1 和 v2 格式，由 OpenZipkin 庫(kù)提供支持
  2. Jaeger 采用 Zipkin Thrift 或 JSON v1/v2 格式

SkyWalking 測(cè)試用例代碼

Zuul

<dependencies>
   <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
   </dependency>

   <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
   </dependency>
</dependencies>

spring:
 application:
   name:
     spring-cloud-apm-skywalking-zuul
server:
 port: 9020
eureka:
 client:
   service-url:
     defaultZone: http://localhost:8761/eureka/
zuul:
 routes:
   spring-cloud-apm-skywlaking-consumer:
     path: /client/**
     serviceId: spring-cloud-apm-skywlaking-consumer

ribbon:
 eureka:
   enabled: true
 ReadTimeout: 30000
 ConnectionTimeout: 30000
 MaxAutoRetries: 0
 MaxAutoRetriesNextServer: 1
 OkToRetryOnAllOperations: false

hystrix:
 threadpool:
   default:
     coreSize: 1000
     maxQueueSize: 1000
     queueSizeRejectionThreshold: 500

 command:
   default:
     execution:
       isolation:
         thread:
           timeoutInMilliseconds: 120001

@SpringBootApplication
@EnableDiscoveryClient
@EnableZuulProxy
public class SpringCloudApmSkywalkingZuulApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringCloudApmSkywalkingZuulApplication.class, args);
    }

}

Consumer

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
</dependencies>

server:
  port: 9021
spring:
  application:
    name: spring-cloud-apm-skywlaking-consumer
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/

@SpringBootApplication
@EnableFeignClients
@EnableDiscoveryClient
public class SpringCloudApmSkywlakingConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringCloudApmSkywlakingConsumerApplication.class, args);
    }

}



@FeignClient("spring-cloud-apm-skywalking-provider")
public interface SkyWalkingFeignService {

    @RequestMapping(value = "/get-send-info", method = RequestMethod.GET)
    String getSendInfo(@RequestParam("serviceName") String serviceName);

}


@RestController
public class SkyWalkingController {

    private final SkyWalkingFeignService feignService;

    @Autowired
    public SkyWalkingController(SkyWalkingFeignService feignService) {
        this.feignService = feignService;
    }

    @GetMapping(value = "/get-info")
    public String getInfo(){
        return feignService.getSendInfo("service");
    }

}

Provider

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
</dependencies>

server:
  port: 9022
spring:
  application:
    name: spring-cloud-apm-skywalking-provider
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/

@SpringBootApplication
@EnableDiscoveryClient
@RestController
public class SpringCloudApmSkywalkingProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringCloudApmSkywalkingProviderApplication.class, args);
    }

    @GetMapping(value = "/get-send-info")
    public String getSendInfo(@RequestParam("serviceName") String serviceName){
        return serviceName + " --> " + "spring-cloud-apm-skywalking-provider";
    }

}

SkyWalking 安裝

SkyWalking 依賴環(huán)境：

  • 被監(jiān)控的應(yīng)用運(yùn)行在 JDK6+
  • SkyWalking collector 和 WebUI 運(yùn)行在 JDK8+
  • elasticsearch 5.x（集群可能不能使用）

下載 elasticsearch_5.6.10 版本

注意：一定要用 5.x 的 elasticsearch，否則會(huì)出現(xiàn)版本問題！

解壓安裝后，進(jìn)入 config/elasticsearch.yml 文件，修改 network.host 為 0.0.0.0。elasticsearch 不允許 root 用戶啟動(dòng)，建立新用戶并賦權(quán)：

useradd es
chown -R es:es /path/to/es

切換到 es 用戶，啟用 es

./bin/elasticsearch

控制臺(tái)報(bào)錯(cuò)：

[1]: max file descriptors [4096] for elasticsearch process is too low, increase to at least [65536]
[2]: max virtual memory areas vm.max_map_count [65530] is too low, increase to at least [262144]

修改 /etc/security/limits.conf，增加如下配置：

* soft nofile 819200
* hard nofile 819200

修改 /etc/sysctl.conf，增加配置：

vm.max_map_count=655360

重新加載配置：

sysctl -p

后臺(tái)啟動(dòng) es： ./bin/elasticsearch -d

查看 es 日志：tail -f logs/elasticsearch.log，正常啟動(dòng)。

瀏覽器訪問 elasticsearch，可見，默認(rèn)的 cluster name 為 elasticsearch：

elasticsearch

SkyWalking 目錄結(jié)構(gòu)

SkyWalking 目錄結(jié)構(gòu)
  • agent：探針相關(guān)
  • bin：collectorService、webappService 啟動(dòng)腳本，其中 startup.* 是同事啟動(dòng)兩個(gè)腳本的合并命令
  • config：Collector 的相關(guān)配置信息
  • log：collector、web 的日志文件
  • webapp：存放 SkyWalking 展示 UI 的 jar 和配置文件

SkyWalking 的默認(rèn)端口為：8080、10800、11800、12800 等，如果要修改端口，需要修改 config 目錄下的 application.yml、webapp 下的 webapp.yml。

修改 config/application.yml 文件，clusterName 與 elasticsearch 的 cluster name 一致，其余采用默認(rèn)設(shè)置。

application.yml

啟動(dòng) SkyWalking

啟動(dòng) SkyWalking：

./bin/startup.sh
啟動(dòng) SkyWalking

訪問 SkyWalking：


訪問 SkyWalking

默認(rèn) 用戶名/密碼 為：admin/admin

SkyWalking Dashboard

監(jiān)控項(xiàng)目

創(chuàng)建目錄

創(chuàng)建四個(gè)目錄，分別對(duì)應(yīng)：consumer、provider、zuul、eureka-server 四個(gè)應(yīng)用，每個(gè)應(yīng)用使用一個(gè)對(duì)應(yīng)的 agent 進(jìn)行啟動(dòng)，其中 agent 是 SkyWalking 的 agent 目錄。

修改 agent.config 文件中 agent.application_code，這項(xiàng)配置代表應(yīng)用。對(duì)應(yīng)修改為 consumer、provider、zuul、eureka。將 eureka、zuul、consumer、provider 打包為 jar，上傳到對(duì)應(yīng)目錄中。

修改 es 內(nèi)存配置

elasticsearch 默認(rèn) JVM 內(nèi)存為 2g，如果虛擬機(jī)內(nèi)存過小，無法啟動(dòng)。如果略大于 JVM 內(nèi)存，啟動(dòng)后無法啟動(dòng)其他組件。所以需要修稿 elasticsearch 的默認(rèn) JVM 內(nèi)存。修改 $ES_HOME/config/jvm.options:

es jvm 參數(shù)

修改后重啟 es、SkyWalking

使用 top 命令查看使用內(nèi)存最高的應(yīng)用，使用 free 命令，查看內(nèi)存總用量、剩余內(nèi)存。

free top 命令

依次啟動(dòng)四個(gè)應(yīng)用

啟動(dòng)時(shí)需要指定 JVM 內(nèi)存，防止出現(xiàn)內(nèi)存不夠的情況。
-Xms 指定最小內(nèi)存，-Xmx 指定最大內(nèi)存

eureka
java -javaagent:/usr/local/src/soft/eureka/agent/skywalking-agent.jar -jar /usr/local/src/soft/eureka/spring-cloud-eureka-server-simple-0.0.1-SNAPSHOT.jar -Xms256m -Xmx256m

provider
java -javaagent:/usr/local/src/soft/provider/agent/skywalking-agent.jar -jar /usr/local/src/soft/provider/spring-cloud-apm-skywalking-provider-0.0.1-SNAPSHOT.jar -Xms256m -Xmx256m

consumer
java -javaagent:/usr/local/src/soft/consumer/agent/skywalking-agent.jar -jar /usr/local/src/soft/consumer/spring-cloud-apm-skywalking-consumer-0.0.1-SNAPSHOT.jar -Xms256m -Xmx256m

zuul
java -javaagent:/usr/local/src/soft/zuul/agent/skywalking-agent.jar -jar /usr/local/src/soft/zuul/spring-cloud-apm-skywalking-zuul-0.0.1-SNAPSHOT.jar -Xms256m -Xmx256m

確認(rèn)啟動(dòng)成功

使用 jps 命令查看啟動(dòng)進(jìn)程：

jps

查看剩余內(nèi)存是否滿足正常運(yùn)行：


free

驗(yàn)證 SkyWalking

啟動(dòng)成功后訪問eureka： http://192.168.67.135:8761/


eureka

訪問 SkyWalking：


SkyWalking

可見 4 個(gè) app 都啟動(dòng)成功了。使用 zuul 訪問 consumer，調(diào)用 provider：


zuul

再次查看 SkyWalking：


SkyWalking

在 service 選項(xiàng)卡中可以看到每個(gè) service 的具體調(diào)用情況


service
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容