…Java之SpringCloud

Alibaba【一】【Nacos一篇文章精通系列】跳转Java之SpringCloud

Alibaba【二】【微服务调用组件Feign】跳转Java之SpringCloud

Alibaba【三】【微服务Nacos-config配置中心】跳转Java之SpringCloud

Alibaba【四】【微服务

Sentinel服务熔断】跳转Java之SpringCloud

Alibaba【五】【微服务

Sentinel整合openfeign进行降级】跳转Java之SpringCloud

Alibaba【六】【Alibaba微服务分布式事务组件—Seata】跳转Java之SpringCloud

Alibaba【七】【Spring

Cloud微服务网关Gateway组件】跳转Java之SpringCloud

Alibaba【八】【Spring

Cloud微服务Gateway整合sentinel限流】跳转Java之SpringCloud

Alibaba【九】【Spring

一、简介1、skywalking是什么2、链路追踪框架对比3、性能对比4、skywalking主要功能特性

二、Skywalking环境搭建部署1、下载skywalking2、搭建skywalking

OAP服务

三、skywalking跨多个微服务跟踪Windows环境在IDEA中使用skywalking四、skywalking设置集成gateway第三方内容五、Linux环境通过jar的方式接入六、skywalking持久化跟踪数据1、默认使用的H2数据库存储内存2、基于mysql持久化

七、自定义skywalking链路追踪【设置业务方法记录到skywalking】1、引入依赖2、Trace将方法加入追踪链路3、加入Tags或Tag

设置记录返回值和参数

八、skywalking性能剖析九、skywalking告警功能

一、简介

