欢乐颂第二季,盗墓笔记全集,盗墓笔记

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案

自從上了SkyWalking，睡覺真香?。?！

圖片來自 Pexels

創(chuàng)新互聯(lián)公司主營贛州網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營網(wǎng)站建設(shè)方案,重慶APP開發(fā)公司,贛州h5微信小程序開發(fā)搭建,贛州網(wǎng)站營銷推廣歡迎贛州等地區(qū)企業(yè)咨詢

除了應用指標監(jiān)控以外，它還能對分布式調(diào)用鏈路進行追蹤。類似功能的組件還有：Zipkin、Pinpoint、CAT 等。

上幾張圖，看看效果，然后再一步一步搭建并使用：

概念與架構(gòu)

SkyWalking 是一個開源監(jiān)控平臺，用于從服務和云原生基礎(chǔ)設(shè)施收集、分析、聚合和可視化數(shù)據(jù)。

SkyWalking 提供了一種簡單的方法來維護分布式系統(tǒng)的清晰視圖，甚至可以跨云查看。它是一種現(xiàn)代 APM，專門為云原生、基于容器的分布式系統(tǒng)設(shè)計。

SkyWalking 從三個維度對應用進行監(jiān)視：

service(服務)
service instance(實例)
endpoint(端點)

服務和實例就不多說了，端點是服務中的某個路徑或者說 URI：

SkyWalking allows users to understand the topology relationship between Services and Endpoints, to view the metrics of every Service/Service Instance/Endpoint and to set alarm rules.

SkyWalking 允許用戶了解服務和端點之間的拓撲關(guān)系，查看每個服務/服務實例/端點的度量，并設(shè)置警報規(guī)則。

架構(gòu)如下圖：

SkyWalking 邏輯上分為四個部分：

Probes(探針)
Platform backend(平臺后端)
Storage(存儲)
UI

這個結(jié)構(gòu)就很清晰了，探針就是 Agent 負責采集數(shù)據(jù)并上報給服務端，服務端對數(shù)據(jù)進行處理和存儲，UI 負責展示。

下載與安裝

SkyWalking 有兩中版本，ES 版本和非 ES 版。如果我們決定采用 ElasticSearch 作為存儲，那么就下載 ES 版本。

 
 
 
  
  
  https://skywalking.apache.org/downloads/ 
  
  
  https://archive.apache.org/dist/skywalking/

如上圖：

agent 目錄將來要拷貝到各服務所在機器上用作探針。
bin 目錄是服務啟動腳本。
config 目錄是配置文件。
oap-libs 目錄是 oap 服務運行所需的 jar 包。
webapp 目錄是 web 服務運行所需的 jar 包。

接下來，要選擇存儲了，支持的存儲有：

H2
ElasticSearch 6，7
MySQL
TiDB
InfluxDB

作為監(jiān)控系統(tǒng)，首先排除 H2 和 MySQL，這里推薦 InfluxDB，它本身就是時序數(shù)據(jù)庫，非常適合這種場景。但是 InfluxDB 我不是很熟悉，所以這里先用 ElasticSearch7。

 
 
 
  
  
  https://github.com/apache/skywalking/blob/master/docs/en/setup/backend/backend-storage.md

①安裝 ElasticSearch

鏈接如下：

 
 
 
  
  
  https://www.elastic.co/guide/en/elasticsearch/reference/7.10/targz.html

 
 
 
  
  
  # 啟動 
  
  
  ./bin/elasticsearch -d -p pid 
  
  
  # 停止 
  
  
  pkill -F pid

ElasticSearch 7.x 需要 Java 11 以上的版本，但是如果你設(shè)置了環(huán)境變量 JAVA_HOME 的話，它會用你自己的 Java 版本。

通常，啟動過程中會報以下三個錯誤：

 
 
 
  
  
  [1]: max file descriptors [4096] for elasticsearch process is too low, increase to at least [65535] 
  
  
  [2]: max virtual memory areas vm.max_map_count [65530] is too low, increase to at least [262144] 
  
  
  [3]: the default discovery settings are unsuitable for production use; at least one of [discovery.seed_hosts, discovery.seed_providers, cluster.initial_master_nodes] must be configured

解決方法：在 /etc/security/limits.conf 文件中追加以下內(nèi)容。

 
 
 
  
  
  * soft nofile 65536 
  
  
  * hard nofile 65536 
  
  
  * soft nproc  4096 
  
  
  * hard nproc  4096

可通過以下四個命令查看修改結(jié)果：

 
 
 
  
  
  ulimit -Hn 
  
  
  ulimit -Sn 
  
  
  ulimit -Hu 
  
  
  ulimit -Su

修改 /etc/sysctl.conf 文件，追加以下內(nèi)容：

 
 
 
  
  
  vm.max_map_count=262144

