SpringCloud微服务治理一（介绍，环境搭建，Eureka）

时间  2019-11-15
标签 springcloud 微服 治理 介绍 环境 搭建 eureka 繁體版
原文   原文链接

SpringCloud微服务治理一（介绍，环境搭建，Eureka）
SpringCloud微服务治理二(Robbin,Hystix,Feign)
SpringCloud微服务治理三（Zuul网关）php

1.远程调用方式

了解一下微服务的调用方式java

1.1.RPC

RPC，即 Remote Procedure Call（远程过程调用），是一个计算机通讯协议。 该协议容许运行于一台计算机的程序调用另外一台计算机的子程序，而程序员无需额外地为这个交互做用编程。mysql

1.2.Http

Http协议：超文本传输协议，是一种应用层协议。程序员

2.Http客户端工具

2.1 Spring的RestTemplate

Spring提供了一个RestTemplate模板工具类，对基于Http的客户端进行了封装，而且实现了对象与json的序列化和反序列化，很是方便。RestTemplate并无限定Http的客户端类型，而是进行了抽象，目前经常使用的3种都有支持：web

  • HttpClient
  • OkHttp
  • JDK原生的URLConnection（默认的）

首先在项目中注册一个RestTemplate对象，能够在启动类位置注册：spring

@SpringBootApplication
public class HttpDemoApplication {

	public static void main(String[] args) {
		SpringApplication.run(HttpDemoApplication.class, args);
	}

	@Bean
	public RestTemplate restTemplate() {
        // 默认的RestTemplate，底层是走JDK的URLConnection方式。
		return new RestTemplate();
	}
}
复制代码

在测试类中直接@Autowired注入：sql

@RunWith(SpringRunner.class)
@SpringBootTest(classes = HttpDemoApplication.class)
public class HttpDemoApplicationTests {

	@Autowired
	private RestTemplate restTemplate;

	@Test
	public void httpGet() {
		User user = this.restTemplate.getForObject("http://localhost/hello", User.class);
		System.out.println(user);
	}
}
复制代码

接下来正式介绍微服务。apache

3.SpringCloud

3.1.简介

SpringCloud是Spring旗下的项目之一，官网地址：http://projects.spring.io/spring-cloud/编程

SpringCloud将如今很是流行的一些技术整合到一块儿，实现了诸如：配置管理，服务发现，智能路由，负载均衡，熔断器，控制总线，集群状态等等功能。其主要涉及的组件包括：json

netflix

  • Eureka：注册中心
  • Zuul：服务网关
  • Ribbon：负载均衡
  • Feign：服务调用
  • Hystix：熔断器

接下来，咱们就一一学习SpringCloud中的重要组件。

4.微服务场景模拟

首先，咱们须要模拟一个服务调用的场景。方便后面学习微服务架构

4.1.服务提供者

咱们新建一个项目，对外提供查询用户的服务。

4.1.1.Spring脚手架建立工程

依赖也已经所有自动引入：

<?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>

	<groupId>com.leyou.demo</groupId>
	<artifactId>user-service-demo</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

	<name>user-service-demo</name>
	<description>Demo project for Spring Boot</description>

	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.0.1.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
		<java.version>1.8</java.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-jdbc</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<dependency>
			<groupId>org.mybatis.spring.boot</groupId>
			<artifactId>mybatis-spring-boot-starter</artifactId>
			<version>1.3.2</version>
		</dependency>
		<dependency>
			<groupId>mysql</groupId>
			<artifactId>mysql-connector-java</artifactId>
			<scope>runtime</scope>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
	</dependencies>

	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
			</plugin>
		</plugins>
	</build>
</project>

复制代码

固然，由于要使用通用mapper，因此咱们须要手动加一条依赖：

<dependency>
    <groupId>tk.mybatis</groupId>
    <artifactId>mapper-spring-boot-starter</artifactId>
    <version>2.0.2</version>
</dependency>
复制代码

很是快捷啊！

4.1.2.编写代码

添加一个对外查询的接口：

@RestController
@RequestMapping("user")
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("/{id}")
    public User queryById(@PathVariable("id") Long id) {
        return this.userService.queryById(id);
    }
}
复制代码

Service：

@Service
public class UserService {

    @Autowired
    private UserMapper userMapper;

    public User queryById(Long id) {
        return this.userMapper.selectByPrimaryKey(id);
    }
}
复制代码

