SpringCould服务注册中心

Posted 2021-12-12 覃会程

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了SpringCould服务注册中心相关的知识，希望对你有一定的参考价值。

Spring Could主要内容结构图：

服务注册中心

Eureka

Eureka 基础知识

Eureka包含两个组件:Eureka Server和Eureka Client

Eureka Server提供服务注册服务
各个微服务节点通过配置启动后，会在EurekaServer中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观看到。

EurekaClient通过注册中心进行访问
是一个Java客户端，用于简化Eureka Server的交互，客户端同时也具备一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后，将会向Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳,EurekaServer将会从服务注册表中把这个服务节点移除（默认90秒)

什么是服务治理

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

什么是服务注册与发现

Eureka采用了CS的设计架构，Eureka senver作为服务注册功能的服务器，它是服务注册中心。而系统中的其他微服务，使用Eureka的客户端连接到Eureka Sever并维持心跳连接。这样系统的维护人员就可以通过Eureka Server来监控系统中各个微服务是否正常运行。

在服务注册与发现中，有一个注册中心。当服务器启动的时候，会把当前自己服务器的信息比如服务地址通讯地址等以别名方式注册到注册中心上。另一方(消费者服务提供者)，以该别名的方式去注册中心上获取到实际的服务通讯地址，然后再实现本地RPC调用RPC远程调用框架核心设计思想:在于注册中心，因为使用注册中心管理每个服务与服务之间的一个依赖关系(服务治理概念)。在任何rpc远程框架中，都会有一个注册中心(存放服务地址相关信息(接口地址))

单机Eureka构建

EurekaServer服务安装

pom文件：

    <artifactId>cloud-eureka-server7001</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </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>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>

    </dependencies>

yam文件：

server:
  port: 7001

spring:
  application:
    name: cloud-eureka-server7001

eureka:
  instance:
    hostname: www.eureka7001.com
  client:
    fetch-registry: false  #不注册自己
    register-with-eureka: false # 不检索自己
    #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。
    service-url:
#      defaultZone: http://www.eureka7002.com:7002/eureka/
      defaultZone: http://www.eureka7001.com:7001/eureka/
  server:
    #关闭自我保护机制，保证不可用服务立即被踢出
    enable-self-preservation: false
    eviction-interval-timer-in-ms: 2000

启动类：

注意：需要添加@EnableEurekaServer注解

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

测试：
启动后，访问本地，看到如下界面，则表示成功

在这里可以查看已经入驻的服务（目前没有服务入驻）

服务提供者（provider）入驻EurekaServer

pom文件：

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

yml文件：

eureka:
  client:
    service-url:
   # 配置集群的写法，使用逗号分隔
      defaultZone: http://www.eureka7001.com:7001/eureka/,http://www.eureka7002.com:7002/eureka/
#      defaultZone: http://eureka7001.com:7001/eureka/        单机版写法
  instance:
    ip-address: 127.0.0.1
    # 设置主机名
    instance-id: payment8001
    # 设置访问路径可以显示ip地址
    prefer-ip-address: true
    lease-renewal-interval-in-seconds: 1
    lease-expiration-duration-in-seconds: 2

启动类：
注意添加@EnableEurekaClient注解

@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient
public class PaymentMain8001 {

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

备注：@EnableEurekaClient只适用于使用Eureka作为注册中心的场景，@EnableDiscoveryClient可以适用于其他注册中心的场景比如nacos等。

入驻的名称和application：name相同

服务消费者（consumer）入驻EurekaServer

和服务提供者入驻差不多

pom文件：

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

yam文件：

eureka:
  client:
    service-url:
    # 集群写法，使用逗号分隔，如果是单机，写一个即可
      defaultZone: http://www.eureka7002.com:7002/eureka/,http://www.eureka7001.com:7001/eureka/

启动类：

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

注册服务成功后，服务消费者（订单服务）不再根据ip和端口号进行调用，而是根据服务名（CLOUD-PAYMENT-SERVICE）进行调用：

@RestController
@RequestMapping("comsumer")
public class OrderController {

//    public static final String PAYENT_URL = "http://localhost:8001";

