一.如何解决硬编码问题
上节课我们一起学习了服务提供者和服务发现者,其中有个非常大问题就是硬编码的问题,众所周知,在现在互联网开发中,访问地址的 IP 和端口号是动态的,一个服务停掉再重新启用后 IP 和端口就可能发生了改变,所以用硬编码是肯定不行了。
二.服务发现
基于上面提到的问题,解决的办法是采用服务发现组件动态维护访问路径等关系,如下图所示。服务提供者会把 IP 和端口注册到服务发现组件当中,当有服务消费者需要消费服务的时候,它只需要去服务发现组件中去获取访问路径即可。那么它们的关系是如何维持的呢?其实也是用到了心跳机制,就是说,服务提供者和服务消费者在服务发现组件当中注册之后每隔固定的时间就会发送一次心跳,服务发现组件接收到心跳便认为被管理的对象是可用的,如果长时间接收不到心跳,那么服务发现组件便认为该对象已经挂掉,便把它的注册信息删除掉。再对外提供服务的时候便不再使用挂掉的服务提供者的 IP 和端口。
三.服务发现组件的功能
服务发现组件的功能分为三个:
1.服务注册表
服务注册表是一个记录当前可用服务实例的网络信息的数据库,是服务发现机制的核心。服务注册表提供查询 API 和管理 API,使用查询 API 获得可用的服务实例,使用管理 API 实现注册和注销。
2.服务注册
注册功能是前提,服务组件要想对外提供服务,起码得有供它管理服务才行,因此注册功能是基础,是前提。
3.健康检查
一个服务注册到服务组件之后并不是就万事大吉了,服务发现组件还要定时检查注册进来的这些服务是不是已经宕掉了,如果宕掉了,就不再对外提供该服务所提供的服务。
四.服务发现的方式
1.客户端发现
客户端发现常见的有两种方式,分别是 Eureka 和 Zookeeper
服务端发现常见的方式是 Consul+nginx
五.服务发现组件选择 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。
1.Eureka Server 提供服务注册服务,各个节点启动后,会在 Eureka Server 中进行注册,这样 Eureka Server 中的服务注册表中将会存储所有可用服务节点的信息,服务节点的信息可以在界面中直观的看到。
2.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 的子项目。
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>
复制代码
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>
复制代码
下面我们来修改一下 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 工程的启动类,在 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)
评论