mapper:

@Mapper
public interface UserMapper extends tk.mybatis.mapper.common.Mapper<User>{
}
复制代码

实体类：

@Table(name = "tb_user")
public class User implements Serializable {

    private static final long serialVersionUID = 1L;

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    // 用户名
    private String userName;

    // 密码
    private String password;

    // 姓名
    private String name;

    // 年龄
    private Integer age;

    // 性别，1男性，2女性
    private Integer sex;

    // 出生日期
    private Date birthday;

    // 建立时间
    private Date created;

    // 更新时间
    private Date updated;

    // 备注
    private String note;

   // 。。。省略getters和setters
}

复制代码

属性文件,这里咱们采用了yaml语法，而不是properties：

server:
 port: 8081
spring:
 datasource:
 url: jdbc:mysql://localhost:3306/mydb01
 username: root
 password: 123
 hikari:
 maximum-pool-size: 20
 minimum-idle: 10
mybatis:
 type-aliases-package: com.leyou.userservice.pojo
复制代码

4.2.服务调用者

4.2.1.建立工程

与上面相似，须要注意的是，咱们调用user-service的功能，所以不须要mybatis相关依赖了。

pom：

<?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>

	<groupId>com.leyou.demo</groupId>
	<artifactId>user-consumer-demo</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

	<name>user-consumer-demo</name>
	<description>Demo project for Spring Boot</description>

	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.0.1.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
		<java.version>1.8</java.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
        <!-- 添加OkHttp支持 -->
		<dependency>
			<groupId>com.squareup.okhttp3</groupId>
			<artifactId>okhttp</artifactId>
			<version>3.9.0</version>
		</dependency>
	</dependencies>

	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
			</plugin>
		</plugins>
	</build>

</project>

复制代码

4.2.2.编写代码

首先在启动类中注册RestTemplate：

@SpringBootApplication
public class UserConsumerDemoApplication {

    @Bean
    public RestTemplate restTemplate() {
        // 此次咱们使用了OkHttp客户端,只须要注入工厂便可
        return new RestTemplate(new OkHttp3ClientHttpRequestFactory());
    }

    public static void main(String[] args) {
        SpringApplication.run(UserConsumerDemoApplication.class, args);
    }
}
复制代码

经过RestTemplate远程查询user-service-demo中的接口：

@Component
public class UserDao {

    @Autowired
    private RestTemplate restTemplate;

    public User queryUserById(Long id){
        String url = "http://localhost:8081/user/" + id;
        return this.restTemplate.getForObject(url, User.class);
    }
}
复制代码

而后编写user-service，循环查询UserDAO信息：

@Service
public class UserService {

    @Autowired
    private UserDao userDao;

    public List<User> querUserByIds(List<Long> ids){
        List<User> users = new ArrayList<>();
        for (Long id : ids) {
            User user = this.userDao.queryUserById(id);
            users.add(user);
        }
        return users;
    }
}
复制代码

编写controller：

@RestController
@RequestMapping("consume")
public class ConsumerController {

    @Autowired
    private UserService userService;

    @GetMapping
    public List<User> consume(@RequestParam("ids") List<Long> ids) {
        return this.userService.queryUserByIds(ids);
    }
}
复制代码

4.3.问题？

  • 在consumer中，咱们把url地址硬编码到了代码中，不方便后期维护
  • consumer须要记忆user-service的地址，若是出现变动，可能得不到通知，地址将失效
  • consumer不清楚user-service的状态，服务宕机也不知道
  • user-service只有1台服务，不具有高可用性
  • 即使user-service造成集群，consumer还需本身实现负载均衡

其实上面说的问题，归纳一下就是分布式服务必然要面临的问题：

  • 服务管理
    • 如何自动注册和发现
    • 如何实现状态监管
    • 如何实现动态路由
  • 服务如何实现负载均衡
  • 服务如何解决容灾问题
  • 服务如何实现统一配置

以上的问题，咱们都将在SpringCloud中获得答案。

5.Eureka注册中心

5.1.原理图

基本架构：

1525597885059

  • Eureka：就是服务注册中心（能够是一个集群），对外暴露本身的地址
  • 提供者：启动后向Eureka注册本身信息（地址，提供什么服务）
  • 消费者：向Eureka订阅服务，Eureka会将对应服务的全部提供者地址列表发送给消费者，而且按期更新
  • 心跳(续约)：提供者按期经过http方式向Eureka刷新本身的状态

