Dubbo应用篇

news2025/2/24 9:18:56

文章目录

  • 一、Dubbo简介
  • 二、SSM项目整合Dubbo
    • 1.生产者方配置
    • 2.消费者方配置
  • 三、Spring Boot 项目整合Dubbo
    • 1.生产者方配置
    • 2.消费者方配置
  • 四、应用案例
  • 五、Dubbo配置的优先级别
    • 1. 方法级配置(Highest Priority)
    • 2. 接口级配置
    • 3. 消费者/提供者级配置
    • 4. 全局配置
  • 六、Dubbo超时时间和重试
  • 七、设置本地存根
  • 八、整合Hystrix
  • 总结


一、Dubbo简介

  Dubbo 是一个RPC(远程过程调用)服务框架:

  1. 服务注册与发现:Dubbo 提供内置的注册中心(如 Zookeeper 等),服务提供者注册服务,消费者动态发现服务。
  2. 高效的远程调用:通过支持多种通信协议(默认 Dubbo 协议),实现快速、可靠的远程方法调用。
  3. 负载均衡:提供多种负载均衡策略,如随机、轮询、一致性哈希等,保证服务调用的高效性和稳定性。
  4. 服务治理:包括限流、降级、熔断、动态路由等功能,提升系统稳定性和灵活性。
  5. 扩展性强:采用模块化设计,用户可以根据需求定制和扩展功能。

  Dubbo主要由以下五部分组成:

  1. Provider(服务提供者):提供服务的应用。
  2. Consumer(服务消费者):调用服务的应用。
  3. Registry(注册中心):管理服务的注册与发现。
  4. Monitor(监控中心):监控服务的调用性能。
  5. Protocol(协议层):定义服务调用的规则和数据传输方式。

在这里插入图片描述

  常见的远程调用工具,除了Dubbo还有Open Feign,HttpClient等,那么Dubbo和Open Feign有什么区别?

  1. 框架定位和设计目标
DubboOpenFeign
分布式服务框架,重点在 服务治理声明式 HTTP 客户端,主要关注 HTTP 调用
提供端到端的解决方案,包括服务注册发现、负载均衡、服务路由、服务降级等。偏重于与 REST API 的集成,通常依赖 Spring Cloud 生态提供更多功能。
支持多种通信协议(如 Dubbo 协议、HTTP、gRPC)。仅支持基于 HTTP 的远程调用。

  1. 通信协议
DubboOpenFeign
支持多种通信协议,默认采用高性能的 Dubbo 协议,基于二进制序列化,通信效率高。仅支持 HTTP,通常基于 JSON 格式的数据交换,性能比二进制协议略低。
可以支持 TCP、HTTP、gRPC 等不同的底层传输协议。依赖 HTTP 和 RESTful 风格,灵活性较低。

  1. 注册与发现
DubboOpenFeign
通过注册中心(如 Zookeeper、Nacos)实现动态的服务注册与发现。通常依赖 Spring Cloud 服务注册中心(如 Eureka、Consul)。
服务发现、路由完全由 Dubbo 框架管理。需要依赖 Spring Cloud 相关组件完成服务发现。

  1. 负载均衡与服务治理
DubboOpenFeign
内置多种负载均衡算法(如随机、轮询、一致性哈希)。负载均衡通常依赖 Ribbon 或 Spring Cloud LoadBalancer。
提供丰富的服务治理功能,如熔断、限流、动态路由等。通常通过 Hystrix、Resilience4j 等第三方库实现。

  1. 性能与适用场景
DubboOpenFeign
性能高,适合 高并发、低延迟的场景(如 RPC 调用)。易用性高,适合 跨服务的 RESTful 调用 场景。
偏向于大规模、高性能分布式系统。偏向于 REST 风格 API 的微服务开发。

  1. 扩展性与生态
DubboOpenFeign
自带强大的扩展能力,可以通过 SPI 自定义组件,如协议、序列化机制等。集成简单,主要依赖 Spring Cloud 生态,与其他组件兼容性好。
社区活跃度较高,但主要适用于阿里系生态。社区支持广泛,与 Spring Cloud 微服务结合更紧密。

二、SSM项目整合Dubbo

  无论是生产者方,消费者方,首先加入依赖:

<!--        dubbo-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.2</version>
        </dependency>
<!--        zookeeper-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.10.0</version>
        </dependency>

