注册中心 Eureka； Ribbo - 负载均衡； 负载均衡策略 ；注册中心的配置集群， 创建 namespace，配置命名空间，nacos添加配置文件，从nacos拉取配置等相关的操作

通过这篇文章来跟大家聊聊spring cloud中的注册中心

注册中心

需求：当一个服务提供者 service 部署了多个实例交给 user 远程调用时：

• 服务消费者 user 应该调用哪个实例，如何获取其对应地址和端口？
• user 如何获知实例是否健康？

注册中心作用：

• 帮助管理服务，并帮助服务调用者选择并调用服务
• 实时监测服务实例是否健康

eureka：

构成：
eureka-server：服务端，注册中心
记录服务信息，心跳监控

eureka-client：客户端，
服务提供者（注册到服务端，定期向服务端发送心跳）、服务消费者（从服务端拉取服务列表，基于负载均衡选择服务）
作用：

服务注册： service实例启动后，会将自己的信息注册到 eureka服务端
服务拉取： user 根据 实例名 获取 service 地址列表

服务搭建

配置文件:

我们需要将 eureka 注册到spring容器中，所以需要在配置文件中做相关配置。

server:
  port: 8099
spring:
  application:
    name: eureka_server
eureka:
  client:
  	# 配置eureka服务地址
    service-url:
      defaultzone: http://127.0.0.1:8099/eureka

项目启动：

为了让项目能启动 eureka，需要在启动类上加一个注解：@enableeurekaserver

@springbootapplication
@enableeurekaserver
public class serverapplication {
    public static void main(string[] args) {
        springapplication.run(serverapplication.class, args);
    }
}

启动项目，访问地址：http://127.0.0.1:8099：

注册的服务名称就是配置文件中的名称的大写。

服务注册

在上一步，已经将 eureka-server （eureka服务中心）搭建完毕，现在就开始注册服务实例了。

注意：

无论是 服务提供者 还是 服务消费者，他们的身份都是 eureka-client

记得添加 spring-boot-starter-web 的依赖，不然会报错：field optionalargs in org.springframework.cloud.netflix.eureka.eurekaclientautoconfiguration$refreshableeurekaclientconfiguration required a bean of type ‘com.netflix.discovery.abstractdiscoveryclientoptionalargs’ that could not be found.

服务发现、服务注册统一都封装在eureka-client依赖。

需要在配置文件中配置 eureka-server 的地址。

spring:
  application:
    name: service_provider
eureka:
  client:
    service-url:
      defaultzone: http://127.0.0.1:8099/eureka

启动多个实例

为了让项目能启动 eureka，需要在启动类上加一个注解：@enableeurekaclient。

@springbootapplication
@enableeurekaclient
public class providerapplication {
    public static void main(string[] args) {
        springapplication.run(providerapplication.class, args);
    }
}

我们可以通过 idea 自带功能模仿启动多个服务实例。

• 打开 service 面板

****

复制原来的 provider 启动配置

查看 eureka注册中心

服务发现

依赖导入

<dependency>
    <groupid>org.springframework.cloud</groupid>
    <artifactid>spring-cloud-starter-netflix-eureka-client</artifactid>
</dependency>

配置文件：

spring:
  application:
    name: service_user
server:
  port: 8084

eureka:
  client:
    service-url:
      defaultzone: http://127.0.0.1:8099/eureka

服务拉取和负载均衡

服务拉取：

• 修改 controller 代码，将 url 路径的 ip、端口 修改为 服务名：

  @restcontroller
  @requestmapping("user")
  public class usercontroller {
  
      @autowired
      private resttemplate resttemplate;
  
      @getmapping("/{id}")
      public book getbookbyid(@pathvariable("id") integer id) {
          // string url = "http://127.0.0.1:8081/provider" + id;
          string url = "http://service_provider/provider";
          if (id != null) {
              url = url + id;
          }
          book book = resttemplate.getforobject(url, book.class);
          return book;
      }
  }
  

注册 resttemplate 的时候加上注解 @loadbalanced

    @loadbalanced
    @bean
    public resttemplate resttemplate() {
        return new resttemplate();
    }

接口调用：

@restcontroller
@requestmapping("user")
public class usercontroller {
    @autowired
    private resttemplate resttemplate;

    @getmapping("/{id}")
    public book getbookbyid(@pathvariable("id") integer id) {
        // string url = "http://127.0.0.1:8081/provider" + id;
        string url = "http://provider/pro/";
        if (id != null) {
            url = url + id;
        }
        book book = resttemplate.getforobject(url, book.class);
        return book;
    }
}

访问接口：

访问报错：

解决方案：

多测试几下接口，可以发现，user一会儿调用的是 provider:8081 一会儿调用的是 provider:8082。这就是负载均衡算法选择的。

