dubbo整合nacos进行远程调用

news2024/10/6 10:36:20

doubbo是什么？

Apache Dubbo 最初在 2008 年由 Alibaba 捐献开源，很快成为了国内开源服务框架选型的事实标准框架 ，得到了各行各业的广泛应用。在 2017 年，Dubbo 正式捐献到 Apache 软件基金会并成为 Apache 顶级项目，目前 Dubbo3 已经是一站式的微服务解决方案提供：

  • 基于 HTTP/2 的 Triple 协议以及面向代理 API 的编程体验。
  • 强大的流量治理能力，如地址发现、负载均衡、路由选址、动态配置等。
  • 多语言 SDK 实现，涵盖 Java、Golang、Javascript 等，更多语言实现将会陆续发布。
  • 灵活的适配与扩展能力，可轻松与微服务体系其他组件如 Tracing、Transaction 等适配。
  • Dubbo Mesh 解决方案，同时支持 Sidecar、Proxyless 等灵活的 Mesh 部署方案。

Apache Dubbo 总体架构能很好的满足企业的大规模微服务实践，因为它从设计之初就是为了解决超大规模微服务集群实践问题，不论是阿里巴巴还是工商银行、中国平安、携程等社区用户，它们都通过多年的大规模生产环境流量对 Dubbo 的稳定性与性能进行了充分验证，因此，Dubbo 在解决业务落地与规模化实践方面有着无可比拟的优势：

  • 开箱即用
    • 易用性高，如 Java 版本的面向接口代理特性能实现本地透明调用
    • 功能丰富，基于原生库或轻量扩展即可实现绝大多数的微服务治理能力
  • 面向超大规模微服务集群设计
    • 极致性能，高性能的 RPC 通信协议设计与实现
    • 横向可扩展，轻松支持百万规模集群实例的地址发现与流量治理
  • 高度可扩展
    • 调用过程中对流量及协议的拦截扩展，如 Filter、Router、LB 等
    • 微服务治理组件扩展，如 Registry、Config Center、Metadata Center 等

Dubbo 基本工作流程

在分布式系统中，尤其是随着微服务架构的发展，应用的部署、发布、扩缩容变得极为频繁，作为 RPC 消费方，如何动态的发现服务提供方地址成为 RPC 通信的前置条件。Dubbo 提供了自动的地址发现机制，用于应对分布式场景下机器实例动态迁移的问题。如下图所示，通过引入注册中心来协调提供方与消费方的地址，提供者启动之后向注册中心注册自身地址，消费方通过拉取或订阅注册中心特定节点，动态的感知提供方地址列表的变化。

image-20221008140759864

Dubbo 核心特性

高性能 RPC 通信协议

跨进程或主机的服务通信是 Dubbo 的一项基本能力，Dubbo RPC 以预先定义好的协议编码方式将请求数据（Request）发送给后端服务，并接收服务端返回的计算结果（Response）。RPC 通信对用户来说是完全透明的，使用者无需关心请求是如何发出去的、发到了哪里，每次调用只需要拿到正确的调用结果就行。除了同步模式的 Request-Response 通信模型外，Dubbo3 还提供更丰富的通信模型选择：

  • 消费端异步请求(Client Side Asynchronous Request-Response)
  • 提供端异步执行（Server Side Asynchronous Request-Response）
  • 消费端请求流（Request Streaming）
  • 提供端响应流（Response Streaming）
  • 双向流式通信（Bidirectional Streaming）

具体可参见各语言 SDK 实现的可选协议列表 或 Triple协议

自动服务（地址）发现

Dubbo 的服务发现机制，让微服务组件之间可以独立演进并任意部署，消费端可以在无需感知对端部署位置与 IP 地址的情况下完成通信。Dubbo 提供的是 Client-Based 的服务发现机制，使用者可以有多种方式启用服务发现：

  • 使用独立的注册中心组件，如 Nacos、Zookeeper、Consul等。
  • 将服务的组织与注册交给底层容器平台，如 Kubernetes，这被理解是一种更云原生的使用方式

运行态流量管控

透明地址发现让 Dubbo 请求可以被发送到任意 IP 实例上，这个过程中流量被随机分配。当需要对流量进行更丰富、更细粒度的管控时，就可以用到 Dubbo 的流量管控策略，Dubbo 提供了包括负载均衡、流量路由、请求超时、流量降级、重试等策略，基于这些基础能力可以轻松的实现更多场景化的路由方案，包括金丝雀发布、A/B测试、权重路由、同区域优先等，更酷的是，Dubbo 支持流控策略在运行态动态生效，无需重新部署。

入门程序

1、父项目版本锁定：

