【SpringCloud微服务实战学习系列】服务治理Spring Cloud Eureka

Spring Cloud Eureka是Spring Cloud Netflix微服务中的一部分，它基于NetFlix Sureka作了二次封装，主要负责完成微服务架构中的服务治理功能。

1、服务治理

服务治理是微服务架构中最为核心和基础的模块。它主要用来实现各个微服务实例的自动化注册与发现。

为了解决微服务架构中的服务实例维护问题，产生了大量的服务治理框架和产品，这下框架和产品的实现都围绕着服务注册与服务发现机制来完成对微服务应用实例的自动化管理。

一、服务注册

在服务治理框架中，一般都会构建一个注册中心，每一个服务单元向注册中心登记本身提供的服务，将主机与端口号、版本号、通讯协议等一些附加信息告知注册中心，注册中心按服务名分类组织服务清单。好比，咱们有两个提供服务A的进程分别用于192.168.0.100:8080和192.168.1.101:8080位置上，另外还有三个提供服务B的进程分别运行于192.168.0.100:9090、192.168.0.101:9090、192.168.0.102:9090位置上，当这些线程均启动、并向注册中心注册本身的服务以后，注册中会就会维护类型以下非服务清单。另外，服务注册中心还须要以心跳的方式去监测清单中的服务是否可用，若不可用须要从服务清单中剔除，达到排除故障服务的效果。

二、服务发现

因为在服务治理框架下运做，服务间的调用再也不须要经过指定具体的实例地址来实现，而是经过向服务名发起请求调用实现，因此，服务调用方在调用服务提供方的时候，并不知道具体的服务实例位置。所以，调用方须要向服务注册中心咨询服务，并获取全部服务的实例清单，以实现对具体服务实例的访问。好比：现有服务C但愿调用服务A，服务C就须要向注册中心发起咨询服务请求，服务注册中心就会将服务A的位置清单返回给服务C，如按上例服务A的状况。服务C便得到了服务A的两个可用位置192.168.0.100:8080和192.168.1.101:8080。当服务C要发起调用的时候便从该清单中以某种轮询策略取出一个位置来进行服务调用，这就是后续咱们将要介绍的负载均衡，

2、Netflix Eureka

Spring Cloud Eureka，使用Netflix Eureka来实现服务注册与发现，它既包含 服务端组件，也包含了客户端组件，而且服务端与客户端组件均采用java编写，因此Eureka主要使用于经过java实现的分布式系统，或是与JVM兼容语言构建的系统，可是因为Eureka服务端的服务治理机制提供了完备的RESTful API,因此它也支持非java语言构建的微服务应用归入Eureka的服务治理体系中来，只是在使用其余语言平台的时候须要租户来实现Eureka的客户端程序。

Eureka服务端，咱们也称为服务注册中心，它通其余服务注册中心同样，支持高可用配置。它依托于强一致性提供良好的服务实例可用性，能够应对多种不一样的故障场景。若是Eureka以集群模式部署，当集群中有分片出现故障时，那么Eureka就转入自我保护模式，它容许在分片故障期间继续提供服务的发行和注册，当故障分片回复运行时，集群中的其余分片会把他们的状态再次同步回来。以在AWS上的实践为例，Netflix推荐每一个可用的区域运营一个Eureka服务端，经过它来造成集群。不一样可用区域的服务注册中心经过异步模式互相复制格子的状态，这意味着在任何给定的时间点每一个实例关于全部服务的状态是有细微差异的。

Eureka客户端。主要处理服务的注册与发现。客户端服务经过注册和参数配置的方式，嵌入在客户端应用程序的代码中，在应用程序运行时，Eureka客户端向注册中心注册自身提供的服务并周期性的发生心跳来更新它的服务租约。同时，它也能从服务端查询当前注册的服务消息并把他们缓存到本地并周期性的刷新服务状态。

 3、搭建服务注册中心

