Spring Cloud Eureka(服务治理)（1）

我就是我 2022-05-14 04:11 356阅读 0赞

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

1.服务治理

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

服务注册：在服务治理框架中通常会构建一个注册中心，每个服务单元向注册中心登记自己提供的服务，将主机与端口号、版本号、通信协议、等一些附加信息告知注册中心，注册中心按服务名分类名分类组织服务清单。

服务发现：由于在服务治理框架下运作，服务间的调用不再通过指明具体的实例地址来实现，而是通过向服务名发起请求调用实现。所以服务调用方在调用服务提供方接口的时候，并不知道具体的服务实例位置。因此，调用方需要向服务注册中心咨询服务，并获取所有服务的实例清单，以实现对具体服务实例的访问。

假如此时有两个提供服务A的进程分别运行与192.168.0.100:8000和192.168.0.101:8000位置上，则此时的服务注册为：












服务名 位置
服务A 192.168.0.100:8000、192.168.0.101:8000

当有个服务B希望调用服务A时，服务B就需要向注册中心发起咨询服务请求，服务注册中心就会将服务A的位置返回给服务B，此时返回的是192.168.0.100:8000、192.168.0.101:8000。当服务B要发起调用的时候便会从该清单中以某种轮询策略取出一个位置来进行服务调用。

2.Netflix Eureka

Spring Cloud Eureka,使用Netflix Eureka来实现服务注册与发现，它既包含了服务端组件也包含了客户端组件，并且服务端和客户端均采用Java编写，所以Eureka主要适用于通过Java实现分布式系统或与Jvm兼容语言的系统。

Eureka服务端（服务注册中心）它同其他服务注册中心一样，支持高可用配置。它依托于强一致性提供良好的服务实例可用性，可以应对多种不同的故障场景。

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

3.搭建服务注册中心

这里我用的是idea,首先新建一个boot项目然后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>
  6.     <groupId>com.example</groupId>
  7.     <artifactId>eureka-server</artifactId>
  8.     <version>0.0.1-SNAPSHOT</version>
  9.     <packaging>jar</packaging>
  11.     <name>eureka-server</name>
  12.     <description>Demo project for Spring Boot</description>
  14.     <parent>
  15.         <groupId>org.springframework.boot</groupId>
  16.         <artifactId>spring-boot-starter-parent</artifactId>
  17.         <version>2.0.4.RELEASE</version>
  18.         <relativePath/> <!-- lookup parent from repository -->
  19.     </parent>
  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.         <spring-cloud.version>Finchley.SR1</spring-cloud.version>
  26.     </properties>
  28.     <dependencies>
  29.         <dependency>
  30.             <groupId>org.springframework.cloud</groupId>
  31.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  32.         </dependency>
  34.         <dependency>
  35.             <groupId>org.springframework.boot</groupId>
  36.             <artifactId>spring-boot-starter-test</artifactId>
  37.             <scope>test</scope>
  38.         </dependency>
  39.     </dependencies>
  41.     <dependencyManagement>
  42.         <dependencies>
  43.             <dependency>
  44.                 <groupId>org.springframework.cloud</groupId>
  45.                 <artifactId>spring-cloud-dependencies</artifactId>
  46.                 <version>${spring-cloud.version}</version>
  47.                 <type>pom</type>
  48.                 <scope>import</scope>
  49.             </dependency>
  50.         </dependencies>
  51.     </dependencyManagement>
  53.     <build>
  54.         <plugins>
  55.             <plugin>
  56.                 <groupId>org.springframework.boot</groupId>
  57.                 <artifactId>spring-boot-maven-plugin</artifactId>
  58.             </plugin>
  59.         </plugins>
  60.     </build>
  63. </project>

通过@EnableEurekaServer注解启动一个服务注册中心提供给其他应用进行对话。如：

  1. @EnableEurekaServer
  2. @SpringBootApplication
  3. public class EurekaServerApplication {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(EurekaServerApplication.class, args);
  7.     }
  8. }

在默认设置下，该服务注册中心也会将自己作为客户端来尝试注册它自己，所以我们需要禁用它的客户端注册行为，在application.properties中增加如下配置：

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

eureka.client.register-with-eureka:由于该应用为注册中心，所以设置为false，代表不向注册中心注册自己。

eureka.client.fetch-registry:由于注册中心的职责就是维护服务实例，它不需要去检索服务，所以也设置为false。

启动后访问localhost:1111

70此时nstances currently registered with Eureka是空的，说明注册中心还没注册任何服务。

4.注册服务提供者

