正文
SpringBoot Cloud eureka 注册中心
提示：扫一扫查出行【扫一扫了解最新限行尾号】
复制提示
SpringBoot Cloud是什么
Spring Cloud是一个分布式的整体解决方案。 Spring Cloud 为开发者提供了在
分布式系统（配置管理，服务发现，熔断，路由，微代理，控制总线，一次性token，全局琐， leader选举，分布式session，集群状态）中快速构建的工具，
使用Spring Cloud的开发者可以快速的启动服务或构建应用、同时能够快速和云平台资源进行对接。
SpringCloud分布式开发五大常用组件
• 服务发现——Netflix Eureka (发现了 英 [,jʊ(ə)'riːkə] )
• 客服端负载均衡——Netflix Ribbon (缎带 英 ['rɪbən] )
• 断路器——Netflix Hystrix (断路器)
• 服务网关——Netflix Zuul (路由网关)
• 分布式配置——Spring Cloud Config (配置)
https://www.processon.com/diagraming/5cef1a48e4b05d5b38bdb090
特别强调: springboot和springcloud如果版本不兼容会报异常java.lang.NoSuchMethodError: org.springframework.boot.builder.SpringApplicationBuilder.<init>([Ljava/lang/Class;)V
springcloud中eureka搭建
建一个空项目springboot-07-cloud,内有三个子模块
- eureka-server (注册中心)
- cloud-provider (服务提供者)
- cloud-consumer (消费者)
三个子模块文件结构如下
springboot-07-cloud base分支中三个子模块如下
| springboot-07-cloud中三个子模块 | eureka-server (注册中心) | cloud-provider (服务提供者) | cloud-consumer (消费者) |
 |  |  | |
| pom.xml区别 | <?xml version="1.0" encoding="UTF-8"?> | <?xml version="1.0" encoding="UTF-8"?> | <?xml version="1.0" encoding="UTF-8"?> |
| application.yml区别 | server: 默认eureka服务注册中心也会将自己作为客户端来尝试注册它自己，所以我们需要禁用它的客户端注册行为,将register-with-eureka置为false 若未禁用eureka服务注册中心的客户端注册行为，需提供service-url注册中心地址 | server: | server: |
特别注意: springboot和springcloud的版本有对应要求, 本样例用的是
springboot <version>1.5.21.RELEASE</version> 对应 springbloud <spring-cloud.version>Edgware.SR6</spring-cloud.version>
在实际开发过程中，我们需要更详细的版本对应：以伦敦地铁站命名
| spring-boot-starter-parent | spring-cloud-dependencies | ||||
|---|---|---|---|---|---|
| 版本号 | 发布日期 | 版本号 | 发布日期 | ||
| 1.5.2.RELEASE | 2017年3月 | 稳定版 | Dalston.RC1 | 2017年未知月 | |
| 1.5.9.RELEASE | 2017年11月 | 稳定版 | Edgware.RELEASE | 2017年11月 | 稳定版 |
| 1.5.16.RELEASE | Edgware.SR5 | ||||
| 1.5.20.RELEASE | Edgware.SR5 | ||||
| 2.0.2.RELEASE | 2018年5月 | Finchley.BUILD-SNAPSHOT | 2018年未知月 | ||
| 2.0.6.RELEASE | Finchley.SR2 | ||||
| 2.1.4.RELEASE | Greenwich.SR1 | ||||
| 2.2.2.RELEASE | Hoxton.SR1 | 2019年 | |||
| 待更新... | |||||
eureka-server (注册中心)EurekaServerApplication.java
注册中心启动入口 , 注意需要@EnableEurekaServer注解支持
package com.example.eurekaserver;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;/**
* 使用注册中心步骤
* 1. application.yml配置
* 2. @EnableEurekaServer注解添加
*/
@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication { public static void main(String[] args) {
SpringApplication.run(EurekaServerApplication.class, args);
}}
cloud-provider (服务提供者)CloudProviderApplication.java
生产者启动类, 不需要额外注解, 因为做了注册到eureka上的配置, 就可以直接把@RestController注解的所有接口自动注册到eureka注册中心 , 供消费者调用.
package com.example.cloud.provider;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class CloudProviderApplication { public static void main(String[] args) {
SpringApplication.run(CloudProviderApplication.class, args);
}}
CloudProviderController.java
package com.example.cloud.provider.controller;import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class CloudProviderController {
static int number; @GetMapping("/buyTicket")
public String buyTicker(){
return "ticker "+ ++number;
}
}
cloud-consumer (消费者)CloudConsumerApplication.java
消费者启动入口 , 注意需要开启@EnableDiscoveryClient注解
package com.example.cloud.consumer;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;/**
* cloud 客户端调用时需要引入 @EnableDiscoveryClient 注解
*/
@SpringBootApplication
@EnableDiscoveryClient
public class CloudConsumerApplication { public static void main(String[] args) {
SpringApplication.run(CloudConsumerApplication.class, args);
}}
MyConfiguration.java
需要把RestTemplate类组装到springboot容器中, 专门用于调用eureka上发现的服务
package com.example.cloud.consumer.config;import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;@Configuration
public class MyConfiguration { @LoadBalanced//负载均衡
@Bean//需要把RestTemplate装配进来,专门用于调用Eureka上发现的服务
public RestTemplate restTemplate() {
return new RestTemplate();
}
}
CloudConsumberController.java
使用 http://localhost:8002/buyTicket 访问
package com.example.cloud.consumer.controller;import com.netflix.discovery.converters.Auto;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;@RestController
public class CloudConsumberController { @Autowired
RestTemplate restTemplate; //http://localhost:8002/buyTicket
@GetMapping("/buyTicket")
public String buyTicker(){
String retData = restTemplate.getForObject("http://PROVIDER/buyTicket",String.class);//
retData = "成功购买" + retData;
return retData;
}}
访问
访问springcloud的eureka-server 注册中心 http://localhost:8761/
访问cloud-consumer消费者提供的controller接口 http://localhost:8002/buyTicket 后,浏览器显示如下
成功购买ticker 1
注意Status一栏显示的是服务实例名, 默认取名规则为${spring.cloud.client.hostname}:${spring.application.name}:${spring.application.instance_id:${server.port}} , 最后的写法意为如果spring.application.instance_id没有定义,则取server.port, 如果已定义了则舍掉server.port取spring.application.instance_id
遇见异常Error creating bean with name 'gsonBuilder' defined in class path resource
异常详情如下:
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'gsonBuilder' defined in class path resource [org/springframework/boot/autoconfigure/gson/GsonAutoConfiguration.class]:Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.google.gson.GsonBuilder]: Factory method 'gsonBuilder' threw exception; nested exception is java.lang.BootstrapMethodError: java.lang.NoSuchMethodError: com.google.gson.GsonBuilder.setLenient()Lcom/google/gson/GsonBuilder
那是因为整个项目没有引入parent依赖 , 添加如下<parent>即可
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.4.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
Eureka服务心跳检测(健康检测机制)1.Eureka服务端
在某一些时候注册在Eureka的服务已经挂掉了，但是服务却还留在Eureka的服务列表的情况。
Eureka服务端的配置application.yml：
server:
port: 9501eureka:
instance:
hostname: 127.0.0.1
client:
registerWithEureka: false
fetchRegistry: false
serviceUrl:
defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
server:
# 关闭自我保护机制
enable-self-preservation: false
# 每隔10s扫描服务列表，移除失效服务
eviction-interval-timer-in-ms: 10000
默认情况下，如果Eureka Server在一定时间内（默认90秒）没有接收到某个微服务实例的心跳，Eureka Server将会移除该实例。但是当网络分区故障发生时，微服务与Eureka Server之间无法正常通信，而微服务本身是正常运行的，此时不应该移除这个微服务，所以引入了自我保护机制。
自我保护模式正是一种针对网络异常波动的安全保护措施，使用自我保护模式能使Eureka集群更加的健壮、稳定的运行。
自我保护机制的工作机制是如果在15分钟内超过85%的客户端节点都没有正常的心跳，那么Eureka就认为客户端与注册中心出现了网络故障，Eureka Server自动进入自我保护机制，此时会出现以下几种情况：
1、Eureka Server不再从注册列表中移除因为长时间没收到心跳而应该过期的服务。
2、Eureka Server仍然能够接受新服务的注册和查询请求，但是不会被同步到其它节点上，保证当前节点依然可用。
3、当网络稳定时，当前Eureka Server新的注册信息会被同步到其它节点中。
因此Eureka Server可以很好的应对因网络故障导致部分节点失联的情况，而不会像ZK那样如果有一半不可用的情况会导致整个集群不可用而变成瘫痪。
# 该配置可以移除这种自我保护机制，防止失效的服务也被一直访问 (Spring Cloud默认该配置是 true)
eureka.server.enable-self-preservation: false# 该配置可以修改检查失效服务的时间，每隔10s检查失效服务，并移除列表 (Spring Cloud默认该配置是 60s)
eureka.server.eviction-interval-timer-in-ms: 10
2.Eureka客户端
Eureka客户端的配置application.yml：
eureka:
instance:
# 每隔10s发送一次心跳
lease-renewal-interval-in-seconds: 10
# 告知服务端30秒还未收到心跳的话，就将该服务移除列表
lease-expiration-duration-in-seconds: 30
client:
serviceUrl:
defaultZone: http://localhost:9501/eureka/server:
port: 9502
spring:
application:
name: service-hi
# 该配置指示eureka客户端需要向eureka服务器发送心跳的频率 (Spring Cloud默认该配置是 30s)
eureka.instance.lease-renewal-interval-in-seconds: 10# 该配置指示eureka服务器在接收到最后一个心跳之后等待的时间，然后才能从列表中删除此实例 (Spring Cloud默认该配置是 90s)
eureka.instance.lease-expiration-duration-in-seconds: 30
SpringCloud：Eureka的健康检测机制==>https://blog.csdn.net/akaks0/article/details/79512680
遗留问题
defaultZone 需要添加/eureka后缀? 是的默认就这样.
我的git项目地址
https://gitee.com/KingBoBo/springboot-07-cloud base分支
入门篇
Eureka 服务的注册和发现==>https://www.cnblogs.com/fangwu/p/8975990.html
进阶篇
SpringBoot SpringCloud集群==>https://www.cnblogs.com/whatlonelytear/p/10894161.html