一、pom.xml

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 4     <modelVersion>4.0.0</modelVersion>
 5 
 6     <groupId>com.slp</groupId>
 7     <artifactId>eureka-server</artifactId>
 8     <version>0.0.1-SNAPSHOT</version>
 9     <packaging>jar</packaging>
 10 
 11     <name>eureka-server</name>
 12     <description>Demo project for Spring Boot</description>
 13 
 14     <parent>
 15         <groupId>org.springframework.boot</groupId>
 16         <artifactId>spring-boot-starter-parent</artifactId>
 17         <version>1.3.7.RELEASE</version>
 18         <relativePath/> <!-- lookup parent from repository -->
 19     </parent>
 20 
 21     <properties>
 22         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 23         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 24         <java.version>1.8</java.version>
 25     </properties>
 26 
 27     <dependencies>
 28         <dependency>
 29             <groupId>org.springframework.boot</groupId>
 30             <artifactId>spring-boot-starter</artifactId>
 31         </dependency>
 32         <dependency>
 33             <groupId>org.springframework.boot</groupId>
 34             <artifactId>spring-boot-starter-web</artifactId>
 35         </dependency>
 36         <dependency>
 37             <groupId>org.springframework.boot</groupId>
 38             <artifactId>spring-boot-starter-test</artifactId>
 39             <scope>test</scope>
 40         </dependency>
 41         <!--添加服务注册依赖-->
 42         <dependency>
 43             <groupId>org.springframework.cloud</groupId>
 44             <artifactId>spring-cloud-starter-eureka-server</artifactId>
 45         </dependency>
 46         
 47     </dependencies>
 48 
 49     <build>
 50         <plugins>
 51             <plugin>
 52                 <groupId>org.springframework.boot</groupId>
 53                 <artifactId>spring-boot-maven-plugin</artifactId>
 54             </plugin>
 55         </plugins>
 56     </build>
 57 
 58     <repositories>
 59         <repository>
 60             <id>spring-snapshots</id>
 61             <name>Spring Snapshots</name>
 62             <url>https://repo.spring.io/snapshot</url>
 63             <snapshots>
 64                 <enabled>true</enabled>
 65             </snapshots>
 66         </repository>
 67         <repository>
 68             <id>spring-milestones</id>
 69             <name>Spring Milestones</name>
 70             <url>https://repo.spring.io/milestone</url>
 71             <snapshots>
 72                 <enabled>false</enabled>
 73             </snapshots>
 74         </repository>
 75     </repositories>
 76 
 77     <pluginRepositories>
 78         <pluginRepository>
 79             <id>spring-snapshots</id>
 80             <name>Spring Snapshots</name>
 81             <url>https://repo.spring.io/snapshot</url>
 82             <snapshots>
 83                 <enabled>true</enabled>
 84             </snapshots>
 85         </pluginRepository>
 86         <pluginRepository>
 87             <id>spring-milestones</id>
 88             <name>Spring Milestones</name>
 89             <url>https://repo.spring.io/milestone</url>
 90             <snapshots>
 91                 <enabled>false</enabled>
 92             </snapshots>
 93         </pluginRepository>
 94     </pluginRepositories>
 95 
 96 <dependencyManagement>
 97 
 98     <dependencies>
 99 
100         <dependency>
101             <groupId>org.springframework.cloud</groupId>
102             <artifactId>spring-cloud-dependencies</artifactId>
103             <version>Brixton.SR5</version>
104             <type>pom</type>
105             <scope>import</scope>
106         </dependency>
107     </dependencies>
108 </dependencyManagement>
109 </project>

二、经过@EnableEurekaServer注解启动一个服务注册中心提供给其余应用进行对话

 1 package com.slp.eurekaserver;  2 
 3 import org.springframework.boot.SpringApplication;  4 import org.springframework.boot.autoconfigure.SpringBootApplication;  5 import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;  6 
 7 /**  8  * 经过@EnableEurekaServer注解启动一个服务注册中心提供给其余应用进行注册  9  */
10 @EnableEurekaServer 11 @SpringBootApplication 12 public class EurekaServerApplication { 13 
14     public static void main(String[] args) { 15         SpringApplication.run(EurekaServerApplication.class, args); 16  } 17 }

三、默认设置下，该服务注册中心会将本身做为客户端来尝试注册本身，因此先禁用它本身的注册行为

application.properties

server.port=1111 eureka.instance.hostname=localhost eureka.client.register-with-eureka=false eureka.client.fetch-registry=false eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/

eureka.client.register-with-eureka:设置为false表示不向注册中心注册本身

eureka.client.fetch-registry：注册中的职责是维护服务实例，它不须要去检索服务，因此设置为false

 

四、访问http://localhost:1111

如今Instance currently registed with Eureka仍是空的，说明目前该注册中心尚未注册任何服务。

 4、注册服务提供者

在完成上述的服务中心注册以后，咱们尝试加入以前的项目到服务治理体系中去。

