【分布式】SpringCloud(3)–Eureka服务注册与发现
- 2021 年 4 月 2 日
- 筆記
- SpringCloud
1.Eureka概述
1.1.什么是Eureka
Eureka是Netflix的一个子模块。基于REST的服务,用于定位服务,以实现云端中间层服务发现和故障转移。
只需要使用服务的标识符,就可以访问到服务,而不需要修改服务调用的配置文件。功能类似于dubbo的注册中心,比如Zookeeper。
Eureka在设计时遵守的是AP原则,而Zookeeper 就是则是CP原则。C一致性(Consistency)、A可用性(Availability)、P分区容错性(Partition tolerance)。
1.2.Eureka架构
Eureka CS架构图
Eureka包含两个组件:Eureka Server和Eureka Client
Eureka Server提供服务注册服务:SpringCloud中的微服务启动后会在Eureka Server中注册,由Server存储所有可用服务微服务节点的信息到服务注册表,可以在Eureka服务启动后界面中看到。
Eureka Client是一个Java的客户端,用于简化Eureka Server的交互,客户端同时也具备内置的、轮询(round-robin)的负载均衡器。在应用启动后,
会向Eureka Server发送心跳(默认30秒)。如果Eureka Server在多个心跳周期没有接收到某个节点的心跳,EurekaServer将会从服务注册表中把这个服务节点移除(默认90秒)。基于EurekaServer的“自我保护”模式,认定微服务是是启动的健康状态,不会注销这个微服务。
1.3.Eureka三大角色
Eureka Server:提供服务注册与发现
Server Provider:服务提供方将自身服务注册到Eureka,从而使服务消费方能够找到
Servcie Consumer:服务消费方从Eureka获取注册服务列表,从而能够消费服务
2.Eureka Server服务注册中心实现
2.1.pom.xml依赖
<dependency> <groupId>org.springframework.cloud</groupId> <!--server表明是server端--> <artifactId>spring-cloud-starter-eureka-server</artifactId> <version>1.4.6.RELEASE</version> </dependency> <!--热部署插件--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> </dependency>
2.2.application.yml
server:
port: 7001
#Eureka配置
eureka:
instance:
hostname: localhost #Eureka服务端的实例名称
client:
register-with-eureka: false #表示是否向Eureka注册中心注册自己,false表示不注册自己
fetch-registry: false #如果为false,则表示自己为注册中心
service-url: #服务注册页面地址
defaultZone: //${eureka.instance.hostname}:${server.port}/eureka/
2.3.启动类
注意:在启动类上添加@EnableEurekaServer注解标识这个是Server服务注册类
@SpringBootApplication @EnableEurekaServer //标识是Eureka服务的启动类,可以接受消费者注册进来 public class EurekaServer_7001 { public static void main(String[] args) { SpringApplication.run(EurekaServer_7001.class, args); } }
启动SpringBoot项目,访问服务注册页面地址//localhost:7001/:
3.Service Provider服务提供方
3.1.pom.xml依赖
<!--微服务provider方引入eureka--> <dependency> <groupId>org.springframework.cloud</groupId> <!--没有带sever表示就是client客户端--> <artifactId>spring-cloud-starter-eureka</artifactId> <version>1.4.6.RELEASE</version> </dependency> <!--actuator:完善监控信息--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <!--需要拿到实体类,引入api module--> <dependency> <groupId>com.fengye</groupId> <artifactId>springcloud-api</artifactId> <version>1.0-SNAPSHOT</version> </dependency>
3.2.application.yml
#spring的配置
spring:
application:
name: springcloud-provider-dept #默认注册进eureka中的实例名称(显示大写)
#eureka的配置,确定客户端服务注册到eureka服务列表内
eureka:
client:
service-url:
defaultZone: //localhost:7001/eureka/
3.3.启动类
@SpringBootApplication @EnableEurekaClient //在服务启动后自动注册到eureka中 public class DeptServiceProvider { public static void main(String[] args) { SpringApplication.run(DeptServiceProvider.class, args); } }
启动注册中心Server与Provider Client类,发现在Eureka注册中心已经注册上了实例:
3.4.注册中心实例显示细节配置
①主机名称:服务名称修改
#eureka的配置,确定客户端服务注册到eureka服务列表内
eureka:
client:
service-url:
defaultZone: //localhost:7001/eureka/
instance:
instance-id: springcloud-provider-dept-8001 #修改eureka上默认的服务描述信息
②访问信息有IP地址信息提示
instance:
instance-id: springcloud-provider-dept-8001 #修改eureka上默认的服务描述信息
prefer-ip-address: true #访问路径可以显示ip地址
③微服务info内容详细信息显示
(1)provider service中pom.xml添加actuator配置:
<!--actuator:完善监控信息--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency>
(2)父工程中修改pom.xml添加构建build信息:
<build> <finalName>springcloud_helloworld</finalName> <resources> <resource> <directory>src/main/resources</directory> <filtering>true</filtering> </resource> </resources> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-resources-plugin</artifactId> <configuration> <delimiters> <delimit>$</delimit> </delimiters> </configuration> </plugin> </plugins> </build>
(3)provider service中的application.yml中添加info配置:
#info配置
info:
app.name: fengye-springcloud
company.name: blog.fengye.com
build.artifactId: $project.artifactId$
build.version: $project.version$
之后点击服务重定向info页面不会显示error页面,会重定向获取到info数据:
4.Service Consumer服务消费方
其实服务方和消费方在配置时候没有任何区别,它们都属于Eureka Client组件。只是涉及服务间的调用,所以就把被调方称为提供方,调用方称为消费方。就好比订单微服务,
订单服务肯定需要去调商品微服务接口,所以这个订单微服务对于商品来讲可以理解服务提供方。一个微服务即可以是服务方也同时是提供方。
4.1.pom.xml
<!--微服务provider方引入eureka--> <dependency> <groupId>org.springframework.cloud</groupId> <!--没有带sever表示就是client客户端--> <artifactId>spring-cloud-starter-eureka</artifactId> <version>1.4.6.RELEASE</version> </dependency> <!--actuator:完善监控信息--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <dependency> <groupId>com.fengye</groupId> <artifactId>springcloud-api</artifactId> <version>1.0-SNAPSHOT</version> </dependency>
4.2.application.yml
#spring的配置
spring:
application:
name: springcloud-consumer-dept #默认注册进eureka中的实例名称(显示大写)
#eureka的配置,确定客户端服务注册到eureka服务列表内
eureka:
client:
service-url:
defaultZone: //localhost:7001/eureka/
instance:
instance-id: springcloud-consumer-dept-8002 #修改eureka上默认的服务描述信息
prefer-ip-address: true #访问路径可以显示ip地址
4.3.启动类
@SpringBootApplication @EnableEurekaClient //标识这是一个eureka的client客户端 public class DeptServiceConsumer { public static void main(String[] args) { SpringApplication.run(DeptServiceConsumer.class, args); } }
启动消费者微服务,访问端口://localhost:7001/,发现消费中服务也已经注册进来了:
4.4.服务发现
服务发现是指服务的提供者provider可以通过对外暴露一个服务的发现接口获取Eureka Server中注册的服务信息,同时也可以让consumer调用者进行接口访问。获得
接口请求的数据。
服务发现比较简单,主要是微服务之间进行接口的调用、通信,主要配置如下:
(1)注入DiscoveryClient接口:
@RestController @RequestMapping("/dept") public class DeptController { @Autowired //对外暴露一个服务发现的接口 private DiscoveryClient client; //获取注册进来的微服务的一些消息 @GetMapping("/discovery") public Object discovery(){ //获取微服务列表的清单 List<String> services = client.getServices(); System.out.println("discovery=>:" + services); //得到一个具体的微服务信息,通过具体的微服务Application id List<ServiceInstance> instances = client.getInstances("SPRINGCLOUD-PROVIDER-DEPT"); for (ServiceInstance instance : instances) { System.out.println( instance.getHost() + "\t" + instance.getPort() + "\t" + instance.getUri() + "\t" + instance.getServiceId() ); } return this.client; } }
(2)启动类开启服务发现注解:
@SpringBootApplication @EnableEurekaClient //在服务启动后自动注册到eureka中 @EnableDiscoveryClient //服务发现 public class DeptServiceProvider { public static void main(String[] args) { SpringApplication.run(DeptServiceProvider.class, args); } }
(3)服务消费者访问接口请求地址:
@RestController public class DeptConsumerController { /** * 消费者:不应该有service实现层 * RestTemplate:提供多种便捷的访问远程http服务的方法,提供简单的restful服务模板(使用简单无脑粗暴) * 参数类型:(url, requestMap, ResponseBean.class)分别代表REST请求地址、请求参数、HTTP响应转换被转换成的对象类型 */ @Autowired private RestTemplate restTemplate; //服务端的请求地址,这里是本机localhost,也可以是其他任意的服务机ip地址 private static final String REST_URL_PREFIX = "//localhost:8001"; //测试@EnableDiscoveryClient,消费端可以调用服务发现 @RequestMapping("/consumer/dept/discovery") public Object discovery(){ return restTemplate.getForObject(REST_URL_PREFIX + "/dept/discovery", Object.class); } }
最终访问8002端口调用服务提供者请求发现接口,访问到数据:
示例代码已上传至Github地址:
//github.com/devyf/SpringCloud_Study/tree/main/springcloud_hello