实战 Eureka 服务注册、调用、集群搭建

大家好，我是悟空呀~

之前已经写过 7 篇 Eureka 注册中心的源码剖析和理论相关的文章了，缺少一点实战。

本篇会带大家做一个实战案例，涉及内容：

• 配置服务注册到 Eureka 注册中心。
• 服务之间通过注册的服务名来访问。
• 本地如何搭建 Eureka 集群。
• 本地如何搭建微服务集群。
• -如何用 Ribbon 实现负载均衡。

之前的几篇 Eureka 文章也汇总下：

领导让我研究 Eureka 源码 | 启动过程

领导“叕”让我研究 Eureka 源码：注册过程

值得收藏的 Eureka 控制台详解

原来一个 Map 就能搞定注册表了

6 张图 | 剖析客户端首次同步注册表

11 张图 | 讲透原理，最细的增量拉取

12 张图 | 硬刚了一波，三层缓存架构

本文已同步至我的个人网站：www.passjava.cn

一、基本原理

注册 + 服务调用

先上原理图：

下面说下原理图中对应的场景：

场景：

• 有一个订单服务部署在一台机器上，另外有两个商品服务部署在一台机器上，三个服务的端口都不一样。
• 商品服务和订单服务都将自己的地址信息注册到 Eureka，Eureka 把这些信息都缓存到注册表中。
• 当订单服务想要调用商品服务时，其实是先从 eureka 上获取商品服务的地址信息。
• 订单服务向两个商品服务发送 HTTP 请求。

服务宕机

当有一个商品服务宕机后，eureka 会把这个服务的注册信息移除掉，订单服务也不会调用这个商品服务。

下面我们按照上面服务调用的场景来简单使用下 Eureka。

需求：首先有一个订单服务 OrderService，一个商品服务 ProductService， 订单服务不知道商品服务的 IP 地址，只知道商品服务的 的名字，订单服务通过向 Eureka 注册中心获取到了商品服务的具体 IP 地址，然后成功调用商品服务的的 getProduct API。

二、创建 Eureka Server

总共会启动 4 个微服务，如下图所示：

创建一个 Eureka 服务。

前提条件：Spring Cloud 基于 Hoxton.SR10 版本，Spring Boot 基于 2.3.2.RELEASE。

启动类

创建启动类，Eureka Server 就是这个类启动的。

/**
 * @Author: 公众号 | 悟空聊架构
 * @Date: 2021/9/13 7:28
 * @Site: www.passjava.cn
 * @Github: https://github.com/Jackson0714/eureka-learning
 */
@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaServerApplication.class, args);
    }
}

配置项

然后配置下 Eureka Server 的基本信息。配置信息可以放到 application.yml 文件中。

server:
  port: 8761
eureka:
  client:
    register-with-eureka: false
    fetch-registry: false

port：Eureka Server 监听的端口。

register-with-eureka: 是否把自己注册到 Eureka，单机情况下，不需要注册自己。

fetch-registry: 是否到 Euraka 服务抓取注册信息。

pom.xml 文件

首先需要配置 pom.xml 文件，引入 Eureka 依赖。

  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.3.2.RELEASE</version>
  </parent>
  
  <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-dependencies</artifactId>
        <version>Hoxton.SR10</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>
  
  <dependencies>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-config</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>

  </dependencies>

启动

接下来启动 Eureka Server 的控制台。浏览器访问 http://localhost:8761/ 就可以看到控制台了。

因为还没有服务注册到 Eureka，所以控制台中的服务列表是空的。

三、创建商品服务

application.yml 配置

商品服务对应的端口为 8006 和 8007，可以先启动一个商品服务，然后修改端口后，再启动另外一个商品服务。

server:
  port: 8006
spring:
  application:
    name: ProductService
eureka:
  instance:
    hostname: localhost
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka

Controller 类

定义了获取商品的 API，提供给订单服务调用。

/**
 * 订单服务的接口
 *
 */
@RestController
public class ProductServiceController {

    /**
     * 订单服务
     * @param name 商品名称
     * @return 测试返回商品名
     */
    @RequestMapping(value = "/product/{name}",
            method = RequestMethod.GET)
    public String getProduct(@PathVariable("name") String name) {

        System.out.println("商品服务被调用了");
        return "order" + name;
    }
}

启动类

用来启动商品服务。

/**
 * 商品服务
 * @Author: 公众号 | 悟空聊架构
 * @Date: 2021/9/13 7:28
 * @Site: www.passjava.cn
 * @Github: https://github.com/Jackson0714/eureka-learning
 */
@SpringBootApplication
@EnableEurekaClient
public class ProductServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProductServiceApplication.class, args);
    }

}

pom.xml 文件

引入 Eureka Client 依赖。

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
                  <version>Hoxton.SR10</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
 </dependencies>
</dependencyManagement>

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-config</artifactId>
  </dependency>
  <dependency>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  </dependency>
</dependencies>