image-20221008141642072

 <dependencyManagement>

        <dependencies>
            <!-- springboot 版本锁定 -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>2.3.8.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <!-- springcloud的 阿里巴巴 版本锁定 -->
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>2.2.2.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <!-- 添加SpringCloud版本锁定 -->
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Hoxton.SR9</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>

    </dependencyManagement>

2、 dobbo-client定义服务接口

public interface UserDubboClient {
    String hello(String id);
}

3、 dobbo-product提供方实现接口并暴露服务

@DubboService
public class UserServiceImpl implements UserDubboClient {

    @Override
    public String hello(String id) {
        return "dubbo com.hk.client ... " + id;
    }
}

4、dobbo-product配置 application.yml 文件

server:
  port: 8000

spring:
  application:
    name: dubboproduct
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848
dubbo:
  scan:
    base-packages: com.hk.product.service   # dubbo 扫描包路径
  protocol:
    name: dubbo								# dubbo 协议
    port: -1
  registry:
    address: nacos://localhost:8848			# 注册地址

5、dobbo-consumer引用远程服务

@RestController
@RequestMapping("/user")
public class UserController {

    @DubboReference(check = false)
    private UserDubboClient userDubboClient;

    @RequestMapping("{id}")
    public String hello(@PathVariable("id")String id){
        String hello = userDubboClient.hello(id);
        return hello;
    }
}

6、dobbo-consumer定义 application.yml

server:
  port: 9000

spring:
  application:
    name: dubboconsumer
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848

dubbo:
  scan:
    base-packages: com.hk.product.service
  protocol:
    name: dubbo
    port: -1
  registry:
    address: nacos://localhost:8848

7、dobbo-consumer加载 Spring 配置，并调用远程服务

@EnableDubbo
@SpringBootApplication
public class DubboConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(DubboConsumerApplication.class,args);
    }
}

注解说明：

1、@DubboService 注解，定义好 Dubbo 服务接口后，提供服务接口的实现逻辑，并用 @DubboService 注解标记，就可以实现 Dubbo 的服务暴露

@DubboService
public class UserServiceImpl implements UserDubboClient {

}

2、@DubboReference 注解，@DubboReference 注解将自动注入为 Dubbo 服务代理实例，使用 userDubboClient即可发起远程服务调用

@RestController
@RequestMapping("/user")
public class UserController {

    @DubboReference(check = false)
    private UserDubboClient userDubboClient;

    @RequestMapping("{id}")
    public String hello(@PathVariable("id")String id){
        String hello = userDubboClient.hello(id);
        return hello;
    }
}

3、@EnableDubbo 注解

@EnableDubbo 注解必须配置，否则将无法加载 Dubbo 注解定义的服务，@EnableDubbo 可以定义在主类上

@EnableDubbo
@SpringBootApplication
public class DubboConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(DubboConsumerApplication.class,args);
    }
}

Spring Boot 注解默认只会扫描 main 类所在的 package，如果服务定义在其它 package 中，需要增加配置

@EnableDubbo(scanBasePackages = {"org.apache.dubbo.springboot.demo.provider"})

dobbo-Product的依赖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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>dubbo-parent</artifactId>
        <groupId>com.hk</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>dubbo-product</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--  注册中心 把  服务注册到nacos中-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>

        <!--  dubbo 的依赖 -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.8</version>
        </dependency>

        <!--dubbo nacos-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo-registry-nacos</artifactId>
            <version>2.7.6</version>
        </dependency>

        <dependency>
            <groupId>com.hk</groupId>
            <artifactId>dubbo-client</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>

dobbo-Consumer的依赖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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>dubbo-parent</artifactId>
        <groupId>com.hk</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>dubbo-consumer</artifactId>

    <dependencies>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--  注册中心 把  服务注册到nacos中-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>

        <!--  dubbo 的依赖 -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.8</version>
        </dependency>

        <!--dubbo nacos-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo-registry-nacos</artifactId>
            <version>2.7.6</version>
        </dependency>

        <dependency>
            <groupId>com.hk</groupId>
            <artifactId>dubbo-client</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

DJI 无人机 Onboard SDK ROS 功能包demo运行

DJI 无人机 Onboard SDK ROS 功能包demo运行

DJI 无人机 Onboard SDK ROS 功能包demo运行demo功能准备测试环境运行 dji sdk 节点运行 demo 节点自动飞行任务航点自动飞行兴趣点环绕自动飞行飞行控制本地坐标位置控制搭建好 Onboard SDK ROS 的开发环境后&#xff0c;功能包自身具备一些写好的demo功能案例 dji sdk 的节点…
阅读更多...
华为OD机试 - 猴子爬山 | 机试题算法思路 【2023】

华为OD机试 - 猴子爬山 | 机试题算法思路 【2023】

