一、服务发现组件我们为什么选择Eureka?

    1.Eureka来自生产环境,这是它天生的优势

    2.Spring Cloud对Eureka支持很好

二、Eureka简介

     Eureka是Netflix开发的服务发现框架,本身是一个基于REST的服务,主要用于定位运行在AWS域中的中间层服务,以达到负载均衡和中间层服务故障转移的目的。Spring Cloud将它集成在其子项目spring-cloud-netflix中,以实现Spring Cloud的服务发现功能。

     Eureka项目相当活跃,代码更新相当频繁,目前最新的版本是1.5.5.Eureka 2.0的版本也正在紧锣密鼓的开发中,2.0将会带来更好的扩展性,并且使用细粒度的订阅模型取代了基于拉取的模型。

三、Eureka原理


       上面的架构描述了Eureka如何在Netflix上部署,这是你通常运行它的方式。每个区域有一个Eureka簇,它只知道其区域中的实例。 每个区域至少有一个eureka服务器来处理区域故障。

        想理解上面的原理图首先要了解Region和Zone的关系,如下图所示,可以看到region的范围是要比zone大的,在每一个zone下有多个eureka。


            关于region和zone的关系,推荐大家看一篇博客,博客地址:http://blog.csdn.net/awschina/article/details/17639191,下面我截取了其中的一段介绍,如下图所示。

         

          

        了解了AWS的region和zone的概念后,我们再来看一下Eureka的原理图,从图中可以看到,Eureka包含两个组件:Eureka Server和Eureka Client。Eureka Server提供服务注册服务,各个节点启动后,会在Eureka Server中进行注册,这样Eureka Server中的服务注册表中将会存储所有可用服务节点的信息,服务节点的信息可以在界面中直观的看到。Eureka Client是一个Java客户端,用于简化Eureka Server的交互,客户端同时也具备一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后,将会向Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳,Eureka Server将会从服务注册表中把这个服务节点移除(默认90秒)Eureka Server之间将会通过复制的方式完成数据的同步。Eureka还提供了客户端缓存的机制,即使所有的Eureka Server都挂掉了,客户端依然可以利用缓存中的信息消费其它服务的API。综上,Eureka通过心跳检测、健康检查、客户端缓存等机制,确保了系统的高可用性、灵活性和可伸缩性。(us-east-1c、us-east-1d、us-east-1e是属于同一个region(us-east-1)下的三个不同的可用区)

 


四、搭建一个Eureka Server

       我们在第三课的时候搭建了一个服务提供者和一个服务消费者,现在我们对项目进行下调整,把服务提供者和服务消费者作为spring cloud的子项目。

1.我们找到服务提供者和服务消费者所在的目录,如下图所示


2.我们把项目名称改一下,去掉其中的simple,如下图所示


3.从任意一个子项目中复制一份pom.xml文件到与两个子项目同一级目录下,如下图所示。


    为了便于代码管理,我们最好不要直接将父工程放到E:\\MicroService下,应该新建一个目录microservice-spring-cloud,然后把上图的三个文件都放到该目录下,如下图所示


    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>

   <groupId>com.itmuch.cloud</groupId>
   <artifactId>microservice-spring-cloud</artifactId>
   <version>0.0.1-SNAPSHOT</version>
   <packaging>pom</packaging>

    <modules>
      <module>microservice-consumer-movie</module>
      <module>microservice-provider-user</module>
   </modules>
   <properties>
      <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
      <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
      <java.version>1.8</java.version>
   </properties>
   <parent>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-parent</artifactId>
      <version>1.4.4.RELEASE</version>
   </parent>
   <dependencyManagement>
      <dependencies>
         <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Camden.SR5</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>
上面的配置文件中<parent>和<dependencyManagement>的配置内容均来自spring-cloud的官网,如下图所示

4.修改movie项目的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>

   <artifactId>microservice-consumer-movie</artifactId>
   <packaging>jar</packaging>

   <name>microservice-consumer-movie</name>
   <description>Demo project for Spring Boot</description>

   <parent>
      <groupId>com.itmuch.cloud</groupId>
      <artifactId>microservice-spring-cloud</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <relativePath>../pom.xml</relativePath>
   </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>
   </dependencies>

