Java开发 - 带你了解集群间的相互调用，你还在等什么？

左手的ㄟ右手 2023-10-12 15:55 92阅读 0赞

**目录**

前言

导读

项目准备

集群准备

父工程引入子项目

服务调用方HelloService准备

pom文件

yml文件

Controller文件

服务提供方HelloWorld准备

pom文件

yml文件

Controller文件

运行此两个工程

hello\_world组集群

集群调用测试

RestTemplate换成Dubbo行不行，怎么换

两个pom文件引入依赖

两个启动文件添加新注解

结构调整

helloWorld调整

helloService调整

编辑

重新运行

权重

结语

--------------------

## 前言 ##

前文中，对Redis的集群做了详细的讲解，能一路读到这里的相信你们对集群的概念已经基本了解，今天博主要带给大家的是集群之间的相互调用，同时还带负载均衡，这也是目前比较流行的集群使用方法，可以有效避免故障时对整个系统造成影响。既然有集群，那一定少不了RPC的使用，没错，这里会简单涉及，后续会单独讲解更详细的使用，下面，就让我们一起来学习这篇集群之间的相互调用吧。

## 导读 ##

**本篇的重点不在于讲RPC，而是单纯的一种集群调用思想和调用结构！！！**

在开始学习前，不知道你对Nacos了解多少？本文主要依靠的便是Nacos注册中心，如果不还不太了解，下面这篇博客将带你初步了解：

[Java开发 - 配置中心初体验][Java_ -]

## 项目准备 ##

在开始讲解之前，我们需要先准备一个基础项目其结构大概如下：

![b4705aa74b4e442a88402558384cb0cc.png][]

你不必像创建过多子项目，圈起来的俩红色的是博主创建的，service是业务调用方，helloworld是业务提供方，好吧，world还写错了，请不要嘲笑博主，手滑，真的是手滑。

关于微服务项目基本结构不知道大家了解多少，如果你对微服务项目里父子项目的基本结构不了解的话，那么建议你先去了解下面下，博主给大家准备好了，点下面链接：

[Java开发 - 数风流人物，还看“微服务”][Java_ - 1]

赶紧去看，趁博主还没收费哦～

不选择在这里给大家讲解是因为篇幅过长，不利于大家学习，学习应该是一个循序渐进的过程，而不是一蹴而就。

下面就是一个集群的异地容灾结构图，大家看看：

![bc5cefd535cf4a168523fde416a0c0b2.png][]

## 集群准备 ##

上面主要是让大家熟悉微服务父子项目的配置，这里也会涉及点，但基本上是一笔带过，若果你了解父子项目结构，那么请继续。

### 父工程引入子项目 ###

![fd3020ec3d7c435cb5b90c1ec52bf024.png][]

详细的结构大家还是要通过上面那篇去学习，这里不再赘述。

### 服务调用方HelloService准备 ###

#### pom文件 ####

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>com.codingfire</groupId>
            <artifactId>cloud</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </parent>
        <groupId>com.codingfire</groupId>
        <artifactId>HelloService</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>HelloService</name>
        <description>Demo project for Spring Boot</description>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            <dependency>
                <groupId>com.codingfire</groupId>
                <artifactId>Cloud-helloword</artifactId>
                <version>0.0.1-SNAPSHOT</version>
            </dependency>
        </dependencies>
    </project>

#### yml文件 ####

spring:
      application:
        # 当前Springboot项目的名称,用于注册中心服务的名称
        name: hello_service
      cloud:
        nacos:
          discovery:
            server-addr: localhost:8848
            cluster-name: HZ # 集群名称
    
    hello_world:
      ribbon:
        NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

其中，hello\_world是我们要调用的业务的名字，在对方的pom文件中。下面有负载均衡策略，是随机的。

#### Controller文件 ####

我们简单搞个Controller，用来调用hello\_world服务：

