springcloud组件-eureka

Posted liuqijia

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了springcloud组件-eureka相关的知识,希望对你有一定的参考价值。

1、eureka什么?

2、eureka单节点如何使用?

3、eureka集群配置?

4、zookeeper的cp性与eureka的ap性

5、关于eureka的自我保护机制


1、eureka是什么?

  springcloud中的eureka就相当于之前dubbo中的zookeeper,也是一个注册中心。

一个基于REST的服务,用于定位服务,以实现云端中间层服务发现和故障转移,并且支持集群部署。

 

2、eureka单节点?

  以自身所写的项目来说:

   首先新建一个父项目Springcloud,分别去新建子项目:

    springcloud-consumer-management:各个消费者项目

    springcloud-provider-management:各个提供者项目

    springcloud-management:MVC层

    springcloud-eureka-management:eureka项目

  下一步所要做的是:

    (1)在父项目中引入所需要的所有jar包

    (2)在springcloud-management中将Mapper、model、service层新建出来,

      并进行层级依赖的建立:mapper-->model    service-->mapper

    (3)在consumer-management中去引入对应的依赖,并新建一个consumer的子工程:6081

    (4)在provider-management中去引入对应的依赖,并新建一个consumer的子工程:8081

  实现:

  (1)父项目的依赖:

 1 <!--
 2         项目jar包的构建:
 3             之前使用的parent标签直接引入项目中,可以继承父项目的jar包
 4             但是项目中已经使用到了springcloud和springboot
 5             springcloud和springboot需要些两个parent,但是在pom工程中不能这样实现
 6             所以直接引入springboot和springcloud的jar包工程,并且使用dependencyManagement标签进行管理,用到了什么jar包直接重写
 7 
 8             springboot-parent, springcloud-parent的父级工程都是dependencies
 9     -->
10 
11     <dependencyManagement>
12         <dependencies>
13             <dependency>
14                 <groupId>org.springframework.boot</groupId>
15                 <artifactId>spring-boot-dependencies</artifactId>
16                 <version>2.1.8.RELEASE</version>
17                 <type>pom</type>
18                 <scope>import</scope>
19             </dependency>
20             <dependency>
21                 <groupId>org.springframework.cloud</groupId>
22                 <artifactId>spring-cloud-dependencies</artifactId>
23                 <version>Greenwich.SR3</version>注意版本号
24                 <type>pom</type>
25                 <scope>import</scope>
26             </dependency>
27             <dependency>
28                 <groupId>io.zipkin.java</groupId>
29                 <artifactId>zipkin-server</artifactId>
30                 <version>2.11.8</version>
31                 <exclusions>
32                     <exclusion>
33                         <groupId>org.apache.logging.log4j</groupId>
34                         <artifactId>log4j-slf4j-impl</artifactId>
35                     </exclusion>
36                 </exclusions>
37             </dependency>
38             <dependency>
39                 <groupId>io.zipkin.java</groupId>
40                 <artifactId>zipkin-autoconfigure-ui</artifactId>
41                 <version>2.11.8</version>
42             </dependency>
43             <dependency>
44                 <groupId>mysql</groupId>
45                 <artifactId>mysql-connector-java</artifactId>
46                 <version>5.0.4</version>
47             </dependency>
48             <dependency>
49                 <groupId>com.alibaba</groupId>
50                 <artifactId>druid</artifactId>
51                 <version>1.0.31</version>
52             </dependency>
53             <dependency>
54                 <groupId>org.mybatis.spring.boot</groupId>
55                 <artifactId>mybatis-spring-boot-starter</artifactId>
56                 <version>1.3.0</version>
57             </dependency>
58         </dependencies>
59     </dependencyManagement>

 

 

(2)springcloud-management中的各层级:

Mapper层的pom: 
1
<?xml version="1.0" encoding="UTF-8"?> 2 <project xmlns="http://maven.apache.org/POM/4.0.0" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 5 <parent> 6 <artifactId>springcloud-management</artifactId> 7 <groupId>com.aaa.liu.springcloud</groupId> 8 <version>1.0-SNAPSHOT</version> 9 </parent> 10 <modelVersion>4.0.0</modelVersion> 11 12 <artifactId>springcloud-mapper</artifactId> 13 14 15 <dependencies> 16 <dependency> 17 <groupId>com.aaa.liu.springcloud</groupId> 18 <artifactId>springcloud-model</artifactId> 19 <version>1.0-SNAPSHOT</version> 20 </dependency> 21 <!-- 22 需要引入mysql mybatis springboot druid 23 --> 24 <dependency> 25 <groupId>mysql</groupId> 26 <artifactId>mysql-connector-java</artifactId> 27 </dependency> 28 <dependency> 29 <groupId>com.alibaba</groupId> 30 <artifactId>druid</artifactId> 31 </dependency> 32 <dependency> 33 <groupId>org.mybatis.spring.boot</groupId> 34 <artifactId>mybatis-spring-boot-starter</artifactId> 35 </dependency> 36 <dependency> 37 <groupId>org.springframework.boot</groupId> 38 <artifactId>spring-boot-starter-web</artifactId> 39 </dependency> 40 </dependencies> 41 </project>

 

 

 service层的pom:
