SpringCloud-服务注册与发现

2023-11-19

服务注册与发现

前面我们没有服务注册中心,也可以服务间调用,为什么还要服务注册?

当服务很多时,单靠代码手动管理是很麻烦的,需要一个公共组件,统一管理多服务,包括服务是否正常运行,等

Eureka用于**服务注册,目前官网已经停止更新**

1、Eureka

服务治理

Spring Cloud封装了Netflix 公司开发的Eureka模块来实现服务治理

在传统的rpc远程调用框架中，管理每个服务与服务之间依赖关系比较复杂，管理比较复杂，所以需要使用服务治理，管理服务于服务之间依赖关系，可以实现

服务调用、负载均衡、容错等，实现服务发现与注册。

服务注册

Eureka采用了CS的设计架构，Eureka sever作为服务注册功能的服务器，它是服务注册中心。而系统中的其他做服务，使用 fureka的客户端连接到Eureka

Server并维持心跳连接。这样系统的维护人员就可以通过Eureka Server来监控系统中各个微服务是否正常运行。

在服务注册与发现中，有一个注册中心。当服务器启动的时候，会把当前自己服务器的信息，比如：服务地址通讯地址等以别名方式注册到注册中心上。另一方(消费者 | 服务提供者)，以该别名的方式去注册中心上获取到实际的服务通讯地址，然后再实现本地RPC调用

RPC远程调用框架核心设计思想：在于注册中心，因为使用注册中心管理每个服务与服务之间的一个依赖关系(服务治理概念)。在任何rpc远程框架中，都会有一个注册中心(存放服务地址相关信息(接口地址)
在这里插入图片描述

Eureka的两个组件：

Eureka Server

Eureka Server 提供服务注册服务

各个微服务节点通过配置启动后，会在EurekaServer中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以

在界面中直观看到。

Eureka Client

Eureka Client 通过注册中心进行访问

是一个Java客户端，用于简化Eureka Server的交互，客户端同时也具备一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后，将会向

Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，EurekaServer将会从服务注册表中把这个服务节点

移除（默认90秒)

单机版

EurekaServer端服务注册中心类似物业中心

EurekaClient端cloud-provider-payment8001将注册进EurekaServer 成为服务提供者provider

EurekaClient端cloud-consumer-order80将注册进EurekaServer 成为服务消费者consumer

1.创建cloud-eureka-server7001

2引入pom依赖

eureka最新的依赖变了

在这里插入图片描述

3.配置文件

server:
  port: 7001

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

4.主启动类

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

5.此时就可以启动当前项目了

浏览器输入：localhost:7001

在这里插入图片描述

6.其他服务注册到eureka

将payment模块加入eureka

1.在pom中添加依赖

<!--Eureka-client-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

2.主启动类上，加注解。表示当前是eureka客户端

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

3.修改yml

eureka:
  client:
    # 表示是否将自己注册进EurekaServer 默认为true
    register-with-eureka: true
    # 是否从EurekaServer 抓取已有的注册信息。默认为true。单节点无所谓，集群必须设置为true才能配合ribbon 使用负载均衡
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:7001/eureka

重启

在这里插入图片描述

成功注册

将order模块加入eureka

1.在pom中添加依赖

<!--Eureka-client-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

2.主启动类上，加注解。表示当前是eureka客户端

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

3.修改yml

spring:
  application:
    name: cloud-order-service
eureka:
  client:
    # 表示是否将自己注册进EurekaServer 默认为true
    register-with-eureka: true
    # 是否从EurekaServer 抓取已有的注册信息。默认为true。单节点无所谓，集群必须设置为true才能配合ribbon 使用负载均衡
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:7001/eureka

重启

在这里插入图片描述

集群

集群原理：

在这里插入图片描述

1,就是pay模块启动时,注册自己,并且自身信息也放入eureka
2.order模块,首先也注册自己,放入信息,当要调用pay时,先从eureka拿到pay的调用地址
3.通过HttpClient调用
并且还会缓存一份到本地,每30秒更新一次

微服务RPC远程服务调用最核心的是什么？

高可用：如果只有一个注册中心，出故障整个系统就瘫痪了。会导致整个微服务环境不可用。

解决办法：搭建Eureka注册中心集群，实现负载均衡+故障容错。

集群搭建原理：

互相注册

在这里插入图片描述

构建新erueka项目

cloud-eureka-server7002

1.pom文件

和7001一样即可

2.配置文件

在写配置文件之前，修改本机的hosts文件(C:\Windows\System32\drivers\etc)

# eureka
127.0.0.1 eureka7001.com
127.0.0.1 eureka7002.com
127.0.0.1 eureka7003.com

首先修改之前的7001的eureka项目,因为多个eureka需要互相注册

