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

这篇具有很好参考价值的文章主要介绍了Java开发 - 带你了解集群间的相互调用,你还在等什么?。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

目录

前言

导读

项目准备

集群准备

父工程引入子项目

服务调用方HelloService准备

pom文件

yml文件

Controller文件

服务提供方HelloWorld准备 

pom文件

yml文件

Controller文件 

运行此两个工程 

hello_world组集群

集群调用测试

RestTemplate换成Dubbo行不行,怎么换

两个pom文件引入依赖

 两个启动文件添加新注解

结构调整

helloWorld调整

helloService调整

​编辑

重新运行

权重 

结语


前言

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

导读

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

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

Java开发 - 配置中心初体验

项目准备

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

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

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

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

Java开发 - 数风流人物,还看“微服务”

赶紧去看,趁博主还没收费哦~

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

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

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

集群准备

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

父工程引入子项目

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

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

服务调用方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:

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

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

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

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

hello_world组集群

请大家点击此处:

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

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

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

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

下面我们先运行8082:

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

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

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

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

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

此时hello_world的集群有两个,实例有四个,符合我们的预期,我们点击“详情”按钮查看:

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

完美。

集群调用测试

下面我们调用接口: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

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

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

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

刷新url并查看控制台:

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

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

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

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

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

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

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

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

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调整

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

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调整

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

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中状态:

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

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

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

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

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

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

查看控制台:

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

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

漂亮!!!

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

权重 

关于集群访问,还可设置权重:

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

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

结语

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

到了这里,关于Java开发 - 带你了解集群间的相互调用,你还在等什么?的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • AIGC盛行,带你轻松调用开发

    本篇文章基于java和阿里云的通义千问大模型手把手带你使用AIGC开发,实现文本对话和图像分析。 你知道什么是AIGC吗?不知道?没关系,我来告诉你: AIGC就是 由AI自动创作生成的内容 (AI Generated Content),比如图片、视频、音乐、文字等。AIGC就像一支神奇的画笔,拥有无限

    2024年02月04日
    浏览(34)
  • 用java带你了解网络IO模型

    BIO是同步阻塞IO,所有连接都是同步执行的,在上一个连接未处理完的时候是无法接收下一个连接 在上述代码中,如果启动一个客户端起连接服务端时如果没有发送数据,那么下一个连接将永远无法进来 优点: 简单易用,代码实现比较简单。 对于低并发量的场景,因为每个

    2024年02月06日
    浏览(36)
  • 万字长文带你快速了解整个Flutter开发流程

    可以用以下提纲在短时间内了解 Flutter 的开发流程时,经过本次培训,你可以大致了解Flutter的开发流程 Flutter 是什么?为什么选择 Flutter? 跨平台开发的优势:一套代码多平台运行。 Flutter 是由 Google 开发的开源用户界面框架,用于创建跨平台移动应用、Web 应用和桌面应用。

    2024年02月11日
    浏览(51)
  • 【JAVA】十分钟带你了解java的前世今生

    个人主页:【😊个人主页】 系列专栏:【初始JAVA】 玩过我的世界的朋友想必对JAVA以及它的图标都很熟悉,在游戏开始画面停留在此时,我们可能会好奇, “它”有什么作用,“它”为什么会被称之为“JAVA”,它为什么又“长”成这样? Java是一种编程语言,被特意设计用

    2024年02月11日
    浏览(70)
  • 【JAVA】一文带你了解java的数据类型与变量

    作者主页:paper jie的博客 本文作者:大家好,我是paper jie,感谢你阅读本文,欢迎一建三连哦。 本文录入于《JAVASE语法系列》专栏,本专栏是针对于大学生,编程小白精心打造的。笔者用重金(时间和精力)打造,将javaSE基础知识一网打尽,希望可以帮到读者们哦。 其他专栏

    2024年02月14日
    浏览(35)
  • 一文带你了解Java对接soap接口

    soap是一种简单的基于XML的协议:HTTP+RPC+XML A、Envelope(信封)元素,必选,可把此XML文档标识为一条SOAP消息。 B、Header(报头)元素,可选,包含头部信息(包含了使消息在到达最终目的地之前,能够被路由到一个或多个中间节点的信息)。 C、Body(主体)元素,必选,包含所有

    2024年02月08日
    浏览(39)
  • 【JAVASE】带你一文了解java中异常捕获

        我们在java的学习之中可能会听到异常这个词,那么当程序出现异常之后,后面的程序还能正常运行吗,我们又该如何处理异常呢,本文就带你详细了解java中的异常。       在生活中,我们时常会感觉到不舒服,头疼,程序中也是一样的,程序员们每天可能会书写大量的

    2024年03月22日
    浏览(47)
  • java之路——带你了解Hibernate与基本过程

    Hibernate框架的发展可以追溯到2001年,它在过去的几年里获得了广泛的应用和持续的发展。 其中的发展演变: 初期版本(2001-2006年): Hibernate框架最早由Gavin King创建,目的是为了简化Java应用程序与关系数据库之间的数据交互。在这个阶段,Hibernate开始以一种简单但强大的方

    2024年02月12日
    浏览(42)
  • nacos不同局域网如何相互调用?nacos微服务云开发,远程联调部署,内网穿透,frp部署

    最近每个人都在家办公,公司项目是微服务的,一个人负责一个小服务,而且每个人都不在同一个局域网内,公司有一个云服务器(部署nacos),一开始大家都把自己负责的服务都注册到nacos上(作为服务注册和服务发现已经配置中心),大家都能注册,当前端人员来联调的时

    2023年04月17日
    浏览(37)
  • 一文带你了解如何在Java中操作Redis

    为了巩固所学的知识,作者尝试着开始发布一些学习笔记类的博客,方便日后回顾。当然,如果能帮到一些萌新进行新技术的学习那也是极好的。作者菜菜一枚,文章中如果有记录错误,欢迎读者朋友们批评指正。 (博客的参考源码可以在我主页的资源里找到,如果在学习的

    2024年02月16日
    浏览(40)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包