一、pom.xml

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 4     <modelVersion>4.0.0</modelVersion>
 5 
 6     <groupId>com.slp</groupId>
 7     <artifactId>springBoot</artifactId>
 8     <version>0.0.1-SNAPSHOT</version>
 9     <packaging>jar</packaging><!--SpringBoot默认将Web应用打包为jar的形式，而非war的形式，由于默认的Web模块会依赖抱哈嵌入式的Tomcat,这样使得咱们的jar自身具有提供web服务的能力。-->
10 
11     <name>springBoot</name>
12     <description>Demo project for Spring Boot</description>
13 
14     <parent>
15         <!--父项中定义了SpringBoot的版本的基础依赖以及一些默认配置信息，好比配置文件application.properties的位置等-->
16         <groupId>org.springframework.boot</groupId>
17         <artifactId>spring-boot-starter-parent</artifactId>
18         <version>1.3.7.RELEASE</version>
19         <relativePath/> <!-- lookup parent from repository -->
20     </parent>
21 
22     <properties>
23         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
24         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
25         <java.version>1.8</java.version>
26     </properties>
27 
28     <dependencies>
29         <dependency>
30             <!--全栈Web开发模块，包含嵌入式Tomcat SpringMVC-->
31             <groupId>org.springframework.boot</groupId>
32             <artifactId>spring-boot-starter-web</artifactId>
33         </dependency>
34 
35         <dependency>
36             <!--通用测试模块，包含JUnit  Hamcrest Mockito-->
37             <groupId>org.springframework.boot</groupId>
38             <artifactId>spring-boot-starter-test</artifactId>
39             <scope>test</scope>
40         </dependency>
41         <dependency>
42             <!--监控模块-->
43             <groupId>org.springframework.boot</groupId>
44             <artifactId>spring-boot-starter-actuator</artifactId>
45         </dependency>
46         <!--服务注册中心提供者-->
47         <dependency>
48             <groupId>org.springframework.cloud</groupId>
49             <artifactId>spring-cloud-starter-eureka</artifactId>
50         </dependency>
51     </dependencies>
52 
53     <dependencyManagement>
54 
55         <dependencies>
56 
57             <dependency>
58                 <groupId>org.springframework.cloud</groupId>
59                 <artifactId>spring-cloud-dependencies</artifactId>
60                 <version>Brixton.SR5</version>
61                 <type>pom</type>
62                 <scope>import</scope>
63             </dependency>
64         </dependencies>
65     </dependencyManagement>
66     <build>
67         <plugins>
68             <plugin>
69                 <groupId>org.springframework.boot</groupId>
70                 <artifactId>spring-boot-maven-plugin</artifactId>
71             </plugin>
72         </plugins>
73     </build>
74 
75 
76 </project>

二、HelloController.java

package com.slp.web; import com.slp.service.UserService; import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.stereotype.Controller; import org.springframework.ui.ModelMap; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; /** * @author sanglp * @create 2018-06-28 8:39 * @desc 第一个 controller **/ @Controller public class HelloController { private final Logger logger = Logger.getLogger(getClass()); @Autowired private DiscoveryClient client; @RequestMapping(value = "helloindex",method = RequestMethod.GET) public String helloindex(ModelMap map){ ServiceInstance instance = client.getLocalServiceInstance(); logger.info("/hello ,host:"+instance.getHost()+", service_id:"+instance.getServiceId()); return "helloindex"; } }

三、Application.java

package com.slp; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; /** * 在主类中经过加上@EnableDiscoveryClient注解，激活Eureka中的DiscoveryClient实现（自动化配置，建立DiscoveryClient接口针对Eureka客户端的EurekaDiscoveryClient实例） */ @EnableDiscoveryClient @SpringBootApplication public class Application { public static void main(String[] args) { //jar包包含Tomcat
        SpringApplication.run(Application.class, args); } }

四、在application.properties配置文件中，经过spring.application.name属性来为服务命名，再经过eureka.client.serviceUrl.defaultZone属性来指定服务注册中心的地址

1 spring.application.name=hello-service 2 eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/

五、启动注册服务提供者

注册提供者控制台：

1 2018-07-10 09:11:29.163  INFO 17484 --- [nfoReplicator-0] com.netflix.discovery.DiscoveryClient    : DiscoveryClient_HELLO-SERVICE/windows10.microdone.cn:hello-service - registration status: 204

注册中心控制台：

1 2018-07-10 09:11:29.154  INFO 18928 --- [io-1111-exec-10] c.n.e.registry.AbstractInstanceRegistry  : Registered instance HELLO-SERVICE/windows10.microdone.cn:hello-service with status UP (replication=false)