1
<?xml version="1.0" encoding="UTF-8"?> 2 <project xmlns="http://maven.apache.org/POM/4.0.0" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 5 <parent> 6 <artifactId>springcloud-management</artifactId> 7 <groupId>com.aaa.liu.springcloud</groupId> 8 <version>1.0-SNAPSHOT</version> 9 </parent> 10 <modelVersion>4.0.0</modelVersion> 11 12 <artifactId>springcloud-service</artifactId> 13 14 <dependencies> 15 <dependency> 16 <groupId>com.aaa.liu.springcloud</groupId> 17 <artifactId>springcloud-mapper</artifactId> 18 <version>1.0-SNAPSHOT</version> 19 </dependency> 20 </dependencies> 21 </project>

 

 

(3)consumer-management依赖:

 1 <dependencies>
 2         <dependency>
 3             <groupId>com.aaa.liu.springcloud</groupId>
 4             <artifactId>springcloud-model</artifactId>
 5             <version>1.0-SNAPSHOT</version>
 6         </dependency>
 7         <dependency>
 8             <groupId>org.springframework.boot</groupId>
 9             <artifactId>spring-boot-starter-web</artifactId>
10         </dependency>
11     </dependencies>

 

 

 

(4)provider-management项目的依赖:

 1 <dependencies>
 2         <dependency>
 3             <groupId>org.springframework.cloud</groupId>
 4             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
 5         </dependency>
 6         <dependency>
 7             <groupId>org.springframework.boot</groupId>
 8             <artifactId>spring-boot-starter-actuator</artifactId>
 9         </dependency>
10         <dependency>
11             <groupId>com.aaa.liu.springcloud</groupId>
12             <artifactId>springcloud-service</artifactId>
13             <version>1.0-SNAPSHOT</version>
14         </dependency>
15     </dependencies>

 

 

 

正式开始:

先进行尝试consumer是否能够直接调用到provider中的方法

  在provider-management新建的第一个provider为provider-8081,

在Java下的包中只需要添加controller包和一个主启动类:

主启动类:

@SpringBootApplication
@MapperScan("com.aaa.liu.springcloud.mapper")
public class ApplicationRun8081 
    public static void main(String[] args) 
        SpringApplication.run(ApplicationRun8081.class,args);
    

 

controller层下的UserController:

@RestController
public class UserController 
    @Autowired
    private UserService userService;

    @RequestMapping("/userAll")
    public List<User> selectAllUsers()
        System.out.println("8081");
        return userService.selectAllUsers();
    

 

然后在provider下的resources中新建config包,包下是application.properties:

基本的一些配置:
server.port=8081
server.servlet.context-path=/

spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/mybatis?useSSL=false
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

mybatis.type-aliases-package=com.aaa.liu.springcloud.model
mybatis.mapper-locations=classpath:mapper/*Mapper.xml

 

 

下面是consumer-management中新建一个consumer6081:

主启动类:

@SpringBootApplication
public class ApplicationRun6081 
    public static void main(String[] args) 
        SpringApplication.run(ApplicationRun6081.class,args);
    

 

在Java包下新建了一个config包和controller包

config包下的ConfigRest:

/**
 * 对配置类,需要加上configuration或者SpringbootApplication
 * RestTemplate:模拟http协议,使得两个controller调用
 */
@SpringBootApplication
public class ConfigRest 
    @Bean
    public RestTemplate getTemplate()
        return  new RestTemplate();
    

 

controller包下的UserController:

@RestController
public class UserController 

    @Autowired
    private RestTemplate restTemplate;
    //调用service,consumer项目的controller调用的是provider项目的controller(使用的是http协议)
    //如果可以模拟http协议,就可以实现两个controller之间的调用
    //getForObject:(使用get请求方式)该方法有两个参数
    //第一个参数:URL(请求路径(localhost:8081/userAll))
    //第二个参数:规定返回值的类型

    @RequestMapping("/userAll")
    public List<User> selectAllUsers()
        return restTemplate.getForObject("http://localhost:8081/userAll",List.class);
    

 

