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"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.21.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.example</groupId> <artifactId>eureka-server</artifactId> <version>0.0.1-SNAPSHOT</version> <name>eureka-server</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> <spring-cloud.version>Edgware.SR6</spring-cloud.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- starter-netflix-eureka-server自动依赖starter-actuator --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>	<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.21.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.example</groupId> <artifactId>cloud-provider</artifactId> <version>0.0.1-SNAPSHOT</version> <name>cloud-provider</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> <spring-cloud.version>Edgware.SR6</spring-cloud.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>	<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.21.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.example</groupId> <artifactId>cloud-consumer</artifactId> <version>0.0.1-SNAPSHOT</version> <name>cloud-consumer</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> <spring-cloud.version>Edgware.SR6</spring-cloud.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
application.yml区别	server: port: 8761 eureka: instance: hostname: eureka-server # eureka实例主机名 client: register-with-eureka: false # 不把自己注册到eureka上, 因为自己本来就是注册中心 fetch-registry: false # 不从eureka上获取服务的注册信息 service-url: defaultZone: http://localhost:8761/eureka/ #defaultZone 是注册中心服务注册的地址默认eureka服务注册中心也会将自己作为客户端来尝试注册它自己，所以我们需要禁用它的客户端注册行为,将register-with-eureka置为false 若未禁用eureka服务注册中心的客户端注册行为，需提供service-url注册中心地址	server: port: 8001 spring: application: name: provider eureka: instance: prefer-ip-address: true # 注册服务时使用服务的ip地址 client: register-with-eureka: true # 把自己注册到eureka上 fetch-registry: true # 从eureka上获取服务的注册信息 service-url: defaultZone: http://localhost:8761/eureka/ #defaultZone 是注册中心服务注册的地址	server: port: 8002 spring: application: name: consumer eureka: instance: prefer-ip-address: true # 注册服务时使用服务的ip地址 client: register-with-eureka: true # 把自己注册到eureka上 fetch-registry: true # 从eureka上获取服务的注册信息 service-url: defaultZone: http://localhost:8761/eureka/ #defaultZone 是注册中心服务注册的地址

特别注意: 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: 9501

eureka:

  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

巴特西