服务器集群搭建（实战 Eureka 集群搭建+服务注册+调用）

原文链接：https://mp.weixin.qq.com/s/z-lZlUEKyktNo0N9sv4y6Q
本篇会带大家做一个实战案例，涉及内容：

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

 
目录
 
一、基本原理
注册 + 服务调用
先上原理图：
 
下面说下原理图中对应的场景：
场景：

有一个订单服务部署在一台机器上，另外有两个商品服务部署在一台机器上，三个服务的端口都不一样。
商品服务和订单服务都将自己的地址信息注册到 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 依赖。

<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 注解后，就可以实现负载均衡。
测试
启动订单服务，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 集群上。
如何将多个相同的服务组成微服务集群。

本文出自快速备案，转载时请注明出处及相应链接。

本文永久链接: https://www.175ku.com/26545.html