server:
  port: 7001
#集群版
eureka:
  instance:
    hostname: eureka7001.com    #eureka服务端的实例名字
  client:
    register-with-eureka: false    #表示不向注册中心注册自己
    fetch-registry: false   #表示自己就是注册中心，职责是维护服务实例，并不需要去检索服务
    service-url:
      #设置与eureka server交互的地址查询服务和注册服务都需要依赖这个地址
#      defaultZone: http://eureka7001.com:7001/eureka/
      defaultZone: http://eureka7002.com:7002/eureka/  #这个是集群版开启 互相注册

修改7002

server:
  port: 7002
#集群版
eureka:
  instance:
    hostname: eureka7002.com    #eureka服务端的实例名字
  client:
    register-with-eureka: false    #表示不向注册中心注册自己
    fetch-registry: false   #表示自己就是注册中心，职责是维护服务实例，并不需要去检索服务
    service-url:
      #设置与eureka server交互的地址查询服务和注册服务都需要依赖这个地址
#      defaultZone: http://eureka7002.com:7002/eureka/
      defaultZone: http://eureka7001.com:7001/eureka/  #这个是集群版开启 互相注册

3,主启动类:

复制7001的即可

4,然后启动7001,7002即可

在这里插入图片描述

将pay,order模块注册到eureka集群中:

1,只需要修改配置文件即可:

eureka:
  client:
    # 表示是否将自己注册进EurekaServer 默认为true
    register-with-eureka: true
    # 是否从EurekaServer 抓取已有的注册信息。默认为true。单节点无所谓，集群必须设置为true才能配合ribbon 使用负载均衡
    fetch-registry: true
    service-url:
      #      defaultZone: http://localhost:7001/eureka   # 单机版
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka    # 集群版

2,两个模块都修改上面的都一样即可

然后启动两个模块

要先启动7001,7002,然后是pay模块8001,然后是order(80)
在这里插入图片描述

将payment模块也配置为集群模式

1,创建新模块,8002

名称: cloud-provider-payment8002

2.pom文件

复制8001的

3,yml配置文件

复制8001的

端口修改成8002

服务名称不用改，用一样的

4.主启动类

复制8001的

修改为8002

5,mapper,service,controller都复制一份

为了区分，分别打印端口号：

@Slf4j
@RestController
@RequestMapping("/payment")
public class PaymentController {
    @Autowired
    private PaymentService paymentService;

    @Value("${server.port}")
    private String servicePort;

    @PostMapping("/create")
    public CommonResult<Payment> create(@RequestBody Payment payment){
        int result = paymentService.create(payment);
        log.info("****插入结果*****:"+result);
        if(result > 0){
            return new CommonResult(200,"插入数据库成功,serverPort: "+servicePort,result);
        }
        return new CommonResult(444,"插入数据库失败",result);
    }

    @GetMapping("/get/{id}")
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id){
        Payment payment = paymentService.getPaymentById(id);
        if(payment != null){
            return new CommonResult(200,"查询成功,serverPort: "+servicePort,payment);
        }
        return new CommonResult(444,"没有对应的记录，查询id"+id);
    }
}

然后就启动服务即可

在这里插入图片描述

此时访问order模块,发现并没有负载均衡到两个pay,模块中,而是只访问8001

在这里插入图片描述

虽然我们是使用RestTemplate访问的微服务,但是也可以负载均衡的

修改order80的访问地址

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

注意这样还不行,需要让RestTemplate开启负载均衡注解,还可以指定负载均衡算法,默认轮询

修改RestTemplate的配置添加@LoadBalanced

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

Ribben和Eureka 整合后Consumer可以直接调用服务而不用再关心地址和端口号，且改该服务还有负载能力了。

修改服务主机名和ip在eureka的web上显示

修改服务主机名

修改yml配置文件

添加instance.instance-id

eureka:
  client:
    # 表示是否将自己注册进EurekaServer 默认为true
    register-with-eureka: true
    # 是否从EurekaServer 抓取已有的注册信息。默认为true。单节点无所谓，集群必须设置为true才能配合ribbon 使用负载均衡
    fetch-registry: true
    service-url:
#      defaultZone: http://localhost:7001/eureka   # 单机版
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka    # 集群版
  instance:
    instance-id: payment8001

同样的修改8002的

在这里插入图片描述

添加ip显示

修改yml配置文件

添加instance.prefer-ip-address

eureka:
  client:
    # 表示是否将自己注册进EurekaServer 默认为true
    register-with-eureka: true
    # 是否从EurekaServer 抓取已有的注册信息。默认为true。单节点无所谓，集群必须设置为true才能配合ribbon 使用负载均衡
    fetch-registry: true
    service-url:
#      defaultZone: http://localhost:7001/eureka   # 单机版
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka    # 集群版
  instance:
    instance-id: payment8001
    prefer-ip-address: true       # 访问路径可以显示IP地址

同样的修改8002的

服务发现

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

以payment模块为例

1，引入DiscoveryClient

在controller里面

@Slf4j
@RestController
@RequestMapping("/payment")
public class PaymentController {
    @Autowired
    private PaymentService paymentService;

    @Value("${server.port}")
    private String servicePort;

    @Resource
    private DiscoveryClient discoveryClient;
    
        @GetMapping("/discovery")
    public Object discovery(){
        List<String> services = discoveryClient.getServices();
        for (String element : services) {
            log.info("*****element:  "+element);
        }

        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
        for (ServiceInstance instance : instances) {
            log.info("instance:"+instance.getInstanceId()+"\t"+instance.getHost()+"\t"+instance.getPort()+"\t"+instance.getUri());
        }
        return this.discoveryClient;
    }
}

2,在主启动类上添加一个注解

@EnableDiscoveryClient

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

然后重启8001。访问/payment/discovery

Eureka的自我保护机制

自我保护机制原理

保护模式主要用于一组客户端和Eureka Server之间存在网络分区场景下的保护。
一旦进入保护模式，Eureka Server将会尝试保护其服务注册表中的信息，不再删除服务注册表中的数据，也就是不会注销任何微服务。

如果在Eureka Server的首页看到以下这段提示，则说明Eureka进入了保护模式:[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-XZLJT1Qc-1658487143734)(SpringCloud/image-20220717174142427.png)]

即：某时刻某一个微服务不可用了。Eureka不会立刻清理，依旧会对该微服务的信息进行保存。（属于CAP里面的AP分支）

为什么会产生Eureka自我保护机制？

为了防lEurekaClient可以正常运行，但是与EurekaServer网络不通情况下，EurekaServer不会立刻将EurekaClient服务剔除

什么是自我保护机制？

默认情况下，如果EurekaServer在一定时间内没有接收到某个微服务实例的心跳，EurekaServer将会注销该实例（默认90秒)。但是当网络分区故障发生(延时、卡

顿、拥挤)时，微服务与EurekaServer之间无法正常通信，以上行为可能变得非常危险了——因为微服务本身其实是健康的，此时本不应该注销这个微服务。

Eureka通过“自我保护模式”来解决这个问题——当EurekaServer节点在短时间内丢失过多客户端时(可能发生了网络分区故障)，那么这个节点就会进入自我保护模

式。

总结：

在自我保护模式中，Eureka Server会保护服务注册表中的信息，不再注销任何服务实例。

它的设计哲学就是宁可保留错误的服务注册信息，也不盲目注销任何可能健康的服务实例。一句话讲解：好死不如赖活着

综上，自我保护模式是一种应对网络异常的安全保护措施。它的架构哲学是宁可同时保留所有微服务（健康的微服务和不健康的微服务都会保留）)也不盲目注销

任何健康的微服务。使用自我保护模式，可以让Eureka集群更加的健壮、稳定。

禁止自我保护

以7001和8001为例

修改7001的yml：

eureka:
  instance:
    hostname: eureka7001.com    #eureka服务端的实例名字
  client:
    register-with-eureka: false    #表示不向注册中心注册自己
    fetch-registry: false   #表示自己就是注册中心，职责是维护服务实例，并不需要去检索服务
    service-url:
      #设置与eureka server交互的地址查询服务和注册服务都需要依赖这个地址
      defaultZone: http://eureka7001.com:7001/eureka/
#      defaultZone: http://eureka7002.com:7002/eureka/  #这个是集群版开启 互相注册 集群就是指向其他的eureka
  server:
#    关闭自我保护机制，保证不可用服务被及时踢除
    enable-self-preservation: false
    eviction-interval-timer-in-ms: 2000

修改8001的yml

eureka:
  client:
    # 表示是否将自己注册进EurekaServer 默认为true
    register-with-eureka: true
    # 是否从EurekaServer 抓取已有的注册信息。默认为true。单节点无所谓，集群必须设置为true才能配合ribbon 使用负载均衡
    fetch-registry: true
    service-url:
#      defaultZone: http://localhost:7001/eureka   # 单机版
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka    # 集群版
  instance:
    instance-id: payment8001
    prefer-ip-address: true       # 访问路径可以显示IP地址
    # Eureka 客户端向服务端发送心跳的时间间隔，单位为秒（默认为30秒）
    lease-renewal-interval-in-seconds: 1
    # Eureka 客户端在收到最后一次心跳后等待的时间上限，单位为秒（默认为90秒），超时将剔除服务
    lease-expiration-duration-in-seconds: 2