5.2.入门案例

5.2.1.编写EurekaServer

接下来咱们建立一个项目，启动一个EurekaServer：

依然使用spring提供的快速搭建工具，选择依赖：

1525598312368

完整的Pom文件：

<?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>

	<groupId>com.leyou.demo</groupId>
	<artifactId>eureka-demo</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

	<name>eureka-demo</name>
	<description>Demo project for Spring Boot</description>

	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.0.1.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
		<java.version>1.8</java.version>
        <!-- SpringCloud版本，是最新的F系列 -->
		<spring-cloud.version>Finchley.RC1</spring-cloud.version>
	</properties>

	<dependencies>
        <!-- Eureka服务端 -->
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
		</dependency>
	</dependencies>

	<dependencyManagement>
		<dependencies>
            <!-- SpringCloud依赖，必定要放到dependencyManagement中，起到管理版本的做用便可 -->
			<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>

	<repositories>
		<repository>
			<id>spring-milestones</id>
			<name>Spring Milestones</name>
			<url>https://repo.spring.io/milestone</url>
			<snapshots>
				<enabled>false</enabled>
			</snapshots>
		</repository>
	</repositories>
</project>
复制代码

编写启动类：

@SpringBootApplication
@EnableEurekaServer // 声明这个应用是一个EurekaServer
public class EurekaDemoApplication {

	public static void main(String[] args) {
		SpringApplication.run(EurekaDemoApplication.class, args);
	}
}
复制代码

编写配置：

server:
 port: 10086 # 端口
spring:
 application:
 name: eureka-server # 应用名称，会在Eureka中显示
eureka:
 client:
 register-with-eureka: false # 是否注册本身的信息到EurekaServer，默认是true
 fetch-registry: false # 是否拉取其它服务的信息，默认是true
 service-url: # EurekaServer的地址，如今是本身的地址，若是是集群，须要加上其它Server的地址。
 defaultZone: http://127.0.0.1:${server.port}/eureka

复制代码

启动服务，并访问：http://127.0.0.1:10086/eureka

1525604959508

1525605081129

5.2.2.将user-service注册到Eureka

注册服务，就是在服务上添加Eureka的客户端依赖，客户端代码会自动把服务注册到EurekaServer中。

咱们在user-service-demo中添加Eureka客户端依赖：

先添加SpringCloud依赖：

<!-- SpringCloud的依赖 -->
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Finchley.RC1</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
<!-- Spring的仓库地址 -->
<repositories>
    <repository>
        <id>spring-milestones</id>
        <name>Spring Milestones</name>
        <url>https://repo.spring.io/milestone</url>
        <snapshots>
            <enabled>false</enabled>
        </snapshots>
    </repository>
</repositories>
复制代码

而后是Eureka客户端：

<!-- Eureka客户端 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
复制代码

在启动类上开启Eureka客户端功能

经过添加@EnableDiscoveryClient来开启Eureka客户端功能

@SpringBootApplication
@EnableDiscoveryClient // 开启EurekaClient功能
public class UserServiceDemoApplication {
	public static void main(String[] args) {
		SpringApplication.run(UserServiceDemoApplication.class, args);
	}
}
复制代码

编写配置

server:
 port: 8081
spring:
 datasource:
 url: jdbc:mysql://localhost:3306/mydb01
 username: root
 password: 123
 hikari:
 maximum-pool-size: 20
 minimum-idle: 10
 application:
 name: user-service # 应用名称
mybatis:
 type-aliases-package: com.leyou.userservice.pojo
eureka:
 client:
 service-url: # EurekaServer地址
 defaultZone: http://127.0.0.1:10086/eureka
 instance:
 prefer-ip-address: true # 当调用getHostname获取实例的hostname时，返回ip而不是host名称
 ip-address: 127.0.0.1 # 指定本身的ip信息，不指定的话会本身寻找
复制代码

注意：

  • 这里咱们添加了spring.application.name属性来指定应用名称，未来会做为应用的id使用。
  • 不用指定register-with-eureka和fetch-registry，由于默认是true

重启项目，访问Eureka监控页面http://127.0.0.1:10086/eureka查看

1525609225152

咱们发现user-service服务已经注册成功了

5.2.3.消费者从Eureka获取服务

接下来咱们修改consumer-demo，尝试从EurekaServer获取服务。

