Spring Cloud 微服务实战（二）—— 服务治理

我就是我 2022-12-09 02:44 181阅读 0赞

# 服务治理 Eureka #

### 服务注册 ###

每个服务去构建中心中注册自己提供的服务，将主机，端口号、版本号通信协议等一些附加信息告知注册中心，注册中心按服务名分类组织服务清单。

一个例子：

服务中心还要以心跳机制不断检测清单中服务是否可用并剔除不可用服务

### 服务发现 ###

服务间调用不再指定具体的实例地址，而是通过向服务名发起请求调用实现。

例如服务C想要调用服务A，就向注册中心询问，得到服务A下面的两个地址，然后通过某种轮询策略（客户端负载均衡），取出一个位置来进行服务调用。

### Netflix Eureka ###

Eureka分为服务端和客户端

服务端就是注册中心，依托于强一致性提供良好的服务实例可用性，如果按集群部署，允许在分片故障期间继续提供服务的发现和注册，故障恢复后，集群中其他分片会把它们的状态同步回来。**在任意给定时间点每个实例关于所有服务的状态是有细微差别的**。

客户端主要处理服务的注册与发现，客户端服务通过注解和参数配置的方式，嵌入在客户端应用程序的代码中。

*  可以向注册中心注册自己的服务，并周期性地发送心跳更新服务租约
 *  可以从服务端查询当前注册的服务信息并缓存到本地周期性地刷新服务状态

### 搭建服务注册中心 ###

新建项目 eureka-server，配置文件如下

<?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.3.3.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.lzy.springcloud</groupId>
        <artifactId>eureka-server</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>eureka-server</name>
        <description>Demo project for Spring Boot Cloud Eureka</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
                <version>2.2.5.RELEASE</version>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

由于我们的模块很多，所以我们又抽象了一层，来管理子项目的公共的依赖。为了项目的正确运行，必须让所有的子项目使用依赖项的统一版本，必须确保应用的各个项目的依赖项和版本一致，才能保证测试的和发布的是相同的结果。
    
    在我们项目顶层的POM文件中，我们会看到dependencyManagement元素。通过它元素来管理jar包的版本，让子项目中引用一个依赖而不用显示的列出版本号。Maven会沿着父子层次向上走，直到找到一个拥有dependencyManagement元素的项目，然后它就会使用在这个dependencyManagement元素中指定的版本
    
    一般使用了<parent>标签的，就是要向父项目pom文件中拿去依赖的意思，如果有单独的版本号要求，再添加即可

**tips：解决maven爆红问题**

*  有时候会因为编译后会自动使用缓存，删除项目中的target文件，让依赖重新导入即可
 *  有时候即使依赖没问题，maven也爆红，这时候把依赖注释掉重新导入，然后取消注释再导入

只需要在Springboot应用中使用 `@EnableEurekaServer` 就可以开启注册中心功能

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

默认设置下，该服务注册中心也会将自己作为客户端来尝试注册自己，应该在配置文件中禁用客户端注册行为，在配置文件中作如下配置

server.port= 1111
    
    eureka.instance.hostname=localhost
    #不需要注册自己
    eureka.client.register-with-eureka=false    
    #不需要检索服务
    eureka.client.fetch-registry=false
    eureka.client.serviceUrl.defaultZone= http://${ eureka.instance.hostname}:${ server.port}/eureka/
    #关闭自我保护机制
    eureka.server.enableSelfPreservation=false

启动项目，访问 http://localhost:1111/ ，可以看到eureka注册中心界面

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkyNTI3Nw_size_16_color_FFFFFF_t_70_pic_center]

### 注册服务提供者 ###

使用上一篇中的快速入门工程 hello world来改造，让其向服务注册发现中心注册自己，首先向pom.xml添加如下依赖

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
                <version>2.2.5.RELEASE</version>
            </dependency>

改造/hello请求处理接口，注入DiscoveryClient对象，以及日志打印组件

@RestController
    public class HelloController { 
    
        private final Logger logger = Logger.getLogger(String.valueOf(getClass()));
    
        @Autowired
        private DiscoveryClient client;
    
        @RequestMapping(value = "/hello", method = RequestMethod.GET)
        public String index(){ 
            String instanceInfo = client.description();
            logger.info("/hello host :" +instanceInfo);
            return "Hello World!";
        }
    }

在主类中通过加上@EnableDiscoveryClient注解，激活Eureka的DiscoveryClient 实现（自动化配置，创建DiscoveryClient接口针对Eureka客户端的EurekaDiscoveryClient实例），才能实现对服务信息的输出

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

最后，在该服务的配置文件中，来配置一些属性，命名和指定服务注册中心地址，添加配置如下

spring:
      application:
        name: hello-service
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:1111/eureka

启动服务注册中心和改造后的服务，在hello-service服务控制台打印出了该服务的注册信息如下，注册成功

