公司网站备案多少钱,企业年金,wordpress 编辑器字体,网络平台创建需要多少钱3. Spring Cloud Eureka 服务注册与发现(超详细说明及使用) 文章目录 3. Spring Cloud Eureka 服务注册与发现(超详细说明及使用)前言1. Spring Cloud Eureka 的概述1.1 服务治理概述1.2 服务注册与发现 2. 实践#xff1a;创建单机 Eureka Server 注册中心2.1 需求说明 图解…3. Spring Cloud Eureka 服务注册与发现(超详细说明及使用) 文章目录 3. Spring Cloud Eureka 服务注册与发现(超详细说明及使用)前言1. Spring Cloud Eureka 的概述1.1 服务治理概述1.2 服务注册与发现 2. 实践创建单机 Eureka Server 注册中心2.1 需求说明 图解2.3 具体实现步骤2.3.1 创建相关的 Moduel 以及 完成配置2.3.2 配置 member-service-consumer-80 作为 EurekaClient 可 以 拉 取/获取 e-commerce-eureka-server-9001 提供的服务信息2.3.3 架构示意图2.3.4 将 member-service-provider-10000 作为 EurekaClient 注册到 e-commerce-eureka-server-9001 成为服务提供者2.3.5 架构示意图 3. Service Consumer 、Service Provider 、EurekaServer 的维护机制4. Eureka 自我保护模式4.1 自我保护模式理论4.2 禁用自我保护模式(生产环境中, 一般不禁用) 5. 搭建 EurekaServer 集群- 实现负载均衡故障容错5.1 为什么需要集群 Eureka Server5.2 需求分析/图解5.3 搭建 Eureka Server 集群 6. 补充定义本地的域名机制5.4 搭建会员中心服务提供方-集群5.5 配置服务消费端 member-service-consumer-80 使用会员中心服务集群5.6 获取 Eureka Server 服务注册信息 - DiscoveryClient5.5.1 具体操作步骤5.5.1.1 注意事项和细节说明 7. Eureka 后续说明8. 总结9. 最后 前言 对应上一篇学习内容2. Spring Cloud 微服务基础环境搭建_搭建cloud微服务-CSDN博客对应下一篇学习内容 4. Spring Cloud Ribbon 实现“负载均衡”的详细配置说明-CSDN博客 1. Spring Cloud Eureka 的概述
从上个学习内容上我们可以知道 补充, 当中的 、Spring Cloud 组件选型- 图 从上图可以看出目前主流的服务注册/发现的组件是 Nacos但是Eureka 作为一个老牌经典的服务 注册/发现技术还是有必要回顾一下 原因
一些早期的分布式 微服务项目使用的是 Eureka 大家工作中完全有可能遇到这种情况。后期的服务注册/发现组件/技术都参考了 Eureka 的设计和理念学习了 Eureka 后我们上手 Nacos 容易很多而且理解的更深刻。
分析上述我们上一篇内容补充 当中项目架构问题分析 当前项目问题分析
在企业项目中服务消费访问请求会存在高并发如果只有一个会议中心-提供服务可用性就比较差了所以会议中心提供服务往往是一个集群也就是说会有多个会议中心-提供服务微服务模块那么这个时候就存在一个问题就是服务消费方怎么去发现可以使用的服务(哪些服务又不可以使用)当服务消费方发现了可以使用的服务后(可能是多个又存在一个问题就是到底调用 A服务 还是调用B服务这就引出了服务注册和负载均衡的问题)Eureka 就可以解决上述问题
引入 Eureka 项目架构一图胜千言 上图 Eureka 项目架构图解析
会员中心—— 提供服务的在项目中会做成集群 提供高可用Eureka Server 有必要的话也可以做成集群 。Eureka 包含两个组件: Eureka Server 和 Eureka ClientEureka Server 提供注册服务各个微服务节点童工配置启动后会在 EurekaServer 中进行注册 这样Eureka Server 中的服务注册表中将会存储所有可用服务节点的信息服务节点的信息可以在界面中直观看到。Eureka Client 通过注册中心进行访问是一个Java客户端用于简化 Eureka Server 的交互 客户端同时也具备一个内置的使用轮询(round-robin) 负载算法的负载均衡器。在应用启动后 将会向 Eureka Server 发送心跳(默认周期为 30秒)。如果 Eureka Server 在多个心跳周期 内没有接收到某个节点的心跳Eureka Server 将会从服务注册表中把这个服务节点移除(默认90秒)
1.1 服务治理概述
Eureka 实现服务治理
在传统的 rpc 远程调用框架中管理每个服务与服务之间依赖关系比较复杂管理困难所以 需要治理服务之间依赖关系
服务治理实现服务调用、负载均衡、容错等实现服务发现与注册。
二说分布式开发: https://jingyan.baidu.com/article/46650658def479f549e5f83e.html
1.2 服务注册与发现 Eureka 采用了CS[client-server-java] 基础我们讲过一个多人聊天项目。的设计架构 Eureka Server 作为服务注册的服务器它是服务注册中心 系统中的其它微服务使用Eureka 的客户端连接到 Eureka Server 并维持心跳连接 通过 Eureka Server 来监控系统中各个微服务是否正常运行 在服务注册与发现中有一个注册中心当服务启动的时候会把当前自己服务器的信息比如服务地址通讯地址等以别名方式注册到注册中心上。 服务消费者或者服务提供者以服务别名的方式去注册中心上获取到实际的服务提供 者通讯地址然后通过 RPC 调用服务
2. 实践创建单机 Eureka Server 注册中心
2.1 需求说明 图解 2.3 具体实现步骤
2.3.1 创建相关的 Moduel 以及 完成配置
创建 e-commerce-eureka-server-9001 微服务模块[作为注册中心] 父工程的 pom.xml-会做相应变化管理 e-commerce-eureka-server-9001 微服务子模块 修改 e-commerce-eureka-server-9001 的 pom.xml , 加入依赖
?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdparentartifactIde-commerce-center/artifactIdgroupIdcom.rainbowsea/groupIdversion1.0-SNAPSHOT/version/parentmodelVersion4.0.0/modelVersionartifactIde-commerce-eureka-server-9001/artifactIddependencies!-- 引入web-starter 说明:这里我们使用版本仲裁(从父项目继承了版本)--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependency!--1. starter-actuator 是sprng boot 程序的监控系统,可以实现健康检查,info 信息等2. 访问http://localhost:10000/actuator 可以看到相关链接,还可以做相关配置--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-actuator/artifactId/dependency!-- 引入 eureka-server 场景启动器 starter: 使用版本仲裁注意不要搞错了有一个 starter 的--dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-netflix-eureka-server/artifactId/dependency!-- lombok 引入--dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId!-- 不进行转递依赖--optionaltrue/optional/dependencydependencygroupIdjunit/groupIdartifactIdjunit/artifactId/dependency!-- 引入 test-starter --dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency!-- 引入我们自己对 bean 封装成 api 的模块内容--dependencygroupIdcom.rainbowsea/groupIdartifactIde_commerce_center-common-api/artifactIdversion${project.version}/version/dependency/dependencies/project创建 resources/application.yml server:port: 9001
# 配置 eureka-server
eureka:instance:hostname: localhost # 服务实例名或者别名client:# 配置不向注册中心注册自己,默认是 trueregister-with-eureka: false# 表示自己就是注册中心作用就是维护注册服务实例不需要去检索服务默认是 truefetch-registry: falseservice-url:#设置与 eureka server 交互的模块,查询服务和注册服务都需要依赖这个地址# defaultZone: http://localhost:9001/eureka/ ,也可以使用别名在同一个文件当中可以引用defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ 特别说明注意这里从架构图上可以知道的是这里的这个e-commerce-eureka-server-9001 充当为 Eureka Server 服务角色 所以自然我们需要将其配置为 服务角色。 创建主启动类 com/rainbwosea/springcloud/EurekaApplication.java
package com.rainbowsea.springcloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;EnableEurekaServer // EnableEurekaServer 表示该项目/该模块/该程序作为 Eureka Server 角色进行运行
SpringBootApplication
public class EurekaApplication9001 {public static void main(String[] args) {SpringApplication.run(EurekaApplication9001.class, args);}
}
完成测试 补充说明 Spring Eureka 完整的可视化页面展示 2.3.2 配置 member-service-consumer-80 作为 EurekaClient 可 以 拉 取/获取 e-commerce-eureka-server-9001 提供的服务信息
2.3.3 架构示意图 配置 member-serivce-consumer-10000 作为 EurekaClient 注册发现到 commerce-eureka-server-9001 服务当中我们需要在 resource目录下的 application.yaml 文件当进行一个配置。如下图所示
配置 member-serivce-consumer-80 作为 EurekaClient 注册发现到 commerce-eureka-server-9001 服务当中我们需要在 resource目录下的 application.yaml 文件当进行一个配置。如下图所示 server:port: 80 # 浏览器默认就是 80 端口spring:application:name: member-service-consumer-80 # 该项目/模块名称eureka:client:register-with-eureka: true # 表示将自己注册到 Eureka-Server 当中fetch-registry: true # 表示将信息发送到 Eureka-Server 当中service-url:# 表示将自己注册到那个 eureka-serverdefaultZone: http://localhost:9001/eureka 同时我们也需要将该 member-service-consumer-80项目配置指明为是 Eureka Client 角色在该项目的场景启动器上添加 注解即可 。 package com.rainbowsea.springcloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;// 如果错误: 加入排除 DataSourceAutoConfiguration 自动配置
//SpringBootApplication(exclude DataSourceAutoConfiguration.class)
EnableEurekaClient //表示将项目/模块/程序 标注作为 Eureka Client
SpringBootApplication
public class MemberConsumerApplication80 {public static void main(String[] args) {SpringApplication.run(MemberConsumerApplication80.class, args);}
}
运行测试 注意测试的时候我们尽量先将 EukekatServer (也就是我们这里的 e-commerce-eureka-server-9001) 注册中心启动然后再将 Eukekat Client(也就是我们这里的 member-service-consumer-80) 启动。 然后打开浏览器输入http://localhost:9001/ 查看结果。 2.3.4 将 member-service-provider-10000 作为 EurekaClient 注册到 e-commerce-eureka-server-9001 成为服务提供者
上述操作我们是已经将 定义为了一个 Eureka Server 服务器那么我们就需要将 服务提供者 注册到我们的 Eureka Server 当中。注册到 Eureka Server 当中换句话说就是将我们 Eureka Client 告诉 Eureka Server 我还没有宕机还活着我还可以继续提供服务下去。
2.3.5 架构示意图 配置 member-service-provider-10000 作为 EurekaClient 注册发现到 commerce-eureka-server-9001 服务当中我们需要在 resource目录下的 application.yaml 文件当进行一个配置。如下图所示 server:port: 10000
spring:application:name: member-service-provider-10000 # 配置应用的名称datasource:type: com.alibaba.druid.pool.DruidDataSource # 配置 alibaba 的数据库连接池password: MySQL123username: rooturl: jdbc:mysql://localhost:3306/e_commerce_center_db?useSSLtrueuseUnicodetruecharacterEncodingUTF-8
mybatis:mapper-locations: classpath:mapper/*.xml # 指定 mapper.xml 文件位置 classpath 表示 resources 目录下type-aliases-package: com.rainbowsea.springcloud.entity # 实例 bean 类所在的包,这样可以通过类名的方式# 配置 eureka-client
eureka:client:register-with-eureka: true # 表示将自己注册到 Eureka-Server# 表示从 Eureka-Server 抓取注册信息# 如果是单节点是可以配置的但是如果是一个集群则必须配置true# 才能配合 Ribbon 使用负载均衡fetch-registry: trueservice-url:# 表示将自己注册到那个 eureka-serverdefaultZone: http://localhost:9001/eureka
同时我们也需要将该 member-service-provider-10000项目配置指明为是 Eureka Client 角色在该项目的场景启动器上添加 注解即可 。 package com.rainbowsea.springcloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;EnableEurekaClient 表示将该程序/项目/模块 标识为 eureka-client 端
EnableEurekaClient
SpringBootApplication
public class MemberApplication10000 {public static void main(String[] args) {SpringApplication.run(MemberApplication10000.class, args);}
}
测试
启动 e-commerce-eureka-server-9001启动 member-service-provider-10000浏览器: http://localhost:9001 3. Service Consumer 、Service Provider 、EurekaServer 的维护机制
示图 4. Eureka 自我保护模式
4.1 自我保护模式理论
在默认情况下 Eureka 启动了自我保护模式(如图红字, 需要刷新页面, 可以看到) 默认情况下EurekaClient 定时向 EurekaServer 端发送 心跳包 如果 Eureka 在 server 端一定时间内(默认90秒) 没有收到 EurekaClient 发送心跳包便会 直接从服务注册表中剔除该服务 如果Eureka 开启了**“自我保护机制/模式”** ,那么在短时间(90秒中)内丢失了大量的服务实例心跳。 这时候Eureka Server 会开启自我保护机制不会剔除该服务(该现象可能出现在如果网络不通或者 阻塞)因为客户端还能正常发送心跳只是网络延迟问题而保护机制是为了解决此问题而产生的。 自我保护是属于CAP里面的AP分支 保证高可用和分区容错性 自我保护模式是一种应对网络异常的安全保护措施它的架构哲学是宁可同时保留所有微服务(健康 的微服务和不健康的微服务都会保留)也不盲目注销任何健康的微服务。使用自我保护模式 可以让 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 服务是否还在. 4.2 禁用自我保护模式(生产环境中, 一般不禁用)
演示禁用自我保护模式
修改 e-commerce-eureka-server-9001 的 application.yml 修改 member-service-provider-10000 的 application.yml 启 动 e-commerce-eureka-server-9001 和 member-service-provider-10000 在 member-service-provider-10000 注册成功后再关闭 看看 eureka server 服务注册信息的变化 提醒测试完毕后别忘了恢复原状启用自我保护
5. 搭建 EurekaServer 集群- 实现负载均衡故障容错
5.1 为什么需要集群 Eureka Server
示意图(上图) 为什么需要集群 Eureka Server 说明: 微服务 RPC 远程服务调用最核心的是实习高可用如果注册中心只有1个它出故障会导致整个服务环境不可用解决办法: 搭建 Eureka 注册中心集群实习 负载均衡 故障容错 5.2 需求分析/图解 5.3 搭建 Eureka Server 集群
1. 创建 e-commerce-eureka-server-9002 微服务模块[作为注册中心] 修改 pom.xml , 加入依赖 ?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdparentartifactIde-commerce-center/artifactIdgroupIdcom.rainbowsea/groupIdversion1.0-SNAPSHOT/version/parentmodelVersion4.0.0/modelVersionartifactIde-commerce-eureka-server-9002/artifactIddependencies!-- 引入web-starter 说明:这里我们使用版本仲裁(从父项目继承了版本)--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependency!--1. starter-actuator 是spring boot 程序的监控系统,可以实现健康检查,info 信息等2. 访问http://localhost:9002/actuator 可以看到相关链接,还可以做相关配置--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-actuator/artifactId/dependency!-- 引入 eureka-server 场景启动器 starter: 使用版本仲裁注意不要搞错了有一个 starter 的--dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-netflix-eureka-server/artifactId/dependency!-- lombok 引入--dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId!-- 不进行转递依赖--optionaltrue/optional/dependencydependencygroupIdjunit/groupIdartifactIdjunit/artifactId/dependency!-- 引入 test-starter --dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency!-- 引入我们自己对 bean 封装成 api 的模块内容--dependencygroupIdcom.rainbowsea/groupIdartifactIde_commerce_center-common-api/artifactIdversion${project.version}/version/dependency/dependencies/project创建 resources/application.yml server:port: 9002
# 配置 eureka server
eureka:instance:hostname: eureka9002.com # 服务实例名/或者叫别名client:# 配置不向注册中心注册自己(因为自己就是注册中心)默认是 trueregister-with-eureka: falsefetch-registry: falseservice-url:#设置与 eureka server 交互的模块,查询服务和注册服务都需要依赖这个地址# defaultZone: http://localhost:9001/eureka/ ,也可以使用别名在同一个文件当中可以引用# 相互注册这里应用注册到 eureka server 9001 上defaultZone: http://eureka9001.com:9001/eureka/创建主启动类 EurekaApplication9002.java package com.rainbowsea.springcloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;SpringBootApplication
EnableEurekaServer //该注解标注当前的项目/模块/程序作为 Eureka Server 角色
public class EurekaApplication9002 {public static void main(String[] args) {SpringApplication.run(EurekaApplication9002.class, args);}
}
修改 e-commerce-eureka-server-9001 微服务模块修改其中的内容 resources/application.yml
让 e-commerce-eureka-server-9001 微服务模块 与 e-commerce-eureka-server-9002 相互注册 。 server:port: 9001
# 配置 eureka-server
eureka:instance:hostname: eureka9001.com # 服务实例名或者别名client:# 配置不向注册中心注册自己,默认是 trueregister-with-eureka: false# 表示自己就是注册中心作用就是维护注册服务实例不需要去检索服务默认是 truefetch-registry: falseservice-url:#设置与 eureka server 交互的模块,查询服务和注册服务都需要依赖这个地址# defaultZone: http://localhost:9001/eureka/ ,也可以使用别名在同一个文件当中可以引用# 相互注册这里应用注册到 eureka server 9002 上defaultZone: http://eureka9002.com:9002/eureka/
6. 补充定义本地的域名机制
如下图所示 无论是 9001 还是 9002 我们都定义了别名如果想要让定义的别名生效的话我们需要在本地设置域名映射。 设置本地的域名映射需要找到本地电脑当中的 host 文件在该 host文件当中编写添加相应的域名映射。 host文件路径: C:\Windows\System32\drivers\etc\host # 配置 eureka 主机 和 ip 的映射
127.0.0.1 eureka9001.com
127.0.0.1 eureka9002.com# Copyright (c) 1993-2009 Microsoft Corp.
#
# This is a sample HOSTS file used by Microsoft TCP/IP for Windows.
#
# This file contains the mappings of IP addresses to host names. Each
# entry should be kept on an individual line. The IP address should
# be placed in the first column followed by the corresponding host name.
# The IP address and the host name should be separated by at least one
# space.
#
# Additionally, comments (such as these) may be inserted on individual
# lines or following the machine name denoted by a # symbol.
#
# For example:
#
# 102.54.94.97 rhino.acme.com # source server
# 38.25.63.10 x.acme.com # x client host# localhost name resolution is handled within DNS itself.
# 127.0.0.1 localhost
# ::1 localhost127.0.0.1 account.wondershare.com
# 配置 eureka 主机 和 ip 的映射
127.0.0.1 eureka9001.com
127.0.0.1 eureka9002.com 特别提醒如果发现文件修改后无法保存那么可以将文件复制到桌面上然后修改复制到桌面上的那份复制过来的 host 文件修改保存完后再拷贝回原来路径位置进行一个替换。
运行测试
启动 e-commerce-eureka-server-9001启动 e-commerce-eureka-server-9002浏览器: http://eureka9001.com:9001 浏览器: http://eureka9002.com:9002 将 member-service-consumer-80 注册到 EurekaServer 集群(目前 2 台)
修改 member-service-consumer-80 模块当中的resources/application.yml 启动 e-commerce-eureka-server-9001 和 e-commerce-eureka-server-9002启动 member-service-consumer-80观察 member-service-consumer-80 是否注册到 Eureka 集群(目前 2 台) 浏览器输入: http://eureka9001.com:9001/ 5.4 搭建会员中心服务提供方-集群 创建 member-service-provider-10002
参考 member-service-provider-10000 来创建 member-service-provider-10002 即可
创 建 好 后 使 用 member-service-provider-10000 的 源 码 和 配 置 替 换 member-service-provider-10002 生成的代码
(不要到磁盘整体拷贝会出现关联到 member-service-provider-10000 的问题很麻烦, 可以创建好新项目的包然后再拷贝对应包下的文件就不会出问题)
提醒拷贝时不要忘记拷贝 resources/mapper/MemberMapper.xml 这些 xxx.xml 文 件。
创建 resources/application.yml
创建好 application.yml
从 member-service-provider-10000 拷贝 application.yml 的内容
修改端口号即可 server:port: 10002
spring:application:name: member-service-provider # 配置应用的名称datasource:type: com.alibaba.druid.pool.DruidDataSource # 配置 alibaba 的数据库连接池password: MySQL123username: rooturl: jdbc:mysql://localhost:3306/e_commerce_center_db?useSSLtrueuseUnicodetruecharacterEncodingUTF-8
mybatis:mapper-locations: classpath:mapper/*.xml # 指定 mapper.xml 文件位置 classpath 表示 resources 目录下type-aliases-package: com.rainbowsea.springcloud.entity # 实例 bean 类所在的包,这样可以通过类名的方式# 配置 eureka-client
eureka:client:register-with-eureka: true # 示将自己注册到 Eureka-Server,因为自己是作为 eureka-client客户端的角色的# 表示从 Eureka-Server 抓取注册信息# 如果是单节点是可以配置的但是如果是一个集群则必须配置true# 才能配合 Ribbon 使用负载均衡fetch-registry: trueservice-url:# 表示将自己注册到那个 eureka-server# 将本微服务注册到多个 eureka - server 当中使用逗号间隔即可defaultZone: http://eureka9001.com:9001/eureka/,http://eureka9002.com:9002/eureka/创建主启动类名(场景启动器) 启动 eureka server 集群(目前 2 台)
启动 member-service-provider-10000
启动 member-service-provider-10002
浏览器输入: http://eureka9001.com:9001/ 浏览器输入: http://eureka9002.com:9002/ 5.5 配置服务消费端 member-service-consumer-80 使用会员中心服务集群
因为 member-service-provider-10000 和 member-service-provider-10002 作为一个集 群提供服务, 因此需要将 spring.application.name 进行统一方便用于负载均衡 这样消费方通过统一的别名进行负载均衡调用。
示意图 修改 member-service-consumer-80 模块下的MemberConsumerController.java package com.rainbowsea.springcloud.controller;import com.rainbowsea.springcloud.entity.Member;
import com.rainbowsea.springcloud.entity.Result;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;import javax.annotation.Resource;
import java.util.List;RestController
Slf4j
public class MemberConsumerController {// 定义 MEMBER_SERVICE_PROVIDER_URL 这是一个基础 url地址// 使用 shiftctrlu 进行字母大小写的切换//private static final String MEMBER_SERVICE_PROVIDER_URL http://localhost:10000;// 负载均衡统一别名修改为提供服务模块的注册别名: 不需要配置指明端口号因为是一个负载集群了。不是特指某个了Service 服务来处理了/*server:port: 10000
spring:application:name: member-service-provider # 配置应用的名称*//*说明:1. MEMBER-SERVICE-PROVIDER 就是服务提供方【集群】注册到Eureka Server 的名称2. 也就是服务提供方【集群】对外暴露的名称为 MEMBER-SERVICE-PROVIDER3. MEMBER-SERVICE-PROVIDER 目前有两个 Availability Zones UP (2) - localhost:member-service-provider:10000 , localhost:member-service-provider:10002还有一个 member-service-provider:10002需要增加一个注解 LoadBalanced 赋予 RestTemplate 才能有负载均衡的能力也就是会根据你的负载均衡来选择某个服务去访问默认是“轮询算法”当然我们也可以自己配置负载均衡算法4. 在对应的 RestTemplate 配置类上的Bean注解下面加上 LoadBalanced 注解。*/private static final String MEMBER_SERVICE_PROVIDER_URL http://MEMBER-SERVICE-PROVIDER;// 装配 RestTemplate bean/对象Resourceprivate RestTemplate restTemplate;PostMapping(/member/consumer/save)public ResultMember save(Member member) {// 1.第1个参数: 就是请求的完整的url:MEMBER_SERVICE_PROVIDER_URL /member/save http://localhost:10000/member/save// 表示你向将该请求发送给那个微服务处理注意无论是返回值还是参数 PostMapping() 请求方式都要一一对应上对应处理的微服务上的内容//2. 第2个参数: member : 就是通过 restTemplate 发出的 post 请求携带数据或者对象//3. 第3个参数: Result.class 微服务当中的对应处理的方法的返回值也就是返回对象类型// 注意坑点// 这里通过 restTemplate 调用服务模块的接口就是一个远程调用//log.info(member-service-consumer-80 save member{}, member);return restTemplate.postForObject(MEMBER_SERVICE_PROVIDER_URL /member/save, member, Result.class);}/*1.与PostMapping(/member/save)public Result save(Member member) {int affected memberService.save(member);if (affected 0) { // 说明添加成功return Result.success(添加会员成功, affected);} else {return Result.error(401, 添加会员失败);}}*//*** 方法/接口调用服务接口返回 member 对象信息** param id* return*/GetMapping(/member/consumer/get/{id})public ResultMember getMemberById(PathVariable(id) Long id) {// 这里就用两个参数// 第一个参数因为是查询所以这里我们直接字符串拼接上去// 这里通过return restTemplate.getForObject(MEMBER_SERVICE_PROVIDER_URL /member/get/ id, Result.class);}/*保持一致* 提交方式* 返回类型* 参数* 路径映射要对应上GetMapping(/member/get/{id})public Result getMemberById(PathVariable(id) Long id) {Member member memberService.queryMemberById(id);// 使用 Result 把查询到的结果返回if (member ! null) {return Result.success(查询会员成功, member);} else {return Result.error(402, ID id 不存在);}}*/// 注意有两个是这个包下的 org.springframework.cloud.client.discovery.DiscoveryClientResource // 装配到 Spring ioc 容器当中private DiscoveryClient discoveryClient;// 注意想要获取到服务端信息还需要在SpringBoot 启动场景上加上EnableDiscoveryClient // 启用服务发现 注解才行GetMapping(/member/consumer/discovery)public Object discovery(){ListString services discoveryClient.getServices();// 遍历 servicesfor (String service : services) {log.info(服务名{},service);// 再根据服务名获取更加详细的信息ListServiceInstance instances discoveryClient.getInstances(service);for (ServiceInstance instance : instances) {log.info(id{},host{},uri{},instance.getServiceId(),instance.getHost(),instance.getUri());}}return this.discoveryClient;}
}
为了看到测试效果修改服务提供方
在两个服务提供方的查询和添加返回结果处增加自己服务名称信息如图, 其它位置可参考加入 /*** 这里我们使用 url占位符 PathVariable** param id* return*/GetMapping(/member/get/{id})public Result getMemberById(PathVariable(id) Long id) {Member member memberService.queryMemberById(id);// 使用 Result 把查询到的结果返回if (member ! null) {return Result.success(查询会员成功 member-service-provider-10000 , member);} else {return Result.error(402, ID id 不存在 member-service-provider-10000 );}}
/*** 这里我们使用 url占位符 PathVariable** param id* return*/GetMapping(/member/get/{id})public Result getMemberById(PathVariable(id) Long id) {Member member memberService.queryMemberById(id);// 使用 Result 把查询到的结果返回if (member ! null) {return Result.success(查询会员成功 member-service-provider-10002 , member);} else {return Result.error(402, ID id 不存在 member-service-provider-10002 );}}
特别说明 我们想要能够实现 member 交替访问的话需要在 RestTemplate 配置类上Bean方法上加上该 LoadBalanced注解的)才行。 底层是 Ribbon 支持算法 交替访问 member服务说明
注解LoadBalanced(在RestTemplate 配置类的Bean方法上加上该 LoadBalanced注解的) 底层是 Ribbon 支持算法 Ribbon 和 Eureka 整合后 consumer 直接调用服务而不用再关心地址和端口号且该服务还有负载功能
运行测试
启动 member-service-consumer-80
浏览器访问http://eureka9001.com:9001/ 浏览器访问: http://localhost/member/consumer/get/1 这个是通过客户端 Eureka Client 发送的请求路径映射 5.6 获取 Eureka Server 服务注册信息 - DiscoveryClient
先看需求分析示意图 这里我们以服务消费方 去获取 Eureka Server 的服务注册信息为例讲解 当然也可以在服务提供方获取 Eureka Server 的服务注册信息。
5.5.1 具体操作步骤
所在模块 member-service-consumer-80修改com.rainbowsea.springcloud.controller.MemberConsumerController 包当中的
增加如下代码 Resource // 装配到 Spring ioc 容器当中private DiscoveryClient discoveryClient;// 注意想要获取到服务端信息还需要在SpringBoot 启动场景上加上EnableDiscoveryClient // 启用服务发现 注解才行GetMapping(/member/consumer/discovery)public Object discovery(){ListString services discoveryClient.getServices();// 遍历 servicesfor (String service : services) {log.info(服务名{},service);// 再根据服务名获取更加详细的信息ListServiceInstance instances discoveryClient.getInstances(service);for (ServiceInstance instance : instances) {log.info(id{},host{},uri{},instance.getServiceId(),instance.getHost(),instance.getUri());}}return this.discoveryClient;}package com.rainbowsea.springcloud.controller;import com.rainbowsea.springcloud.entity.Member;
import com.rainbowsea.springcloud.entity.Result;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;import javax.annotation.Resource;
import java.util.List;RestController
Slf4j
public class MemberConsumerController {// 定义 MEMBER_SERVICE_PROVIDER_URL 这是一个基础 url地址// 使用 shiftctrlu 进行字母大小写的切换//private static final String MEMBER_SERVICE_PROVIDER_URL http://localhost:10000;// 负载均衡统一别名修改为提供服务模块的注册别名: 不需要配置指明端口号因为是一个负载集群了。不是特指某个了Service 服务来处理了/*server:port: 10000
spring:application:name: member-service-provider # 配置应用的名称*//*说明:1. MEMBER-SERVICE-PROVIDER 就是服务提供方【集群】注册到Eureka Server 的名称2. 也就是服务提供方【集群】对外暴露的名称为 MEMBER-SERVICE-PROVIDER3. MEMBER-SERVICE-PROVIDER 目前有两个 Availability Zones UP (2) - localhost:member-service-provider:10000 , localhost:member-service-provider:10002还有一个 member-service-provider:10002需要增加一个注解 LoadBalanced 赋予 RestTemplate 才能有负载均衡的能力也就是会根据你的负载均衡来选择某个服务去访问默认是“轮询算法”当然我们也可以自己配置负载均衡算法4. 在对应的 RestTemplate 配置类上的Bean注解下面加上 LoadBalanced 注解。*/private static final String MEMBER_SERVICE_PROVIDER_URL http://MEMBER-SERVICE-PROVIDER;// 装配 RestTemplate bean/对象Resourceprivate RestTemplate restTemplate;PostMapping(/member/consumer/save)public ResultMember save(Member member) {// 1.第1个参数: 就是请求的完整的url:MEMBER_SERVICE_PROVIDER_URL /member/save http://localhost:10000/member/save// 表示你向将该请求发送给那个微服务处理注意无论是返回值还是参数 PostMapping() 请求方式都要一一对应上对应处理的微服务上的内容//2. 第2个参数: member : 就是通过 restTemplate 发出的 post 请求携带数据或者对象//3. 第3个参数: Result.class 微服务当中的对应处理的方法的返回值也就是返回对象类型// 注意坑点// 这里通过 restTemplate 调用服务模块的接口就是一个远程调用//log.info(member-service-consumer-80 save member{}, member);return restTemplate.postForObject(MEMBER_SERVICE_PROVIDER_URL /member/save, member, Result.class);}/*1.与PostMapping(/member/save)public Result save(Member member) {int affected memberService.save(member);if (affected 0) { // 说明添加成功return Result.success(添加会员成功, affected);} else {return Result.error(401, 添加会员失败);}}*//*** 方法/接口调用服务接口返回 member 对象信息** param id* return*/GetMapping(/member/consumer/get/{id})public ResultMember getMemberById(PathVariable(id) Long id) {// 这里就用两个参数// 第一个参数因为是查询所以这里我们直接字符串拼接上去// 这里通过return restTemplate.getForObject(MEMBER_SERVICE_PROVIDER_URL /member/get/ id, Result.class);}/*保持一致* 提交方式* 返回类型* 参数* 路径映射要对应上GetMapping(/member/get/{id})public Result getMemberById(PathVariable(id) Long id) {Member member memberService.queryMemberById(id);// 使用 Result 把查询到的结果返回if (member ! null) {return Result.success(查询会员成功, member);} else {return Result.error(402, ID id 不存在);}}*/// 注意有两个是这个包下的 org.springframework.cloud.client.discovery.DiscoveryClientResource // 装配到 Spring ioc 容器当中private DiscoveryClient discoveryClient;// 注意想要获取到服务端信息还需要在SpringBoot 启动场景上加上EnableDiscoveryClient // 启用服务发现 注解才行GetMapping(/member/consumer/discovery)public Object discovery(){ListString services discoveryClient.getServices();// 遍历 servicesfor (String service : services) {log.info(服务名{},service);// 再根据服务名获取更加详细的信息ListServiceInstance instances discoveryClient.getInstances(service);for (ServiceInstance instance : instances) {log.info(id{},host{},uri{},instance.getServiceId(),instance.getHost(),instance.getUri());}}return this.discoveryClient;}
}
这里修改所在模块 member-service-consumer-80当中的主启动类(场景启动类) com.rainbowsea.springcloud.MemberConsumerApplication80 package com.rainbowsea.springcloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;// 如果错误: 加入排除 DataSourceAutoConfiguration 自动配置
//SpringBootApplication(exclude DataSourceAutoConfiguration.class)
//EnableEurekaClient 表示将项目/模块/程序 标注作为 Eureka Client
EnableEurekaClient
SpringBootApplication
EnableDiscoveryClient // 启用服务发现
public class MemberConsumerApplication80 {public static void main(String[] args) {SpringApplication.run(MemberConsumerApplication80.class, args);}
}
重启 member-service-consumer-80
浏览器输出 http://localhost/member/consumer/discovery 5.5.1.1 注意事项和细节说明
在引入 DiscoveryClient 时不要引入错误的包 正确的包: import org.springframework.cloud.client.discovery.DiscoveryClient; 错误的包: import com.netflix.discovery.DiscoveryClient; 演示的是在服务消费方使用 DiscoveryClient 来完成服务发现同样在服务提供 方/模块也 OK
7. Eureka 后续说明
Eureka 停更说明: https://github.com/Netflix/eureka/wiki 对于一些早期使用 Eureka 项目掌握老师讲解技术基本可以应付了(这也是老师为什么还要讲Eureka的原因) 目前替代Eureka做服务注册和发现均衡负载的最佳组件是Nacos , 后面会重点讲解 Spring Cloud Alibaba 虽然 Eureka 停更目前用的不多但是它的服务注册和发现均衡负载的思想是优先 的有了Eureka的基础我们学习Spring Cloud Alibaba Nacos会轻松很多
8. 总结
Spring Cloud Eureka 服务注册于发现Eureka 自我保护模式 默认情况下EurekaClient 定时向 EurekaServer 端发送 心跳包 如果 Eureka 在 server 端一定时间内(默认90秒) 没有收到 EurekaClient 发送心跳包便会 直接从服务注册表中剔除该服务 如果Eureka 开启了**“自我保护机制/模式”** ,那么在短时间(90秒中)内丢失了大量的服务实例心跳。 这时候Eureka Server 会开启自我保护机制不会剔除该服务(该现象可能出现在如果网络不通或者 阻塞)因为客户端还能正常发送心跳只是网络延迟问题而保护机制是为了解决此问题而产生的。 自我保护是属于CAP里面的AP分支 保证高可用和分区容错性 自我保护模式是一种应对网络异常的安全保护措施它的架构哲学是宁可同时保留所有微服务(健康 的微服务和不健康的微服务都会保留)也不盲目注销任何健康的微服务。使用自我保护模式 可以让 Eureka 集群更加的健壮稳定参考 https://blog.csdn.net/wangliangluang/article/details/120626014 在生产环境中一般不会禁用自我保护模式 。
Eureka 集群-实现负载均衡故障容错 为什么需要集群 Eureka Server 说明: 微服务 RPC 远程服务调用最核心的是实习高可用如果注册中心只有1个它出故障会导致整个服务环境不可用解决办法: 搭建 Eureka 注册中心集群实习 负载均衡 故障容错 因为 member-service-provider-10000 和 member-service-provider-10002 作为一个集 群提供服务, 因此需要将 spring.application.name 进行统一方便用于负载均衡 这样消费方通过统一的别名进行负载均衡调用。 特别说明 我们想要能够实现 member 交替访问的话需要在 RestTemplate 配置类上Bean方法上加上该 LoadBalanced注解的)才行。 底层是 Ribbon 支持算法 交替访问 member服务说明
注解LoadBalanced(在RestTemplate 配置类的Bean方法上加上该 LoadBalanced注解的) 底层是 Ribbon 支持算法 Ribbon 和 Eureka 整合后 consumer 直接调用服务而不用再关心地址和端口号且该服务还有负载功能
定义本地的域名机制
设置本地的域名映射需要找到本地电脑当中的 host 文件在该 host文件当中编写添加相应的域名映射。 host文件路径: C:\Windows\System32\drivers\etc\host 127.0.0.1 account.wondershare.com
# 配置 eureka 主机 和 ip 的映射
127.0.0.1 eureka9001.com
127.0.0.1 eureka9002.com特别提醒如果发现文件修改后无法保存那么可以将文件复制到桌面上然后修改复制到桌面上的那份复制过来的 host 文件修改保存完后再拷贝回原来路径位置进行一个替换。
获取 Eureka Server 服务注册信息 - DiscoveryClient在引入 DiscoveryClient 时不要引入错误的包正确的包: import org.springframework.cloud.client.discovery.DiscoveryClient;
9. 最后 “在这个最后的篇章中我要表达我对每一位读者的感激之情。你们的关注和回复是我创作的动力源泉我从你们身上吸取了无尽的灵感与勇气。我会将你们的鼓励留在心底继续在其他的领域奋斗。感谢你们我们总会在某个时刻再次相遇。”