resource下的application.properties(由于只是请求服务,不用与数据打交道,不用数据源):

server.port=6081
server.servlet.context-path=/

 

完事!分别启动provider和consumer,在浏览器中访问localhost:6081/userAll,请求到数据,则调用无碍。

 

下面开始eureka的单节点设置:

  代码很简单,在eureka-management中新建一个eureka7081项目

在Java中只有一个主启动类:

/**
 * @EnableEurekaServer:就是开启eureka的服务器
 * @EnableEurekaClient:不让用,因为springcloud1.x的注解(我们使用的是格林威治RS3版本)
 */
@SpringBootApplication
@EnableEurekaServer
public class ApplicationRun7081 
    public static void main(String[] args) 
        SpringApplication.run(ApplicationRun7081.class,args);
    

 

resource中的properties.properties:

server.port=7081
server.servlet.context-path=/

# eureka服务器端的实例名称
eureka.instance.hostname=eureka01

# eureka也会把自己注册进注册中心里,这里因为最终eureka是不需要被发现的服务,
# 所以不再需要把自己注册到注册中心里
# 默认值为true,表示把自己注册进注册中心
eureka.client.register-with-eureka=false
# 表示自己就是注册中心,注册中心的职责是维护服务实例,并不需要从注册中心里去发现自己
eureka.client.fetch-registry=false
# 配置eureka的注册地址
# zookeeper需要在linux服务器上进行配置,最终的情况下使用zookeeper的时候必须要指向zookeeper的IP地址
# eureka不需要做任何服务器配置,但是也必须要指向地址(直接指向eureka的项目即可:http://localhost:7081/eureka)
# 该地址中的localhost就是eureka.instance.hostname的值,端口号就是server.port的值,/eureka:固定的(eureka自己提供)
# defaultZone:eureka默认所提供的命名空间
# 在eureka的注册地址中,是可以分空间(zone)的,是命名空间,根据空间的不同来配置不同集群的eureka来实现不同的作用
# 如果为单节点可以随意配置,但是如果为集群则目前为止必须要配置成defaultZone(因为如果是集群版就必须先要声明命名空间,如果不声明则无法使用)
eureka.client.service-url.defaultZone=http://localhost:7081/eureka

 

在provider8081中进行配置:

  现在主启动类中添加:@EnableDiscoveryClient 注解,与eureka的主启动类的@EnableEurekaServer对应

(对于eureka来说,provider就是客户端,而eureka是服务端)

然后就是.properties配置文件了:

spring.datasource.password=123456
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

