自从上了SkyWalking，睡觉真香！！！

图片来自 Pexels

除了应用指标监控以外，它还能对分布式调用链路进行追踪。类似功能的组件还有：Zipkin、Pinpoint、CAT 等。

上几张图，看看效果，然后再一步一步搭建并使用：

概念与架构

SkyWalking 是一个开源监控平台，用于从服务和云原生基础设施收集、分析、聚合和可视化数据。

SkyWalking 提供了一种简单的方法来维护分布式系统的清晰视图，甚至可以跨云查看。它是一种现代 APM，专门为云原生、基于容器的分布式系统设计。

SkyWalking 从三个维度对应用进行监视：

• 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 允许用户了解服务和端点之间的拓扑关系，查看每个服务/服务实例/端点的度量，并设置警报规则。

架构如下图：

SkyWalking 逻辑上分为四个部分：

• Probes(探针)
• Platform backend(平台后端)
• Storage(存储)
• UI

这个结构就很清晰了，探针就是 Agent 负责采集数据并上报给服务端，服务端对数据进行处理和存储，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

作为监控系统，首先排除 H2 和 MySQL，这里推荐 InfluxDB，它本身就是时序数据库，非常适合这种场景。但是 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-ppid
#停止
pkill-Fpid

ElasticSearch 7.x 需要 Java 11 以上的版本，但是如果你设置了环境变量 JAVA_HOME 的话，它会用你自己的 Java 版本。

通常，启动过程中会报以下三个错误：

[1]:maxfiledescriptors[4096]forelasticsearchprocessistoolow,increasetoatleast[65535]
[2]:maxvirtualmemoryareasvm.max_map_count[65530]istoolow,increasetoatleast[262144]
[3]:thedefaultdiscoverysettingsareunsuitableforproductionuse;atleastoneof[discovery.seed_hosts,discovery.seed_providers,cluster.initial_master_nodes]mustbeconfigured

解决方法：在 /etc/security/limits.conf 文件中追加以下内容。

*softnofile65536
*hardnofile65536
*softnproc4096
*hardnproc4096

可通过以下四个命令查看修改结果：

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

修改 /etc/sysctl.conf 文件，追加以下内容：

vm.max_map_count=262144

修改 ES 配置文件 elasticsearch.yml 取消注释，保留一个节点：

cluster.initial_master_nodes:["node-1"]

为了能够 ip:port 方式访问，还需修改网络配置：

network.host:0.0.0.0

修改完是这样的：

至此，ElasticSearch 算是启动成功了。一个节点还不够，这里用三个节点搭建一个集群。

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"]

同时，建议修改三个节点 config/jvm.options：

-Xms2g
-Xmx2g

依次启动三个节点：

pkill-Fpid
./bin/elasticsearch-d-ppid

接下来，修改 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./agentchengjs@192.168.100.12:~/

这里，我将它拷贝至各个服务目录下：

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

修改 agent/config/agent.config 配置文件，也可以通过命令行参数指定。主要是配置服务名称和后端服务地址：

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

当然，也可以通过环境变量或系统属性的方式来设置，例如：

exportSW_AGENT_COLLECTOR_BACKEND_SERVICES=127.0.0.1:11800

最后，在服务启动的时候用命令行参数 -javaagent 来指定探针：

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

例如：

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

启动服务

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

server:
port:9000

collector:
path:/graphql
ribbon:
ReadTimeout:10000
#Pointtoallbackend'srestHost:restPort,splitby,
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 设置告警规则和通知：

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

重点说下告警通知：

为了使用钉钉机器人通知，接下来，新建一个项目：

<?xmlversion="1.0"encoding="UTF-8"?>
<projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.4.0</version>
<relativePath/><!--lookupparentfromrepository-->
</parent>
<groupId>com.wt.monitor</groupId>
<artifactId>skywalking-alarm</artifactId>
<version>1.0.0-SNAPSHOT</version>
<name>skywalking-alarm</name>

<properties>
<java.version>1.8</java.version>
</properties>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
<groupId>com.aliyun</groupId>
<artifactId>alibaba-dingtalk-service-sdk</artifactId>
<version>1.0.1</version>
</dependency>

<dependency>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
<version>1.15</version>
</dependency>

<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.75</version>
</dependency>

<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>

</project>