测试商品服务是否正常启动

先按照 8006 端口启动一个商品服务，然后按照 8007 端口启动另外一个商品服务。

Eureka 控制台可以看到两个商品服务已启动。

测试访问商品服务

用 Postman 工具进行测试：

http://localhost:8006/getProduct/悟空聊架构专属商品

返回结果：

四、创建订单服务

订单服务和商品服务的区别

• 多了一个 Ribbon 依赖。
• 订单服务会调用商品服务。

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

订单服务调用商品服务的 API

@RestController
@Configuration
public class OrderServiceController {

    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate() {

        return new RestTemplate();
    }

    /**
     * 根据订单 id 查找商品信息
     * @param id 订单 id
     * @return 商品服务返回的数据
     */
    @RequestMapping(value = "/order/{id}", method = RequestMethod.GET)
    public String getOrder(@PathVariable("id") String id) {
        RestTemplate restTemplate = getRestTemplate();
        return restTemplate.getForObject("http://ProductService/product/" + id, String.class);
    }
}

我们看到有一个 @LoadBalanced 注解，这里做下说明：

RestTemplate 用来实现单个 http 请求的，加了 @LoadBalanced 注解后，就可以实现负载均衡。

测试

启动订单服务，IDEA 中可以看到

可以在 eureka 控制台看到订单服务在注册列表上。

测试访问订单 API

http://localhost:9091/order/悟空聊架构专属商品

测试结果：

说明订单服务 OrderService 通过 Eureka 拿到了的商品服务 ProductService 的 URL 信息，然后成功调用商品服务。如下 URl 所示，只知道商品服务的名字 ProductService，但是不知道具体的 IP 地址。

http://ProductService/product/

通过 Eureka 的注册表信息获取到了具体的 IP 地址。z

192.168.10.197:ProductService:8007
192.168.10.197:ProductService:8006

Eureka + 商品服务 + 订单服务 的演示案例已经完成。

接下来我们看下怎么把两个 Eureka Server 组成 Eureka 集群。

五、组成 Eureka 集群

修改本地 hosts 配置

host 文件添加两台 Eureka server 的地址映射，都为本地 localhost 地址

127.0.0.1 eureka-server1
127.0.0.1 eureka-server2

修改 Eureka Server 配置

两个服务互相向对方注册，第一个 Eureka 开放 8761 端口，注册到第二个 Eureka 的 8762 端口。

第一个 Eureka Server 的配置并启动

server:
  port: 8761
eureka:
  instance:
    hostname: eureka-server1
  client:
    serviceUrl:
      defaultZone: http://eureka-server1:8762/eureka/

修改第二个 Eureka Server 的配置，并启动

server:
  port: 8762
eureka:
  instance:
    hostname: eureka-server2
  client:
    serviceUrl:
      defaultZone: http://eureka-server2:8761/eureka/

访问 http://localhost:8761/

访问 http://localhost:8762/

说明两台 Eureka Server 组成了一个集群环境。

六组成服务集群

接下来将服务注册到 Eureka 集群上。另外因为我最开始用的商品服务的名字是 ServiceA，而不是 ProductService，所以案例中的截图都是 ServiceA，订单服务对应的是 ServiceB，不影响案例演示

将服务 A 配置成注册到 Eureka 集群。在 defaultZone 配置中添加第二个 eureka 的服务地址。

server:
  port: 8006
spring:
  application:
    name: ServiceA
eureka:
  instance:
    hostname: localhost
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka,http://localhost:8762/eureka

然后启动服务 。

然后将服务 A 的 port 改为 8006 后，再次启动一个服务 A，相当于部署了两个服务 A，后续可以作为测试负载均衡的功能。

发现一个 Eureka 的问题，注册列表总是刷新不出最新的注册信息，重启 Eureka 服务后就刷出来了。

接着我们把服务 A 的passjava 方法，打下日志，后面观察两个服务 A 分别被服务 B 调用了几次。

七、修改调用者的配置

将服务 B 配置成注册到 Eureka 集群。在 defaultZone 配置中添加第二个 eureka 的服务地址。

两个 Eureka 服务中都有服务 B 的注册信息。

八、测试集群微服调用

多次刷新浏览器，访问订单服务的 API

http://localhost:9091/test/悟空

第一个服务 A 被服务 B 调用了 6 次：

第二个服务A 被服务 B 调用了 7 次：

根据上面的结果说明 Eurkea 集群 + Ribbon + 微服务集群的案例演示完成。

九、总结

本篇通过案例演示的方式，带着大家练习了如下内容：

• 如何使用 Eureka 作为注册中心。
• 如何将多个服务注册到 Eureka 上。
• 通过使用 Eureka，服务间的调用不再需要知道对方的 IP 地址。
• 如何将两个 Eureka Server 在本地组成 Eureka 集群。
• 如何将多个服务注册到 Eureka 集群上。
• 如何将多个相同的服务组成微服务集群。