微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用

🏷️个人主页:鼠鼠我捏,要死了捏的主页 

🏷️系列专栏:Golang全栈-专栏

🏷️个人学习笔记,若有缺误,欢迎评论区指正 

前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站AI学习网站。

目录

前言

快速上手

创建示例项目

导入依赖

编写配置

添加启动类注解

编写服务接口与服务实现类

引入common项目

新建common项目

总结


前言

随着互联网技术的飞速发展,越来越多的企业和开发者开始关注微服务架构。微服务架构可以将一个大型的应用拆分成多个独立、可扩展、可维护的小型服务,每个服务负责实现应用的一部分功能。这种架构方式可以提高开发效率,降低系统复杂度,方便团队协作,同时也有利于资源的合理利用和弹性伸缩。

在微服务架构中,服务之间的通信是一个关键问题。传统的HTTP通信方式在高并发、高性能的场景下存在性能瓶颈,因此,越来越多的开发者开始采用RPC(远程过程调用)技术来实现服务之间的通信。Dubbo是一款高性能、轻量级的开源Java RPC框架,它提供了丰富的服务治理功能,如服务注册、服务发现、负载均衡、容错等,被广泛应用于微服务架构中。

Nacos是阿里巴巴开源的一个动态服务发现、配置管理和服务管理平台,它支持基于DNS和基于RPC的服务发现,具有跨语言、跨平台、灵活扩展的特点。网上很多都是Springcloud整合Dubbo,本文讲解如何将Spring Boot与Dubbo和Nacos整合,实现RPC调用。

快速上手

在实现DubboRPC服务调用时,我们首先需要一个服务注册中心,常用的服务注册中心有Zookeeper,Nacos等,我们这里采用Nacos,没有部署Nacos的请先自行教程部署,这里不细讲

创建示例项目

我们这里创建两个名为ProviderDemo和ConsumerDemo的项目

导入依赖

整合nacos和dubbo主要需要nacos-client和dubbo这两项依赖

        <!--这里对应的Springboot版本为2.7.6-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>3.0.9</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>2.1.0</version>
        </dependency>

ProviderDemo的maven配置信息如下

<?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>
    <groupId>com.luckysj</groupId>
    <artifactId>ProviderDemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>ProviderDemo</name>
    <description>ProviderDemo</description>
    <properties>
        <java.version>1.8</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <spring-boot.version>2.7.6</spring-boot.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>3.0.9</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>2.1.0</version>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>


</project>

ConsumerDemo的配置信息如下

<?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>
    <groupId>com.luckysj</groupId>
    <artifactId>ConsumerDemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>ConsumerDemo</name>
    <description>ConsumerDemo</description>
    <properties>
        <java.version>1.8</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <spring-boot.version>2.7.6</spring-boot.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>3.0.9</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>2.1.0</version>
        </dependency>

    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

</project>

编写配置

consumerDemo项目的配置如下,注意把nacos信息更改为自己的

server:
  port: 7777

dubbo:
  application:
    #设置应用的名称
    name: dubbo-springboot-consumer
    #qos监控服务是否启动
    qos-enable: true
    #qos监控服务端口
    qos-port: 23456
    qos-accept-foreign-ip: false

  #指定使用Dubbo协议,且端口设置为-1,表示随机分配可用端口
  protocol:
    name: dubbo
    port: -1
  registry:
    #配置注册中心为Nacos
    id: nacos-registry
    address: nacos://nacos服务的ip:nacos服务的端口
    username: nacos账户
    password: nacos密码
    parameters:
      namespace: f74484c1-02d8-4322-a50c-630bc814fe54   #nacos命名空间
    group: dubbo-demo    #nacos分组
  config-center:
    timeout: 40000 #设置服务超时时间

 providerDemo项目的配置如下

server:
  port: 6666
dubbo:
  application:
    #设置应用的名称
    name: dubbo-springboot-provider
    qos-enable: true
    qos-port: 23444
    qos-accept-foreign-ip: false
  #指定使用Dubbo协议,且端口设置为-1,表示随机分配可用端口
  protocol:
    name: dubbo
    port: -1
  registry:
    #配置注册中心为Nacos
    id: nacos-registry
    address: nacos://ip:端口
    username: 账户
    password: 密码
    parameters:
      namespace: f74484c1-02d8-4322-a50c-630bc814fe54   #nacos命名空间
    group: dubbo-demo    #nacos分组
  config-center:
    timeout: 40000 #设置服务超时时间

添加启动类注解

我们要使用Dubbo服务的话需要在服务启动类上编写@EnableDubbo注解(提供者项目和消费者项目都需要)

编写服务接口与服务实现类

我们在Provider项目中provider包下新建服务接口与实现类

PrintService接口内容如下

public interface PrintService {
    public void print(String str);
}

PrintServiceImpl接口内容如下,我们通过@DubboService注解暴露该服务,

