实战 Eureka 服务注册、调用、集群搭建
实战 Eureka 服务注册、调用、集群搭建
大家好,我是悟空呀~
之前已经写过 7 篇 Eureka 注册中心的源码剖析和理论相关的文章了,缺少一点实战。
本篇会带大家做一个实战案例,涉及内容:
- 配置服务注册到 Eureka 注册中心。
- 服务之间通过注册的服务名来访问。01.eureka_practice.md-temp
- 本地如何搭建 Eureka 集群。
- 本地如何搭建微服务集群。
- -如何用 Ribbon 实现负载均衡。
之前的几篇 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/
说明两台 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 集群上。
如何将多个相同的服务组成微服务集群。