修改 ES 配置文件 elasticsearch.yml 取消注釋，保留一個節(jié)點：

 
 
 
  
  
  cluster.initial_master_nodes: ["node-1"]

為了能夠 ip:port 方式訪問，還需修改網(wǎng)絡(luò)配置：

 
 
 
  
  
  network.host: 0.0.0.0

修改完是這樣的：

至此，ElasticSearch 算是啟動成功了。一個節(jié)點還不夠，這里用三個節(jié)點搭建一個集群。

192.168.100.14 config/elasticsearch.yml：

 
 
 
  
  
  cluster.name: my-monitor 
  
  
  node.name: node-1 
  
  
  network.host: 192.168.100.14 
  
  
  http.port: 9200 
  
  
  discovery.seed_hosts: ["192.168.100.14:9300", "192.168.100.15:9300", "192.168.100.19:9300"] 
  
  
  cluster.initial_master_nodes: ["node-1"]

192.168.100.15 config/elasticsearch.yml：

 
 
 
  
  
  cluster.name: my-monitor 
  
  
  node.name: node-2 
  
  
  network.host: 192.168.100.15 
  
  
  http.port: 9200 
  
  
  discovery.seed_hosts: ["192.168.100.14:9300", "192.168.100.15:9300", "192.168.100.19:9300"] 
  
  
  cluster.initial_master_nodes: ["node-1"]

192.168.100.19 config/elasticsearch.yml：

 
 
 
  
  
  cluster.name: my-monitor 
  
  
  node.name: node-3 
  
  
  network.host: 192.168.100.19 
  
  
  http.port: 9200 
  
  
  discovery.seed_hosts: ["192.168.100.14:9300", "192.168.100.15:9300", "192.168.100.19:9300"] 
  
  
  cluster.initial_master_nodes: ["node-1"]

同時，建議修改三個節(jié)點 config/jvm.options：

 
 
 
  
  
  -Xms2g 
  
  
  -Xmx2g

依次啟動三個節(jié)點：

 
 
 
  
  
  pkill -F pid 
  
  
  ./bin/elasticsearch -d -p pid

接下來，修改 skywalking下config/application.yml 中配置 es 地址即可：

 
 
 
  
  
  storage: 
  
  
    selector: ${SW_STORAGE:elasticsearch7} 
  
  
    elasticsearch7: 
  
  
      nameSpace: ${SW_NAMESPACE:""} 
  
  
      clusterNodes: ${SW_STORAGE_ES_CLUSTER_NODES:192.168.100.14:9200,192.168.100.15:9200,192.168.100.19:9200}

②安裝 Agent

地址如下：

 
 
 
  
  
  https://github.com/apache/skywalking/blob/v8.2.0/docs/en/setup/service-agent/java-agent/README.md

將 agent 目錄拷貝至各服務所在的機器上：

 
 
 
  
  
  scp -r ./agent [email protected]:~/

這里，我將它拷貝至各個服務目錄下：

plugins 是探針用到各種插件，SkyWalking 插件都是即插即用的，可以把 optional-plugins 中的插件放到 plugins 中。

修改 agent/config/agent.config 配置文件，也可以通過命令行參數(shù)指定。主要是配置服務名稱和后端服務地址：

 
 
 
  
  
  agent.service_name=${SW_AGENT_NAME:user-center} 
  
  
  collector.backend_service=${SW_AGENT_COLLECTOR_BACKEND_SERVICES:192.168.100.17:11800}

當然，也可以通過環(huán)境變量或系統(tǒng)屬性的方式來設(shè)置，例如：

 
 
 
  
  
  export SW_AGENT_COLLECTOR_BACKEND_SERVICES=127.0.0.1:11800

最后，在服務啟動的時候用命令行參數(shù) -javaagent 來指定探針：

 
 
 
  
  
  java -javaagent:/path/to/skywalking-agent/skywalking-agent.jar -jar yourApp.jar

例如：

 
 
 
  
  
  java -javaagent:./agent/skywalking-agent.jar -Dspring.profiles.active=dev -Xms512m -Xmx1024m -jar demo-0.0.1-SNAPSHOT.jar

啟動服務

修改 webapp/webapp.yml 文件，更改端口號及后端服務地址：

 
 
 
  
  
  server: 
  
  
    port: 9000 
  
  
   
  
  
  collector: 
  
  
    path: /graphql 
  
  
    ribbon: 
  
  
      ReadTimeout: 10000 
  
  
      # Point to all backend's restHost:restPort, split by , 
  
  
      listOfServers: 127.0.0.1:12800

啟動服務：

 
 
 
  
  
  bin/startup.sh

或者分別依次啟動：

 
 
 
  
  
  bin/oapService.sh 
  
  
  bin/webappService.sh

