您现在的位置是:首页 >技术交流 >SpringCloud Eureka 的详细讲解及示意图网站首页技术交流

SpringCloud Eureka 的详细讲解及示意图

尘觉 2024-06-18 12:01:02
简介SpringCloud Eureka 的详细讲解及示意图

目录

SpringCloud Eureka 服务注册与发现

Spring Cloud 组件选型- 图

当前项目架构问题分析-引出Eureka

一图胜千言

问题分析

引入Eureka 项目架构

 解读上图

 Eureka采用了  CS  的设计架构,

创建单机Eureka Server-注册中心

 创建e-commerce-eureka-server-9001 微服务模块[作为注册中心

 修改e-commerce-eureka-server-9001 的pom.xml , 加入依赖

创建resources/application.yml

创建主启动类/EurekaApplication.java

完成测试

 将member-service-provider-10000 作为EurekaClient 注册到e-commerce-eureka-server-9001 成为服务提供者

示意图 

修改member-service-provider-10000 的pom.xml

修改member-service-provider-10000 的resources/application.yml

修改member-service-provider-10000 的com/wyxedu/springcloud/MemberApplication.java

完成测试

微服务注册名配置说明

​编辑 

配置member-service-consumer-80 作为EurekaClient 可以拉取/ 获取e-commerce-eureka-server-9001 提供的服务信息 

架构示意图

 修改member-service-consumer-80 的pom.xml

修改application.yml

修改MemberConsumerApplication.java

完成测试

Service Consumer 、Service Provider 、EurekaServer 的维护机制

 示意图

 Eureka 自我保护模式

自我保护模式理论

自我保证机制/模式说明

测试

禁用自我保护模式(生产环境中, 一般不禁用) 

1. 说修改e-commerce-eureka-server-9001 的application.yml

2. 修改member-service-provider-10000 的application.yml

搭建EurekaServer 集群- 实现负载均衡&故障容错

示意图 

说明

示意图

搭建Eureka Server 集群

 修改pom.xml , 加入依赖

创建resources/application.yml

创建主启动类EurekaApplication9002.java

修改e-commerce-eureka-server-9001 微服务模块

修改hosts 文件

完成测试

 将member-service-provider-10000 注册到EurekaServer 集群(目前2 台)

修改resources/application.yml

完成测试

将member-service-consumer-80 注册到EurekaServer 集群(目前2 台)

修改resources/application.yml

完成测试

 搭建会员中心服务提供方-集群

-- 示意图

创建member-service-provider-10002

创建resources/application.yml

创建启动类MemberApplication10002 

完成测试

注意事项和细节

 配置服务消费端member-service-consumer-80 使用会员中心服务集群

示意图

修改MemberConsumerController.java

 修改CustomizationBean.java

为了看到测试效果,修改服务提供方

如 member-service-provider-10000

完成测试

交替访问member 服务说明:

包依赖配置图

 获取Eureka Server 服务注册信息-DiscoveryClient

先看需求分析示意图

代码实现

测试

Eureka 后续说明


SpringCloud Eureka 服务注册与发现

Spring Cloud 组件选型- 图

2、从上图可以看出, 目前主流的服务注册&发现的组件是Nacos, 但是Eureka 作为一个老牌经典的服务注册&发现技术还是有必要学习一下, 原因

(1) 一些早期的分布式微服务项目使用的是Eureka, 小伙伴在工作中, 完全有可能遇到这种情况

(2) 后期的服务注册&发现组件/技术, 都参考了Eureka 设计和理念, 学习了Eureka 后, 上手Nacos 容易很多,而且理解的更深刻

当前项目架构问题分析-引出Eureka

一图胜千言

问题分析

1.在企业级项目中,服务消费访问请求会存在高并发

2.如果只有一个会员中心-提供服务,可用性差 

3.所以,会员中心提供服务往往是一个集群,也就是说会有多个会员中心-提供服务微服务模块

4.那么这个时候,就存在一个问题就是服务消费方,怎么去发现可以使用的服务

5.当服务消费方,发现了可以使用的服务后(可能是多个,又存在一个问题就是到底调用A服务,还是B 服务的问题,这就引出了服务注册和负载均衡)

6.Eureka 就可以解决上述问题

引入Eureka 项目架构

 解读上图

1. 会员中心-提供服务的,在项目中,会做成集群,提供高可用

2. Eureka Server 有必要的话,也可以做成集群

3. Eureka 包含两个组件∶Eureka Server 和Eureka Client

4. Eureka Server 提供注册服务, 各个微服务节点通过配置启动后,

会在Eureka Server 中进行注册,

这样EurekaServer 中的服务注册表中将会存储所有可用服务节点的信息,

服务节点的信息可以在界面中直观看到。

5. EurekaClient 通过注册中心进行访问, 是一个Java 客户端,用于简化Eureka Server 的交互,

客户端同时也具备一个内置的、使用轮询(round-robin) 负载算法的负载均衡器。

在应用启动后,将会向Eureka Server 发送心跳(默认周期为30 秒)。

如果Eureka Server 在多个心跳周期内没有接收到某个节点的心跳,

EurekaServer 将会从服务注册表中把这个服务节点移除(默认90 秒)

服务治理介绍
1 Eureka 实现服务治理

2 在传统的rpc 远程调用框架中,管理每个服务与服务之间依赖关系比较复杂,管理困难,所以
需要治理服务之间依赖关系

3 服务治理实现服务调用、负载均衡、容错等,实现服务发现与注册。

4 二说分布式开发:

在一个庞大的企业项目之中(业务很负责,用户的访问量很高、信息的保密级别很负责、、、),那么分布式的核心概念实际上非常简单,就是将在一台服务器上完成的计算操作分给两台甚至更多台的主机一起完成,这样的开发模式就成为分布式开发

分布式开发的本质就在于:虽然所有的主机物理上分布了,但是对于用户而言就仿佛是一个整体。我们的java开发人员而言,那么分布式开发的意义是什么呢?,也就是说哪里需要去使用分布式开发,在任何一个项目里面(MVC设计模式),业务操作是最为核心的部分,而所有项目之中你的业务操作是否完成直接决定了你的项目本身是否健壮。

详细请看    什么是分布式开发-百度经验 (baidu.com)

5 服务注册和发现

 Eureka采用了  CS  的设计架构,

Eureka Server 作为服务注册功能的服务器,它是服务注册中心。

 1. 系统中的其他微服务,使用Eureka的客户端连接到Eureka Server并维持心跳连接,通过Eureka Server 来监控系统中各个微服务是否正常运行。

2. 在服务注册与发现中,有一个注册中心。当服务器启动的时候,会把当前自己服务器的信息比如服务地址通讯地址等以别名方式注册到注册中心上。

3. 服务消费者或者服务提供者,以服务别名的方式去注册中心上获取到实际的服务提供
者通讯地址,然后通过RPC调用服务

创建单机Eureka Server-注册中心

 创建e-commerce-eureka-server-9001 微服务模块[作为注册中心

 

 

 

父工程的pom.xml-会做相应变化,管理e-commerce-eureka-server-9001 微服务子模块 

 

注意本篇博客只演示这一遍因为创建项目的步骤一样的就是名字不一样 

 修改e-commerce-eureka-server-9001 的pom.xml , 加入依赖

    <!--引入的依赖可以参考-provider-10000来进行调整-->
    <!--引入相关的依赖: 如果有需要,可以调整-->
    <dependencies>
        <!--引入eureka-server 场景启动器starter: 使用版本仲裁-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <!--引入web-starter 说明我们使用版本仲裁(从父项目继承了版本)
        -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--说明:starter-actuator 是springboot程序的监控系统, 可以实现系统的健康检测
        可以通过http://localhost:9001/actuator 看到相关的连接,和信息
        -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>


        <!--lombok-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

        <!--引入test-starter-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
        <!--引入e_commerce_center-common-api-->
        <dependency>
            <groupId>com.hspedu.springcloud</groupId>
            <artifactId>e_commerce_center-common-api</artifactId>
            <version>${project.version}</version>
        </dependency>
    </dependencies

创建resources/application.yml

server:
  port: 9001

#配置eureka-server
eureka:
  instance:
    hostname: eureka9001.com #服务实例名
  client:
    #配置不向注册中心注册自己
    register-with-eureka: false
    #表示自己就是注册中心,作用就是维护注册服务实例, 不需要去检索服务
    fetch-registry: false
    service-url:
      #设置与eureka server 交互模块, 查询服务和注册服务都需要依赖这个地址
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

创建主启动类/EurekaApplication.java

//@EnableEurekaServer 表示该程序作为 EurekaServer
@EnableEurekaServer
@SpringBootApplication
public class EurekaApplication9001 {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication9001.class, args);
    }
}