package com.codingfire.helloservice.controller;
    
    import com.codingfire.cloud.helloword.controller.HHelloController;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    @RequestMapping("/hello")
    public class SHelloController {
    
        @Autowired
        private RestTemplate restTemplate;
    
    
        @GetMapping("/service")
        public String hello(){
            //hello_world也可以用ip：port替代，但你要集群调用，就不能写死，要写对方的集群的服务名
            String helloWorld = "http://hello_world/hello/world";
    
            return "XiaoMing says:" + helloWorld;
        }
    
    }

此处我们先用最简单的RestTemplate来进行RPC，此处肯定报错，还需要在启动类中添加此方法：

package com.codingfire.helloservice.config;
    
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    @Configuration
    public class RestTemplateConfig {
    
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate(){
            return new RestTemplate();
        }
    }

到此，服务调用方的准备就已经就绪。

### 服务提供方HelloWorld准备 ###

#### pom文件 ####

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>com.codingfire</groupId>
            <artifactId>cloud</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </parent>
        <groupId>com.codingfire</groupId>
        <artifactId>Cloud-helloword</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>Cloud-helloword</name>
        <description>Demo project for Spring Boot</description>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
        </dependencies>
    
    </project>

#### yml文件 ####

spring:
      application:
        # 当前Springboot项目的名称,用于注册中心服务的名称
        name: hello_world
      cloud:
        nacos:
          discovery:
            server-addr: localhost:8848
            cluster-name: SH # 集群名称

#### Controller文件 ####

package com.codingfire.cloud.helloword.controller;
    
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @RequestMapping("/hello")
    public class HHelloController {
    
        @GetMapping("/world")
        public String hello(){
            return "Hello World!";
        }
    
    }

到此，服务提供方准备就绪。

### 运行此两个工程 ###

**在此之前，请大家确保Nacos已经启动，否则无法运行项目！！！**

由于本地运行项目时，没有指定端口，所以tomcat端口8080会冲突，我们给hello\_world指定版本号8081:

![dcfd2684abf0457abf7653f9939c01f2.png][]

接下来分别运行这两个项目，并在Nacos后台查看:

![a0b2270f3ecb4c39846c82b73f280c79.png][]

此时看到两个服务都已经成功注册进来，但我们要做的是调用集群服务，所以还需要给hello\_world增加一个服务，组成集群。

### hello\_world组集群 ###

请大家点击此处：

![042d3ed5d5b34d9bb8f846f40e5ab64f.png][]

在下图中复制多个启动文件出来：

![271cae8ff72049e990b218755cc9c817.png][]

并分别指定端口为8082，8083，8084。

下面我们先运行8082：

![ae76e0faf02a4035bde62e68e4b9003a.png][]

在运行8083和8084之前，我们需要把yml文件中的集群名HZ，改为SH，已经运行的项目不要暂停，本地模拟需要，生产环境多台服务器的时候不需要这样。

![507a673593e4450795bfdb1110163d37.png][]

接着分别运行8083和8084的启动文件，然后去Nacos后台刷新查看：

![304e1dbad87e47c193d3d2552fa0db3d.png][]

此时hello\_world的集群有两个，实例有四个，符合我们的预期，我们点击“详情”按钮查看：

![735b754a62d842e2aa298735688a32d1.png][]

完美。

### 集群调用测试 ###