    public static final String PAYENT_URL = "http://CLOUD-PAYMENT-SERVICE";
    @Resource
    private RestTemplate restTemplate;
    @Resource
    private LoadBalaner loadBalaner;
    @Resource
    private DiscoveryClient discoveryClient;

    @GetMapping("payment/create")
    public CommonResult<Payment> create(Payment payment) {
        return restTemplate.postForObject(PAYENT_URL+"/payment/create",payment,CommonResult.class);
    }
    @GetMapping("payment/selectOne/{id}")
    public CommonResult<Payment> getPayment(@PathVariable("id") long id) {
        return restTemplate.getForObject(PAYENT_URL+"/payment/selectOne/"+id,CommonResult.class);
    }

    @GetMapping("payment/lb")
    public String getPaymentLB() {
        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
        if (instances == null || instances.size() == 0) {
            return null;
        }
        ServiceInstance serviceInstance = loadBalaner.instance(instances);
        URI uri = serviceInstance.getUri();
        System.out.println(uri+"/payment/lb");
        return restTemplate.getForObject(uri+"/payment/lb",String.class);
//        return uri+"/payment/lb";
    }
}

注意：这是需要使用@LoadBalanced注解赋予RestTemplate负载均衡的能力（如果已经整合Ribbon的负载均衡功能，则不需要添加这个注解）

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

Eureka工作流程

先启动eureka注册中心
启动服务提供者payment支付服务
支付服务启动后会把自身信息(比如服务地址以别名方式主册进eureka)
消费者order服务在需要调用接口时，使用服务别名去注册中心获取实际的RPC远程调用地址
消费者获得调用地址后，底层实际是利用HttpClient技术实现远程调用
消费者获得服务地址后会缓存在本地jvm内存中，默认每间隔30秒更新—次服务调用地址

集群搭建的原理：注册中心：互相注册，相互守望

7002服务的写法：

server:
  port: 7002
spring:
  application:
    name: cloud-eureka-server7002

eureka:
  instance:
    hostname: www.eureka7002.com
  client:
    register-with-eureka: false
    fetch-registry: false
    service-url:
      defaultZone: http://www.eureka7001.com:7001/eureka/
  server:
    enable-self-preservation: false
    eviction-interval-timer-in-ms: 2000

7001服务的写法：

server:
  port: 7001

spring:
  application:
    name: cloud-eureka-server7001

eureka:
  instance:
    hostname: www.eureka7001.com
  client:
    fetch-registry: false  #不注册自己
    register-with-eureka: false # 不检索自己
    service-url:
      defaultZone: http://www.eureka7002.com:7002/eureka/
  server:
    #关闭自我保护机制，保证不可用服务立即被踢出
    enable-self-preservation: false
    eviction-interval-timer-in-ms: 2000

访问7001能看到7002服务：

访问7002服务也能看到7001：

将两个服务提供者（支付服务）注入到eureka注册中心后，会看到一个服务下有两台机器

服务发现

作用：
对于注册进eureka里面的微服务，可以通过服务发现来获得该服务的信息，使用DiscoveryClient 对象即可获取。

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

    @Resource
    private DiscoveryClient discoveryClient;
  
    @GetMapping("discovery")
    public Object discovery() {
        // 获取注册中心的所有服务名称
        List<String> services = discoveryClient.getServices();
        services.forEach(service->{
            System.out.println("---service-->"+service);
        });
        
        // 获取指定服务下的所有实例信息，信息包括：主机名，端口，ip
        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
        instances.forEach(instance->{
            System.out.println(instance.getServiceId()+"\\t"+instance.getHost()+"\\t"+instance.getPort()+"\\t"+instance.getUri());
        });
        return this.discoveryClient;
    }

}

eureka自我保护理论

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

如果在Eureka Server的首页看到以下这段提示，则说明Eureka进入了保护模式：

导致原因：

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

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

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

什么是自我保护模式?