先关闭8001

在这里插入图片描述

此时启动erueka和pay.此时如果直接关闭了pay,那么erueka会直接删除其注册信息

2、Zookeeper

zookeeper是一个分布式协调工具，可以实现注册中心功能

关闭Linux服务器防火墙后启动zookeeper服务器

Zookeeper服务器取代Eureka服务器，zk作为服务注册中心

1.安装zookeeper并启动

2.创建新的pay模块

单独用于注册到zk中

名字：cloud-provider-zookeeper-payment8004

1.pom依赖

    <dependencies>
        <!--springboot 整合 zookeeper 客户端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
        </dependency>

        <dependency>
            <groupId>org.example</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <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>
            <optional>true</optional>
        </dependency>

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

2.yml配置文件

# 8004 表示注册到zookeeper服务器的支付服务提供者端口号
server:
  port: 8004

# 服务别名----注册到zookeeper 到注册中心的名称
spring:
  application:
    name: cloud-provider-payment
  cloud:
    zookeeper:
      connect-string: 192.168.160.128:2181

3,主启动类

@SpringBootApplication
// 该注解用于向使用consul或者zookeeper 作为注册中心时的注册服务
@EnableDiscoveryClient
public class PaymentMain8004 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentMain8004.class,args);
    }
}

4,controller

@Slf4j
@RestController
@RequestMapping("/payment")
public class PaymentController {
    @Value("${server.port}")
    private String serverPort;

    @RequestMapping("/zk")
    public String paymentZk(){
        return "Springcloud with zookeeper:  "+serverPort +"\t"+ UUID.randomUUID();
    }

}

5,启动

此时启动,会报错,因为jar包与我们的zk版本不匹配

修改pom文件，改成与我们zk相匹配的jar包

eg：
在这里插入图片描述

再次重启：

在这里插入图片描述

此时8004就已经注册到zk中了。

6.测试

验证测试：浏览器 - http://localhost:8004/payment/zk

在这里插入图片描述

验证测试2 ：接着用zookeeper客户端操作

[zk: localhost:2181(CONNECTED) 5] ls /services/cloud-provider-payment
[9e03f796-9672-4136-ae32-84f0de4ccacc]
[zk: localhost:2181(CONNECTED) 6] ls /services/cloud-provider-payment/9e03f796-9672-4136-ae32-84f0de4ccacc
[]
[zk: localhost:2181(CONNECTED) 7] get /services/cloud-provider-payment/9e03f796-9672-4136-ae32-84f0de4ccacc
{"name":"cloud-provider-payment","id":"9e03f796-9672-4136-ae32-84f0de4ccacc","address":"DESKTOP-3058MDQ.lan","port":8004,"sslPort":null,"payload":{"@class":"org.springframework.cloud.zookeeper.discovery.ZookeeperInstance","id":"application-1","name":"cloud-provider-payment","metadata":{}},"registrationTimeUTC":1658057554392,"serviceType":"DYNAMIC","uriSpec":{"parts":[{"value":"scheme","variable":true},{"value":"://","variable":false},{"value":"address","variable":true},{"value":":","variable":false},{"value":"port","variable":true}]}}

json格式化get /services/cloud-provider-payment/a4567f50-6ad9-47a3-9fbb-7391f41a9f3d的结果：

{
    "name": "cloud-provider-payment",
    "id": "9e03f796-9672-4136-ae32-84f0de4ccacc",
    "address": "DESKTOP-3058MDQ.lan",
    "port": 8004,
    "sslPort": null,
    "payload": {
        "@class": "org.springframework.cloud.zookeeper.discovery.ZookeeperInstance",
        "id": "application-1",
        "name": "cloud-provider-payment",
        "metadata": {}
    },
    "registrationTimeUTC": 1658057554392,
    "serviceType": "DYNAMIC",
    "uriSpec": {
        "parts": [
            {
                "value": "scheme",
                "variable": true
            },
            {
                "value": "://",
                "variable": false
            },
            {
                "value": "address",
                "variable": true
            },
            {
                "value": ":",
                "variable": false
            },
            {
                "value": "port",
                "variable": true
            }
        ]
    }
}

ZooKeeper的服务节点是临时节点，没有Eureka那含情脉脉。

3.创建order消费模块注册到zk

1,创建项目

名字: cloud-consum-zookeeper-order80

2,pom

 <dependencies>
        <!--springboot 整合 zookeeper 客户端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
        </dependency>

        <dependency>
            <groupId>org.example</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <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>
            <optional>true</optional>
        </dependency>

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

3,配置文件

server:
  port: 80

