springcloud(三)-Eureka

Eureka是Netflix开源的一款提供服务注册和发现的产品，它提供了完整的Service Registry和Service Discovery实现。也是springcloud体系中最重要最核心的组件之一。

服务发现简介

服务中心又称注册中心，管理各种服务功能包括服务的注册、发现、熔断、负载、降级等，比如dubbo admin后台的各种功能。

有了服务中心调用关系会有什么变化？

上一节我们见识了springcloud最简单的微服务调用。类似于

项目A调用项目B

正常调用项目A请求项目B

有了服务发现Eureka机制，任何一个服务都不能直接去掉用，都需要通过服务中心来调用

如果是项目A调用项目B，项目B在调用项目C

这时候调用的步骤就会为两步：第一步，项目A首先从服务中心请求项目B服务器，然后项目B在从服务中心请求项目C服务。

这样做有什么好处呢？如果只有这样一两个服务，而且访问量不大的情况下，这样做确实有点画蛇添足的感觉。但是，如果像这样的服务由二三十个，上百个呢？画一张图来描述几十个项目之间的相互调用关系全是线条，任何其中的一个项目改动，就会牵连好几个项目跟着重启，巨麻烦而且容易出错。通过服务中心来获取服务你不需要关注你调用的项目IP地址，由几台服务器组成，每次直接去服务中心获取可以使用的服务去调用既可。

由于各种服务都注册到了服务中心，就有了去做很多高级功能条件。比如几台服务提供相同服务来做均衡负载；监控服务器调用成功率来做熔断，移除服务列表中的故障点；监控服务调用时间来对不同的服务器设置不同的权重等等。

Eureka 简介

Eureka由两个组件组成：Eureka服务器和Eureka客户端。Eureka服务器用作服务注册服务器。Eureka客户端是一个java客户端，用来简化与服务器的交互、作为轮询负载均衡器，并提供服务的故障切换支持。Netflix在其生产环境中使用的是另外的客户端，它提供基于流量、资源利用率以及出错状态的加权负载均衡。

用一张图来认识以下：

上图简要描述了Eureka的基本架构，由3个角色组成：

1、Eureka Server

提供服务注册和发现

2、Service Provider

服务提供方
将自身服务注册到Eureka，从而使服务消费方能够找到

3、Service Consumer

服务消费方
从Eureka获取注册服务列表，从而能够消费服务

编写Eureka Server

spring cloud已经帮我实现了服务注册中心，我们只需要很简单的几个步骤就可以完成。

1.创建一个maven工程，pom.xml文件添加依赖

<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>

 <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.itmuch.cloud</groupId>

   <artifactId>microservice-discovery-eureka</artifactId>

   <version>0.0.1-SNAPSHOT</version>

   <packaging>jar</packaging>

   <name>microservice-discovery-eureka</name>

   <url>http://maven.apache.org</url>

   <parent>

         <groupId>org.springframework.boot</groupId>

         <artifactId>spring-boot-starter-parent</artifactId>

         <version>1.5.9.RELEASE</version>

     </parent>

   <properties>

     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

     <java.version>1.8</java.version>

   </properties>

   <dependencies>

            <dependency>

             <groupId>org.springframework.boot</groupId>

             <artifactId>spring-boot-starter-web</artifactId>

         </dependency>

         <!--         用于监控spring boot 端点 -->

         <dependency>

             <groupId>org.springframework.boot</groupId>

             <artifactId>spring-boot-starter-actuator</artifactId>

         </dependency>

         <dependency>

             <groupId>org.springframework.boot</groupId>

             <artifactId>spring-boot-starter-tomcat</artifactId>

         </dependency>

         <dependency>

             <groupId>org.springframework.boot</groupId>

             <artifactId>spring-boot-devtools</artifactId>

             <optional>true</optional> <!-- 这个需要为 true 热部署才有效 -->

         </dependency>

         <dependency>

             <groupId>org.springframework.cloud</groupId>

             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>

         </dependency>

   </dependencies>

 <!--   引入spring cloud 的依赖 -->

     <dependencyManagement>

         <dependencies>

             <dependency>

                 <groupId>org.springframework.cloud</groupId>

                 <artifactId>spring-cloud-dependencies</artifactId>

                 <version>Edgware.RELEASE</version>

                 <type>pom</type>

                 <scope>import</scope>

             </dependency>

         </dependencies>

     </dependencyManagement>

 <!--   添加spring-boot 的maven插件 -->

     <build>

         <plugins>

             <plugin>

                 <groupId>org.springframework.boot</groupId>

                 <artifactId>spring-boot-maven-plugin</artifactId>

             </plugin>

         </plugins>

     </build>

 </project>