默认情况下，如果EurekaServer在一定时间内没有接收到某个微服务实例的心跳EurekaServer将会注销该实例(默认90秒）。但是当网络分区故障发生(延时、卡顿、拥挤)时，微服务与EurekaServer之间无法正常通信，以上行为可能变得非常危险了——因为微服务本身其实是健康的，此时本不应该注销这个微服务。Eureka通过“自我保护模式”来解决这个问题——当EurekaServer节点在短时间内丢失过多客户端时(可能发生了网络分区故障)，那么这个节点就会进入自我保护模式。

综上，自我保护模式是一种应对网络异常的安全保护措施。它的架构哲学是宁可同时保留所有微服务（健康的微服务和不健康的微服务都会保留）也不盲目注销任何健康的微服务。使用自我保护模式，可以让Eureka集群更加的健壮、稳定。

怎么禁止自我保护机制

注册中心的配置：

eureka:
  server:
    # 关闭自我保护机制，保证不可用服务立即被踢出，默认是true
    enable-self-preservation: false
    # 设置间隔时间
    eviction-interval-timer-in-ms: 2000

客户端配置：

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

Zookeeper

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

和eureka不一样的是zookeeper注册中心不放在本地，安装到远程服务器上

支付服务注入进zookeeper

pom文件：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
        </dependency>

注意：服务器上的zookeeper版本要和导入的依赖版本相符合

yml文件：

server:
  port: 8004

# 服务别名，注册到zookeeper注册中心名称
spring:
  application:
    name: cloud-payment-service
  cloud:
    zookeeper:
      connect-string: 000.000.000.000:2181

启动类：
添加 @EnableDiscoveryClient注解

@SpringBootApplication
@EnableDiscoveryClient
public class PaymentMain8004 {

    public static void main(String[] args) {
        SpringApplication.run(PaymentMain8004.class,args);
    }

}

zookeeper注入的服务是临时性的，当服务出现异常（收不到心跳），zookeeper注册中心就会删除该服务。

服务消费者（订单服务）入驻注册中心

pom文件：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
        </dependency>

yml文件：

server:
  port: 80
spring:
  cloud:
    zookeeper:
      connect-string: 000.000.000.000:2181
  application:
    name: cloud-comsumer-order

启动类：

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

调用服务：
使用服务名代替ip和端口

@RestController
@RequestMapping("comsumer")
public class OrderController {

    @Resource
    private RestTemplate restTemplate;

    public static final String PAYENT_URL = "http://cloud-payment-service";

    @GetMapping("payment/zk")
    public String getpaymentInfo() {
        String res = restTemplate.getForObject(PAYENT_URL+"/payment/zk",String.class);
        return res;
    }
}

Consul

Consul是一套开源的分布式服务发现和配置管理系统，由HashiCorp公司用Go语言开发。
提供了微服务系统中的服务治理、配置中心、控制总线等功能。这些功能中的每一个都可以根据需要单独使用，也可以一起使用以构建全方位的服务网格，总之Consul提供了一种完整的服务网格解决方案。
它具有很多优点。包括:基于raft协议，比较简洁;支持健康检查,同时支持HTTP和DNS协议支持跨数据中心的WAN集群提供图形界面跨平台，支持Linux、Mac、Windows

作用：

服务发现
提供HTTP和DNS两种发现方式。
健康监测
支持多种方式，HTTP、TCP、Docker、Shell脚本定制化
KV存储
Key.Value的存储方式
多数据中心
Consul支持多数据中心
可视化Web界面

服务提供者入驻Consul

pom文件：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>

yml文件：

server:
  port: 8006
spring:
  application:
    name: consul-payment-service
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        service-name: ${spring.application.name}

启动类：

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

服务消费者入驻Consul

pom文件：

        <dependency>  
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul190-SpringCould中的Eureka的配置文件是什么样子？
 190-SpringCould中的Eureka的配置文件是什么样子？
 2018第47周日
 springcould 项目以nacos作为配置中心
 springcould 项目以nacos作为配置中心
 SpringCould服务网关GateWay

SpringCould服务注册中心

文章目录

服务注册中心

Eureka

Eureka 基础知识

什么是服务治理

什么是服务注册与发现

单机Eureka构建

EurekaServer服务安装

服务提供者（provider）入驻EurekaServer

服务消费者（consumer）入驻EurekaServer

Eureka工作流程

服务发现

eureka自我保护理论

怎么禁止自我保护机制

Zookeeper

支付服务注入进zookeeper

服务消费者（订单服务）入驻注册中心

Consul

服务提供者入驻Consul

服务消费者入驻Consul