@DubboService
public class PrintServiceImpl implements PrintService {

    @Override
    public void print(String str) {
        System.out.println("dubbo调用打印信息为" + str);
    }
}

 在服务消费方项目中也定义相同的接口

public interface PrintService {
    public void print(String str);
}

特别注意这里调用者与提供者的服务接口需要有相同的包路径,否则无法找到对应服务,我们后续通过引入一个common项目来解决这个问题

在服务消费方项目编写一个测试接口,使用@DubboReference注解声明引用的服务

@RestController
@RequestMapping("/demo")
public class DemoController {
    @DubboReference //声明服务引用
    private PrintService printService;

    @GetMapping("/test")
    public void testDubbo(String str){
        System.out.println("consumer开始RPC调用provider服务");
        printService.print(str);
    }
}

访问接口,测试两项目之间的服务调用,可以看到我们ConsumerDemo项目通过Dubbo成功的调用了ProviderDemo项目

http://localhost:7777/demo/test?str=111

 

引入common项目

我们上面可以发现提供者和消费者的服务接口必须在相同的包路径下,十分的不优雅,故我们可以新建一个common项目,在这个项目中定义双方服务调用的接口,相当于定义了一种规范,两边都采用common中的服务接口,这样就不会因为包路径不同导致dubbo找不到对应服务

新建common项目

打包该项目到本地(云)仓库中,在消费者和提供者项目中引入该项目

双方都使用common包内的服务接口

测试接口,运行正常,结束

总结

Dubbo是一个基于Java的RPC (远程过程调用)框架,比OpenFeign支持更多的通讯协议,且性能更高,更加适应于大规模的分布式项目中。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/393024.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

4核8G云服务器能承受多少人访问?

4核8G服务器支持多少人同时在线访问&#xff1f;阿腾云的4核8G服务器可以支持20个访客同时访问&#xff0c;关于4核8G服务器承载量并发数qps计算测评&#xff0c;云服务器上运行程序效率不同支持人数在线人数不同&#xff0c;公网带宽也是影响4核8G服务器并发数的一大因素&…

基于java springboot+mybatis学生学科竞赛管理管理系统设计和实现

基于java springbootmybatis学生学科竞赛管理管理系统设计和实现 &#x1f345; 作者主页 央顺技术团队 &#x1f345; 欢迎点赞 &#x1f44d; 收藏 ⭐留言 &#x1f4dd; &#x1f345; 文末获取源码联系方式 &#x1f4dd; &#x1f345; 查看下方微信号获取联系方式 承接各…

STM32CubeMX 配置 STM32F407时钟树和烧录方式

时钟树 要先把High Speed Clock设置为外部晶振&#xff0c;再去设置时钟树 PLL选用高速外部时钟线&#xff08;HSE&#xff09; Input frequency 数值为外部晶振&#xff0c;大多开发板上为8M SYSCLK 为系统时钟&#xff0c;F407为168MHz APB2 外设时钟线为系统时钟的一半 APB…

统信UOS终端:使用方法解析系列(中篇)

原文链接&#xff1a;统信UOS终端&#xff1a;使用方法解析系列&#xff08;中篇&#xff09; 亲爱的读者们&#xff0c;继我们上次关于统信UOS终端基础使用的介绍后&#xff0c;今天我们将在系列文章的中篇中&#xff0c;深入探讨终端的进阶使用方法&#xff0c;包括自定义命令…

LeetCode.589. N 叉树的前序遍历

题目 589. N 叉树的前序遍历 分析 我们之前有做过LeetCode的 144. 二叉树的前序遍历&#xff0c;其实对于 N 插树来说和二叉树的思路是一模一样的。 二叉树的前序遍历是【根 左 右】 N叉树的前序遍历顺序是【根 孩子】&#xff0c;你可以把二叉树的【根 左 右】想象成【根 孩…

什么是软件测试?软件测试的目的与原则是什么?

&#x1f525; 交流讨论&#xff1a;欢迎加入我们一起学习&#xff01; &#x1f525; 资源分享&#xff1a;耗时200小时精选的「软件测试」资料包 &#x1f525; 教程推荐&#xff1a;火遍全网的《软件测试》教程 &#x1f4e2;欢迎点赞 &#x1f44d; 收藏 ⭐留言 &#x1…

企业大宽带服务器用哪里最合适

如今&#xff0c;数字经济的发展速度不断加快&#xff0c;进入数字化跑道的企业&#xff0c;每天都在大量输出、共享、存储数字内容&#xff0c;想要更高效、安全地让用户看到内容&#xff0c;企业的服务器需要满足大带宽、低延时、高并发等要求。 中小企业受限于资金、资源等…

BUGKU-WEB 头等舱