使用说明 参加华为od机试，一定要注意不要完全背诵代码，需要理解之后模仿写出，通过率才会高。 华为 OD 清单查看地址：https://blog.csdn.net/hihell/category_12201821.html 华为OD详细说明：https://dream.blog.csdn.net/article/details/128980730 猴子爬山 | 华为OD机…
阅读更多...
特征工程-定义+意义+安装scikit-learn+数据的特征抽取（字典、文本）

特征工程-定义+意义+安装scikit-learn+数据的特征抽取（字典、文本）

目录 数据中对特征的处理 特征工程定义 特征工程意义 安装scikit-learn 数据的特征抽取 字典特征抽取 DictVectorizer语法 文本特征抽取 CountVectorizer语法 TfidfVectorizer语法 数据中对特征的处理 pandas:一个数据读取非常方便以及基础的处理格式的工具 sklear…
阅读更多...
Spring Boot + Vue3 前后端分离 实战 wiki 知识库系统＜一＞---Spring Boot项目搭建

Spring Boot + Vue3 前后端分离 实战 wiki 知识库系统＜一＞---Spring Boot项目搭建

前言&#xff1a; 接下来又得被迫开启新的一门课程的学习了&#xff0c;上半年末尾淘汰又即将拉开序幕【已经记不清经历过多少次考试了】&#xff0c;需要去学习其它领域的技术作为考试内容&#xff0c;我选了spring boot相关技术&#xff0c;所以。。总之作为男人&#xff0c…
阅读更多...
Linux之网络流量监控工具ntopng YUM安装

Linux之网络流量监控工具ntopng YUM安装

一、ntopng简介 Ntop是一种监控网络流量工具&#xff0c;用ntop显示网络的使用情况比其他一些网络管理软件更加直观、详细。Ntop甚至可以列出每个节点计算机的网络带宽利用率。他是一个灵活的、功能齐全的&#xff0c;用来监控和解决局域网问题的工具&#xff1b;尤其当ntop与n…
阅读更多...
【Spring Cloud Alibaba】003-Nacos 概述与单机搭建

【Spring Cloud Alibaba】003-Nacos 概述与单机搭建

【Spring Cloud Alibaba】003-Nacos 概述与单机搭建 文章目录【Spring Cloud Alibaba】003-Nacos 概述与单机搭建一、Nacos 概述0、新技术学习思路推荐1、什么是 Nacos2、架构图架构图架构图信息二、Nacos 单机搭建1、下载与启动下载地址编辑 startup.cmd 文件下面对两种模式的…
阅读更多...
“王炸”产品+集资2000万美元，D-Wave在赌什么？

“王炸”产品+集资2000万美元，D-Wave在赌什么？

&#xff08;图片来源&#xff1a;网络&#xff09;D-Wave是量子计算系统、软件和服务的领导者&#xff0c;也是全球量子计算机商业供应商。近日&#xff0c;它发布了一系列的最新产品和业务&#xff0c;展示出其在推动量子计算商业化方面的强劲势头。随着全球越来越多的企业将…
阅读更多...
C++入门：内联函数、auto关键字、基于范围for循环及指针空值nullptr

C++入门：内联函数、auto关键字、基于范围for循环及指针空值nullptr

目录 一. 内联函数 1.1 内联函数的概念 1.2 内联函数的特性 1.3 内联函数和宏的优缺点对比 二. auto关键字&#xff08;C11&#xff09; 2.1 auto的功能 2.2 auto在使用时的注意事项 三. 基于范围的for循环&#xff08;C11&#xff09; 四. 指针空值nullptr&#xff08…
阅读更多...
开发日记-lombok

开发日记-lombok

开发日记-lombok环境问题解决方案&#xff1a;1 Data注解失效 无法正常生成 get和set方法2 RequiredArgsConstructor(onConstructor _(Lazy)) 符号_无法识别环境 idea2020.1lombok1.18.24jdk1.8 问题 Data注解失效 无法正常生成 get和set方法RequiredArgsConstructor(onCons…
阅读更多...
机器学习：学习k-近邻（KNN）模型建立、使用和评价

机器学习：学习k-近邻（KNN）模型建立、使用和评价

机器学习&#xff1a;学习k-近邻&#xff08;KNN&#xff09;模型建立、使用和评价 文章目录机器学习&#xff1a;学习k-近邻&#xff08;KNN&#xff09;模型建立、使用和评价一、实验目的二、实验原理三、实验环境四、实验内容五、实验步骤1.数据读取2.数据理解3.数据准备4.算…
阅读更多...
Talk预告 | 悉尼科技大学澳大利亚人工智能研究所讲师方震：广义分布外检测的学习理论