小结

eureka-server 搭建：

• 引入依赖：

<dependency>
    <groupid>org.springframework.cloud</groupid>
    <artifactid>spring-cloud-starter-netflix-eureka-server</artifactid>
</dependency>

• 启动类添加 @enableeurekaserver
• 配置文件配置 eureka 地址

server:
  port: 8099
spring:
  application:
    name: server
eureka:
  client:
  	# 配置eureka服务地址
    service-url:
      defaultzone: http://127.0.0.1:8099/eureka

服务注册：

• 引入依赖：

<dependency>
    <groupid>org.springframework.cloud</groupid>
    <artifactid>spring-cloud-starter-netflix-eureka-client</artifactid>
</dependency>

• 启动类添加 @enableeurekaclient
• 配置文件配置 eureka 地址

server:
  port: 8081
spring:
  application:
    name: provider
eureka:
  client:
  	# 配置eureka服务地址
    service-url:
      defaultzone: http://127.0.0.1:8099/eureka

服务发现：

• 引入依赖：

<dependency>
    <groupid>org.springframework.cloud</groupid>
    <artifactid>spring-cloud-starter-netflix-eureka-client</artifactid>
</dependency>

• 启动类添加 @enableeurekaclient
• 配置文件配置 eureka 地址

server:
  port: 8089
spring:
  application:
    name: user
eureka:
  client:
  	# 配置eureka服务地址
    service-url:
      defaultzone: http://127.0.0.1:8099/eureka

ribbo - 负载均衡

1. 负载均衡流程

ribbon负载均衡流程图：

http://provider/pro/4 并非真实的地址，这个需要ribbon负载均衡去拦截，然后选择具体的服务地址。而，ribbon就是通过 loadbalancerinterceptor 的 intercept 方法来实现拦截请求并解析选择地址。

    public clienthttpresponse intercept(final httprequest request, final byte[] body, final clienthttprequestexecution execution) throws ioexception {
        uri originaluri = request.geturi();
        string servicename = originaluri.gethost();
        assert.state(servicename != null, "request uri does not contain a valid hostname: " + originaluri);
        return (clienthttpresponse)this.loadbalancer.execute(servicename, this.requestfactory.createrequest(request, body, execution));
    }

负载均衡流程：

2. 负载均衡策略

ribbon的负载均衡策略是由 irule 接口来定义的。

自定义负载均衡策略：

• 方式一： 在user中，@bean 注入自定义 irule

@bean
public irule randomrule(){
    return new randomrule();
}

• 方式二： 在user，配置文件修改 irule

provider: # 给某个微服务配置负载均衡规则，这里是userservice服务
  ribbon:
    nfloadbalancerruleclassname: com.netflix.loadbalancer.randomrule # 负载均衡规则

注意：

方式一的作用范围是：在访问任何微服务的时候，都是使用 randomrule 负载均衡策略；

方式二的作用范围是：在访问 provider 微服务的时候才是采用 randomrule 策略，其他的还是使用默认策略。

加载策略：

ribbon默认采用懒加载，即会在第一次访问时才会去创建 loadbalanceclient ，所以会在第一次请求的时候花上较长的等待时间。

可以通过配置文件更改加载策略为饿加载策略，即初始化时就创建 loadbalanceclient ，降低第一次访问的耗时。

ribbon:
  eager-load:
    enabled: true # 开启饥饿加载
    clients: provider # 指定饥饿加载的服务名称

nacos

概念：
服务注册中心
作用：

心跳检查： 不同于 eureka 只能 service实例 主动发起心跳，nacos 对于非临时实例可以主动发起心跳检查
临时心跳检查异常的会被剔除出 服务地址列表

• 非临时心跳检查异常的不会被剔除
• 定时推送变更： nacos 支持服务列表变更的消息推送模式，服务列表更新更及时

注册中心

引入依赖、修改配置

父工程添加 springcloudalibaba 的管理依赖。

<!--spring-cloud-alibaba-->
<dependency>
    <groupid>com.alibaba.cloud</groupid>
    <artifactid>spring-cloud-alibaba-dependencies</artifactid>
    <version>2.2.6.release</version>
    <type>pom</type>
    <scope>import</scope>
</dependency>

子工程中注释掉 eureka 依赖，引入 nacos 依赖。

<dependency>
    <groupid>com.alibaba.cloud</groupid>
    <artifactid>spring-cloud-starter-alibaba-nacos-discovery</artifactid>
</dependency>

配置文件配置nacos地址：

spring:
  cloud:
    nacos:
      server-addr: localhost:8848 # nacos服务地址

启动 user 和 provider ：

注意： eureka 注册名会变成大写，nacos 不会，所以改成 nacos 之后，需要把访问地址改成小写。

请求测试：