完成测试

浏览器: http://localhost:9001

 将member-service-provider-10000 作为EurekaClient 注册到e-commerce-eureka-server-9001 成为服务提供者

示意图 

修改member-service-provider-10000 的pom.xml

<dependencies>
    <!-- 引入eureka-client 依赖-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <!-- 引入e_commerce_center-common-api -->
    <dependency>
        <groupId>com.hspedu.springcloud</groupId>
        <artifactId>e_commerce_center-common-api</artifactId>
        <version>${project.version}</version>
    </dependency>

修改member-service-provider-10000 的resources/application.yml

server:
  port: 10000

spring:
  application:
    name: member-service-provider #配置应用的名称

  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    url: jdbc:mysql://localhost:3306/e_commerce_center_db?useSSL=true&useUnicode=true&characterEncoding=UTF-8
    username: root
    password: 自己的密码

#配置mybatis
mybatis:
  mapper-locations: classpath:mapper/*.xml #指定mapper.xml文件位置
  type-aliases-package: com.wyxedu.springcloud.entity # 实例类所在的包,这样通过类名就可以引用

#配置eureka-client
eureka:
  client:
    register-with-eureka: true #将自己注册到Eureka-Server
    #表示从Eureka-Server 抓取注册信息
    #如果是单节点,是可以不配置的,但是如果是一个集群,则必须配置true,
    #才能配合Ribbon使用负载均衡
    fetch-registry: true
    service-url:
      #表示将自己注册到哪个eureka-server
      #将本微服务注册到多个eureka-server ,使用逗号间隔即可
      defaultZone: http://eureka9001.com:9001/eureka

修改member-service-provider-10000 的com/wyxedu/springcloud/MemberApplication.java

//@EnableEurekaClient: 将该程序标识为eureka-client
@EnableEurekaClient
@SpringBootApplication
public class MemberApplication10000 {
    public static void main(String[] args) {
        SpringApplication.run(MemberApplication10000.class, args);
    }
}

完成测试

1 启动e-commerce-eureka-server-9001

2 启动member-service-provider-10000

3 浏览器: http://localhost:9001

微服务注册名配置说明

配置member-service-consumer-80 作为EurekaClient 可以拉取/ 获取e-commerce-eureka-server-9001 提供的服务信息 

架构示意图

 修改member-service-consumer-80 的pom.xml

<dependencies>
    <!-- 引入eureka-client 依赖-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <!-- 引入e_commerce_center-common-api -->
    <dependency>
        <groupId>com.hspedu.springcloud</groupId>
        <artifactId>e_commerce_center-common-api</artifactId>
        <version>${project.version}</version>
    </dependency>

修改application.yml

server:
  port: 80
spring:
  application:
    name: e-commerce-consumer-openfeign-80
#eureka 客户端配置
#配置eureka-client
eureka:
  client:
    register-with-eureka: true #将自己注册到Eureka-Server
    fetch-registry: true
    service-url:
      #表示将自己注册到哪个eureka-server
      #这里我们将本微服务注册到EurekaServer 集群,使用逗号间隔
      defaultZone: http://eureka9001.com:9001/eureka

修改MemberConsumerApplication.java

@SpringBootApplication
@EnableEurekaClient
//启动OpenFeignClient
@EnableFeignClients
public class MemberConsumerOpenfeignApplication {
    public static void main(String[] args) {
        SpringApplication.run(MemberConsumerOpenfeignApplication.class, args);
    }
}

完成测试

1 启动e-commerce-eureka-server-9001

2 启动member-service-consumer-80

3 浏览器: http://localhost:9001

Service Consumer 、Service Provider 、EurekaServer 的维护机制

 示意图

 Eureka 自我保护模式

自我保护模式理论

在默认情况下, Eureka 启动了自我保护模式(如图红字, 需要刷新页面, 可以看到)

自我保证机制/模式说明

1. 默认情况下EurekaClient定时向EurekaServer端发送心跳包

2.如果Eureka在server端在一定时间内(默认90秒)没有收到EurekaClient发送心跳包,

便会直接从服务注册列表中剔除该服务

3.  如果Eureka 开启了自我保护模式/机制, 那么在短时间(90秒中)

内丢失了大量的服务实例心跳,这时候EurekaServer会开启自我保护机制,

不会剔除该服务(该现象可能出现在如果网络不通或者阻塞) 因为客户端还能正常发送心跳,

只是网络延迟问题,而保护机制是为了解决此问题而产生的

4.. 自我保护是属于CAP 里面的AP 分支, 保证高可用和分区容错性

5.. 自我保护模式是—种应对网络异常的安全保护措施。

它的架构哲学是宁可同时保留所有微服务(健康的微服务和不健康的微服务都会保留

也不盲目注销任何健康的微服务。使用自我保护模式, 可以让Eureka 集群更加的健壮、稳定。

参考:https://blog.csdn.net/wangliangluang/article/details/120626014 

测试

启动member-service-provider-10000 和e-commerce-eureka-server-9001
让member-service-provider-10000 正确的注册
然后关闭member-service-provider-10000
观察注册的member-service-provider-10000 服务是否还在.

禁用自我保护模式(生产环境中, 一般不禁用) 

1. 说修改e-commerce-eureka-server-9001 的application.yml

server:
  port: 9001

#配置eureka-server
eureka:
  instance:
    hostname: eureka9001.com #服务实例名
  client:
    #配置不向注册中心注册自己
    register-with-eureka: false
    #表示自己就是注册中心,作用就是维护注册服务实例, 不需要去检索服务
    fetch-registry: false
    service-url:
      #设置与eureka server 交互模块, 查询服务和注册服务都需要依赖这个地址
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
  server:
    #禁用自我保护模式
    enable-self-preservation: false
    #设置超时时间为2秒,在2秒钟,收不到心跳包,就认为是超时
    eviction-interval-timer-in-ms: 2000

2. 修改member-service-provider-10000 的application.yml

#配置eureka-client
eureka:
  client:
    register-with-eureka: true #将自己注册到Eureka-Server
    #表示从Eureka-Server 抓取注册信息
    #如果是单节点,是可以不配置的,但是如果是一个集群,则必须配置true,
    #才能配合Ribbon使用负载均衡
    fetch-registry: true
    service-url:
      #表示将自己注册到哪个eureka-server
      #将本微服务注册到多个eureka-server ,使用逗号间隔即可
      defaultZone: http://eureka9001.com:9001/eureka
  instance:
    #客户端向服务端发送心跳的时间间隔 1s(默认是30)
    lease-renewal-interval-in-seconds: 1
    #服务端收到最后一次心跳后等待的时间上限
    #时间单位(秒),默认是90s, 超时将剔除服务
    lease-expiration-duration-in-seconds: 2

3. 启动e-commerce-eureka-server-9001 和member-service-provider-10000

4. 在member-service-provider-10000 注册成功后,再关闭, 看看eureka server服务注册信息的变化 

 

提醒:测试完毕后,别忘了恢复原状,启用自我保护 

搭建EurekaServer 集群- 实现负载均衡&故障容错

为什么需要集群Eureka Server

示意图 

说明

1. 微服务RPC 远程服务调用最核心的是实现高可用

2. 如果注册中心只有1 个,它出故障,会导致整个服务环境不可用

3. 解决办法∶搭建Eureka 注册中心集群,实现负载均衡+故障容错 

示意图

搭建Eureka Server 集群

创建e-commerce-eureka-server-9002 微服务模块[作为注册中心]

创建步骤参考e-commerce-eureka-server-9001

 修改pom.xml , 加入依赖

    <!--引入相关的依赖: 如果有需要,可以调整-->
    <dependencies>
        <!--引入eureka-server 场景启动器starter: 使用版本仲裁-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <!--引入web-starter 说明我们使用版本仲裁(从父项目继承了版本)
        -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--说明:starter-actuator 是springboot程序的监控系统, 可以实现系统的健康检测
        可以通过http://localhost:9002/actuator 看到相关的连接,和信息
        -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>


        <!--lombok-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

        <!--引入test-starter-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
        <!--引入e_commerce_center-common-api-->
        <dependency>
            <groupId>com.hspedu.springcloud</groupId>
            <artifactId>e_commerce_center-common-api</artifactId>
            <version>${project.version}</version>
        </dependency>
    </dependencies>

创建resources/application.yml

server:
  port: 9002

#配置eureka-server
eureka:
  instance:
    hostname: eureka9002.com #服务实例名
  client:
    #配置不向注册中心注册自己
    register-with-eureka: false
    #表示自己就是注册中心,作用就是维护注册服务实例, 不需要去检索服务
    fetch-registry: false
    service-url:
      #这里注册到eureka9001 server
      defaultZone: http://eureka9001.com:9001/eureka/

创建主启动类EurekaApplication9002.java

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

修改e-commerce-eureka-server-9001 微服务模块

server:
  port: 9001

#配置eureka-server
eureka:
  instance:
    hostname: eureka9001.com #服务实例名
  client:
    #配置不向注册中心注册自己
    register-with-eureka: false
    #表示自己就是注册中心,作用就是维护注册服务实例, 不需要去检索服务
    fetch-registry: false
    service-url:
      #设置与eureka server 交互模块, 查询服务和注册服务都需要依赖这个地址
      #defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
      #相互注册,这里应该注册到eureka server9002
      defaultZone: http://eureka9002.com:9002/eureka/

修改hosts 文件

1. 文件: C:WindowsSystem32driversetchost
2. 文件可以先拷贝到桌面,修改后,再拷贝会去
3. 加入内容

#eureka 主机名和ip 映射
127.0.0.1 eureka9001.com
127.0.0.1 eureka9002.com

完成测试

1 启动e-commerce-eureka-server-9001

2 启动e-commerce-eureka-server-9002

3 浏览器: http://eureka9001.com:9001 浏览器: http://eureka9002.com:9002

 

 将member-service-provider-10000 注册到EurekaServer 集群(目前2 台)

修改resources/application.yml

service-url:
# defaultZone: http://localhost:9001/eureka #表示将自己注册到哪个eurekaServer
# 将本微服务注册到多个eurekaServer, 使用逗号隔开
defaultZone: http://eureka9001.com:9001/eureka,http://eureka9002.com:9002/eureka

完成测试

1. 启动e-commerce-eureka-server-9001 和e-commerce-eureka-server-9002
2. 启动member-service-provider-10000
3. 观察member-service-provider-10000 是否注册到Eureka 集群(目前2 台)

浏览器输入: http://eureka9001.com:9001/

浏览器输入: http://eureka9002.com:9002/

将member-service-consumer-80 注册到EurekaServer 集群(目前2 台)

修改resources/application.yml

service-url:
# defaultZone: http://localhost:9001/eureka #表示将自己注册到哪个eurekaServer
# 将本微服务注册到多个eurekaServer, 使用逗号隔开
defaultZone: http://eureka9001.com:9001/eureka,http://eureka9002.com:9002/eureka

完成测试

1. 启动e-commerce-eureka-server-9001 和e-commerce-eureka-server-9002
2. 启动member-service-provider-10000
3. 观察member-service-provider-10000 是否注册到Eureka 集群(目前2 台)

浏览器输入: http://eureka9001.com:9001/

浏览器输入: http://eureka9002.com:9002/

 搭建会员中心服务提供方-集群

-- 示意图

创建member-service-provider-10002

1. 参考member-service-provider-10000 来创建member-service-provider-10002 即可

2. 创建好后, 使用member-service-provider-10000 的源码和配置替换member-service-provider-10002 生成的代码(不要到磁盘整体拷贝,会出现关联到member-service-provider-10000 的问题,很麻烦,可以创建好新项目的包,然后再拷贝对应包下的文件,就不会出问题)

3. 提醒,拷贝时不要忘记拷贝resources/mapper/MemberMapper.xml 这些xxx.xml 文件 

创建resources/application.yml

1. 创建好application.yml
2. 从member-service-provider-10000 拷贝application.yml 的内容
3. 修改端口号即可

server:
port: 10002

创建启动类MemberApplication10002 

//@EnableEurekaClient: 将该程序标识为eureka-client
@EnableEurekaClient
@SpringBootApplication
public class MemberApplication10002 {
    public static void main(String[] args) {
        SpringApplication.run(MemberApplication10002.class, args);
    }
}

完成测试

1 启动eureka server 集群(目前2 台)

2 启动member-service-provider-10000

3 启动member-service-provider-10002

完成测试

浏览器输入: http://eureka9001.com:9001/


浏览器输入: http://eureka9002.com:9002/

注意事项和细节

1. 因为member-service-provider-10000 和member-service-provider-10002 作为一个集群提供服务, 因此需要将spring.application.name 进行统一

2. 这样消费方通过统一的别名进行负载均衡调用 

将member-service-provider-10000 和member-service-provider-10002的名字统一成member-service-provider进行负载均衡调用

spring:
  application:
    name: member-service-provider #配置应用的名称

 配置服务消费端member-service-consumer-80 使用会员中心服务集群

示意图

修改MemberConsumerController.java

// 文件位置: member-service-consumer-80 模块
com/springcloud/controller/MemberConsumerController.java 

@RestController
@Slf4j
public class MemberConsumerController {

    //定义member_service_provider_url 这是一个基础url地址
    //使用shift+ctrl+u 进行字母大小写的切换
    /**
     * 说明:
     * 1. MEMBER-SERVICE-PROVIDER 就是服务提供方[集群], 注册到Eureka Server 的名称
     * 2. 也就是服务提供方[集群]对外暴露的名称为 MEMBER-SERVICE-PROVIDER
     * 3. MEMBER-SERVICE-PROVIDER 目前有 两个 Availability Zones member-service-provider:10000
     *    还有一个 member-service-provider:10002
     *    需要增加一个注解@LoadBalanced 赋予 RestTemplate 负载均衡的能力,也就是会根据你的负载均衡算法
     *    来选择某个服务去访问, 默认是轮询算法, 当然我们也可以自己配置负载均衡算法
     */
    public static final String MEMBER_SERVICE_PROVIDER_URL =
            "http://MEMBER-SERVICE-PROVIDER"; //后面这里地方会修改成提供服务模块的注册别名
    //装配RestTemplate bean/对象
    @Resource
    private RestTemplate restTemplate;

    //装配DiscoveryClient
    @Resource
    private DiscoveryClient discoveryClient;

 修改CustomizationBean.java