查看 logs 目錄下的日志文件，看是否啟動成功。瀏覽器訪問：

 
 
 
  
  
  http://127.0.0.1:9000

告警

編輯 alarm-settings.yml 設(shè)置告警規(guī)則和通知：

 
 
 
  
  
  https://github.com/apache/skywalking/blob/v8.2.0/docs/en/setup/backend/backend-alarm.md

重點說下告警通知：

為了使用釘釘機器人通知，接下來，新建一個項目：

 
 
 
  
  
   
  
  
  
  
  
  
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> 
  
  
      4.0.0 
  
  
       
  
  
          org.springframework.boot 
  
  
          spring-boot-starter-parent 
  
  
          2.4.0 
  
  
            
  
  
       
  
  
      com.wt.monitor 
  
  
      skywalking-alarm 
  
  
      1.0.0-SNAPSHOT 
  
  
      skywalking-alarm 
  
  
   
  
  
       
  
  
          1.8 
  
  
       
  
  
   
  
  
       
  
  
           
  
  
              org.springframework.boot 
  
  
              spring-boot-starter-web 
  
  
           
  
  
   
  
  
           
  
  
              com.aliyun 
  
  
              alibaba-dingtalk-service-sdk 
  
  
              1.0.1 
  
  
           
  
  
   
  
  
           
  
  
              commons-codec 
  
  
              commons-codec 
  
  
              1.15 
  
  
           
  
  
   
  
  
           
  
  
              com.alibaba 
  
  
              fastjson 
  
  
              1.2.75 
  
  
           
  
  
   
  
  
           
  
  
              org.projectlombok 
  
  
              lombok 
  
  
              true 
  
  
           
  
  
       
  
  
   
  
  
       
  
  
           
  
  
               
  
  
                  org.springframework.boot 
  
  
                  spring-boot-maven-plugin

可選依賴(不建議引入)：

 
 
 
  
  
  
  
  
  
    org.apache.skywalking 
  
  
      server-core 
  
  
      8.2.0

定義告警消息實體類：

 
 
 
  
  
  package com.wt.monitor.skywalking.alarm.domain; 
  
  
   
  
  
  import lombok.Data; 
  
  
   
  
  
  import java.io.Serializable; 
  
  
   
  
  
  /** 
  
  
   * @author ChengJianSheng 
  
  
   * @date 2020/12/1 
  
  
   */ 
  
  
  @Data 
  
  
  public class AlarmMessageDTO implements Serializable { 
  
  
   
  
  
      private int scopeId; 
  
  
   
  
  
      private String scope; 
  
  
   
  
  
      /** 
  
  
       * Target scope entity name 
  
  
       */ 
  
  
      private String name; 
  
  
   
  
  
      private String id0; 
  
  
   
  
  
      private String id1; 
  
  
   
  
  
      private String ruleName; 
  
  
   
  
  
      /** 
  
  
       * Alarm text message 
  
  
       */ 
  
  
      private String alarmMessage; 
  
  
   
  
  
      /** 
  
  
       * Alarm time measured in milliseconds 
  
  
       */ 
  
  
      private long startTime; 
  
  
   
  
  
  }

