AI 助理
文档备案控制台
开发者社区 云原生 文章 正文

SpringCloudAlibaba篇（四）整合Dubbo（RPC 分布式服务框架）

2022-05-27 1612
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： SpringCloudAlibaba篇（四）整合Dubbo（RPC 分布式服务框架）

什么是 Dubbo

Apache Dubbo (incubating) |ˈdʌbəʊ| 是一款高性能、轻量级的开源 Java RPC 分布式服务框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。她最大的特点是按照分层的方式来架构，使用这种方式可以使各个层之间解耦合（或者最大限度地松耦合）。从服务模型的角度来看，Dubbo 采用的是一种非常简单的模型，要么是提供方提供服务，要么是消费方消费服务，所以基于这一点可以抽象出服务提供方（Provider）和服务消费方（Consumer）两个角色。

调用关系说明

  • 服务容器负责启动，加载，运行服务提供者
  • 服务提供者在启动时，向注册中心注册自己提供的服务
  • 服务消费者在启动时，向注册中心订阅自己所需的服务
  • 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者
  • 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用
  • 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心

Dubbo 功能特点

  • 面向接口代理的高性能 RPC 调用： 提供高性能的基于代理的远程调用能力，服务以接口为粒度，为开发者屏蔽远程调用底层细节
  • 智能负载均衡： 内置多种负载均衡策略，智能感知下游节点健康状况，显著减少调用延迟，提高系统吞吐量
  • 服务自动注册与发现： 支持多种注册中心服务，服务实例上下线实时感知
  • 高度可扩展能力： 遵循微内核 + 插件的设计原则，所有核心能力如 Protocol、Transport、Serialization 被设计为扩展点，平等对待内置实现和第三方实现
  • 运行期流量调度： 内置条件、脚本等路由策略，通过配置不同的路由规则，轻松实现灰度发布，同机房优先等功能
  • 可视化的服务治理与运维： 提供丰富服务治理、运维工具：随时查询服务元数据、服务健康状态及调用统计，实时下发路由策略、调整配置参数

1.添加dubbo依赖


<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
    <version>${spring-cloud-alibaba.version}</version> <!--2021.0.1.0-->
</dependency>

1.1nacos中创建dubbo.yaml

在这里插入图片描述

dubbo:
  application:
    qos-enable: false
    qos-accept-foreign-ip: false
  registry:
    address: spring-cloud://localhost
  consumer:
  # check为false，则关闭该Consumer下所有服务检查
    check: false
  • dubbo另一部分我这边写在了本地， nacos中的配置我是用来共享的

1.2 修改bootstrap.yml ,application.yml

  • 在bootstrap.yml中最佳dubbo.yaml

在这里插入图片描述

  • application.yml
dubbo:
  protocol:
    # dubbo 协议
    name: dubbo
    # dubbo 协议端口（ -1 表示自增端口，从 20880 开始）
    port: 20881
  cloud:
      # producer 服务名 ， "" 为不加载，多个服务名用逗号分隔
    subscribed-services: ""
  • application.properties
spring.main.allow-circular-references=true

2.创建order-service服务

在这里插入图片描述

<?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>SpringCloudAlibaba2022</artifactId>
        <groupId>top.fate</groupId>
        <version>1.0.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>order-service</artifactId>
    <name>${project.artifactId}</name>
    <version>${fate.project.version}</version>
    <packaging>jar</packaging>

    <dependencies>
        <dependency>
            <groupId>top.fate</groupId>
            <artifactId>service-starter-parent</artifactId>
            <version>1.0.0</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-antrun-plugin</artifactId>
                <executions>
                    <execution>
                        <phase>package</phase>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>
</project>

2.1创建启动类

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

2.2创建bootstrap.yml ,application.yml

  • bootstrap.yml
url:
  nacos: localhost:8848