skywalking是分布式系统的应用程序性能监视工具专为微服务、云原生架构和基于容器(Docker、

K8s、

http://skywalking.apache.org/downloads/

Github:

https://github.com/apache/skywalking

文档:

https://skywalking.apache.org/docs/main/v8.4.0/readme/

中文文档:

io/document-cn-translation-of-skywalking/

2、链路追踪框架对比

Zipkin是Twitter开源的调用链分析工具目前基于springcloud

Pinpoint是韩国人开源的基于字节码注入的调用链分析以及应用监控分析工具。

特点是支持多种插件,

SkyWalking是本士开源的基于字节码注入的调用链分析,以及应用监控分析工具。

特点是支持多种插件,

CAT是大众点评开源的基于编码和配置的调用链分析应用监控分析日志采集监控报警等-系列的监控平台工具。

3、性能对比

每个线程发送30个请求设置思考时间为10ms。

使用的采样率为1,即100%

,这边与生产可能有差别。

pinpoint默认的采样率为20即50%,通过设置agent的配置文件改为100%。

zipkin默认也是1。

组合起来,

下面看下汇总表:

从上表可以看出在三种链路监控组件中skywalking的探针对吞吐量的影响最小zipkin的吞吐量居中。

pinpoint的探针对吞吐量的影响较为明显在500并发用户时测试服务的吞吐量从1385降低到774影响很大。

然后再看下CPU和memory的影响在内部服务器进行的压测对CPU和memory的影响都差不多在10%之内。

4、skywalking主要功能特性

agent的监控数据并存储在数据库中;接受skywalking

webapp的前端请求,从数据库查询数据,并返回数据给前端。

Skywalking

oapservice通常以集群的形式存在。

skywalking

webapp,前端界面用于展示数据。

用于存储监控数据的数据库比如mysql、elasticsearch等。

1、下载skywalking

下载http://skywalking.apache.org/downloads/

这里只能下载最新版本

我们在在这里下载旧版本https://archive.apache.org/dist/skywalking/

修改端口号

启动成功后会启动两个服务一个是skywalking-oap-server,

8868

skywalking-oap-server服务启动后会暴露11800和12800两个端口分别为收集监控数据的端口11800和接受前端请求的端口12800,修改端口可以修改config/applicaiton.yml

三、skywalking跨多个微服务跟踪Windows环境在IDEA中使用skywalking

skywalking-agent.jar

-javaagent:D:\ProgramTool\apache-skywalking-apm-es7-8.5.0\apache-skywalking-apm-bin-es7\agent\skywalking-agent.jar

在skywalking的controller的服务的IP以及端口

-DSW_AGENT_COLLECTOR_BACKEND_SERVICES127.0.0.1:11800DSW_AGENT_COLLECTOR_BACKEND_SERVICES可以指定远程地址但是-javaagent必须绑定你本机物理路径的skywalking-agent.jar

Skywalking跨多个微服务跟踪只需要每个微服务启动时添加javaagent参数即可。

测试:

http://localhost:8888/user/findOrderByUserld/1

id:

order-service服务名修改一下OrderController

配置项目启动参数

-javaagent:D:\ProgramTool\apache-skywalking-apm-es7-8.5.0\apache-skywalking-apm-bin-es7\agent\skywalking-agent.jar

-DSW_AGENT_COLLECTOR_BACKEND_SERVICES127.0.0.1:11800-javaagent:D:\ProgramTool\apache-skywalking-apm-es7-8.5.0\apache-skywalking-apm-bin-es7\agent\skywalking-agent.jar

-DSW_AGENT_COLLECTOR_BACKEND_SERVICES127.0.0.1:11800-javaagent:D:\ProgramTool\apache-skywalking-apm-es7-8.5.0\apache-skywalking-apm-bin-es7\agent\skywalking-agent.jar

-DSW_AGENT_COLLECTOR_BACKEND_SERVICES127.0.0.1:11800分别启动上述设置的内容

访问http://localhost:8088/order/add

修改OrderController

http://localhost:8088/order/add

集成gateway

在D:\ProgramTool\apache-skywalking-apm-es7-8.5.0\apache-skywalking-apm-bin-es7\agent\optional-plugins当中的有gateway的jar

需要进入到复制到D:\ProgramTool\apache-skywalking-apm-es7-8.5.0\apache-skywalking-apm-bin-es7\agent\plugins当中

重新启动运行Skywalking

http://localhost:8088/order/add

访问http://localhost:8868/topology

准备一个springboot程序,打成可执行jar包,写一个shelI脚本,在启动项目的Shel脚本上,通过-javaagent参数进行配置SkyWalking

Agent来跟踪微服务;

SW_AGENT_NAMEspringboot-skywalking-demo

#Agent名字,一般

SW_AGENT_COLLECTOR_BACKEND_SERVICES127.0.0.1:11800

export

JAVA_AGENT-javaagent:/usr/local/soft/apache-skywalking-apm-bin-es7/agent/skywalking-agent.jar

java

springboot-skywalking-demo-0.0.1-SNAPSHOT.jar

#jar启动等同于

-javaagent:/usr/local/soft/apache-skywalking-apm-bin-es7/agent/skywalking-agent.jar

-DSW_AGENT_COLLECTOR_BACKEND_SERVICES127.0.0.1:11800

-DSW_AGENT_NAME

springboot-skywalking-demo-0.0.1-SNAPSHOT.jar参数名对应agentconfig/agent.config配置文件中的属性。

org.apache.skywalking.apm.agent.core.conf.Config.java

The

agent.service_name${SW_AGENT_NAME:Your_ApplicationName

Backend

collector.backend_service${SW_AGENT_COLLECTOR_BACKEND_SERVICES:127.0.0.1:11800}我们也可以使用skywalking.配置文件中的配置名作为系统配置项来进行覆盖。

javaagent参数配置方式优先级更高

六、skywalking持久化跟踪数据

1修改config目录下的application.yml使用mysql作为持久化存储的仓库

2修改mysql连接配置

在mysql当中创建swtest即可Skywalking会自动创建对应的表结构

我们本次使用的是mysql8Skywalking默认没有对应的驱动需要设置对应的驱动

拷贝MySQL连接驱动到oap-libs文件夹下可以用mysql-connector-java-8.0.25.jar这个版本的数据库连接驱动

重新启动Skywalking

访问http://localhost:8088/order/add

七、自定义skywalking链路追踪【设置业务方法记录到skywalking】

1、引入依赖

如果我们希望对项目中的业务方法实现链路追踪方便我们排查问题可以使用如下的代码

引入依赖

SkyWalking工具类--dependencygroupIdorg.apache.skywalking/groupIdartifactIdapm-toolkit-trace/artifactIdversion8.5.0/version/dependency2、Trace将方法加入追踪链路

ListOrder

orderService.all();}重新启动alibaba-order-seata

访问http://localhost:8088/order/all

3、加入Tags或Tag

获取单个订单信息RequestMapping(/get/{id})public

Order

getById(id);}RequestMapping(/all)public