可选依赖(不建议引入)：<!–/maven.apache.org/POM/4.0.0:dependency

<dependency
<groupId>org.apache.skywalking</groupId>
<artifactId>server-core</artifactId>
<version>8.2.0</version>
</dependency>

定义告警消息实体类：

packagecom.wt.monitor.skywalking.alarm.domain;

importlombok.Data;

importjava.io.Serializable;

/**
*@authorChengJianSheng
*@date2020/12/1
*/
@Data
publicclassAlarmMessageDTOimplementsSerializable{

privateintscopeId;

privateStringscope;

/**
*Targetscopeentityname
*/
privateStringname;

privateStringid0;

privateStringid1;

privateStringruleName;

/**
*Alarmtextmessage
*/
privateStringalarmMessage;

/**
*Alarmtimemeasuredinmilliseconds
*/
privatelongstartTime;

}

发送钉钉机器人消息：

packagecom.wt.monitor.skywalking.alarm.service;

importcom.dingtalk.api.DefaultDingTalkClient;
importcom.dingtalk.api.DingTalkClient;
importcom.dingtalk.api.request.OapiRobotSendRequest;
importcom.taobao.api.ApiException;
importlombok.extern.slf4j.Slf4j;
importorg.apache.commons.codec.binary.Base64;
importorg.springframework.beans.factory.annotation.Value;
importorg.springframework.stereotype.Service;

importjavax.crypto.Mac;
importjavax.crypto.spec.SecretKeySpec;
importjava.io.UnsupportedEncodingException;
importjava.net.URLEncoder;
importjava.security.InvalidKeyException;
importjava.security.NoSuchAlgorithmException;

/**
*https://ding-doc.dingtalk.com/doc#/serverapi2/qf2nxq
*@authorChengJianSheng
*@data2020/12/1
*/
@Slf4j
@Service
publicclassDingTalkAlarmService{

@Value("${dingtalk.webhook}")
privateStringwebhook;
@Value("${dingtalk.secret}")
privateStringsecret;

publicvoidsendMessage(Stringcontent){
try{
Longtimestamp=System.currentTimeMillis();
StringstringToSign=timestamp+"\n"+secret;
Macmac=Mac.getInstance("HmacSHA256");
mac.init(newSecretKeySpec(secret.getBytes("UTF-8"),"HmacSHA256"));
byte[]signData=mac.doFinal(stringToSign.getBytes("UTF-8"));
Stringsign=URLEncoder.encode(newString(Base64.encodeBase64(signData)),"UTF-8");

StringserverUrl=webhook+"&timestamp="+timestamp+"&sign="+sign;
DingTalkClientclient=newDefaultDingTalkClient(serverUrl);
OapiRobotSendRequestrequest=newOapiRobotSendRequest();
request.setMsgtype("text");
OapiRobotSendRequest.Texttext=newOapiRobotSendRequest.Text();
text.setContent(content);
request.setText(text);

client.execute(request);
}catch(ApiExceptione){
e.printStackTrace();
log.error(e.getMessage(),e);
}catch(NoSuchAlgorithmExceptione){
e.printStackTrace();
log.error(e.getMessage(),e);
}catch(UnsupportedEncodingExceptione){
e.printStackTrace();
log.error(e.getMessage(),e);
}catch(InvalidKeyExceptione){
e.printStackTrace();
log.error(e.getMessage(),e);
}
}
}

AlarmController.java：

packagecom.wt.monitor.skywalking.alarm.controller;

importcom.alibaba.fastjson.JSON;
importcom.wt.monitor.skywalking.alarm.domain.AlarmMessageDTO;
importcom.wt.monitor.skywalking.alarm.service.DingTalkAlarmService;
importlombok.extern.slf4j.Slf4j;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.web.bind.annotation.PostMapping;
importorg.springframework.web.bind.annotation.RequestBody;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.bind.annotation.RestController;

importjava.text.MessageFormat;
importjava.util.List;

/**
*@authorChengJianSheng
*@date2020/12/1
*/
@Slf4j
@RestController
@RequestMapping("/skywalking")
publicclassAlarmController{

@Autowired
privateDingTalkAlarmServicedingTalkAlarmService;

@PostMapping("/alarm")
publicvoidalarm(@RequestBodyList<AlarmMessageDTO>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

<!–//maven.apache.org/POM/4.0.0:dependency