//文件位置:member-service-consumer-80 模块

@Configuration
public class CustomizationBean {

    //说明: 配置注入RestTemplate bean/对象
    //这里的@LoadBalanced 就是赋予 RestTemplate 负载均衡的能力
    //默认是使用轮询算法来访问远程调用接口/地址
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
}

为了看到测试效果,修改服务提供方

如 member-service-provider-10000

1. 在两个服务提供方的查询和添加返回结果处增加自己服务名称信息, 其它位置可参考加入

    @GetMapping(value = "/member/get/{id}")
    public Result getMemberById(@PathVariable("id") Long id) {
        Member member = memberService.queryMemberById(id);
        log.info("查询结果= " + member);
        if (member != null) {
            return Result.success("查询成功member-service-provider-10000", member);
        } else {
            return Result.error("402", "ID= " + id + " 不存在");
        }
    }

完成测试

1 启动eureka server 集群(目前2 台)

2 启动member-service-provider-10000

3 启动member-service-provider-10002

http://localhost:10000/member/get/1

 http://localhost:10002/member/get/1

启动member-service-consumer-80 

浏览器访问: http://localhost/member/consumer/get/1

再次访问,会看到访问到不同的服务. 

交替访问member 服务说明:

1. 注解@LoadBalanced 底层是Ribbon 支持算法

