SpringCloud 源码剖析（一）实战 Eureka 服务注册、调用、集群搭建

2022-05-09 218

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： SpringCloud 源码剖析（一）实战 Eureka 服务注册、调用、集群搭建

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

大家好，我是悟空呀~

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

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

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

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

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

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

本文已同步至我的个人网站：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/

mark

说明两台 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 集群上。
如何将多个相同的服务组成微服务集群。

SpringCloud 源码剖析（一）实战 Eureka 服务注册、调用、集群搭建

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

一、基本原理

注册 + 服务调用

服务宕机

二、创建 Eureka Server

启动类

配置项

pom.xml 文件

启动

三、创建商品服务

application.yml 配置

Controller 类

启动类

pom.xml 文件

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

测试访问商品服务

四、创建订单服务

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

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

测试

五、组成 Eureka 集群

修改本地 hosts 配置

修改 Eureka Server 配置

六组成服务集群

七、修改调用者的配置

八、测试集群微服调用

九、总结

热门文章

最新文章

相关课程

相关电子书

探索云世界

热门

云计算

大数据

云原生

人工智能

数据库

开发与运维

活动广场

任务中心

训练营

直播

乘风者计划

下载

镜像站

技术资料

SpringCloud 源码剖析（一）实战 Eureka 服务注册、调用、集群搭建

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

一、基本原理

注册 + 服务调用

服务宕机

二、创建 Eureka Server

启动类

配置项

pom.xml 文件

启动

三、创建商品服务

application.yml 配置

Controller 类

启动类

pom.xml 文件

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

测试访问商品服务

四、创建订单服务

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

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

测试

五、组成 Eureka 集群

修改本地 hosts 配置

修改 Eureka Server 配置

六组成服务集群

七、修改调用者的配置

八、测试集群微服调用

九、总结

热门文章

最新文章

相关课程

相关电子书