1.生产者方配置

  resource目录下编写provider.xml文件:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
		http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
		http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

	<!-- 1、指定当前服务/应用的名字(同样的服务名字相同,不要和别的服务同名) -->
	<dubbo:application name="user-service-provider"></dubbo:application>
	
	<!-- 2、指定注册中心的位置 在本案例中使用的是zk,也可以使用其他的 -->
	<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
	
	<!-- 3、指定通信规则(通信协议?通信端口) -->
	<dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>
	
	<!-- 4、暴露服务   ref:指向服务的真正的实现对象 -->
	<dubbo:service interface="com.atguigu.gmall.service.UserService"
		ref="userServiceImpl01" timeout="1000" version="1.0.0">
		<dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
	</dubbo:service>

	<!-- 服务的实现 -->
	<bean id="userServiceImpl01" class="com.light.gmall.service.impl.UserServiceImpl"></bean>
	
	<!--统一设置服务提供方的规则  -->
	<dubbo:provider timeout="1000"></dubbo:provider>
	
	<!-- 连接监控中心 -->
	<dubbo:monitor protocol="registry"></dubbo:monitor>
	
</beans>

2.消费者方配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
	xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd
		http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
		http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
	<!--  扫描消费者的业务类,注册成bean放入容器-->
	<context:component-scan base-package="com.light.gmall.service.impl"></context:component-scan>

	<dubbo:application name="order-service-consumer"></dubbo:application>
	
	<dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
	
	<!--声明需要调用的远程服务的接口;生成远程服务代理  -->
	<dubbo:reference interface="com.atguigu.gmall.service.UserService" 
		id="userService" timeout="5000" retries="3" version="*">
	</dubbo:reference>
		
	<!-- 配置当前消费者的统一规则:所有的服务都不检查 -->
	<dubbo:consumer check="false" timeout="5000"></dubbo:consumer>

	<dubbo:monitor protocol="registry"></dubbo:monitor>
	
</beans>

三、Spring Boot 项目整合Dubbo

  同样地,无论是生产者方,消费者方,首先加入依赖,并且启动类上加入@EnableDubbo注解:

		<dependency>
			<groupId>com.alibaba.boot</groupId>
			<artifactId>dubbo-spring-boot-starter</artifactId>
			<version>0.2.0</version>
		</dependency>

1.生产者方配置

dubbo.application.name=user-service-provider #指定当前服务/应用的名字
dubbo.registry.address=127.0.0.1:2181 #指定注册中心的位置
dubbo.registry.protocol=zookeeper  #指定注册中心的类型

dubbo.protocol.name=dubbo # 指定通信协议
dubbo.protocol.port=20880 # 指定通信端口

dubbo.monitor.protocol=registry #连接监控中心

  暴露服务可以通过@Service注解实现,该注解是import com.alibaba.dubbo.config.annotation.Service。并且只能加在类上。

2.消费者方配置

dubbo.application.name=boot-order-service-consumer # 指定当前服务/应用的名字
dubbo.registry.address=zookeeper://127.0.0.1:2181	# 指定注册中心
dubbo.monitor.protocol=registry #连接监控中心

  调用生产者方暴露的类的方法,可以在注入目标类时加入@Reference方法,并且可以指定负载均衡和超时时间等策略:

	@Reference(loadbalance="random",timeout=1000) //dubbo直连
	UserService userService;

四、应用案例

  在本篇的应用中,将所有需要被远程调用的接口,抽取成一个独立的模块进行管理,消费者生产者去依赖该模块:
在这里插入图片描述  生产者方:

@Service//暴露服务 
@Component
public class UserServiceImpl implements UserService {

	@HystrixCommand
	@Override
	public List<UserAddress> getUserAddressList(String userId) {
		// TODO Auto-generated method stub
		System.out.println("UserServiceImpl..3.....");
		UserAddress address1 = new UserAddress(1, "xxxx", "1", "李老师", "010-56253825", "Y");
		UserAddress address2 = new UserAddress(2, "yyyy", "1", "王老师", "010-56253825", "N");
		if(Math.random()>0.5) {
			throw new RuntimeException();
		}
		return Arrays.asList(address1,address2);
	}

}

  消费者方:

@Controller
public class OrderController {
	
	@Autowired
	OrderService orderService;
	
	@ResponseBody
	@RequestMapping("/initOrder")
	public List<UserAddress> initOrder(@RequestParam("uid")String userId) {
		return orderService.initOrder(userId);
	}

}
@Service
public class OrderServiceImpl implements OrderService {

