16 图 | 实战 Eureka 集群搭建+服务注册+调用

悟空聊架构

发布于 2022-05-13 16:42:35

4470

发布于 2022-05-13 16:42:35

文章被收录于专栏：悟空聊架构 | 公众号

这是悟空的第 136 篇原创文章

作者 | 悟空聊架构

来源 | 悟空聊架构

转载请联系授权

大家好，我是悟空呀~

之前已经写过 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 监听的端口。

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

pom.xml 文件

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

  <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 依赖。

<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 注解后，就可以实现负载均衡。

负载均衡的原理可以这篇：

6000字 | 深入理解 Ribbon 的架构原理

测试

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

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

测试访问订单 API

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

测试结果：

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

http://ProductService/product/

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

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/

可以看到两个 Eureka Server。

访问 http://localhost:8762/

可以看到两个 Eureka Server。

根据上面的两张图，说明两台 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。

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

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

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

七、修改调用者的配置

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

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

八、测试集群调用

接下来测试两个服务 A 组成微服务集群后，利用 Ribbon 负载均衡组件实现服务的负载均衡，说白了，就是两个服务 A，分别被服务 B 平均调用了。

测试方法：多次刷新浏览器，访问服务 B 的 API，服务 B 会调用服务 A。如下图所示：

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

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

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

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

九、总结

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

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

我是悟空，努力变强，变身超级赛亚人！

本文参与腾讯云自媒体同步曝光计划，分享自微信公众号。

原始发表：2021-12-01，如有侵权请联系 cloudcommunity@tencent.com 删除

负载均衡

负载均衡缓存

腾讯云测试服务

本文分享自悟空聊架构微信公众号，前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

负载均衡

负载均衡缓存

腾讯云测试服务

登录后参与评论

0 条评论

热度