# 服务别名----注册到zookeeper 到注册中心的名称
spring:
  application:
    name: cloud-consumer-order
  cloud:
    zookeeper:
      connect-string: 127.0.0.1:2181  # 192.168.160.128:2181

4,主启动类

@SpringBootApplication
// 该注解用于向使用consul或者zookeeper 作为注册中心时的注册服务
@EnableDiscoveryClient
public class OrderZKMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderZKMain80.class,args);
    }
}

5,配置类

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

6,业务类

@Slf4j
@RestController
@RequestMapping("/payment")
public class OrderZKController {
    public static final String INVOKE_URL = "http://cloud-provider-payment";

    @Resource
    private RestTemplate restTemplate;

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

7,启动

可以发现已经注册

在这里插入图片描述

8、集群版的zk注册

只需修改配置文件

这个connect-string指定多个zk地址即可

connect-string: 1.2.3.4,2.3.4.5

3、consul

简介

Consul官网

Consul下载地址

What is Consul?

Consul is a service mesh solution providing a full featured control plane with service discovery, configuration, and segmentation functionality. Each of these features can be used individually as needed, or they can be used together to build a full service mesh. Consul requires a data plane and supports both a proxy and native integration model. Consul ships with a simple built-in proxy so that everything works out of the box, but also supports 3rd party proxy integrations such as Envoy. link

Consul是一个服务网格解决方案，它提供了一个功能齐全的控制平面，具有服务发现、配置和分段功能。这些特性中的每一个都可以根据需要单独使用，也可以一起用于构建全服务网格。Consul需要一个数据平面，并支持代理和本机集成模型。Consul船与一个简单的内置代理，使一切工作的开箱即用，但也支持第三方代理集成，如Envoy。

基本概念

Consul是一套开源的分布式服务发现和配置管理系统，由HashiCorp公司用Go语言开发。

提供了微服务系统中的服务治理、配置中心、控制总线等功能。这些功能中的每一个都可以根据需要单独使用，也可以一起使用以构建全方位的服务网格，总之

Consul提供了一种完整的服务网格解决方案。

它具有很多优点。包括:基于raft协议，比较简洁;支持健康检查,同时支持HTTP和DNS协议支持跨数据中心的WAN集群提供图形界面跨平台，支持Linux、Mac、Windows

功能

服务发现
- 提供http和dns两种发现方式
健康检测
- 支持多种方式，http、tcp、docker、shell脚本定制化
kv存储
- key、value的存储方式
多数据中心
- consul支持多数据中心
可视化web界面

怎么玩

安装并运行consul

官网安装说明

windows版解压缩后，得consul.exe，打开cmd

查看版本 consul -v :

在这里插入图片描述

D:\studytools\springcloud\consul>consul -v
Consul v1.12.3
Revision 2308c75e
Protocol 2 spoken by default, understands 2 to 3 (agent will automatically use protocol >2 when speaking to compatible agents)

开发模式启动consul agent -dev：

浏览器输入 - http://localhost:8500/ - 打开Consul控制页。

在这里插入图片描述

服务提供者注册进consul

1.新建Module支付服务provider8006

名字cloud-provider-consul-payment8006

2.pom依赖

<dependencies>
        <!--springboot 整合 consul 客户端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>
        <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
        <dependency>
            <groupId>org.example</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <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>
            <optional>true</optional>
        </dependency>

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

3.yml配置

# consul 服务端口号
server:
  port: 8006

spring:
  application:
    name: cloud-provider-payment
  cloud:
    # consul注册中心地址
    consul:
      host: localhost
      port: 8500
      discovery:
        #hostname 127.0.0.1
        service-name: ${spring.application.name}

4.主启动类

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

5.业务类controller

@Slf4j
@RestController
@RequestMapping("/payment")
public class PaymentController {

    @Value("${server.port}")
    private String serverPort;

    @RequestMapping("/consul")
    public String paymentZk(){
        return "SpringCloud with consul:  "+serverPort +"\t"+ UUID.randomUUID();
    }
}

6.验证测试

在这里插入图片描述

服务消费者注册进consul

1.新建Module消费服务order80

名字cloud-consumer-consul-order80

2.pom依赖

<dependencies>
        <!--springboot 整合 consul 客户端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>
        <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
        <dependency>
            <groupId>org.example</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <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>
            <optional>true</optional>
        </dependency>

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

3.yml配置

# consul 服务端口号
server:
  port: 80

spring:
  application:
    name: cloud-consul-order
  cloud:
    # consul注册中心地址
    consul:
      host: localhost
      port: 8500
      discovery:
        #hostname 127.0.0.1
        service-name: ${spring.application.name}

4.主启动类

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

5配置类

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

6.业务类controller

@Slf4j
@RestController
@RequestMapping("/consumer")
public class OrderConsulController {
    public static final String INVOKE_URL = "http://cloud-provider-payment";