	//@Autowired
	@Reference(loadbalance="random",timeout=1000) //dubbo直连
	UserService userService;
	
	@HystrixCommand(fallbackMethod="hello")
	@Override
	public List<UserAddress> initOrder(String userId) {
		// TODO Auto-generated method stub
		System.out.println("用户id:"+userId);
		//1、查询用户的收货地址
        return userService.getUserAddressList(userId);
	}
}

  启动Zookeeper和Dubbo-Admin,访问Controller层的路径:
在这里插入图片描述
  登录Dubbo Admin也可以看到:
在这里插入图片描述在这里插入图片描述

五、Dubbo配置的优先级别

总体原则
环境变量或启动参数的优先级更高:

  • 如果通过系统属性(如 -D 参数)或环境变量设置某些配置,它们会覆盖 XML 或注解中的设置。

动态配置的优先级更高:

  • Dubbo Admin 提供的动态配置可以在运行时覆盖静态配置,优先级更高。

本地优先于远程:

  • 如果本地和远程注册中心(如 Zookeeper)同时有配置,本地配置通常优先生效。

1. 方法级配置(Highest Priority)

  • 方法级配置对单个方法生效,优先级最高。
  • 主要用于对某些特殊方法的调用行为进行单独优化。
<dubbo:reference id="demoService" interface="com.example.DemoService">
    <dubbo:method name="sayHello" timeout="3000" retries="2"/>
</dubbo:reference>

2. 接口级配置

  • 通过 <dubbo:reference><dubbo:service> 对整个接口的行为进行配置。
  • 优先级低于方法级配置,但高于全局配置。
<dubbo:reference id="demoService" interface="com.example.DemoService" timeout="5000" retries="3"/>

3. 消费者/提供者级配置

  • 分别通过 <dubbo:consumer><dubbo:provider> 标签进行配置,针对消费者或提供者应用全局生效。
  • 优先级低于接口级配置。
<dubbo:consumer timeout="6000" retries="1"/>
<dubbo:provider timeout="4000"/>

4. 全局配置

  • 通过 <dubbo:application><dubbo:registry> 等标签进行全局性配置。
  • 优先级最低,提供默认值或全局设置。
<dubbo:application name="demoApplication"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>

六、Dubbo超时时间和重试

  在Spring Boot项目中,设置超时时间和重试次数,可以通过在服务消费端的 @DubboReference 注解中设置,优先级高于配置文件中的全局配置。

	@Reference(loadbalance="random",timeout=1000,retries = 3) //dubbo直连
	UserService userService;

  可以在配置文件中全局设置:

dubbo:
  consumer:
    timeout: 5000  # 超时时间,单位为毫秒
    retries: 2  # 重试次数

  可以在配置文件中单个设置:

dubbo:
  consumer:
    services:
      com.example.MyService:
        retries: 1  # 针对某个服务的重试次数
        timeout: 3000  # 指定服务的超时时间

  上述两段配置是放在消费者方的,如果消费者没有设置,可以在生产者方设置:

dubbo:
  provider:
    timeout: 5000
    retries: 2

  如果需要更细粒度控制到接口中的方法级别,则可以:

dubbo:
  consumer:
    services:
      com.example.MyService:
        methods:
          - name: method1
            retries: 0  # method1 不重试
          - name: method2
            retries: 2  # method2 重试 2 次

  演示接口超时
在这里插入图片描述在这里插入图片描述  目前在页面上是直接打印出了报错信息,后续可以通过引入Hystrix引导到降级逻辑上。
在这里插入图片描述

七、设置本地存根

  Dubbo 本地存根用于在消费端(Consumer)对服务进行代理或增强,常用于参数校验、缓存、限流等场景。
  编写本地存根方法,和接口放在同一个包下
在这里插入图片描述

public class UserServiceStub implements UserService{

    private final UserService userService;

    public UserServiceStub(UserService userService) {
        this.userService = userService;
    }


    /**
     * 按照用户id返回所有的收货地址
     *
     * @param userId
     * @return
     */
    @Override
    public List<UserAddress> getUserAddressList(String userId) {
        System.out.println("进入本地存根方法....");
        return userService.getUserAddressList(userId);
    }
}

  在消费者方的@Reference注解上加入stub = "存根类的全路径",重新访问接口:
在这里插入图片描述

八、整合Hystrix

  在生产者方和消费者方同时引入依赖,并且在启动类上加入@EnableHystrix

	<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>
				spring-cloud-starter-netflix-hystrix
			</artifactId>
		</dependency>

  生产者方对外暴露的方法上加入@HystrixCommand注解:
