作者:废物大师兄\
起源:www.cnblogs.com/cjsblog/p/14075486.html
SkyWalking 是一个利用性能监控零碎,特地为微服务、云原生和基于容器(Docker, Kubernetes, Mesos)体系结构而设计。
除了利用指标监控以外,它还能对分布式调用链路进行追踪。相似性能的组件还有:Zipkin、Pinpoint、CAT等。
上几张图,看看成果,而后再一步一步搭建并应用。
1、概念与架构
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容许用户理解服务和端点之间的拓扑关系,查看每个服务/服务实例/端点的度量,并设置警报规定。
1.1. 架构
SkyWalking逻辑上分为四个局部:Probes(探针), Platform backend(平台后端), Storage(存储), UI
这个构造就很清晰了,探针就是Agent负责采集数据并上报给服务端,服务端对数据进行解决和存储,UI负责展现
2、下载与装置
SkyWalking有两中版本,ES版本和非ES版。
如果咱们决定采纳ElasticSearch作为存储,那么就下载es版本。
https://skywalking.apache.org...\
https://archive.apache.org/di...
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/sky...
2.1. 装置ElasticSearch
https://www.elastic.co/guide/...
# 启动./bin/elasticsearch -d -p pid# 进行pkill -F pid
ElasticSearch7.x须要Java 11以上的版本,然而如果你设置了环境变量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 文件中追加以下内容:
* soft nofile 65536* hard nofile 65536* soft nproc 4096* hard nproc 4096
可通过以下四个命令查看批改后果:
ulimit -Hnulimit -Snulimit -Huulimit -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-monitornode.name: node-1network.host: 192.168.100.14http.port: 9200discovery.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-monitornode.name: node-2network.host: 192.168.100.15http.port: 9200discovery.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-monitornode.name: node-3network.host: 192.168.100.19http.port: 9200discovery.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 -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}
2.2. 装置Agent
https://github.com/apache/sky...
将agent目录拷贝至各服务所在的机器上
scp -r ./agent chengjs@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}
当然,也能够通过环境变量或零碎属性的形式来设置,例如:
export SW_AGENT_COLLECTOR_BACKEND_SERVICES=127.0.0.1:11800
最初,在服务启动的时候用命令行参数 -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
3、启动服务
批改 webapp/webapp.yml 文件,更改端口号及后端服务地址
server: port: 9000collector: 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.shbin/webappService.sh
查看logs目录下的日志文件,看是否启动胜利
浏览器拜访 http://127.0.0.1:9000
4、告警
编辑 alarm-settings.yml 设置告警规定和告诉
https://github.com/apache/sky...
重点说下告警告诉
为了应用钉钉机器人告诉,接下来,新建一个我的项目:
<?xml version="1.0" encoding="UTF-8"?><project xmlns="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.0 https://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/> <!-- lookup parent from repository --> </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>
Spring Boot 根底就不介绍了,举荐看下这个教程:
https://github.com/javastacks...
可选依赖(不倡议引入)
<dependency <groupId>org.apache.skywalking</groupId> <artifactId>server-core</artifactId> <version>8.2.0</version></dependency>
定义告警音讯实体类:
package com.wt.monitor.skywalking.alarm.domain;import lombok.Data;import java.io.Serializable;/** * @author ChengJianSheng * @date 2020/12/1 */@Datapublic 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;}
发送钉钉机器人音讯:
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@Servicepublic 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<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...
https://github.com/apache/sky...\
https://archive.apache.org/dist/\
https://www.elastic.co/guide/... \
https://www.elastic.co/guide/...\
https://www.elastic.co/guide/...
最初,感激浏览~
近期热文举荐:
1.Java 15 正式公布, 14 个新个性,刷新你的认知!!
2.终于靠开源我的项目弄到 IntelliJ IDEA 激活码了,真香!
3.我用 Java 8 写了一段逻辑,共事直呼看不懂,你试试看。。
4.吊打 Tomcat ,Undertow 性能很炸!!
5.《Java开发手册(嵩山版)》最新公布,速速下载!
感觉不错,别忘了顺手点赞+转发哦!