    @Resource
    private RestTemplate restTemplate;

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

}

7.验证测试

运行consul，cloud-provider-consul-payment8006，cloud-consumer-consul-order80

http://localhost:8500/ 主页会显示出consul，cloud-providerconsul-payment8006，cloud-consumerconsul-order80三服务。
在这里插入图片描述

三个注册中心异同点

组件名	语言	CAP	服务健康检查	对外暴露接口	Spring Cloud集成
Eureka	Java	AP	可配支持	HTTP	已集成
Consul	Go	CP	支持	HTTP/DNS	已集成
Zookeeper	Java	CP	支持	客户端	已集成

CAP：

C：Consistency (强一致性)
A：Availability (可用性)
P：Partition tolerance （分区容错性)

CAP理论关注粒度是数据，而不是整体系统设计的策略

在这里插入图片描述

最多只能同时较好的满足两个。

CAP理论的核心是：一个分布式系统不可能同时很好的满足一致性，可用性和分区容错性这三个需求。

因此，根据CAP原理将NoSQL数据库分成了满足CA原则、满足CP原则和满足AP原则三大类:

CA - 单点集群，满足—致性，可用性的系统，通常在可扩展性上不太强大。
CP - 满足一致性，分区容忍必的系统，通常性能不是特别高。
AP - 满足可用性，分区容忍性的系统，通常可能对一致性要求低一些。

AP架构（Eureka）

当网络分区出现后，为了保证可用性，系统B可以返回旧值，保证系统的可用性。

结论：违背了一致性C的要求，只满足可用性和分区容错，即AP
在这里插入图片描述

CP架构（ZooKeeper/Consul）

当网络分区出现后，为了保证一致性，就必须拒接请求，否则无法保证一致性。

结论：违背了可用性A的要求，只满足一致性和分区容错，即CP。
在这里插入图片描述

CP 与 AP 对立同一的矛盾关系。

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

SpringCloud-服务注册与发现的相关文章

高性能、可扩展、支持二次开发的企业电子招标采购系统源码

在数字化时代企业需要借助先进的数字化技术来提高工程管理效率和质量招投标管理系统作为企业内部业务项目管理的重要应用平台涵盖了门户管理立项管理采购项目管理采购公告管理考核管理报表管理评审管理企业管理采购管理和系统管理等多个
Feign 客户端中不支持 Spring Data Pageable 作为 RequestParam

我一直在尝试为我的其余 api 公开一个 Feign Client 它采用 Pageable 作为输入并定义了 PageDefaults 控制器 GetMapping value data produces MediaType APPLIC
招投标系统简介企业电子招投标采购系统源码之电子招投标系统 —降低企业采购成本

功能描述 1 门户管理所有用户可在门户页面查看所有的公告信息及相关的通知信息主要板块包含招标公告非招标公告系统通知政策法规 2 立项管理企业用户可对需要采购的项目进行立项申请并提交审批查看所有的立项信息主要功能包含招标
java版直播商城平台规划及常见的营销模式电商源码/小程序/三级分销+商城免费搭建

鸿鹄云商 B2B2C产品概述 B2B2C平台以传统电商行业为基石鸿鹄云商支持商家入驻平台自营多运营模式积极打造全新市场全新模式企业级B2B2C电商平台致力干助力各行互联网创业腾飞并获取更多的收益从消费者出发助力企
DockerCompose - 微服务项目部署全过程（最佳实践）

目录一微服务项目部署 1 1 项目介绍 1 2 准备 MySQL 初始化文件 1 3 pom xml 插件 1 4 测试工作 1 5 编写 Dockerflie 文件 1 6 编写 DockerCompose yml 文件 1 7 修改
spring-boot-starter-oauth2-client、spring-cloud-starter-oauth2 和 spring-security-oauth2 之间有什么区别

我正在为 OAUTH2 中的 client credentials 授予类型流开发客户端应用程序我无法决定在我的项目中为此目的使用以下依赖项 spring boot starter oauth2 客户端 spring cloud star
无法从 Spring Cloud Config Server 获取值到我的 Config-Client(limits-service)

经过几天的互联网搜索和多次尝试对我来说没有任何结果我在这里写下我有项目弹簧云配置服务器其中包含以下文件可以从以下位置访问完整项目https github com AshishBharadwaj94 spring cloud con
LoadBalancerFeignClient 中的 NullPointerException (spring-cloud-netflix)

我们在服务中为客户使用 Feign 最近其中一项服务开始随机抛出一些异常原因如下 Caused by java lang NullPointerException null at org springframework cloud ne
了解Spring Cloud Eureka Server自我保存和更新阈值