题目描述 题目截图如下&#xff1a; 进入场景看看&#xff1a; 解题思路 先看看源码再看看F12请求和响应 相关工具 略 解题步骤 查看源码&#xff0c;好家伙真的什么也没有 2. 看看F12请求和响应&#xff0c;找到了 得到Flag flag{a49c7aba1014c3673ec9982946d0545a…

LeetCode 0429.N 叉树的层序遍历:广度优先搜索(BFS)

【LetMeFly】429.N 叉树的层序遍历&#xff1a;广度优先搜索(BFS) 力扣题目链接&#xff1a;https://leetcode.cn/problems/n-ary-tree-level-order-traversal/ 给定一个 N 叉树&#xff0c;返回其节点值的层序遍历。&#xff08;即从左到右&#xff0c;逐层遍历&#xff09;…

nba2k24 郭艾伦面补

nba2k24 郭艾伦面补 nba2k23-nba2k24通用 郭艾伦面补 下载地址&#xff1a; https://www.changyouzuhao.cn/9460.html

03 类和对象 1

目录 面向过程和面向对象初步认识类的引入类的定义类的访问限定符及封装类的作用域类的实例化类的对象大小的计算类成员函数的this指针 1. 面向过程和面向对象初步认识 c语言是面向过程的&#xff0c;关注的是过程&#xff0c;分析求解问题的步骤&#xff0c;通过函数调用逐步…

免费邮件群发工具有哪些?群发邮件的软件?

免费邮件群发软件盘点&#xff01;EDM免费邮件营销软件哪个好&#xff1f; 电子邮件营销已成为许多企业和个人推广的重要手段。而免费邮件群发工具则成为了这些用户节约成本、提高效率的首选。蜂邮将为您详细介绍几款备受欢迎的免费邮件群发工具&#xff0c;帮助您在众多选择中…

从kafka如何保证数据一致性看通常数据一致性设计

一、前言 在数据库系统中有个概念叫事务&#xff0c;事务的作用是为了保证数据的一致性&#xff0c;意思是要么数据成功&#xff0c;要么数据失败&#xff0c;不存在数据操作了一半的情况&#xff0c;这就是数据的一致性。在很多系统或者组件中&#xff0c;很多场景都需要保证…

JVM-JVM调优基础(理论)

申明&#xff1a;文章内容是本人学习极客时间课程所写&#xff0c;作为笔记进行记录&#xff0c;文字和图片基本来源于课程资料&#xff0c;在某些地方会插入一点自己的理解&#xff0c;未用于商业用途&#xff0c;侵删。 原资料地址&#xff1a;课程资料 JVM参数 标准参数 …

- 工程实践 - 《QPS百万级的有状态服务实践》02 - 冷启动和热更新

本文属于专栏《构建工业级QPS百万级服务》 继续上篇《QPS百万级的有状态服务实践》01 - 存储选型实践。如图1架构&#xff0c;我们已经解决了数据生产的问题。 图1 但是我们的服务已经在运行了&#xff0c;并实时处理大量的请求&#xff0c;我们如何把内存中的数据版本更新呢。…

网页中实现打开qq添加群聊

网页中实现打开qq添加群聊 效果 登录qq群管理后台 1. https://qun.qq.com/#/handy-tool/join-group 2 . 复制生成的链接 代码 在html中使用的话就直接粘贴到对应的内容里面就行 如果是添加点击事件的话&#xff1a; <div click"joinQQGroup">添加群聊</…

Vue23 数据监测总结

代码 <!DOCTYPE html> <html><head><meta charset"UTF-8" /><title>总结数据监视</title><style>button{margin-top: 10px;}</style><!-- 引入Vue --><script type"text/javascript" src"…

mqtt 协议中的 QoS等级介绍

一、QoS等级 MQTT设计了一套保证消息稳定传输的机制&#xff0c;包括消息应答、存储和重传。在这套机制下&#xff0c;提供了三种不同层次QoS&#xff08;Quality of Service&#xff09;&#xff1a; QoS0&#xff0c;At most once&#xff0c;至多一次&#xff1b;QoS1&…

OpenAI全新发布的Sora,到底意味着什么?

16日凌晨&#xff0c;OpenAI发布了文本视频的工具&#xff08;text-do-video&#xff09;Sora&#xff0c;整个世界再次被震撼。 Sora的出现&#xff0c;到底意味着什么&#xff1f; 目录 Sora的背景与概述Sora是什么&#xff1f;能为我们做些什么&#xff1f;存在的一些问题 文…

C++ 里设置Expose on Spawn csv 通过 UStruct 导入为 DataTable

一.蓝图里面暴露的设置如下&#xff1a; C 中写法如下&#xff1a; 属性如下&#xff1a; 关卡蓝图中Spawn时会有 参数接口 二. 创建UObject类&#xff0c;并在C中声明结构体。继承FTableRowBase 在Excel里&#xff0c;创建对应csv文件 如果在头文件修改了属性&#xff0c;使用…