方法与消费者相似，只须要在项目中添加EurekaClient依赖，就能够经过服务名称来获取信息了！

1）添加依赖：

先添加SpringCloud依赖：

<!-- SpringCloud的依赖 -->
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Finchley.RC1</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
<!-- Spring的仓库地址 -->
<repositories>
    <repository>
        <id>spring-milestones</id>
        <name>Spring Milestones</name>
        <url>https://repo.spring.io/milestone</url>
        <snapshots>
            <enabled>false</enabled>
        </snapshots>
    </repository>
</repositories>
复制代码

而后是Eureka客户端：

<!-- Eureka客户端 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
复制代码

2）在启动类开启Eureka客户端

@SpringBootApplication
@EnableDiscoveryClient // 开启Eureka客户端
public class UserConsumerDemoApplication {
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate(new OkHttp3ClientHttpRequestFactory());
    }
    public static void main(String[] args) {
        SpringApplication.run(UserConsumerDemoApplication.class, args);
    }
}

复制代码

3）修改配置：

server:
 port: 8080
spring:
 application:
 name: consumer # 应用名称
eureka:
 client:
 service-url: # EurekaServer地址
 defaultZone: http://127.0.0.1:10086/eureka
 instance:
 prefer-ip-address: true # 当其它服务获取地址时提供ip而不是hostname
 ip-address: 127.0.0.1 # 指定本身的ip信息，不指定的话会本身寻找
复制代码

4）修改代码，用DiscoveryClient类的方法，根据服务名称，获取服务实例：

@Service
public class UserService {

    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private DiscoveryClient discoveryClient;// Eureka客户端，能够获取到服务实例信息