我对开发微服务还很陌生尽管我已经研究它有一段时间了阅读了 Spring 的文档和 Netflix 的文档我开始了一个简单的项目可以在 Github 上找到 https github com codependent storytelle
实例关闭时的 Spring Cloud Gateway 500

我有一个使用Spring Cloud Load Balancer Spring Cloud版本 Hoxton SR6 的Spring Cloud Gateway eureka客户端应用程序并且我有一个Spring Boot应用程序的实例
用于拒绝请求的 NetflixOSS Zuul 过滤器

我正在尝试在简单的 spring cloud Netflix Api 网关反向代理中使用 ZuulFilter 以便对自定义身份验证提供程序进行请求身份验证通过 Rest 调用过滤器应使用 401 拒绝未经授权的请求并且不要将这些
Zuul 调用的基本身份验证服务

我是 Zuul 作为边缘服务器所以所有请求都经过此边缘服务器我有一个微服务A A的所有Web服务都受到基本身份验证的保护我们如何通过Zuul代理来调用A b 的服务呢我应该为消息添加标头吗这是我的 Zuul 过滤器 public
Spring Cloud 2020.0 不再处理 bootstrap.yml 配置

In my Spring Boot 项目 https github com pavankjadda HashiCorpVault SpringCloud 我定义了4个配置文件 demo dev test prod 在启动过程中 YAML 文
如何配置 Spring Cloud Stream 中函数的绑定，以将其输入绑定到 Web 端点并将其输出绑定到 Kafka 主题

我有一个普通的javaFunction 我正在尝试绑定它对 Web 端点的输入其输出到 kafka 主题当我在网络环境中使用我的函数时它总是返回结果值Function单独回到网络客户端我可以做这样的事情吗 spring cloud
将 SpringCloudSleuth 与 AWS X-Ray 集成

我有一个使用 Springboot 应用程序运行 Fargate 实例的 ECS 集群并且希望以最少的代码更改来启用跟踪我开始研究两种方法使用 AWS Xray 步骤 gt 添加依赖项添加 WSXRayServletFilter 在
Zuul - Api 网关身份验证

我想在几个服务前面通过Spring Cloud引入Zuul作为API网关我对身份验证有一些设计疑问身份验证将由 Spring Security 处理它位于 servlet 过滤器链中的 Zuul 之前我的顾虑网关将位于许多服务的前
引起原因：java.lang.IllegalStateException：您需要为git存储库配置一个uri

我正在开发Microservices with Spring Boot 2 0 Eureka and Spring Cloud参考 https piotrminkowski wordpress com 2018 04 26 quick gu
Spring Cloud Gateway 全局异常处理和自定义错误响应

我有一个自定义过滤器可以在使用 Spring Cloud Gateway 调用实际 API 之前对每个请求进行身份验证 Spring Cloud中有没有办法像Spring提供 ControllerAdvice一样集中处理异常我想全局处理
设置了 server.contextPath 的 Spring Boot 与通过 Eureka Server 访问 hystrix.stream 的 URL

我有运行 Turbine 实例的 Eureka Server 以及连接到它的一些发现客户端一切正常但如果我注册一个发现客户端server contextPath设置后它没有被识别InstanceMonitor涡轮流无法结合其hystr
Spring云配置服务器-如何添加在EnvironmentEncryptorEnvironmentRepository的findOne()方法中可见的自定义PropertySource

My goal就是在spring cloud server中添加自定义的PropertySource 我想要实现的是从 spring cloud config client 应用程序中的自定义源获取一些自定义属性根据来自的建议在 spri

随机推荐

wordcloud安装板版本

https www lfd uci edu gohlke pythonlibs wordcloud
jupyter notebook一直显示“内核正在启动，请等待”，或者内核启动失败

在使用anaconda自带的工具jupyter notebook时添加完虚拟环境的内核在jupyter notebook中打开相应虚拟环境的编辑器时一直显示内核正在启动请等待即使等待很久之后也是内核启动失败该问题是笔者在安装py
如何运营好一个自媒体账号？

想要做自媒体赚钱并不只是拍摄或剪辑好视频就可以了还需要懂一些账号运营小技巧如何运营呢今天这期内容大周就来分享几点干货记得先点赞收藏起来 1 用户调查我们做自媒体之前要先做好用户调查这样我们才能更好的获得精准流量并推广自己
全系光谱完整版

宇宙射线也叫电磁波其中包含射线 X射线紫外线可见光红外线近红外远红外还有无线电和超声波无线电波是振荡电路中自由电子作周期性的运动产生的红外线可见光紫外线是原子外层电子受激发产生的 X射线是原子内层电子受激发产生的射
java中函数和数组