[nfoReplicator-0] com.netflix.discovery.DiscoveryClient    :DiscoveryClient_HELLO-SERVICE/172.19.173.181:hello-service:8082: registering service...
    [nfoReplicator-0] com.netflix.discovery.DiscoveryClient    : DiscoveryClient_HELLO-SERVICE/172.19.173.181:hello-service:8082 - registration status: 204

服务注册中心控制台出现输出如下，注册成功

c.n.e.registry.AbstractInstanceRegistry  : Registered instance HELLO-SERVICE/172.19.173.181:hello-service:8082 with status UP (replication=false)

访问注册中心面板，发现已经有一个服务注册上去了

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkyNTI3Nw_size_16_color_FFFFFF_t_70_pic_center 1]

访问该服务时，也会在该服务的控制台打印出相关输出

[nio-8082-exec-1] c.l.springcloudtest.web.HelloController  : /hello host :Composite Discovery Client

### 高可用注册中心 ###

微服务十分关注高可用，作为微服务之一的注册中心也不例外。之前设置的不让注册中心注册自己，现在需要让注册中心把自己作为服务向其他服务注册中心注册自己，这样就可以形成一组互相注册的服务注册中心，实现服务清单的互相同步，达到高可用的目的。

在前面的示例项目基础上，进行修改，构建一个双节点的服务注册中心集群

*  创建`application-peer1.properties`，作为peer1的服务中心配置，并将serviceUrl指向peer2：

spring.application.name= eureka-server
    server.port=1111
    
    eureka.instance.hostname=peer1
    eureka.client.serviceUrl.defaultZone=http://peer2:1112/eureka/

*  创建`application-peer2.properties`，作为peer2的服务中心配置，并将serviceUrl指向peer1：

spring.application.name= eureka-server
    server.port=1112
    
    eureka.instance.hostname=peer2
    eureka.client.serviceUrl.defaultZone=http://peer1:1111/eureka/

*  在本地的 /etc/hosts 文件中添加对 peer1 和peer2 的映射，让host形式的serviceUrl能被访问到（也可以不设置，但要用ip地址形式）

127.0.0.1 peer1
    127.0.0.1 peer2

*  通过spring.profiles.active参数来启动peer1和peer2，如果没有此jar包，先mvn package打包

java -jar eureka-server-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer1
     java -jar eureka-server-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer2

此时peer1的注册中心replicas已经有peer2节点的eureka-server，访问localhost:1111 可以看到，同样peer2也一样

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkyNTI3Nw_size_16_color_FFFFFF_t_70_pic_center 2]

如果 peer2 下线，会看到该分片不可用的信息

*  如果服务提供方想要注册到集群式的服务注册中心，需要修改一下配置中的`eureka.client.serviceUrl.defaultZone`属性，修改如下：
 *      eureka:
          client:
            serviceUrl:
              defaultZone: http://peer1:1111/eureka/, http://peer2:1112/eureka/

启动该服务发现其已经同时注册到了peer1和peer2上，如果断开peer1，在peer2上的其他服务依然能访问到hello-service，从而实现了注册服务中心的高可用

**如果不想使用主机名定义注册中心地址，也可以使用IP地址，需要在配置文件中增加配置参数`eureka.instance.prefer-ip-address=true`**

**这里本机在做服务发现消费的时候踩了个坑，需要关闭代理才能正常用 hosts中的配置，否则会出 500 错误**

### 服务发现与消费 ###

服务的发现任务由eureka客户端完成，服务的消费任务由Ribbon完成。Ribbon是一个基于http和tcp的客户端负载均衡器，可以通过在客户端中配置的`ribbonServerList`服务端列表去轮询访问来达到负载均衡的目的。

*  当Ribbon与eureka联用时，Ribbon的服务清单列表`ribbonServerList`会被`DiscoveryEnableNIWSServerList`重写，扩展成从Eureka注册中心获取的服务端列表
 *  同时用NIWSDiscoveryPing来取代IPing，将职责委托给eureka来确定服务端是否已经启动

通过简单示例来看在Eureka服务治理体系下如何实现服务发现与消费。

*  准备工作，启动之前实现的服务注册中心eureka-server，通过 java -jar 命令行的方式来启动两个不同端口的hello-service（这里我没有改jar包名称，依然是之前的名字 springcloudtest），用来验证负载均衡功能，具体如下：
 *      java -jar springcloudtest-0.0.1-SNAPSHOT.jar --server.port=8081
        java -jar springcloudtest-0.0.1-SNAPSHOT.jar --server.port=8082
 *  启动两个服务后，如下图所示，eureka注册中心看到两个用命令行启动的不同端口的服务

**发现另一本更新的《Spring Cloud与Docker微服务架构实战》，这本书先不读了，转读另一本去了。。。**

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkyNTI3Nw_size_16_color_FFFFFF_t_70_pic_center]: /images/20221123/8bb51c3a74594b24adfa60419aae304c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkyNTI3Nw_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221123/4721c8e1338f40078be4a52cd7e822b8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkyNTI3Nw_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221123/c386dfe425504141b7ab8c50171c6c87.png