首先再新建一个SpringBoot项目,其pom文件如下：

  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>
  6.     <groupId>com.example</groupId>
  7.     <artifactId>eureka-service</artifactId>
  8.     <version>0.0.1-SNAPSHOT</version>
  9.     <packaging>jar</packaging>
  11.     <name>eureka-service</name>
  12.     <description>Demo project for Spring Boot</description>
  14.     <parent>
  15.         <groupId>org.springframework.boot</groupId>
  16.         <artifactId>spring-boot-starter-parent</artifactId>
  17.         <version>2.0.4.RELEASE</version>
  18.         <relativePath/> <!-- lookup parent from repository -->
  19.     </parent>
  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.         <spring-cloud.version>Finchley.SR1</spring-cloud.version>
  26.     </properties>
  28.     <dependencies>
  29.         <dependency>
  30.             <groupId>org.springframework.cloud</groupId>
  31.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  32.         </dependency>
  33.         <dependency>
  34.             <groupId>org.springframework.boot</groupId>
  35.             <artifactId>spring-boot-starter-web</artifactId>
  36.         </dependency>
  38.         <dependency>
  39.             <groupId>org.springframework.boot</groupId>
  40.             <artifactId>spring-boot-starter-test</artifactId>
  41.             <scope>test</scope>
  42.         </dependency>
  43.     </dependencies>
  45.     <dependencyManagement>
  46.         <dependencies>
  47.             <dependency>
  48.                 <groupId>org.springframework.cloud</groupId>
  49.                 <artifactId>spring-cloud-dependencies</artifactId>
  50.                 <version>${spring-cloud.version}</version>
  51.                 <type>pom</type>
  52.                 <scope>import</scope>
  53.             </dependency>
  54.         </dependencies>
  55.     </dependencyManagement>
  57.     <build>
  58.         <plugins>
  59.             <plugin>
  60.                 <groupId>org.springframework.boot</groupId>
  61.                 <artifactId>spring-boot-maven-plugin</artifactId>
  62.             </plugin>
  63.         </plugins>
  64.     </build>
  67. </project>

然后添加一个控制器：

  1. @RestController
  2. public class HelloController {
  3.     @Autowired
  4.     private DiscoveryClient client;
  6.     @RequestMapping("/hello")
  7.     public String index() {
  8.         return "Hello";
  9.     }
  11. }

通过在主类上添加@EnableDiscoveryClient注解激活Eureka中的DiscoveryClient实现（自动化配置，创建DiscoveryClient接口针对Eureka客户端的EurekaDiscoveryClient实例）

然后在application.propertiess配置文件中通过spring.application.name为服务命名，再通过eureka.client.serviceUrl.defaultZone属性指定服务注册中心的地址：

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

然后启动两个服务可以看到：

70 1

70 2

或者通过访问Eureka的信息面板可以看到注册信息：

70 3

5.高可用注册中心

在分布式环境中我们需要考虑发生故障的情况，所以在生成环境中必须对各个组件进行高可用部署。

Eureka Server的设计一开始就考虑了高可用问题，在Eureka的服务治理设计中，所有节点即是服务提供方也是服务消费方，服务注册中心也不例外。所以通过设置下面两个参数让服务注册中心不注册自己：

  1. eureka.client.register-with-eureka=false
  2. eureka.client.fetch-registry=false

Eureka Server的高可用实际上就是将自己作为服务向其他服务注册中心注册自己，这样就可以形成一组互相注册的服务注册中心，以实现服务清单的互相同步，达到高可用的下过。下面来简单尝试下搭建一个双节点的服务注册中心集群。

首先创建application-peer1.properties和application-peer2.properties

两个文件分别如下：

  1. spring.application.name=eureka-server
  2. server.port=1111
  4. eureka.instance.hostname=peer1
  5. eureka.client.serviceUrl.defaultZone=http://peer2:1112/eureka/
  7. spring.application.name=eureka-server
  8. server.port=1112
  10. eureka.instance.hostname=peer2
  11. eureka.client.serviceUrl.defaultZone=http://peer1:1111/eureka/

然后修改C:\Windows\System32\drivers\etc\hosts文件添加下面两行内容：

  1. 127.0.0.1 peer1
  2. 127.0.0.1 peer2

然后通过spring.profiles.active属性来启动peer1和peer2:

首先cd到这个目录下，使用mvn install，如：

70 4

70 5

最后成功如上所示，然后到target目录下：

G:\eureka\eureka-server\target>java -jar eureka-server-0.0.1-SNAPSHOT.jar —spri
ng.profiles.active=peer1

G:\eureka\eureka-server\target>java -jar eureka-server-0.0.1-SNAPSHOT.jar —spri
ng.profiles.active=peer2

70 6

70 7

70 8

在设置多节点的服务注册中心后，服务提供方还要做一些简单的配置才能将服务注册到Eureka Server集群中。

这里以eureka-service为例子：

修改其application.properties

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

通过对eureka.client.serviceUrl.defaultZone属性做改变，将注册中心指向了peer1和peer2

70 9

因此，如果断开了peer1由于eureka-service也向peer2进行了注册，所以peer2上的其他服务任然能访问到hello-service，从而实现服务注册中心得高可用。

如果要用ip的形式来定义注册中心的地址，则要在配置文件中增加配置参数eureka.instance.prefer-ip-address=true其默认为false。

需要注意的是如果将eureka-server的application.properties这两行进行注释。

  1. #eureka.client.register-with-eureka=false 
  2. #eureka.client.fetch-registry=false

那么服务启动后的效果是：

70 10

发表评论

表情：
评论列表 （有 0 条评论，356人围观）

还没有评论，来说两句吧...

相关阅读

    相关 Spring Cloud Eureka(服务治理)（2）

    1.服务发现与消费 下面来尝试构建一个服务消费者，它主要完成两个目标，发现服务以及消费服务。其中服务发现的任务由Eureka的客户端完成，而服务消费者的任务由Ribbon

    墨蓝墨蓝/ 0 赞/ 289 阅读