函数为了提高代码的复用性可以将其定义成一个单独的功能该功能的体现就是java中的函数函数就是体现之一数组用于存储同一类型连续存放数据的一个容器好处可以对该容器中的数据进行编号从0开始数组用于封装数据就是一个具体的实
C++中基本数据类型字节数及取值范围

机器字长是指计算机进行一次整数运算所能处理的二进制数据的位数整数运算即定点整数运算机器字长也就是运算器进行定点数运算的字长通常也是CPU内部数据通路的宽度现在一般为32位即4个字节也有64位和16位的算术类型的存储空间按照机器
足部IMU在复杂场景中行走定位

随着微机电系统 MEMS 技术的快速发展基于MEMS的惯性导航系统 INS 在任意环境的基站定位方面发挥着至关重要的作用惯性导航具有自主性强定位频率高功耗低实时性强等特点因此更适合单兵作战反恐行动应急救援消防救援等环境未知
python模糊图像清晰化_Python图像处理介绍图像模糊与锐化

欢迎关注小白玩转Python 发现更多有趣引言在之前的文章中我们讨论了边缘检测内核在本文我们将讨论如何在图像上应用模糊与锐化内核将这些内核应用到彩色图像上同时保留核心图像一如既往我们从导入所需的python库开始 imp
Flutter_点击事件及手势处理

Flutter 点击事件和手势 Flutter中的手势系统有两个独立的层第一层具有原始指针事件其描述屏幕上指针例如触摸鼠标和测针的位置和移动第二层具有手势其描述由一个或多个指针移动组成的语义动作指针指针表示用户与设备屏幕
lede做无线打印服务器吗,OpenWrt/PandoraBox/LEDE做打印服务器连接HP1020问题汇总

此解决方案适用于HP 1000 1005 1018 1020打印机需要在路由器上面禁用双向模式否则无法正常打印问题一能识别能添加网络打印机不能打印下发打印任务之后发现打印机根本没反应 Windows系统日志有报错Admini
Redis常见命令

命令可以查看的文档 http doc redisfans com https redis io commands 官方文档英文 http www redis cn commands html 中文 https redis com cn c
LoadRunner用户验证码和验证码使用脚本

Action 定义Md5变量用来存放使用md5加密后的字符串 char Md5 33 存放包含用户登录信息的URL char str 174 存放用户账户信息 char str1 92 存放当前时间 int t1 int a char Me
虚拟机重启网络失败service network restart

某天早上发现网络突然重启失败 ping百度也出现未知网络原因可能是NetworkManager和firewall 两个网络管理冲突关掉NetworkManager即可然后重启网络解决 service NetworkManager s
设计模式一之简单工厂模式

生活示例刻板印刷 gt 活字印刷举例喝酒唱歌人生真爽 gt 对酒当歌人生几何可维护需要修改则只需要改需要改的字即可可复用字体可在后来的印刷复用可扩展需要加字只需要加入相应的刻字即可灵活性好字的排列可能竖排或横排
抖音APP接口分析

抖音搜索接口接口名类型链接搜索用户综合信息 post https aweme hl snssdk com aweme v1 challenge search 搜索相关用户列表 post https search hl amemv c
使用 Python 中的 Langchain 从零到高级快速进行工程

大型语言模型 LLM 的一个重要方面是这些模型用于学习的参数数量模型拥有的参数越多它就能更好地理解单词和短语之间的关系这意味着具有数十亿个参数的模型有能力生成各种创造性的文本格式并以信息丰富的方式回答开放式和挑战性的问题 ChatG
PHP base64转图片

转图片 public function tupian base64 image content data image png base64 9j 4AAQSkZJRgABAQEASABIAAD 4QAiRXhpZgAATU0AKgAAAAg
[网络安全]sqli-labs Less-5 解题详析

网络安全 Less 5 GET Double Injection Single quotes String 双注入GET单引号字符型注入判断注入类型判断注入点个数查库名爆破 left函数抓包查库名双查询注入原理实例查库名
Qt VS Tools插件没有Qt Option选项（VS 2022）

Qt VS Tools插件没有Qt Option选项 VS 2022 在尝试用Vs2022搭建Qt开发环境时跟着网上教程发现自己安装完Qt Vs Tools后没有Qt Option选项如图推测可能是版本太新的问题于是点开Opti
SpringCloud-服务注册与发现

服务注册与发现前面我们没有服务注册中心也可以服务间调用为什么还要服务注册当服务很多时单靠代码手动管理是很麻烦的需要一个公共组件统一管理多服务包括服务是否正常运行等 Eureka用于服务注册目前官网已经停止更新 1 Eu