spring:
  application:
    name: order-service #实例名
  profiles:
    active: dev
  cloud:
    nacos:
      discovery:
        #集群环境隔离
        cluster-name: shanghai
        #命名空间
        namespace: ${spring.profiles.active}
        #持久化实例 ture为临时实例 false为持久化实例  临时实例发生异常直接剔除, 而持久化实例等待恢复
        ephemeral: true
        #注册中心地址
        server-addr: ${url.nacos}
      config:
        namespace: ${spring.profiles.active}
        file-extension: yaml
        #配置中心地址
        server-addr: ${url.nacos}
        extension-configs[0]:
          data-id: mysql-user.yaml
          group: DEFAULT_GROUP
          refresh: false
        extension-configs[1]:
          data-id: sentinel.yaml
          group: DEFAULT_GROUP
          refresh: false
        extension-configs[2]:
          data-id: dubbo.yaml
          group: DEFAULT_GROUP
          refresh: false
  • application.yml
dubbo:
  protocol:
    # dubbo 协议
    name: dubbo
    # dubbo 协议端口（ -1 表示自增端口，从 20880 开始）
    port: 20882
  cloud:
    subscribed-services: user-service
  • application.properties
spring.main.allow-circular-references=true
  • nacos中创建order-service.yaml
server:
  port: 8082

3.创建一个service的api接口模块

  • 删除src

在这里插入图片描述

  • 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>SpringCloudAlibaba2022</artifactId>
        <groupId>top.fate</groupId>
        <version>1.0.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>service-api</artifactId>
    <name>${project.artifactId}</name>
    <version>${fate.project.version}</version>
    <packaging>pom</packaging>
    <description>SpringCloudAlibaba 微服务API集合</description>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <skip>true</skip>
                    <finalName>${project.name}</finalName>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

3.1 在service-api的基础上再创建一个user-service-api

在这里插入图片描述

  • 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>service-api</artifactId>
        <groupId>top.fate</groupId>
        <version>1.0.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>user-service-api</artifactId>
    <name>${project.artifactId}</name>
    <version>${fate.project.version}</version>
    <packaging>jar</packaging>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>
</project>

3.2 user-service-api创建 UserService

在这里插入图片描述

public interface UserService {
    String getServiceName();
}

4.user-service添加user-service-api依赖

<dependency>
    <groupId>top.fate</groupId>
    <artifactId>user-service-api</artifactId>
    <version>1.0.0</version>
</dependency>

4.1 user-service 创建UserServiceImpl实现UserService

@DubboService
public class UserServiceImpl implements UserService {
    @Override
    public String getServiceName() {
        return "this is UserService";
    }
}

4.2 user-service启动类中添加注解

@EnableDubbo(scanBasePackages = "top.fate.service")

在这里插入图片描述

5.order-service调用user-service

5.1 pom 添加依赖

<dependency>
    <groupId>top.fate</groupId>
    <artifactId>user-service-api</artifactId>
    <version>1.0.0</version>
</dependency>

5.2 controller调用

@RestController
@RequestMapping(value = "order")
public class OrderController {

    @DubboReference
    private UserService userService;
    
    @GetMapping("getUserService")
    public String getUserService(){
        return userService.getServiceName();
    }

}

5.3 启动运行

在这里插入图片描述

5.4 测试

访问http://localhost:8082/order/getUserService

  • 调用成功

在这里插入图片描述