mybatis.type-aliases-package=com.aaa.liu.springcloud.model
mybatis.mapper-locations=classpath:mapper/*Mapper.xml

# 配置的是在eureka中显示的服务名(Application)
# 如果不配置,则会显示UNKNOWN
spring.application.name=user-provider

# 配置eureka的注册地址(实现provider这个客户端注册进了eureka中)
# GreenWich rs.3:无论是单节点还是集群模式,
# eureka的服务器端和客户端的命名空间务必要保持一致,否则会报错(找不到服务实例)
eureka.client.service-url.defaultZone=http://localhost:7081/eureka

# 是在eureka中配置实例的名字(也就是说Eureka的Status下的显示的名字)
# 不允许重复  (相当于mysql数据库中的表的主键id)
eureka.instance.instance-id=user-provider-8081

# 在eureka中显示IP地址
eureka.instance.prefer-ip-address=true

# 点击eureka的服务名显示出该服务的具体信息
# 根据服务的具体内容,作者,公司,以及对整个服务的描述来进行
# 相当于在html页面上有一个a标签<a href="/actuator/info"></a>--> 跳转到controller:@RequestMapping("/actuator/info">
# 开头用info  其他的随便输入
info.author.name=Liu
info.company.name=AAA SOFTWARE EDU
info.project.description=this is Demo

 

!这个颜色标注的配置信息是可以不用配置的!

OK!接下类分别启动eureka、provider、consumer(顺序不要错了,否则会报出无法发现服务异常)

在浏览器中访问localhost:7081就可以看到eureka的界面了,在上面可以看到关于注册进eureka的provider信息

 

3、集群版eureka:

在eureka-management中再新建两个eureka项目,分别为7082、7083

将eureka组成一个集群,eureka与zookeeper不同,eureka组成集群,是需要在eureka配置信息里分别

注入其他两台的信息,让他们能够互相知道。

server.port=7081
server.servlet.context-path=/

# eureka服务器端的实例名称
eureka.instance.hostname=eureka01-->三台分别为eureka01、eureka02、eureka03

# eureka也会把自己注册进注册中心里,这里因为最终eureka是不需要被发现的服务,
# 所以不再需要把自己注册到注册中心里
# 默认值为true,表示把自己注册进注册中心
eureka.client.register-with-eureka=false
# 表示自己就是注册中心,注册中心的职责是维护服务实例,并不需要从注册中心里去发现自己
eureka.client.fetch-registry=false
# 配置eureka的注册地址
# zookeeper需要在linux服务器上进行配置,最终的情况下使用zookeeper的时候必须要指向zookeeper的IP地址
# eureka不需要做任何服务器配置,但是也必须要指向地址(直接指向eureka的项目即可:http://localhost:7081/eureka)
# 该地址中的localhost就是eureka.instance.hostname的值,端口号就是server.port的值,/eureka:固定的(eureka自己提供)
# defaultZone:eureka默认所提供的命名空间
# 在eureka的注册地址中,是可以分空间(zone)的,是命名空间,根据空间的不同来配置不同集群的eureka来实现不同的作用
# 如果为单节点可以随意配置,但是如果为集群则目前为止必须要配置成defaultZone(因为如果是集群版就必须先要声明命名空间,如果不声明则无法使用)
#eureka.client.service-url.defaultZone=http://localhost:7081/eureka
eureka.client.service-url.defaultZone=http://eureka02:7082/eureka,http://eureka03:7083/eureka

 

与单机版的.properties配置改动很少,主要在两个地方,一个是名字上的区分,一个是最后一行命名空间的配置。

 

4、zookeeper和eureka的区别?

  zookeeper保证的是数据CP性,即数据一致性,而eureka保证的是AP性,即服务可用性。

 

5、关于eureka的自我保护机制

  如果长时间不去连接(激活)eureka的时候,会出现自我保护机制,在eureka页面上显示:

EMERGENCY! EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEY‘RE NOT. RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARE NOT BEING EXPIRED JUST TO BE SAFE.

那么为什么会出现自我保护机制呢?

  在eureka中注册过的服务会定时向eureka发送心跳,当网络故障/网络延迟/服务宕机等情况下,服务器不再向eureka

发送心跳,eureka从接不到心跳开始计时,默认在90秒(这个时间可以修改)之后,eureka会将这个服务剔除。

但此处有关剔除的机制有一个点:假设现在有100台服务,其中三台别检测认为宕机,eureka会剔除这三台;

  但如果此刻有198台provider都没有心跳,eureka不会把这198台provider剔除,而是会保留,这也是eureka的保护机制,

也就是说eureka不会大量剔除服务。这就是eureka的AP性。

为什么eureka不会剔除大量的服务呢

  AP:只保证了服务的可用性,不保证数据的一致性。

  CP:只保证数据的一致性,不保证服务的可用性。

  如果eureka把所有的服务全部剔除,当consumer尽心访问的时候,发现eureka没有任何服务了,整个项目都处于瘫痪状态,

整个客户端的体验就会很差,也就是相当于500.

  假设当大面积服务都没有心跳,eureka不剔除的情况下,consumer进行访问调用的时候依然可以找到服务,然后就可以获取数据,

这些数据可能不是最新的数据,但最起码eureka中还存在服务。

 

我们是可以将eureka的保护机制关掉的,但通常不允许这么做,一般可以对它进行失效操作。

关闭eureka的自我保护机制:

  在eureka-7081项目的application.properties配置文件中,添加:

  eureka.server.enable-self-preservation=false

  然后重新请求eureka,可以在页面上看到THE SELF PRESERVATION MODE IS TURNED OFF等信息。

让eureka的自我保护机制失效:

  首先eureka会定时检测provider的心跳,假如现在eureka检测provider的时间间隔 ,我们给更改为10s.

即在eureka-7081的配置文件中添加:eureka.server.eviction-interval-timer-in-ms=10000

注:单位是毫秒

  其次,假如在provider端是一个集群,现在其中一台provider不需要eureka的自我保护机制,也就是说我们要让

eureka的自我保护机制在这一台上失效。

  在provider的配置文件中进行配置:告诉eureka,我每隔5秒向你发送心跳,你每隔8秒检测一次,如果没有检测到,

就直接把我剔除。这样一来,eureka会按照我们在provide的配置来执行,我们就打成了让eureka的自我保护失效的目的。

provide配置:

  # 规定自己向eureka发送心跳的时间,单位是秒,我们设置为5秒

  eureka.instance.lease-renewal-interval-in-seconds=5

  # 当eureka最后一次检测到心跳的时间间隔(单位是秒),我们给他设置成8秒

  eureka.instance.lease-expiration-duration-in-seconds=8

  

我们现在对provider进行集群搭建:

在provider-management中新建两个provider8082、provider8083

由于只是对provider进行集群配置,所以三台provider上的项目应该是一样的,只是相较于单台provider来说,

我们需要在配置文件中进行一点修改:

server.port=8081
server.servlet.context-path=/

spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/teach?useSSL=false
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

mybatis.type-aliases-package=com.aaa.lee.springcloud.model
mybatis.mapper-locations=classpath:mapper/*Mapper.xml

# 配置的是在eureka中显示的服务名(Application)
# 如果不配置,则会显示UNKNOWN(这个是细节!!,以后有问题)
spring.application.name=user-provider

# 配置eureka的注册地址(实现provider这个客户端注册进了eureka中)
# GreenWich RS.3:无论是单节点还是集群模式,eureka的服务器端和客户端的命名空间必要保持一致,否则会报错(找不到服务实例)
#eureka.client.service-url.defaultZone=http://localhost:7081/eureka
eureka.client.service-url.defaultZone=http://eureka01:7081/eureka,http://eureka02:7082/eureka,http://eureka03:7083/eureka

# 是在eureka中配置实例的名字(也就是说Eureka的Status下的显示的名字)
# !!!不允许重复!!!(相当于mysql数据库中的表的主键id)
eureka.instance.instance-id=user-provider-8081

# 在eureka中显示IP地址
eureka.instance.prefer-ip-address=true

# 点击eureka的服务名显示出该服务的具体信息
# 根据服务的具体内容,作者,公司,以及对整个服务的描述来进行显示
# 相当于在HTML页面上有一个a标签<a href="/actuator/info"></a> --> 跳转到controller:@RequestMapping("/actuator/info")
# !!开头用info!!其他的随便输入
info.author.name=Liu
info.company.name=AAA SOFTWARE EDU
info.project.description=This is Demo
info.dsadasda=eqwewq321312daa

# 规定自己向eureka发送心跳的时间
# 单位是秒
#eureka.instance.lease-renewal-interval-in-seconds=5
# 当eureka最后一次检测到心跳的时间间隔(单位是秒)
# eg:15:05:20是最后一次检测到心跳-->检测8秒之后还是无法检测心跳的时候直接剔除
#eureka.instance.lease-expiration-duration-in-seconds=8

 

这里要注意一点:eureka的同步问题!!!

  在provider的配置中,我们需要将provider注册进eureka中, 由于eureka是集群,所以我们在添加配置的时候需要这样写:

eureka.client.service-url.defaultZone=http://eureka01:7081/eureka,http://eureka02:7082/eureka,http://eureka03:7083/eureka

 

但其实我们只写http://eureka01:7081,我们会发现,在eureka中其它两台eureka中也能看到这台provider,原因是eureka进行了同步。

已有的Eureka Server:在运行过程中,Eureka Server之间会定时同步实例的注册信息。

这样即使新的Application Service只向集群中一台注册服务,则经过一段时间会集群中所有的

Eureka Server都会有这个实例的信息。那么Eureka Server节点之间如何相互发现,

各个节点之间定时(时间由eureka.server.peer-eureka-nodes-update-interval-ms决定)更新节点信息,进行相互发现。

Service Consumer:Service Consumer刚启动时,它会从配置文件读取Eureka Server的地址信息。

当集群中新增一个Eureka Server中时,那么Service Provider如何发现这个Eureka Server?Service Consumer会定时(

此值由eureka.client.eureka
-service-url-poll-interval-seconds决定)调用Eureka Server集群接口,获取所有的Eureka Server信息的并更新本地配置。

 

以上是关于springcloud组件-eureka的主要内容,如果未能解决你的问题,请参考以下文章

springCloud五大核心组件(转载)

浅析-----SpringCloud常用组件

SpringCloud微服务组件介绍

SpringCloud基础组件完结--第七章

SpringCloud 五大组件基础介绍

SpringCloud 五大组件基础介绍