在这里插入图片描述
  消费者方同样加上注解,并且指定触发降级后的逻辑:@HystrixCommand(fallbackMethod="hello"),在本案例中,触发降级之后,会调用hello方法。
在这里插入图片描述  触发降级策略:
在这里插入图片描述

总结

  本篇介绍了Dubbo在SSM项目,以及Spring Boot项目中的集成使用,以及配置文件的优先级,超时时间和重试机制等。此外还有负载均衡策略,如何保证高可用,在官方文档里都有提及,本篇不再赘述。
Dubbo官方文档

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

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

相关文章

Vulnhub---kioptirx5 超详细wp

个人博客 WuTongSec 欢迎大佬指点 打点 nmap 192.168.128.0/24 -sP 找ip nmap 192.168.128.137 --min-rate 10000 -p- 简单全端口扫描 nmap 192.168.128.137 -sC -sV -O -sT 详细 脚本 版本 系统 扫描 dirsearch -u http://192.168.128.137 目录扫描 PORT S…

JAVA八股文-运行篇-创建项目运行(1)

前置环境搭建:jdk、maven、idea、linux环境 一、创建一个java项目 File->New->Project 二、填写基本信息 三、完成&#xff0c;写了一段代码 四、打包 五、本地运行&#xff0c;运行和debug二选一 六、上传至linux环境 七、linux环境下命令执行 7.1 指定Main方法类 …

【C++】异常之道,行者无疆:解锁 C++ 的异常捕获哲学

文章目录 C语言处理错误C异常异常的抛出与捕获基本语法catch 的匹配原则函数调用链中的匹配原则异常的重新抛出 异常安全异常规范C标准库异常 C语言处理错误 终止程序&#xff1a;利用 assert() 断言去终止程序&#xff0c;当 ()的表达结果为 false 时会终止程序。返回错误码&…

[SWPUCTF 2022 新生赛]Ez_upload 详细题解

知识点: 文件上传 MIME绕过 script版本一句话木马 .htaccess配置文件 蚁剑虚拟终端的使用 打开题目可以文件上传 传入php文件, 提示 后缀不能是ph 所以也不能输入 phtml php3 pht等可以解析为php文件的后缀 bp抓包把传入的php木马文件后缀手动修改为jpg图片格式 提示 你上…

V20变频器设置电机电流超过设定的值,变频器报警停止运转

之前使用的台达变频器是有相关参数的设置的&#xff0c;比如设置额定电流的限制比例未1.5A时&#xff0c;超过1.5A时&#xff0c;变频器会输出报警信号&#xff0c;并停机报警。换到V20变频时&#xff0c;翻遍了说明书&#xff0c;并各种参数测试组合&#xff0c;未找到明确的相…

网络安全-态势感知

0x00 定义&#xff1a; 态势感知&#xff08;Situation Awareness&#xff0c;SA&#xff09;能够检测出超过20大类的云上安全风险&#xff0c;包括DDoS攻击、暴力破解、Web攻击、后门木马、僵尸主机、异常行为、漏洞攻击、命令与控制等。利用大数据分析技术&#xff0c;态势感…

未完成_RFdiffusion应用案例_从头设计pMHC的结合剂

目录 1. 论文导读1&#xff09;摘要2&#xff09;设计流程3&#xff09;设计流程的验证 2. 实战 1. 论文导读 Liu, Bingxu, et al. “Design of high specificity binders for peptide-MHC-I complexes.” bioRxiv (2024): 2024-11. 1&#xff09;摘要 MHC-I 将胞内抗原肽递呈…

Vant UI Axure移动端元件库:提升移动端原型设计效率

UI框架的选择对于提升开发效率和用户体验至关重要。Vant UI&#xff0c;作为一款基于Vue.js的轻量、可靠的移动端组件库&#xff0c;自2017年开源以来&#xff0c;凭借其丰富的组件库、良好的性能以及广泛的兼容性&#xff0c;在移动端开发领域崭露头角&#xff0c;赢得了众多开…

stm32中的常用函数

目录 一、定义声明类 1.1 预定义 1.2 条件编译 1.3 extern 声明 1.3 typedef 类型别名 1.4 结构体 二、基础函数 2.1 delay类函数 2.2 printf函数 三、GPIO 3.1 硬件 3.2 通用外设驱动模型 3.3 例程 四、中断 4.1. 什么是中断 4.2. NVIC 4.3. EXTI 4.4. EXTI和…