Talk预告 | 悉尼科技大学澳大利亚人工智能研究所讲师方震：广义分布外检测的学习理论

本期为TechBeat人工智能社区第476期线上Talk&#xff01; 北京时间2月22日(周三)20:00&#xff0c;悉尼科技大学澳大利亚人工智能研究所讲师——方震的Talk将准时在TechBeat人工智能社区开播&#xff01; 他与大家分享的主题是: “广义分布外检测的学习理论”&#xff0c;届时将…
阅读更多...
信息加密技术

信息加密技术

介绍信息加密 信息加密是实现数据保密性的手段。 信息加密&#xff08;Encryption&#xff09;是将明文信息转换为密文信息&#xff0c;使之在缺少特殊信息时不可读的过程。只有拥有解密方法的对象&#xff0c;经由解密过程&#xff0c;才能将密文还原为正常可读的内容。 现…
阅读更多...
Vue — 详解mixins混入使用

Vue — 详解mixins混入使用

前言 当我们的项目越来越大&#xff0c;我们会发现组件之间可能存在很多相似的功能&#xff0c;你在一遍又一遍的复制粘贴相同的代码段&#xff08;data&#xff0c;method&#xff0c;watch、mounted等&#xff09;&#xff0c;如果我们在每个组件中去重复定义这些属性和方法会…
阅读更多...
看了这份Java高级笔试宝典覆盖近3年Java笔试中98%高频知识点，反打面试官

看了这份Java高级笔试宝典覆盖近3年Java笔试中98%高频知识点，反打面试官

首先声明&#xff1a; 本书覆盖了近3年程序员面试笔试中超过98%Java高频知识点&#xff0c;当你细细品读完本书后&#xff0c;面试都是小问题。 一书在手/工作不愁 记住重点&#xff0c;考试要考 前言 程序员求职始终是当前社会的一个热点&#xff0c;而市面上有很多关于程…
阅读更多...
ROS | 键盘控制

ROS | 键盘控制

文章目录 概述一、定义介绍二、功能作用三、使用方法四、实例演示概述 在研发机器人/自动驾驶时，可能没有遥控器，又或者是仿真环境等情况，常常需要通过键盘控制小车。 一、定义介绍 本节详细讲述了如何通过键盘来控制ROS小车，附有全套源码。 二、功能作用 本程序通过向RO…
阅读更多...
Netty （三）：进阶

Netty （三）：进阶

文章目录1. 粘包与半包1.1 粘包现象1.2 半包现象1.3 现象分析1.4 解决方案方法1&#xff0c;短链接方法2&#xff0c;固定长度方法3&#xff0c;固定分隔符方法4&#xff0c;预设长度2. 协议设计与解析2.1 为什么需要协议&#xff1f;2.2 redis 协议举例2.3 http 协议举例2.4 自…
阅读更多...
超级完整 的 Maven 讲解 以及私服搭建

超级完整 的 Maven 讲解 以及私服搭建

第一章 Maven 简介 1.1、Maven 概述 Maven 是一款基于 Java 平台的项目管理和整合工具&#xff0c;它将项目的开发和管理过程抽象成一个项目对象模型&#xff08;POM&#xff09;。开发人员只需要做一些简单的配置&#xff0c;Maven 就可以自动完成项目的编译、测试、打包、发…
阅读更多...
Linux系统点亮LED

Linux系统点亮LED

目录应用层操控硬件的两种方式sysfs 文件系统sysfs 与/sys总结标准接口与非标准接口LED 硬件控制方式编写LED 应用程序在开发板上测试对于一款学习型开发板来说&#xff0c;永远都绕不开LED 这个小小的设备&#xff0c;基本上每块板子都至少会有一颗 LED 小灯&#xff0c;对于我…
阅读更多...
Allegro无法打开10度走线命令的原因和解决办法

Allegro无法打开10度走线命令的原因和解决办法

Allegro无法打开10度走线命令的原因和解决办法 做PCB设计的时候，10度走线也是较为常见的设计方式，Allegro支持10度走线，如下图 需要10度走线的时候，Options只需要勾选Route offset命令即可 但有时options处会看不到10度走线的命令，如下图
阅读更多...
从0到1一步一步玩转openEuler--20 openEuler 管理服务-服务管理

从0到1一步一步玩转openEuler--20 openEuler 管理服务-服务管理

文章目录20 管理系统服务20.1 sysvinit命令和systemd命令20.2 显示所有当前服务20.3 显示服务状态20.4 运行服务20.5 关闭服务20.6 重启服务20.7 启用服务20.8 禁用服务20 管理系统服务 systemd提供systemctl命令来运行、关闭、重启、显示、启用/禁用系统服务。 20.1 sysvini…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023