發(fā)送釘釘機器人消息：

 
 
 
  
  
  package com.wt.monitor.skywalking.alarm.service; 
  
  
   
  
  
  import com.dingtalk.api.DefaultDingTalkClient; 
  
  
  import com.dingtalk.api.DingTalkClient; 
  
  
  import com.dingtalk.api.request.OapiRobotSendRequest; 
  
  
  import com.taobao.api.ApiException; 
  
  
  import lombok.extern.slf4j.Slf4j; 
  
  
  import org.apache.commons.codec.binary.Base64; 
  
  
  import org.springframework.beans.factory.annotation.Value; 
  
  
  import org.springframework.stereotype.Service; 
  
  
   
  
  
  import javax.crypto.Mac; 
  
  
  import javax.crypto.spec.SecretKeySpec; 
  
  
  import java.io.UnsupportedEncodingException; 
  
  
  import java.net.URLEncoder; 
  
  
  import java.security.InvalidKeyException; 
  
  
  import java.security.NoSuchAlgorithmException; 
  
  
   
  
  
  /** 
  
  
   * https://ding-doc.dingtalk.com/doc#/serverapi2/qf2nxq 
  
  
   * @author ChengJianSheng 
  
  
   * @data 2020/12/1 
  
  
   */ 
  
  
  @Slf4j 
  
  
  @Service 
  
  
  public class DingTalkAlarmService { 
  
  
   
  
  
      @Value("${dingtalk.webhook}") 
  
  
      private String webhook; 
  
  
      @Value("${dingtalk.secret}") 
  
  
      private String secret; 
  
  
   
  
  
      public void sendMessage(String content) { 
  
  
          try { 
  
  
              Long timestamp = System.currentTimeMillis(); 
  
  
              String stringToSign = timestamp + "\n" + secret; 
  
  
              Mac mac = Mac.getInstance("HmacSHA256"); 
  
  
              mac.init(new SecretKeySpec(secret.getBytes("UTF-8"), "HmacSHA256")); 
  
  
              byte[] signData = mac.doFinal(stringToSign.getBytes("UTF-8")); 
  
  
              String sign = URLEncoder.encode(new String(Base64.encodeBase64(signData)),"UTF-8"); 
  
  
   
  
  
              String serverUrl = webhook + "×tamp=" + timestamp + "&sign=" + sign; 
  
  
              DingTalkClient client = new DefaultDingTalkClient(serverUrl); 
  
  
              OapiRobotSendRequest request = new OapiRobotSendRequest(); 
  
  
              request.setMsgtype("text"); 
  
  
              OapiRobotSendRequest.Text text = new OapiRobotSendRequest.Text(); 
  
  
              text.setContent(content); 
  
  
              request.setText(text); 
  
  
   
  
  
              client.execute(request); 
  
  
          } catch (ApiException e) { 
  
  
              e.printStackTrace(); 
  
  
              log.error(e.getMessage(), e); 
  
  
          } catch (NoSuchAlgorithmException e) { 
  
  
              e.printStackTrace(); 
  
  
              log.error(e.getMessage(), e); 
  
  
          } catch (UnsupportedEncodingException e) { 
  
  
              e.printStackTrace(); 
  
  
              log.error(e.getMessage(), e); 
  
  
          } catch (InvalidKeyException e) { 
  
  
              e.printStackTrace(); 
  
  
              log.error(e.getMessage(), e); 
  
  
          } 
  
  
      } 
  
  
  }

AlarmController.java：

 
 
 
  
  
  package com.wt.monitor.skywalking.alarm.controller; 
  
  
   
  
  
  import com.alibaba.fastjson.JSON; 
  
  
  import com.wt.monitor.skywalking.alarm.domain.AlarmMessageDTO; 
  
  
  import com.wt.monitor.skywalking.alarm.service.DingTalkAlarmService; 
  
  
  import lombok.extern.slf4j.Slf4j; 
  
  
  import org.springframework.beans.factory.annotation.Autowired; 
  
  
  import org.springframework.web.bind.annotation.PostMapping; 
  
  
  import org.springframework.web.bind.annotation.RequestBody; 
  
  
  import org.springframework.web.bind.annotation.RequestMapping; 
  
  
  import org.springframework.web.bind.annotation.RestController; 
  
  
   
  
  
  import java.text.MessageFormat; 
  
  
  import java.util.List; 
  
  
   
  
  
  /** 
  
  
   * @author ChengJianSheng 
  
  
   * @date 2020/12/1 
  
  
   */ 
  
  
  @Slf4j 
  
  
  @RestController 
  
  
  @RequestMapping("/skywalking") 
  
  
  public class AlarmController { 
  
  
   
  
  
      @Autowired 
  
  
      private DingTalkAlarmService dingTalkAlarmService; 
  
  
   
  
  
      @PostMapping("/alarm") 
  
  
      public void alarm(@RequestBody List alarmMessageDTOList) { 
  
  
         log.info("收到告警信息: {}", JSON.toJSONString(alarmMessageDTOList)); 
  
  
         if (null != alarmMessageDTOList) { 
  
  
             alarmMessageDTOList.forEach(e->dingTalkAlarmService.sendMessage(MessageFormat.format("-----來自SkyWalking的告警-----\n【名稱】: {0}\n【消息】: {1}\n", e.getName(), e.getAlarmMessage()))); 
  
  
         } 
  
  
      } 
  
  
  }

參考文檔：

 
 
 
  
  
  https://skywalking.apache.org/ 
  
  
  https://skywalking.apache.org/zh/\ https://github.com/apache/skywalking/tree/v8.2.0/docs 
  
  
  https://archive.apache.org/dist/ 
  
  
  https://www.elastic.co/guide/en/elasticsearch/reference/master/index.html  
  
  
  https://www.elastic.co/guide/en/elasticsearch/reference/7.10/modules-discovery-bootstrap-cluster.html 
  
  
  https://www.elastic.co/guide/en/elasticsearch/reference/7.10/modules-discovery-hosts-providers.html

作者：廢物大師兄

編輯：陶家龍

出處：https://urlify.cn/Zfy2ia

分享題目：自從上了SkyWalking，睡覺真香！??！
網(wǎng)頁URL：http://www.fisionsoft.com.cn/article/djjceep.html

新聞中心

概念與架構(gòu)

下載與安裝

啟動服務

告警

其他資訊