点击展开

2.编写启动类，添加@EnableEurekaServer注解，声明这是一个Eureka Server

package com.itmuch.cloud;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@SpringBootApplication

@EnableEurekaServer

public class EurekaApplication {

    public static void main(String[] args) {

        SpringApplication.run(EurekaApplication.class, args);

    }

}

3.配置文件application.yml

server:

  port: 8083

eureka:

  client:

    registerWithEureka: false

    fetchRegistry: false

    serviceUrl:

      defaultZone: http://localhost:8083/eureka

简单介绍一下：

eureka.client.registerWithEureka:表示是否将自己注册到Eureka Server，默认为true。由于当前应用就是Eureka Server，故而这里设为false。
eureka.client.fetchRegistry:表示是否从Eureka Server获取注册信息。默认为true。因为这是一个单点的Eureka Server，不需要同步其他的Eureka Server节点的数据，所以设为false
eureka.client.serviceUrl.defaultZone:设置与Eureka Server交互的地址，查询服务和注册服务都需要依赖这个地址。默认是http://localhost:8083/eureka;多个地址间可使用“，”分隔。

这样一个Eureka Server就编写完了。

测试

启动Eureka Server 启动类。访问 http://localhost:8083/,可以打开界面

目前没有任务服务注册到上面。

将微服务注册到Eureka Server上

改写上一节的microservice-simple-provider-user

1.pom.xml文件添加依赖

<dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>

</dependency>

2.配置application.yml

server:

  port: 8084

eureka:

  client:

    serviceUrl:

      defaultZone: http://localhost:8083/eureka/

  instance:

    prefer-ip-address: true

spring:

  application:

    name: microservice-provider-user

  jpa:

    generate-ddl: false

    show-sql: true

    database-platform: org.hibernate.dialect.MySQL5Dialect

    hibernate:

      ddl-auto: none

  datasource:

    url: jdbc:mysql://localhost:3306/cloud?useUnicode=true&characterEncoding=UTF-8

    username: root

    password: 1234

    driver-class-name: com.mysql.jdbc.Driver

  http:

    multipart:

      maxFileSize: 100Mb

      maxRequestSize: 100Mb

logging:

  level:

    root: INFO

    org.hibernate: INFO

    org.hibernate.type.descriptor.sql.BasicBinder: TRACE

    org.hibernate.type.descriptor.sql.BasicExtractor: TRACE

其中，spring.application.name用于指定注册到Eureka Server上的应用名称；eureka.instance.prefer-ip-address = true 表示将自己的IP注册到Eureka Server。若不配置该属性或将其设置为false，则表示注册微服务所在操作系统的hostname到Eureka Server 。

另外，同样的操作，给microservice-consumer-movie也来一遍。

测试

启动 microservice-discovery-eureka

启动 microservice-provider-user

启动 microservice-consumer-movie

注：因为每一个服务在启动的时候都会注册到服务发现上面去，如果eureka没开的话，服务在启动的时候会报找不到服务发现的错误，所以一般都是先开eureka。但是就算你后启动eureka，每一个服务客户端都会在eureka启动之后，再连到上面去，不会影响使用。

访问http://localhost:8083/，可看到页面

由此图可知，我们的两个微服务客户端已经被注册到Eureka Server 上了。

我们访问http://localhost:8082/user/1,得到结果

{"id":1,"username":"account1","name":"张三","age":20,"balance":98.23}

由此可知，movie服务通过Eureka Server 找到 user 服务，访问获得了结果。

OK！完美！

这一节没多少新代码，该有的都再上面贴出来了。源码就不放了。

巴特西