Spring Cloud 微服务架构：网关 Zuul、链路追踪 Sleuth 与 Admin 健康检查

测试访问

网关会将服务名转换成具体服务的 ip 和端口，实际进行访问

http://localhost/consumer/alive

负载均衡

启动两个 Consumer

轮询访问上面地址，会看到返回结果中，端口一直轮询在变。说明负载均衡生效了，默认是轮询

consumer.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule

路由端点

调试的时候，看网关请求的地址，以及 映射是否正确。网关请求有误时，可以通过此处排查错误。

配置

management.endpoints.web.exposure.include=*
management.endpoint.health.show-details=always
management.endpoint.health.enabled=true
management.endpoint.routes.enabled=true

配置指定微服务的访问路径

1. 通过服务名配置（虚拟主机名）

zuul.routes.consumer=/xxoo/**

配置前先访问，然后做对比。

2. 自定义映射

zuul.routes.xx.path=/xx/**
zuul.routes.xx.url=http://dyll.com

1. 自定义下的负载均衡

zuul.routes.xx.path=/xx/**
zuul.routes.xx.service-id=cuid
cuid.ribbon.listOfServers=localhost:82,localhost:83
ribbon.eureka.enabled=false

忽略微服务

配置

zuul.ignored-services=user-provider

前缀

zuul.prefix=/api/v1

带上前缀请求

zuul.strip-prefix=false

高可用

Nginx

分布式计算八大误区

网络可靠。

延迟为零。

带宽无限。

网络绝对安全。

网络拓扑不会改变。

必须有一名管理员。

传输成本为零。

网络同质化。（操作系统，协议）

链路追踪

链路追踪的必要性

如果能跟踪每个请求，中间请求经过哪些微服务，请求耗时，网络延迟，业务逻辑耗时等。我们就能更好地分析系统瓶颈、解决系统问题。因此链路跟踪很重要。

我们自己思考解决方案：在调用前后加时间戳。捕获异常。

链路追踪目的：解决错综复杂的服务调用中链路的查看。排查慢服务。

市面上链路追踪产品，大部分基于 google 的 Dapper 论文。

zipkin,twitter 开源的。是严格按照谷歌的 Dapper 论文来的。 pinpoint 韩国的 Naver 公司的。 Cat 美团点评的 EagleEye 淘宝的

链路追踪要考虑的几个问题

1. 探针的性能消耗。尽量不影响 服务本尊。
2. 易用。开发可以很快接入，别浪费太多精力。
3. 数据分析。要实时分析。维度足够。

Sleuth 简介

Sleuth 是 Spring cloud 的分布式跟踪解决方案。

1. span(跨度)，基本工作单元。一次链路调用，创建一个 span，span 用一个 64 位 id 唯一标识。包括：id，描述，时间戳事件，spanId,span 父 id。span 被启动和停止时，记录了时间信息，初始化 span 叫：root span，它的 span id 和 trace id 相等。
2. trace(跟踪)，一组共享'root span'的 span 组成的树状结构 称为 trace，trace 也有一个 64 位 ID，trace 中所有 span 共享一个 trace id。类似于一颗 span 树。
3. annotation（标签），annotation 用来记录事件的存在，其中，核心 annotation 用来定义请求的开始和结束。
   • CS(Client Send 客户端发起请求)。客户端发起请求描述了 span 开始。
   • SR(Server Received 服务端接到请求)。服务端获得请求并准备处理它。SR-CS=网络延迟。
   • SS（Server Send 服务器端处理完成，并将结果发送给客户端）。表示服务器完成请求处理，响应客户端时。SS-SR=服务器处理请求的时间。
   • CR（Client Received 客户端接受服务端信息）。span 结束的标识。客户端接收到服务器的响应。CR-CS=客户端发出请求到服务器响应的总时间。

其实数据结构是一颗树，从 root span 开始。

使用

Sleuth 单独

1. pom 每个需要监控的系统

<!-- 引入 sleuth 依赖 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-sleuth</artifactId>
</dependency>

测试点：

1. 启动 eureka 7900，service-sms 8002，api-driver 9002.
2. 访问一次。看日志结果。

[api-driver,1a409c98e7a3cdbf,1a409c98e7a3cdbf,true][服务名称，traceId（一条请求调用链中 唯一 ID），spanID（基本的工作单元，获取数据等），是否让 zipkin 收集和展示此信息] 看下游 [service-sms,1a409c98e7a3cdbf,b3d93470b5cf8434,true] traceId， 是一样的。 服务名必须得写。

Zipkin

上面拍错看日志，很原始。加入利器 zipkin。

zipkin 是 twitter 开源的分布式跟踪系统。

原理收集系统的时序数据，从而追踪微服务架构中系统延时等问题。还有一个友好的界面。

由 4 个部分组成：

Collector、Storage、Restful API、Web UI 组成

采集器，存储器，接口，UI。

原理：

sleuth 收集跟踪信息通过 http 请求发送给 zipkin server，zipkin 将跟踪信息存储，以及提供 RESTful API 接口，zipkin ui 通过调用 api 进行数据展示。

默认内存存储，可以用 mysql，ES 等存储。

操作步骤：

1. 每个需要监听的服务的 pom 中添加。

<!-- zipkin -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>

1. 每个需要监听的服务 yml 中

spring:
  #zipkin
  zipkin:
    base-url: http://localhost:9411/
  #采样比例 1
  sleuth:
    sampler:
      rate: 1

1. 启动 zipkin。

jar 包下载：curl -sSL https://zipkin.io/quickstart.sh | bash -s
java -jar zipkin.jar
# 或者 docker：
docker run -d -p 9411:9411 openzipkin/zipkin

SpringCloud Admin 健康检查

Admin 服务器端

引入依赖

<!-- Admin 服务 -->
<dependency>
    <groupId>de.codecentric</groupId>
    <artifactId>spring-boot-admin-starter-server</artifactId>
</dependency>
<!-- Admin 界面 -->
<dependency>
    <groupId>de.codecentric</groupId>
    <artifactId>spring-boot-admin-server-ui</artifactId>
</dependency>

启动类

package com.example.admin;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import de.codecentric.boot.admin.server.config.EnableAdminServer;

@SpringBootApplication
@EnableAdminServer
public class AdminApplication {
    public static void main(String[] args) {
        SpringApplication.run(AdminApplication.class, args);
    }
}

微服务端

<!-- Admin 服务 -->
<dependency>
    <groupId>de.codecentric</groupId>
    <artifactId>spring-boot-admin-starter-client</artifactId>
    <version>2.2.1</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

配置

management.endpoints.web.exposure.include=*
management.endpoint.health.show-details=always
spring.boot.admin.client.url=http://localhost:8080

邮件通知

yml

spring:
  application:
    name: cloud-admin
  security:
    user:
      name: root
      password: root
  # 邮件设置
  mail:
    host: smtp.qq.com
    username: 单纯 QQ 号
    password: xxxxxxx授权码
    properties:
      mail:
        smpt:
          auth: true
          starttls:
            enable: true
            required: true
  #收件邮箱
  spring.boot.admin.notify.mail.to: 2634982208@qq.com
  # 发件邮箱
  spring.boot.admin.notify.mail.from: [email protected]

pom

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

钉钉群通知

启动类

package com.example.admin;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import de.codecentric.boot.admin.server.config.EnableAdminServer;
import de.codecentric.boot.admin.server.domain.entities.InstanceRepository;

@SpringBootApplication
@EnableAdminServer
public class AdminApplication {
    public static void main(String[] args) {
        SpringApplication.run(AdminApplication.class, args);
    }

    @Bean
    public DingDingNotifier dingDingNotifier(InstanceRepository repository) {
        return new DingDingNotifier(repository);
    }
}

通知类

package com.example.admin;

import java.util.Map;
import com.alibaba.fastjson.JSONObject;
import de.codecentric.boot.admin.server.domain.entities.Instance;
import de.codecentric.boot.admin.server.domain.entities.InstanceRepository;
import de.codecentric.boot.admin.server.domain.events.InstanceEvent;
import de.codecentric.boot.admin.server.notify.AbstractStatusChangeNotifier;
import reactor.core.publisher.Mono;

public class DingDingNotifier extends AbstractStatusChangeNotifier {
    public DingDingNotifier(InstanceRepository repository) {
        super(repository);
    }

    @Override
    protected Mono<Void> doNotify(InstanceEvent event, Instance instance) {
        String serviceName = instance.getRegistration().getName();
        String serviceUrl = instance.getRegistration().getServiceUrl();
        String status = instance.getStatusInfo().getStatus();
        Map<String, Object> details = instance.getStatusInfo().getDetails();
        StringBuilder str = new StringBuilder();
        str.append("服务预警 : 【" + serviceName + "】");
        str.append("【服务地址】" + serviceUrl);
        str.append("【状态】" + status);
        str.append("【详情】" + JSONObject.toJSONString(details));
        return Mono.fromRunnable(() -> {
            DingDingMessageUtil.sendTextMessage(str.toString());
        });
    }
}

发送工具类

package com.example.admin;

import java.io.InputStream;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import com.alibaba.fastjson.JSONObject;

public class DingDingMessageUtil {
    public static String access_token = "your_access_token";

    public static void sendTextMessage(String msg) {
        try {
            Message message = new Message();
            message.setMsgtype("text");
            message.setText(new MessageInfo(msg));
            URL url = new URL("https://oapi.dingtalk.com/robot/send?access_token=" + access_token);
            // 建立 http 连接
            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
            conn.setDoOutput(true);
            conn.setDoInput(true);
            conn.setUseCaches(false);
            conn.setRequestMethod("POST");
            conn.setRequestProperty("Charset", "UTF-8");
            conn.setRequestProperty("Content-Type", "application/Json; charset=UTF-8");
            conn.connect();
            OutputStream out = conn.getOutputStream();
            String textMessage = JSONObject.toJSONString(message);
            byte[] data = textMessage.getBytes();
            out.write(data);
            out.flush();
            out.close();
            InputStream in = conn.getInputStream();
            byte[] data1 = new byte[in.available()];
            in.read(data1);
            System.out.println(new String(data1));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

消息类

package com.example.admin;

public class Message {
    private String msgtype;
    private MessageInfo text;

    public String getMsgtype() {
        return msgtype;
    }

    public void setMsgtype(String msgtype) {
        this.msgtype = msgtype;
    }

    public MessageInfo getText() {
        return text;
    }

    public void setText(MessageInfo text) {
        this.text = text;
    }
}

public class MessageInfo {
    private String content;

    public MessageInfo(String content) {
        this.content = content;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }
}

微信通知

服务号 模板消息