    public List<User> queryUserByIds(List<Long> ids) {
        List<User> users = new ArrayList<>();
        // String baseUrl = "http://localhost:8081/user/";
        // 根据服务名称，获取服务实例
        List<ServiceInstance> instances = discoveryClient.getInstances("user-service");
        // 由于只有一个UserService,所以咱们直接get(0)获取
        ServiceInstance instance = instances.get(0);
        // 获取ip和端口信息
        String baseUrl = "http://"+instance.getHost() + ":" + instance.getPort()+"/user/";
        ids.forEach(id -> {
            // 咱们测试屡次查询，
            users.add(this.restTemplate.getForObject(baseUrl + id, User.class));
            // 每次间隔500毫秒
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        return users;
    }
}
复制代码

5.4.Eureka进阶

5.4.1.高可用的Eureka Server

Eureka Server即服务的注册中心，在刚才的案例中，咱们只有一个EurekaServer，事实上EurekaServer也能够是一个集群，造成高可用的Eureka中心。

动手搭建高可用的EurekaServer

咱们假设要搭建两条EurekaServer的集群，端口分别为：10086和10087

1）咱们修改原来的EurekaServer配置：

server:
 port: 10086 # 端口
spring:
 application:
 name: eureka-server # 应用名称，会在Eureka中显示
eureka:
 client:
 service-url: # 配置其余Eureka服务的地址，而不是本身，好比10087
 defaultZone: http://127.0.0.1:10087/eureka

复制代码

所谓的高可用注册中心，其实就是把EurekaServer本身也做为一个服务进行注册，这样多个EurekaServer之间就能互相发现对方，从而造成集群。所以咱们作了如下修改：

  • 删除了register-with-eureka=false和fetch-registry=false两个配置。由于默认值是true，这样就会吧本身注册到注册中心了。
  • 把service-url的值改为了另一台EurekaServer的地址，而不是本身

2）另一台配置刚好相反：

server:
 port: 10087 # 端口
spring:
 application:
 name: eureka-server # 应用名称，会在Eureka中显示
eureka:
 client:
 service-url: # 配置其余Eureka服务的地址，而不是本身，好比10087
 defaultZone: http://127.0.0.1:10086/eureka

复制代码

注意：idea中一个应用不能启动两次，咱们须要从新配置一个启动器：

1525615070033

1525615095693

1525615026937

而后启动便可。

3）启动测试：

1525615165157

4）客户端注册服务到集群

由于EurekaServer不止一个，所以注册服务的时候，service-url参数须要变化：

eureka:
 client:
 service-url: # EurekaServer地址,多个地址以','隔开
 defaultZone: http://127.0.0.1:10086/eureka,http://127.0.0.1:10087/eureka
复制代码

5.4.2.服务提供者

服务提供者要向EurekaServer注册服务，而且完成服务续约等工做。

服务注册

服务提供者在启动时，会检测配置属性中的：eureka.client.register-with-erueka=true参数是否正确，事实上默认就是true。若是值确实为true，则会向EurekaServer发起一个Rest请求，并携带本身的元数据信息，Eureka Server会把这些信息保存到一个双层Map结构中。第一层Map的Key就是服务名称，第二层Map的key是服务的实例id。

服务续约

在注册服务完成之后，服务提供者会维持一个心跳（定时向EurekaServer发起Rest请求），告诉EurekaServer：“我还活着”。这个咱们称为服务的续约（renew）；

有两个重要参数能够修改服务续约的行为：

eureka:
 instance:
 lease-expiration-duration-in-seconds: 90
 lease-renewal-interval-in-seconds: 30
复制代码
  • lease-renewal-interval-in-seconds：服务续约(renew)的间隔，默认为30秒
  • lease-expiration-duration-in-seconds：服务失效时间，默认值90秒

也就是说，默认状况下每一个30秒服务会向注册中心发送一次心跳，证实本身还活着。若是超过90秒没有发送心跳，EurekaServer就会认为该服务宕机，会从服务列表中移除，这两个值在生产环境不要修改，默认便可。

可是在开发时，这个值有点太长了，常常咱们关掉一个服务，会发现Eureka依然认为服务在活着。因此咱们在开发阶段能够适当调小。

eureka:
 instance:
 lease-expiration-duration-in-seconds: 10 # 10秒即过时
 lease-renewal-interval-in-seconds: 5 # 5秒一次心跳
复制代码

实例id

先来看一下服务状态信息：

在Eureka监控页面，查看服务注册信息：

1525617060656

在status一列中，显示如下信息：

  • UP(1)：表明如今是启动了1个示例，没有集群
  • DESKTOP-2MVEC12:user-service:8081：是示例的名称（instance-id），
    • 默认格式是：${hostname} + ${spring.application.name} + ${server.port}
    • instance-id是区分同一服务的不一样实例的惟一标准，所以不能重复。

咱们能够经过instance-id属性来修改它的构成：

eureka:
 instance:
 instance-id: ${spring.application.name}:${server.port}
复制代码

重启服务再试试看：

1525617542081

5.4.3.服务消费者

获取服务列表

当服务消费者启动时会检测eureka.client.fetch-registry=true参数的值，若是为true，则会从Eureka Server服务的列表只读备份，而后缓存在本地。而且每隔30秒会从新获取并更新数据。咱们能够经过下面的参数来修改：

eureka:
 client:
 registry-fetch-interval-seconds: 5
复制代码

生产环境中，咱们不须要修改这个值。

可是为了开发环境下，可以快速获得服务的最新状态，咱们能够将其设置小一点。

5.4.4.失效剔除和自我保护

失效剔除

有些时候，咱们的服务提供方并不必定会正常下线，可能由于内存溢出、网络故障等缘由致使服务没法正常工做。Eureka Server须要将这样的服务剔除出服务列表。所以它会开启一个定时任务，每隔60秒对全部失效的服务（超过90秒未响应）进行剔除。

能够经过eureka.server.eviction-interval-timer-in-ms参数对其进行修改，单位是毫秒，生成环境不要修改。

这个会对咱们开发带来极大的不变，你对服务重启，隔了60秒Eureka才反应过来。开发阶段能够适当调整，好比10S

自我保护

咱们关停一个服务，就会在Eureka面板看到一条警告：

1525618396076

这是触发了Eureka的自我保护机制。当一个服务未按时进行心跳续约时，Eureka会统计最近15分钟心跳失败的服务实例的比例是否超过了85%。在生产环境下，由于网络延迟等缘由，心跳失败实例的比例颇有可能超标，可是此时就把服务剔除列表并不稳当，由于服务可能没有宕机。Eureka就会把当前实例的注册信息保护起来，不予剔除。生产环境下这颇有效，保证了大多数服务依然可用。

可是这给咱们的开发带来了麻烦， 所以开发阶段咱们都会关闭自我保护模式：

eureka:
 server:
 enable-self-preservation: false # 关闭自我保护模式（缺省为打开）
 eviction-interval-timer-in-ms: 1000 # 扫描失效服务的间隔时间（缺省为60*1000ms）
复制代码
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程