</project>
5.修改user项目的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>

   <artifactId>microservice-provider-user</artifactId>
   <packaging>jar</packaging>

   <name>microservice-provider-user</name>
   <description>Demo project for Spring Boot</description>

   <parent>
      <groupId>com.itmuch.cloud</groupId>
      <artifactId>microservice-spring-cloud</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <relativePath>../pom.xml</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-data-jpa</artifactId>
      </dependency>
      <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-web</artifactId>
      </dependency>

      <dependency>
         <groupId>mysql</groupId>
         <artifactId>mysql-connector-java</artifactId>
         <scope>runtime</scope>
      </dependency>
   </dependencies>
   
</project>
         修改完配置文件之后,我们便开始导入我们的工程,首先我们打开Intellij IDEA工具,如下图所示,我们点击"Import Project"。


       接着,我们会看到如下图所示的界面,我们点击工程所在的父目录"MicroService"。


        接下来,我们会看到如下图所示的界面,图的上方是单选按钮,我们选择"Import project from external model",选择后下面白色框中的工具便可以让我们选择了,我们选择Maven,然后点击"Next"。


        接下来,我们会看到如下图所示的界面,我们不用做任何配置,点击"Next"


        接下来我们会看到如下图所示的界面,我们也不用做任何配置,直接点击"Next"


        接下来我们可以看到如下图所示的界面,这里值得注意的是我们本地要先安装jdk1.8,确保工程使用的是jdk1.8,然后点击"Next"。


        接下来,我们可以看到如下图所示的界面,我们不用做任何配置,直接点击"Finish"。


        下面我们便可以看到如下图所示的界面。


       前面做了些铺垫,下面我们便新建一个Maven工程(Eureka Server),我们点击下图红色圈住的那个图标。

       

       我们会看到如下图所示的界面,我们点击"Modules",由于我们要添加的eureka工程也是属于spring-cloud的子工程,因此我们复制一份user或movie工程,这里我以复制user为例,点击"microservice-provider-user",然后再点击上面的那个复制图标。


       我会看到如下图所示的弹出框,我们在"Module name"这一栏输入"microservice-discovery-eureka",然后点击"OK"


       我们会看到如下图所示的弹出框,我们点击"OK"


       下面我们便可以看到如下图所示的界面,我们点击"Apply"和"OK"


       下面我们可以看到如下图所示的界面,可以看到,我们刚才复制的工程"microservice-discovery-eureka"是个空的工程,这时还未加到Maven管理。


       为了把"microservice-discovery-eureka"添加到Maven管理当中,我们在工程"microservice-discovery-eureka"上右键,会弹出右键菜单,我们点击"Add Framework Support...",如下图所示。


      我们会看到如下图所示的界面,我们在左侧找到"Maven"并勾选,然后点击"OK"按钮。


        点击上图的"OK"之后,我们便可以看到如下图所示的界面,可见,一个空的"microservice-discovery-eureka"Maven工程已经建成。


       下面我们来修改一下eureka工程的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>

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

    <parent>
        <groupId>com.itmuch.cloud</groupId>
        <artifactId>microservice-spring-cloud</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <relativePath>../pom.xml</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.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka-server</artifactId>
        </dependency>
    </dependencies>
    
</project>
      依赖eureka的配置如果报错,可以把鼠标点击红色字符串,然后按快捷键"Alt+Enter",会看到如下图所示的下拉菜单,我们点击"Update Maven Indices",Maven便会去下载所需的依赖。等依赖下载完毕,红色错误便消失了。


        下面我们开始写eureka工程的启动类,在java目录下新建一个包"com.itmuch.cloud",然后在该包下新建一个EurekaApplication类,类的内容如下图所示。


       下面我们在resources目录下新建一个application.yml配置文件,内容如下图所示。其中register-with-eureka:  false和fetch-registry:  false表示不要把该eureka server当成eureka客户端(因为默认情况下,一个eureka server同时也是一个eureka client,因为eureka server之间是需要互相通信的,需要有client的功能,我们现在是单机版,因此先把eureka server仅当做server)


       下面我们来启动eureka server,要启动它就要先到eureka server的启动类,右键点击"Run 'EurekaApplication'"运行。


         启动成功之后,我们在地址栏输入:http://localhost:8761访问eureka的首页,如下图所示。由于当前eureka server还未有任何服务注册进来,因此显示的实例是空。


     本节课我们便一起学习到这里。      


Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