投稿
  1. 极客之音首页
  2. 技术随笔

2022最新的SpringCloud(H版&Alibaba)技术（5-7注册中心初级部分，【Eureka、Zookeeper和Consul】）

小半 • • 技术随笔 • 阅读 1078

导读：本篇文章讲解 2022最新的SpringCloud(H版&Alibaba)技术（5-7注册中心初级部分，【Eureka、Zookeeper和Consul】），希望对大家有帮助，欢迎收藏，转发！站点地址：www.bmabk.com

文章目录

Eureka服务注册于发现

1.Eureka基础知识

服务治理

== 什么是服务助理==

SprigCloud封装了Netflix公司的Eureka模块来实现服务治理，在传统的rpc框架中，服务于服务之间的依赖关系，管理关系较复杂，所以需要服务治理，管理服务与服务之间的依赖关系，可以实现服务调用，负载均衡，容错等；实现服务注册与发现。

服务注册

在这里插入图片描述

Eureka两组件

  • Eureka Server & Eureka Client
    在这里插入图片描述

2.单机Eureka构建步骤

Idea生成eurekaServer端服务注册中心

1.新建Module

cloud-eureka-server7001

2.改pom

在pom文件中添加以下：

    <dependencies>
        <!--eureka-server-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
        <dependency>
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!--boot web actuator-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!--一般通用配置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
        </dependency>
    </dependencies>

</project>

3.写yml文件

在resource目录下新建application.yml

server:
  port: 7001

eureka:
  instance:
    hostname: localhost  #eureka服务端的实例名称
  client:
    #false表示不向注册中心注册自己（想注册也可以，不过没必要）
    register-with-eureka: false
    #false表示自己端就是注册中心，职责就是维护服务实例，并不需要去检索服务
    fetch-registry: false
    service-url:
      #设置与eurekaServer交互的地址查询服务和注册服务都需要依赖这个地址
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

4.主启动类

在java包下新建com.atguigu.springcloud.EurekaMain7001

@EnableEurekaServer //表示此项目是eureka的服务注册中心
@SpringBootApplication
public class EurekaMain7001 {
    public static void main(String[] args) {
        SpringApplication.run(EurekaMain7001.class, args);
    }
}
  • 服务注册这里不需要业务类，所以这步skip

5.测试

启动项目，在浏览器输入http://localhost:7001/
在这里插入图片描述
–此时我们将EurekaClient8001注册进EurekaServer成为服务提供者provider

== 1.引入clientpom依赖==

 <!-- eureka-client -->
 <dependency>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
 </dependency>
  1. 在Yml文件里面添加
eureka:
  client:
    #true表示向注册中心注册自己，默认为true
    register-with-eureka: true
    #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:7001/eureka

3.主启动类上

@EnableEurekaClient //表示此项目是eureka的服务注册中心
@SpringBootApplication
public class EurekaMain8001 {
    public static void main(String[] args) {
        SpringApplication.run(EurekaMain8001.class, args);
    }
}

4.启动项目，然后刷新页面，此时客户端就已经注册进去了
在这里插入图片描述
在这里插入图片描述

3.Eureka集群构建步骤

原理说明

在这里插入图片描述

问题：微服务RPC远程服务调用最核心的是什么
高可用，试想你的注册中心只有一个only one， 它出故障了那就呵呵(￣▽￣)”了，会导致整个为服务环境不可用，所以　　解决办法：搭建Eureka注册中心集群 ，实现负载均衡+故障容错

Eureka集群：相互注册，相互守望
在这里插入图片描述

构建eurekaServer集群环境

1.参照cloud-eureka-server7001新建cloud-eureka-server7002和cloud-eureka-server7003
2.Windows系统的兄弟就跟着老师修改hosts文件
在最后一行加入：

127.0.0.1       eureka7001.com
127.0.0.1       eureka7002.com
127.0.0.1		eureka7003.com
  • 这里host需要开启管理员进行修改，如果权限不够的话，可以点击权限修改，开启写功能就行
    3.修改7001的Yml文件，由于是集群了，所以defalutZone变化了
eureka:
  instance:
    hostname: eureka7001.com  #eureka服务端的实例名称
  client:
    register-with-eureka: false
    fetch-registry: false
    service-url:
#      单机
#      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
      #集群版  相互注册，相互守望
      defaultZone: http://eureka7002.com:7002/eureka/, http://eureka7003.com:7003/eureka/ 
      