2.Ribbon 和Eureka整合后consumer 直接调用服务而不用再关心地址和端口号,且该服务还有负载功能 

包依赖配置图

1.spring-cloud-starter-netflix-eureka-client 自带
spring-cloud-starter-netflix-ribbon(如图)

 获取Eureka Server 服务注册信息-DiscoveryClient

先看需求分析示意图

这里我们以服务消费方, 去获取Eureka Server 的服务注册信息为例讲解 

当然也可以在服务提供方获取Eureka Server 的服务注册信息

代码实现

1. 所在模块member-service-consumer-80
2. 修改controller/MemberConsumerController.java 

    //装配DiscoveryClient
    @Resource
    private DiscoveryClient discoveryClient;


    @GetMapping("/member/consumer/discovery")
    public Object discovery() {

        List<String> services = discoveryClient.getServices();
        //遍历services
        for (String service : services) {
            log.info("服务名={}",service);
            List<ServiceInstance> instances = discoveryClient.getInstances(service);
            for (ServiceInstance instance : instances) {
                log.info("id={},host={},port={},uri={}",
                        instance.getServiceId(),instance.getHost(),instance.getPort(),instance.getUri());

            }
        }
        return discoveryClient;
    }

这样配置之后还要在主启动类开启

//@EnableEurekaClient 将程序标识为eureka client
@EnableEurekaClient
@SpringBootApplication
@EnableDiscoveryClient //启用服务发现
public class MemberConsumerApplication {
    public static void main(String[] args) {

        SpringApplication.run(MemberConsumerApplication.class,args);
    }
}

测试

1. 重启member-service-consumer-80
2. 浏览器输入http://localhost/member/consumer/discovery


后台信息:

注意事项和细节说明
1. 在引入DiscoveryClient 时,不要引入错误的包

正确的包: import org.springframework.cloud.client.discovery.DiscoveryClient;
错误的包: import com.netflix.discovery.DiscoveryClient; 

2. 演示的是在服务消费方使用DiscoveryClient 来完成服务发现,同样,在服务提供方/模块也OK

Eureka 后续说明

1. Eureka 停更说明: https://github.com/Netflix/eureka/wiki 

2. 对于一些早期使用Eureka 项目,掌握技术基本可以应付了(这也是为什么还要学Eureka 的原因) 

3. 目前替代Eureka 做服务注册和发现, 均衡负载的最佳组件是Spring Cloud AlibabaNacos , 后面会重点讲解.

4. 虽然Eureka 停更,目前用的不多,但是它的服务注册和发现, 均衡负载的思想是优先的,有了Eureka 的基础,我们学习Spring Cloud Alibaba Nacos 会轻松很多.

风语者!平时喜欢研究各种技术,目前在从事后端开发工作,热爱生活、热爱工作。