静态路由与交换机配置实验

1.建立网络拓扑 添加2台计算机&#xff0c;标签名为PC0、PC1&#xff1b;添加2台二层交换机2960&#xff0c;标签名为S0、S1&#xff1b;添加2台路由器2811&#xff0c;标签名为R0、R1&#xff1b;交换机划分的VLAN及端口根据如下拓扑图&#xff0c;使用直通线、DCE串口线连接…

【Appium】AttributeError: ‘NoneType‘ object has no attribute ‘to_capabilities‘

目录 1、报错内容 2、解决方案 &#xff08;1&#xff09;检查 &#xff08;2&#xff09;报错原因 &#xff08;3&#xff09;解决步骤 3、解决结果 1、报错内容 在PyCharm编写好脚本后&#xff0c;模拟器和appium也是连接成功的&#xff0c;但是运行脚本时报错&…

【汇编语言】标志寄存器(三) —— 条件跳转,精准决策:汇编语言的比较与转移

文章目录 前言1. 检测比较结果的条件转移指令1.1 什么是条件转移指令&#xff1f;1.2 两类条件转移指令 2. 根据无符号比较的条件转移指令2.1 如何记忆&#xff1f;2.2 如何实现比较转移的功能&#xff1f;2.3 举例说明2.3.1 例12.3.2 例2 3. 总结4. 例题巩固4.1 问题一4.1.1 问…

【Unity高级】如何获取着色器(Shader)的关键词

在动态设置Shader时&#xff0c;会需要通过EnableKeyword, DisableKeyword来完成。但一个Shader有哪些关键词呢&#xff1f;Unity的文档中并没有列出来&#xff0c;但我们可以通过遍历Shader的KeywordSpace来查看。 1. 代码如下 using UnityEngine;public class KeywordExamp…

针对边缘计算优化LoRa的TinyML信道跳变管道

论文标题&#xff1a;Optimizing LoRa for Edge Computing with TinyML Pipeline for Channel Hopping&#xff08;针对边缘计算优化LoRa的TinyML信道跳变管道&#xff09; 作者信息&#xff1a;Marla Grunewald, Mounir Bensalem 和 Admela Jukan&#xff0c;来自德国布伦瑞克…

使用AI工具Screenshot to Code将UI设计图翻译成代码

一、获取openAI apikey。 一般有两种方式&#xff0c;一种是到openAI官网注册账号&#xff0c;付费申请GPT4的apikey。另一种是某宝买代理。我这里采用第二种。 二、安装Screenshot to Code 1.到github下载源码。 2.启动&#xff0c;两种方式&#xff1a;源码启动和docker启动…

python学opencv|读取图像(三)放大和缩小图像

【1】引言 前序已经学习了常规的图像读取操作和图像保存技巧&#xff0c;相关文章链接为&#xff1a; python学opencv|读取图像-CSDN博客 python学opencv|读取图像&#xff08;二&#xff09;保存彩色图像-CSDN博客 今天我们更近一步&#xff0c;学习放大和缩小图像的技巧&…

【vue2自定义指令】v-disabled 实现el-switch,el-button等elementUI禁用(disabled)效果

如果你搜过类似的功能&#xff0c;肯定看到过千篇一律的 // 实现按钮禁用el.disabled true// 增加 elementUI 的禁用样式类el.classList.add(is-disabled)但是这个方案明显对el-switch&#xff0c;不起作用&#xff0c;所以我这边直接把方案贴出来&#xff0c;不想了解具体原理…

烟草行业通过Profinet转EthernetIP网关打通数据壁垒

在工业自动化领域&#xff0c;Profinet转Ethernet/IP是两种广泛应用的工业以太网协议。它们各自具有独特的特点和优势&#xff0c;而在实际应用中&#xff0c;经常需要实现这两种协议之间的互通&#xff0c;这时就需要使用到开疆智能Profinet转Ethernet/IP网关KJ-EIP-108。同时…

C++内存布局以及常用关键字

C内存布局以及常用关键字 C的内存空间 代码存储区域&#xff1a;常量区、代码区、静态区&#xff08;全局区&#xff09;、堆区、栈区 栈区向下增长&#xff0c;堆区向上增长。栈由系统管理&#xff0c;没有内存碎片&#xff0c;每个元素之间都是连续的&#xff0c;大小比较…