文章标签：
负载均衡
容器
测试技术
应用服务中间件
运维
负载均衡
传感器
Dubbo
Nacos
SpringCloudAlibaba
算法
关键词：
springcloudalibaba Dubbo
dubbo分布式框架
springcloudalibaba分布式框架
rpc分布式框架
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发，帮助IT从业者们通过“阿里云Web应用上云解决方案”，了解一个企业级Web应用上云的常见架构，了解如何构建一个高可用、可扩展的企业级应用架构。
fate急速出击
目录
相关文章
奔跑的数据
|
数据采集 存储 数据可视化
分布式爬虫框架Scrapy-Redis实战指南
本文介绍如何使用Scrapy-Redis构建分布式爬虫系统，采集携程平台上热门城市的酒店价格与评价信息。通过代理IP、Cookie和User-Agent设置规避反爬策略，实现高效数据抓取。结合价格动态趋势分析，助力酒店业优化市场策略、提升服务质量。技术架构涵盖Scrapy-Redis核心调度、代理中间件及数据解析存储，提供完整的技术路线图与代码示例。
奔跑的数据
1997 0
分布式爬虫框架Scrapy-Redis实战指南
北风几吹夏
|
监控 Java 调度
SpringBoot中@Scheduled和Quartz的区别是什么？分布式定时任务框架选型实战
本文对比分析了SpringBoot中的`@Scheduled`与Quartz定时任务框架。`@Scheduled`轻量易用，适合单机简单场景，但存在多实例重复执行、无持久化等缺陷；Quartz功能强大，支持分布式调度、任务持久化、动态调整和失败重试，适用于复杂企业级需求。文章通过特性对比、代码示例及常见问题解答，帮助开发者理解两者差异，合理选择方案。记住口诀：单机简单用注解，多节点上Quartz；若是任务要可靠，持久化配置不能少。
北风几吹夏
1172 4
nine很菜
|
消息中间件 人工智能 监控
文生图架构设计原来如此简单之分布式服务
想象一下，当成千上万的用户同时要求AI画图，如何公平高效地处理这些请求？文生图/图生图大模型的架构设计看似复杂，实则遵循简单而有效的原则：合理排队、分工明确、防患未然。
nine很菜
615 14
文生图架构设计原来如此简单之分布式服务
一只笨鼠
|
存储 监控 数据可视化
常见的分布式定时任务调度框架
分布式定时任务调度框架用于在分布式系统中管理和调度定时任务，确保任务按预定时间和频率执行。其核心概念包括Job（任务）、Trigger（触发器）、Executor（执行器）和Scheduler（调度器）。这类框架应具备任务管理、任务监控、良好的可扩展性和高可用性等功能。常用的Java生态中的分布式任务调度框架有Quartz Scheduler、ElasticJob和XXL-JOB。
一只笨鼠
6126 66
东阳马生架构
|
Java 开发者 索引
Netty基础—6.Netty实现RPC服务
本文详细介绍了RPC（远程过程调用）的相关概念及其实现细节，涵盖动态代理、Netty客户端和服务端处理、编码解码器以及超时功能的实现。
东阳马生架构
472 0
喵手
|
数据采集 人工智能 分布式计算
MaxFrame：链接大数据与AI的高效分布式计算框架深度评测与实践！
阿里云推出的MaxFrame是链接大数据与AI的分布式Python计算框架，提供类似Pandas的操作接口和分布式处理能力。本文从部署、功能验证到实际场景全面评测MaxFrame，涵盖分布式Pandas操作、大语言模型数据预处理及企业级应用。结果显示，MaxFrame在处理大规模数据时性能显著提升，代码兼容性强，适合从数据清洗到训练数据生成的全链路场景...
喵手
1049 5
MaxFrame：链接大数据与AI的高效分布式计算框架深度评测与实践！
warmhearted
|
人工智能 分布式计算 大数据
MaxFrame 产品评测：大数据与AI融合的Python分布式计算框架
MaxFrame是阿里云MaxCompute推出的自研Python分布式计算框架，支持大规模数据处理与AI应用。它提供类似Pandas的API，简化开发流程，并兼容多种机器学习库，加速模型训练前的数据准备。MaxFrame融合大数据和AI，提升效率、促进协作、增强创新能力。尽管初次配置稍显复杂，但其强大的功能集、性能优化及开放性使其成为现代企业与研究机构的理想选择。未来有望进一步简化使用门槛并加强社区建设。
warmhearted
768 8
六月的雨在钉钉
|
SQL 分布式计算 DataWorks
MaxCompute MaxFrame评测 | 分布式Python计算服务MaxFrame（完整操作版）
在当今数字化迅猛发展的时代，数据信息的保存与分析对企业决策至关重要。MaxCompute MaxFrame是阿里云自研的分布式计算框架，支持Python编程接口、兼容Pandas接口并自动进行分布式计算。通过MaxCompute的海量计算资源，企业可以进行大规模数据处理、可视化数据分析及科学计算等任务。本文将详细介绍如何开通MaxCompute和DataWorks服务，并使用MaxFrame进行数据操作。包括创建项目、绑定数据源、编写PyODPS 3节点代码以及执行SQL查询等内容。最后，针对使用过程中遇到的问题提出反馈建议，帮助用户更好地理解和使用MaxFrame。
六月的雨在钉钉
469 9
aliyun++
|
SQL 分布式计算 数据处理
云产品评测｜分布式Python计算服务MaxFrame | 在本地环境中使用MaxFrame + 基于MaxFrame实现大语言模型数据处理
本文基于官方文档，介绍了由浅入深的两个部分实操测试，包括在本地环境中使用MaxFrame & 基于MaxFrame实现大语言模型数据处理，对步骤有详细说明。体验下来对MaxCompute的感受是很不错的，值得尝试并使用！
aliyun++
439 1
Echo_Wish
|
分布式计算 数据处理 MaxCompute
云产品评测｜分布式Python计算服务MaxFrame
云产品评测｜分布式Python计算服务MaxFrame
Echo_Wish
419 2