服务分级存储模型
一个服务可以拥有多个实例，如：provider 的 8081 和 8082，如果这些实例分布于全国不同的机房，如：provider:8081 在成都机房、provider:8082 在重庆机房，nacos就将同一机房内的实例 划分为一个集群。

即，一个服务可以拥有多个集群，一个集群中可以拥有多个实例。

微服务相互之间访问时，访问本地的速度更快，所以应该尽可能访问相同集群的实例，只有当本集群内存不够时，才去访问其他集群。

1. 配置集群

配置服务集群：

spring:
  cloud:
    nacos:
      server-addr: localhost:8848 # nacos服务地址
      discovery:
        cluster-name: cd

vm options：

-dserver.port=8082 -dspring.cloud.nacos.discovery.cluster-name=cq

2. 同集群优先的负载均衡

默认的 zoneavoidancerule 负载均衡策略并不能实现据同集群优先来实现负载均衡，因此nacos中提供了一个nacosrule的实现，可以优先从同集群中挑选实例。

修改负载均衡策略：

• 方式一：

@bean
public irule nacosrule(){
    return new nacosrule();
}

• 方式二：

provider: # 访问的服务名
  ribbon:
    nfloadbalancerruleclassname: com.alibaba.cloud.nacos.ribbon.nacosrule  # 负载均衡规则

3. 权重配置

服务器的性能之间存在差异，为了让性能能好的服务器承担更多的用户请求，nacos提供了权重配置来控制访问率：权重越大、访问率越高。

注意： 权重为0的服务永远不会被访问。

4. 环境隔离

nacos提供了namespace来实现环境隔离功能。

• nacos中可以有多个namespace
• namespace下可以有group、service等
• 不同namespace之间相互隔离（不同namespace的服务互相不可见）

1. 创建 namespace

nacos默认的namespace是：public

命名空间

nacos创建命名空间流程：

2. 配置命名空间

spring:
  cloud:
    nacos:
      discovery:
        namespace: e11eb3bc-8eed-4cdd-93f0-7a6c01b85eb4 # 命名空间，填id

spring:
  cloud:
    nacos:
      discovery:
        ephemeral: false # 设置为永久实例

3. 配置管理

nacos不仅可以担任微服务的注册中心，还可以担任配置管理。

统一配置管理

可以使用统一配置管理来处理因为部署的微服务数量过多，配置繁杂等问题。

nacos一方面可以将配置集中管理，另一方可以在配置变更时，及时通知微服务，实现配置的热更新。

注意： 只把那些需要热更新的配置文件交给nacos

1. nacos添加配置文件

data id： 配置文件id：服务名称-profile.后缀名 。

2. 从nacos拉取配置

spring引入了一种新的配置文件：bootstrap.yaml文件，会在application.yml之前被读取，流程如下：

引入nacos-config依赖：

<!--nacos配置管理依赖-->
<dependency>
    <groupid>com.alibaba.cloud</groupid>
    <artifactid>spring-cloud-starter-alibaba-nacos-config</artifactid>
</dependency>

添加bootstrap.yml

spring:
  application:
    name: user # 服务名称
  profiles:
    active: dev #开发环境，这里是dev
  cloud:
    nacos:
      server-addr: localhost:8848 # nacos地址
      config:
        file-extension: yaml # 文件后缀名

这里会根据spring.cloud.nacos.server-addr获取nacos地址，再根据
$spring.application.name-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}作为文件id，来读取配置。

读取nacos配置

    @value("${pattern.dateformat}")
    private string dateformat;

    @getmapping("now")
    public string now() {
        return localdatetime.now().format(datetimeformatter.ofpattern(dateformat));
    }

启动报错： org.springframework.beans.factory.beancreationexception: error creating bean with name xxx

解决方案：

检查 namespace，配置文件与服务要在同一个 namespace 中
名称是否拼错
升级 nacos 版本
@value 切换为 @nacosvalue

配置热更新
配置热更新： 修改nacos中的配置后，微服务中无需重启即可让配置生效。

实现方式：

方式一： 在@value注入的变量所在类上添加注解 @refreshscope
方式二：
使用 @configurationproperties 注解代替@value注解
在 user 服务中，添加一个类，读取patterrn.dateformat属性：

@component
@data
@configurationproperties(prefix = "pattern")
public class patternproperties {
    private string dateformat;
}

在usercontroller中使用这个类代替@value:

@autowired
private patternproperties patternproperties;

@getmapping("now")
public string now() {
    return localdatetime.now().format(datetimeformatter.ofpattern(patternproperties.getdateformat));
}

配置共享

其实微服务启动时，会去nacos读取多个配置文件，因为nacos管理的配置文件不包含环境信息，可以被多个环境共享。

只需要取名的时候，不加上 profile 就能被共享，如下：

配置共享时的优先级：