#    defaultZone是固定写法，如果想自定义，需要按以下写法才行：
#    region: eureka-server
#    availability-zones:
#      eureka-server: server1,server2
#    service-url:
#      server1: http://eureka7002.com:7002/eureka/
#      server2: http://eureka7003.com:7003/eureka/
  1. 修改7002.yml
eureka:
  instance:
    hostname: eureka7002.com  #eureka服务端的实例名称
  client:
    register-with-eureka: false
    fetch-registry: false
    service-url:
      #集群版  相互注册，相互守望
      defaultZone: http://eureka7001.com:7001/eureka/, http://eureka7003.com:7003/eureka/ #相互注册，相互守望

5.修改7003.yml

eureka:
  instance:
    hostname: eureka7003.com  #eureka服务端的实例名称
  client:
    register-with-eureka: false
    fetch-registry: false
    service-url:
      #集群版  相互注册，相互守望
      defaultZone: http://eureka7001.com:7001/eureka/, http://eureka7002.com:7002/eureka/ #相互注册，相互守望

6.启动这三个项目
在这里插入图片描述
在这里插入图片描述

将支付服务的8001和订单服务的80微服务注册进集群配置中

  • 只需要改下yml中eureka地址
      #集群版
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka,http://eureka7003.com:7003/eureka

在这里插入图片描述

构建支付provider集群环境

1.按照8001新建8002（只多建了一个提供者，建多了怕电脑受不了）。（除了要yml文件中需要改端口号和主配置类，其他直接复制8001的，yml文件中的应用名不需要改，因为是集群，所以应用名需要一致）
2.分别在业务类controller中加入以下内容
在这里插入图片描述
3.修改消费者的Orderontroller

public static final String PAYMENT_URL = "http://CLOUD-PAYMENT-SERVICE";

在这里插入图片描述

4.然后在消费者的ApplicationContextConfig里的restTemplate方法上加上@LoadBalanced，开启负载均衡功能。
5.启动eurekaServer集群，启动提供者集群，启动消费者。
如果启动提供者后出现，这个错误：Public Key Retrieval is not allowed
请在yml文件中的datasource.datasource.url后加上&allowPublicKeyRetrieval=true即可解决。

在这里插入图片描述

  • 在浏览器中输入http://localhost/consumer/payment/get/1，多次刷新可以看到，提供服务的应用在不同的切换，实现负载均衡的效果。
    在这里插入图片描述

actuator服务信息完善

  • 修改三个微服务的yml文件：
#######8001#######
# client:	
#	 ...	instance要和client对齐
  instance:
    instance-id: payment8001
    prefer-ip-address: true   #访问路径可以显示ip地址

#######8002#######
  instance:
    instance-id: payment8002   #修改显示的主机名
    prefer-ip-address: true   #访问路径可以显示ip地址
    
#######80#######
  instance:
    instance-id: consumer80   #修改显示的主机名
    prefer-ip-address: true   #访问路径可以显示ip地址
  • 修改前
    在这里插入图片描述
  • 修改后
    在这里插入图片描述

服务发现DisCovery

对于注册进eureka里面的微服务，可以通过服务发现来获得该服务的信息

修改提供者集群的controller

1.在主配置类上加上@EnableDiscoveryClient注解，启用发现客户端
在这里插入图片描述
2.在两个提供者中的controller类中加入


    @Resource
    private DiscoveryClient discoveryClient;	//springframework的DiscoveryClient（不要导错包了）
    

    @GetMapping("/payment/discovery")
    public Object discovery(){
        //获取服务列表的信息
        List<String> services = discoveryClient.getServices();
        for (String element : services) {
            log.info("*******element：" + element);
        }

        //获取CLOUD-PAYMENT-SERVICE服务的所有具体实例
        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
        for (ServiceInstance instance : instances) {
            //getServiceId服务器id getHost主机名称 getPort端口号  getUri地址
            log.info(instance.getServiceId() + "\t" + instance.getHost() + "\t" + instance.getPort() + "\t" + instance.getUri());
        }

        return this.discoveryClient;
    }

}

测试

对8001进行测试
，在浏览器输入：http://localhost:8001/payment/discovery
在这里插入图片描述

Eureka自我保护

概述

在这里插入图片描述

  • 导致原因
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述

禁止自我保护

先把cloud-eureka-server7001和cloud-provider-payment8001都切回单机版测试禁止自我保护。

  • 在cloud-eureka-server7001的yml文件中：
#  client
#  	...		server与client对齐
  server:
    #关闭自我保护，默认为true
    enable-self-preservation: false
    #心跳的间隔时间，单位毫秒
    eviction-interval-timer-in-ms: 2000