热门文章

最新文章

  • 1
    如何无缝迁移 SpringCloud/Dubbo 应用到 Serverless 架构
  • 2
    SpringBoot开发案例之整合Dubbo消费者
  • 3
    dubbo-go 的开发、设计与功能介绍
  • 4
    使用 Dubbo 对遗留单体系统进行微服务改造
  • 5
    Go 语言体系下的微服务框架选型: Dubbo-go
  • 6
    SpringBoot开发案例之整合Dubbo提供者(二)
  • 7
    k8s容器云架构之dubbo微服务— K8S(11)配置中心实战-单环境交付apollo三组件
  • 8
    Apache Dubbo 首个 Node.js 3.0-alpha 版本正式发布
  • 9
    【Dubbo3高级特性】「提升系统安全性」手把手教你如何通过令牌进行Dubbo3服务验证及服务鉴权控制实战指南（二）
  • 10
    dubbo-admin安装
  • 1
    gRPC不是银弹：为内网极致性能，如何设计自己的RPC协议？
    550
  • 2
    RPC的三大问题：跨语言、跨平台通信的终极解决方案是如何炼成的？
    422
  • 3
    gRPC凭什么成为微服务通信首选？深度解析RPC进化史
    1223
  • 4
    识别这些API接口定义(http,https,api,RPC,webservice,Restful api ,OpenAPI）
    5567
  • 5
    初探Go语言RPC编程手法
    318
  • 6
    Netty基础—6.Netty实现RPC服务
    475
  • 7
    利用HTTP POST协议实现简单的RPC协议：WireShark抓包分析
    759
  • 8
    利用HTTP POST协议实现简单的RPC协议，并使用WireShark进行抓包分析
    642
  • 9
    【YashanDB知识库】YCP高可用部署离线升级-rpc升级详细步骤
    243
  • 10
    【YashanDB知识库】YCP单机部署离线升级-rpc升级方式详细步骤
    559

    • 相关课程

    更多
  • Dubbo开源、自研、商业化三位一体战略解读
  • Spring Boot+Vue.js+FastDFS实现分布式图片服务器
  • 基于Zookeeper、Dubbo构建互联网分布式基础架构
  • 分布式文件存储系统技术及实现
  • 分布式协调系统 Zookeeper 快速入门
  • Dubbo分布式服务治理实战

    • 相关电子书

    更多
  • 高并发分布式缓存Redis6.0
  • 基于社区的分布式 风险感知模型
  • 如何利用Redisson分布式化传统Web项目
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！