下面我们调用接口：[http://localhost:8080/hello/service][http_localhost_8080_hello_service]

它会去调用hello\_world里面的接口，最终会显示出来一段话，额，你们有没有报500错误？控制台提示下面这段话：

> Request URI does not contain a valid hostname: http://hello\_world/hello/world

如果有的话，恭喜你中奖了，这里要插入一个小小的知识点，spring.application.name中不能带下划线，博主的命名是不是都带了下划线？这是一个非常小的错误，但也是一个非常容易被忽略的错误，问题是你压根不知道发生了什么，所以，大家现在回过头，去yml文件里，把名字改了，改成：helloWorld和helloService，Controller里面的RestTemplate调用处也需要改，改完之后，重新按照博主上面的步骤运行。一个HZ集群，一个SH集群，不要漏一个。

下面就是见证奇迹的时刻，让我们访问：[http://localhost:8080/hello/service][http_localhost_8080_hello_service]

![50b3d7aa3a4b4641816fca74356eef2f.png][]

输出这段话，就表示你的应用运行成功了。下面我们清空四个控制台：

![c530d74bcf114b4e955b2753399071d4.png][]

刷新url并查看控制台：

![20e4b5e890c54df8b62cbab161055cc8.png][]

你会发现在这四个控制台的输出像是轮询，一个一个，我们注意到，helloServcie的集群是HZ，我们希望它能够优先访问本集群内的服务，而不是访问其他集群的服务。

但默认的`ZoneAvoidanceRule`不能实现根据同集群优先来实现负载均衡，所以Nacos中提供了一个`NacosRule`的实现，可以优先从同集群中挑选实例。下面修改负载均衡的策略：

helloWorld:
      ribbon:
    #    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
        NFLoadBalancerRuleClassName: com.alibaba.cloud.nacos.ribbon.NacosRule # 负载均衡规则

使用新的，原来的注释起来，再次运行helloService，重新调用上面的接口，就会优先访问本集群的服务了。

为了测试集群挂掉后是否能访问其他的集群，你需要把HZ集群的两个实例下线掉：

![dce47906dbd341008a79d5fade6f063c.png][]

然后继续访问上面的接口，只要能成功访问，就代表我们的集群策略是没问题的。

## RestTemplate换成Dubbo行不行，怎么换 ##

RestTemplate是一种比较老的用法，我们现在做RPC会更多的用Dubbo，那么Dubbo该怎么使用呢？现在，我们把RestTemplate替换成Dubbo来看看，能不能和上面的集群调用有一样的表现。

### 两个pom文件引入依赖 ###

<dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-dubbo</artifactId>
            </dependency>

两个yml文件引入配置：

dubbo:
      protocol:
        port: -1 # 设置Dubbo服务调用的端口 设置-1能够实现动态自动设置合适端口,生成规则是从20880开始递增
        name: dubbo # 设置端口名称,一般固定就叫dubbo
      registry:
        address: nacos://localhost:8848 # 配置当前Dubbo注册中心的类型和地址
      consumer:
        check: false # 设置为false表示当前项目启动时,不检查要调用的远程服务是否可用,避免报错

### 两个启动文件添加新注解 ###

// 如果当前项目是Dubbo服务的生产者,必须添加这个注解
    @EnableDubbo

生产者就是服务提供方，消费方不需要，为了防止大家搞错，所以就两个启动类都添加，实际使用中要区分。但也存在即是服务提供方，又是服务消费方的情况。

### 结构调整 ###

为了能更贴近于真实使用场景，也是为了不在Controller中直接使用Dubbo（可能会带来一些问题），所以我们对项目结构做一些简单的调整，增加service层，包括接口和实现类 。

#### helloWorld调整 ####

![c68cab5f77114d36b7498a1639b96cea.png][]

IHelloWorldService类：

package com.codingfire.cloud.helloword.service;
    
    public interface IHelloWorldService {
        String helloWorld();
    }

HelloWorldServiceImpl类：

package com.codingfire.cloud.helloword.service.impl;
    import com.codingfire.cloud.helloword.service.IHelloWorldService;
    import org.springframework.stereotype.Service;
    
    @Service
    public class HelloWorldServiceImpl implements IHelloWorldService {
    
        @Override
        public String helloWorld() {
            return "Hello World!";
        }
    }

HHelloController类：

package com.codingfire.cloud.helloword.controller;
    
    import com.codingfire.cloud.helloword.service.IHelloWorldService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @RequestMapping("/hello")
    public class HHelloController {
    
        @Autowired
        private IHelloWorldService helloWorldService;
    
        @GetMapping("/world")
        public String hello(){
            return helloWorldService.helloWorld();
        }
    
    }

#### helloService调整 ####

#### ![9705ea32b3e74a21a31694dd27d0744a.png][] ####

IHelloService类：

package com.codingfire.helloservice.service;
    
    public interface IHelloService {
        String getHelloWorld();
    }

HelloServiceImpl类：

package com.codingfire.helloservice.service.impl;
    
    import com.codingfire.cloud.helloword.service.IHelloWorldService;
    import com.codingfire.helloservice.service.IHelloService;
    import org.apache.dubbo.config.annotation.DubboReference;
    import org.apache.dubbo.config.annotation.DubboService;
    import org.springframework.stereotype.Service;
    
    @DubboService
    @Service
    public class HelloServiceImpl implements IHelloService {
    
        @DubboReference
        private IHelloWorldService dubboHelloService;
    
        @Override
        public String getHelloWorld() {
            String helloWorld = dubboHelloService.helloWorld();
            return helloWorld;
        }
    }

SHelloController类：

package com.codingfire.helloservice.controller;
    import com.codingfire.helloservice.service.IHelloService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @RequestMapping("/hello")
    public class SHelloController {
    
        @Autowired
        private IHelloService helloService;
    
        @GetMapping("/service")
        public String hello(){
    
            String helloWorld = helloService.getHelloWorld();
    
            return "XiaoMing Says:" + helloWorld;
        }
    
    }

### 重新运行 ###

俩集群，不要忘了啊，手动修改，和上面一样的方式。

运行成功后查看Nacos中状态：

![15c77c584cfb49f7a3755847b5b3c2c9.png][]

原来的俩服务还在，但是多了其他的，他们分别是我们注册的dubbo服务，有提供者provider，也有消费者consumer，我们下面点进去看看helloWorld集群启动成功没有：

![21bd60963037407aa262ce3f0385823d.png][]

元数据这一列多了好多数据啊，我们看到是dubbo相关的，集群也都正常，图太长，就不一一截了，下面去访问接口：[http://localhost:8080/hello/service][http_localhost_8080_hello_service]

能得到数据，就说明我们的配置没问题，Dubbo引入就是成功的：

![a4b6e40b7b19439abdf67e0dc9770bb1.png][]

查看控制台：

>     org.apache.dubbo.rpc.RpcException: No provider available from registry localhost:8848 for service com.codingfire.cloud.helloword.service.IHelloWorldService on consumer 192.168.0.102 use dubbo version 2.7.8, please check status of providers(disabled, not registered or in blacklist).

说是com.codingfire.cloud.helloword.service.IHelloWorldService这个类没有注册到白名单？我们看下这个类，这是个接口，所以还是要看其实现类HelloWorldServiceImpl，果然，这个类没有添加Dubbo注解，在类上添加注解：

@DubboService

下面重新运行helloWorld的四个启动类，记得集群哦，这时候，博主仿佛听到有人在吐槽：博主，你不玩我们会死啊？能不能一步到位？

哈哈哈哈～不好意思，这是为了让大家更好的理解细节处，大家还是先运行项目吧。

a few moments later~

好了，大家都运行成功了吧，下面，重新访问接口：[http://localhost:8080/hello/service][http_localhost_8080_hello_service]

![8b61e3fbafcb453a8de4bdbd474dd1b1.png][]

漂亮！！！

但是关于Dubbo单独设置负载均衡策略和同集群优先这些就不在这里介绍了，博主还在进行研究，后续会发详细介绍。

## 权重 ##

关于集群访问，还可设置权重：

![7ce97c71ccb849fba65e23ae0a49f3d6.png][]

各集群权重可自行根据需要设置。

## 结语 ##

到此，这篇关于集群间相互调用的博客就写好了，唯一觉得有些遗憾的是关于Dubbo的详细使用没有给大家讲清楚，后续单独出一篇来进行讲解，请大家稍微期待一下，其实很多人开发中未必用到异地容灾的场景，这篇博客算是给大家一个入门的门票，算不上特别精，但一定对你会有些帮助。未来，会分享更多的集群相关的博客，让我们一起学习，早日成为架构师。

[Java_ -]: https://blog.csdn.net/CodingFire/article/details/129654773?spm=1001.2014.3001.5501
[b4705aa74b4e442a88402558384cb0cc.png]: https://img-blog.csdnimg.cn/b4705aa74b4e442a88402558384cb0cc.png
[Java_ - 1]: https://blog.csdn.net/CodingFire/article/details/129047799?spm=1001.2014.3001.5501
[bc5cefd535cf4a168523fde416a0c0b2.png]: https://img-blog.csdnimg.cn/bc5cefd535cf4a168523fde416a0c0b2.png
[fd3020ec3d7c435cb5b90c1ec52bf024.png]: https://img-blog.csdnimg.cn/fd3020ec3d7c435cb5b90c1ec52bf024.png
[dcfd2684abf0457abf7653f9939c01f2.png]: https://img-blog.csdnimg.cn/dcfd2684abf0457abf7653f9939c01f2.png
[a0b2270f3ecb4c39846c82b73f280c79.png]: https://img-blog.csdnimg.cn/a0b2270f3ecb4c39846c82b73f280c79.png
[042d3ed5d5b34d9bb8f846f40e5ab64f.png]: https://img-blog.csdnimg.cn/042d3ed5d5b34d9bb8f846f40e5ab64f.png
[271cae8ff72049e990b218755cc9c817.png]: https://img-blog.csdnimg.cn/271cae8ff72049e990b218755cc9c817.png
[ae76e0faf02a4035bde62e68e4b9003a.png]: https://img-blog.csdnimg.cn/ae76e0faf02a4035bde62e68e4b9003a.png
[507a673593e4450795bfdb1110163d37.png]: https://img-blog.csdnimg.cn/507a673593e4450795bfdb1110163d37.png
[304e1dbad87e47c193d3d2552fa0db3d.png]: https://img-blog.csdnimg.cn/304e1dbad87e47c193d3d2552fa0db3d.png
[735b754a62d842e2aa298735688a32d1.png]: https://img-blog.csdnimg.cn/735b754a62d842e2aa298735688a32d1.png
[http_localhost_8080_hello_service]: http://localhost:8080/hello/service
[50b3d7aa3a4b4641816fca74356eef2f.png]: https://img-blog.csdnimg.cn/50b3d7aa3a4b4641816fca74356eef2f.png
[c530d74bcf114b4e955b2753399071d4.png]: https://img-blog.csdnimg.cn/c530d74bcf114b4e955b2753399071d4.png
[20e4b5e890c54df8b62cbab161055cc8.png]: https://img-blog.csdnimg.cn/20e4b5e890c54df8b62cbab161055cc8.png
[dce47906dbd341008a79d5fade6f063c.png]: https://img-blog.csdnimg.cn/dce47906dbd341008a79d5fade6f063c.png
[c68cab5f77114d36b7498a1639b96cea.png]: https://img-blog.csdnimg.cn/c68cab5f77114d36b7498a1639b96cea.png
[9705ea32b3e74a21a31694dd27d0744a.png]: https://img-blog.csdnimg.cn/9705ea32b3e74a21a31694dd27d0744a.png
[15c77c584cfb49f7a3755847b5b3c2c9.png]: https://img-blog.csdnimg.cn/15c77c584cfb49f7a3755847b5b3c2c9.png
[21bd60963037407aa262ce3f0385823d.png]: https://img-blog.csdnimg.cn/21bd60963037407aa262ce3f0385823d.png
[a4b6e40b7b19439abdf67e0dc9770bb1.png]: https://img-blog.csdnimg.cn/a4b6e40b7b19439abdf67e0dc9770bb1.png
[8b61e3fbafcb453a8de4bdbd474dd1b1.png]: https://img-blog.csdnimg.cn/8b61e3fbafcb453a8de4bdbd474dd1b1.png
[7ce97c71ccb849fba65e23ae0a49f3d6.png]: https://img-blog.csdnimg.cn/7ce97c71ccb849fba65e23ae0a49f3d6.png