ListOrder

orderService.all();}TraceTags({Tag(key

param,value

orderService.get(id);}重新启动alibaba-order-seata

访问http://localhost:8088/order/all

重新运行并查看

访问http://localhost:8088/order/get/1

八、skywalking性能剖析

我们连续请求http://localhost:8088/order/all

再次修改一下延迟时间

我们连续请求http://localhost:8088/order/all

九、skywalking告警功能

SkyWalking告警功能是在6.x版本新增的,其核心由一组规则驱动,这些规则定义在config/alarm-settings.

义分为两部分:

1.告警规则:它们定义了应该如何触发度量警报应该考虑什么条件。

2.Webhook

SkyWalking的发行版都会默认提供config/alarmrsettings.

如下:

4.服务实例在过去2分钟内平均响应时间超过1s,并且实例名称与正则表达式匹配。

这些预定义的告警规则打开config/alarm-settings.

Rule

name:度量名称,取值为oal脚本中的度量名目前只支持1ong、

详见official

names:该规则作用于哪些实体名称,比如服务名,终端名(可选,

默认为全部)Exclude

names:该规则作不用于哪些实体名称比如服务名,终端名(可选,默认为空)Threshold:阈值P:

操作符,目前支持、

与代码中的事件回调类似只不过是Web层面的。

由于是Web层面的,所以当事件发生时,回调的不再是代码中的方法或函数,而是服务接口。

当该事件发生时SkyWalking就会

SkyWalking的告警消息会通过HTTP请求进行发送,请求方法为POST,

Content-Type

为application/json,其JSON数据实基于Listorg.

apache.

”SERVICE”,”name”:”serviceA”,”id0”:

12,”id1”:

rule””alarmMessage”:”alarmMessage

xxxx,”startTime”:

所有可用的Scope详见org.apache.skywalking.oap.server.core.source.DefaultScopeDefinename:目标Scope的实体名称id0:

Scope

告警规则名称alarmMessage:告警消息内容startTime:告警时间,格式为时间戳

邮件告警功能实践

短信等服务发送告警信息的SkyWalking只会在发生告警时将告警信息发送至配

但我们总不能人工盯着该接口的日志信息来得知服务是否发生了告警,因此我们需要在该接口里实现发送邮件或短信等功能从而达到个性化的告警通知。

接下来开始动手实践这里基于Spring

dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdversion1.18.18/versionscopecompile/scope/dependencySwAlarmDTO

package

service_resp_time_rule,alarmMessage:

alarmMessage

com.itbluebox.controller;import

import

lombok.RequiredArgsConstructor;

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

Slf4j

必须是post*/PostMapping(/receive)public

void

主题message.setSubject(告警邮件);String

content

邮件内容message.setText(content);sender.send(message);*/String

content

getContent(alarmList);log.info(告警邮件已发送...content);}private

String

).append(dto.getScopeId()).append(\nscope:

).append(dto.getScope()).append(\n目标

Scope

).append(dto.getName()).append(\nScope

ID:

).append(dto.getId0()).append(\nid1:

).append(dto.getId1()).append(\n告警规则名称:

).append(dto.getRuleName()).append(\n告警消息内容:

).append(dto.getAlarmMessage()).append(\n告警时间:

).append(dto.getStartTime()).append(\n标签:

).append(dto.getTags()).append(\n\n---------------\n\n);}return

sb.toString();}

访问http://localhost:8088/order/all

Java之SpringCloud

Alibaba【一】【Nacos一篇文章精通系列】跳转Java之SpringCloud

Alibaba【二】【微服务调用组件Feign】跳转Java之SpringCloud

Alibaba【三】【微服务Nacos-config配置中心】跳转Java之SpringCloud

Alibaba【四】【微服务

Sentinel服务熔断】跳转Java之SpringCloud

Alibaba【五】【微服务

Sentinel整合openfeign进行降级】跳转Java之SpringCloud

Alibaba【六】【Alibaba微服务分布式事务组件—Seata】跳转Java之SpringCloud

Alibaba【七】【Spring

Cloud微服务网关Gateway组件】跳转Java之SpringCloud

Alibaba【八】【Spring

Cloud微服务Gateway整合sentinel限流】跳转Java之SpringCloud

Alibaba【九】【Spring