cloud-provider-payment8001的yml文件：

    #Eureka客户端向服务端发送心跳的时间间隔，单位秒（默认30秒）
    lease-renewal-interval-in-seconds: 1
    #Eureka服务端在收到最后一次心跳后等待的时间上限，单位秒（默认90秒），超时剔除服务
    lease-expiration-duration-in-seconds: 2

启动服务注册中心和提供者：
在这里插入图片描述
模拟宕机或网诺延迟等，提供者被提出

在这里插入图片描述

2.consul服务注册和发现

Consul官网：https://www.consul.io/
Consul中文文档：https://www.springcloud.cc/spring-cloud-consul.html

简介：

Consul是一种服务网格解决方案，提供具有服务发现，配置和分段功能的全功能控制平面。这些功能中的每一个都可以根据需要单独使用，也可以一起使用以构建完整的服务网格。Consul需要一个数据平面，并支持代理和本机集成模型。Consul附带了一个简单的内置代理，因此一切都可以直接使用，还支持Envoy等第三方代理集成。

主要特点

  • 服务发现：Consul的客户端可以注册服务，例如 api或mysql，其他客户端可以使用Consul来发现给定服务的提供者。使用DNS或HTTP，应用程序可以轻松找到它们依赖的服务
  • 健康检测：领事客户端可以提供任意数量的运行状况检查，这些检查可以与给定服务（“ Web服务器是否返回200 OK”）或本地节点（“内存利用率低于90％”）相关。操作员可以使用此信息来监视群集的运行状况，服务发现组件可以使用此信息将流量从不正常的主机发送出去。
  • KV存储：应用程序可以将Consul的分层键/值存储用于多种目的，包括动态配置，功能标记，协调，领导者选举等。简单的HTTP API使其易于使用.
  • 安全的服务通信：领事可以为服务生成并分发TLS证书，以建立相互TLS连接。 意图 可用于定义允许哪些服务进行通信。可以使用可以实时更改的意图轻松管理服务分段，而不必使用复杂的网络拓扑和静态防火墙规则。
  • 多数据中心：Consul开箱即用地支持多个数据中心。这意味着Consul的用户不必担心会构建其他抽象层以扩展到多个区域。

下载安装Consul

服务提供者

  1. 新建服务提供者cloud-provider-consul-payment8006
  2. pom
 <dependencies>
        <!--SpringCloud consul-server -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>
        <!-- SpringBoot整合Web组件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!--日常通用jar包配置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>

3.改yml

server:
  port: 8006


spring:
  application:
    name: consul-provider-payment
  cloud:
    consul:
      host: 192.168.117.128  #用linux的ip地址（consul在本机就填localhost）
      port: 8500
      discovery:
        service-name: ${spring.application.name}

4.主启动类和之前一样
5.controller

@RestController
@Slf4j
public class PaymentController {

    @Value("${server.port}")        //获取端口号
    private String serverPort;

    @RequestMapping("/payment/consul")
    public String paymentConsul(){
        return "springcloud with consul：" + serverPort + "\t" + UUID.randomUUID().toString();
    }
}

6.启动项目
在这里插入图片描述

服务消费者

1.新建模块Module;cloud-consumer-consul-order80
2.pom

   <dependencies>
        <!--SpringCloud consul-server -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>
        <!-- SpringBoot整合Web组件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!--日常通用jar包配置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>

.4.主启动类和之前一样
5.Config


@Configuration
public class ApplicationContextConfig {

    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

6.业务类Controller

@RestController
@Slf4j
public class OrderConsulController {

    public static final String INVOKE_URL = "http://consul-provider-payment";

    @Resource
    private RestTemplate restTemplate;

    @RequestMapping("/consumer/payment/consul")
    public String paymentInfo(){
        String result = restTemplate.getForObject(INVOKE_URL + "/payment/consul", String.class);
        return result;
    }
}

7.启动项目
在这里插入图片描述

zookeeper&Consul&Eureka三种关系图

在这里插入图片描述
关于CAP

CAP：（只能二选一）
A：可用性
C：一致性
P：分区容错性（微服务架构必须保证有P）

在这里插入图片描述
在这里插入图片描述
下一篇笔记：更新中…
学习视频(P15-P35)：https://www.bilibili.com/video/BV18E411x7eT?p=15

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。

文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/102026.html

赞 (0)
小半的头像小半
0 0

相关推荐

极客之音——专业性很强的中文编程技术网站，欢迎收藏到浏览器，订阅我们！