dubbo：dubbo服务负载均衡、集群容错、服务降级、服务直连配置详解（五）

文章目录

  • 0. 引言
  • 1. dubbo负载均衡
    • 1.1 负载均衡算法
    • 1.2. dubbo负载均衡使用
    • 1.3 自定义负载均衡策略
  • 2. dubbo服务容错
    • 2.1 8种服务容错策略
    • 2.2 自定义容错策略
  • 3. dubbo服务降级（mock）
  • 4. dubbo服务直连
  • 5. 总结

0. 引言

之前我们讲解了dubbo的基本使用，但在dubbo服务调用过程中，为了保证高可用dubbo提供者一般不是一个节点，当多个节点部署时，节点间的负载均衡问题随之而来，今天我们针对dubbo提供者服务的各类相关配置进行讲解

1. dubbo负载均衡

1.1 负载均衡算法

官方文档：https://cn.dubbo.apache.org/zh-cn/docsv2.7/dev/source/loadbalance/

在dubbo的源码中我们可以看到，dubbo支持5种负载均衡算法：
在这里插入图片描述

  • ConsistentHashLoadBalance：Hash一致性算法

将请求的参数如方法名、参数类型和参数值等作为键值对进行哈希计算，然后将固定范围内的hash值转发到对应的节点

  • RandomLoadBalance：权重随机算法，默认算法

为每一台服务器设置一个权值，当有请求到来时，按照大体的权重比例为该请求分配服务器，比如默认的1:1， 就会大体上按照1:1的比例进行随机转发

  • LeastActiveLoadBalance：最少活跃调用数算法

为每个服务提供者记录一个Active数，表示当前活跃的调用数。当有请求到来时，将该请求分配给当前活跃数最少的服务提供者，当活跃数相同时，就会按照权重大小分配转发

  • RoundRobinLoadBalance：轮询算法

按照顺序依次将请求分配给每一台服务器

  • ShortestResponseLoadBalance：最短响应时间算法

从多个提供者节点中选出成功调用且响应时间最短的节点进行转发，如果节点有多个，则再按照随机算法进行分配

1.2. dubbo负载均衡使用

在消费者端，引入提供者服务时，通过loadbalance参数指定，如下指定了Hash一致性算法

   @DubboReference(loadbalance = ConsistentHashLoadBalance.NAME)private UserService userService;

调用发现因为参数没变化，就会一直转发到同一个提供者节点上
在这里插入图片描述

1.3 自定义负载均衡策略

官方介绍：https://cn.dubbo.apache.org/zh-cn/docsv2.7/dev/impls/load-balance/

1、创建负载均衡实现类，声明LoadBalance接口，实现select方法，该方法即为具体的负载均衡实现算法，如下书写了一个简单的策略，固定取第一个实例

import org.apache.dubbo.common.URL;
import org.apache.dubbo.rpc.Invocation;
import org.apache.dubbo.rpc.Invoker;
import org.apache.dubbo.rpc.RpcException;
import org.apache.dubbo.rpc.cluster.LoadBalance;import java.util.List;public class WuLoadBalance implements LoadBalance {public final static String NAME = "wu";@Overridepublic <T> Invoker<T> select(List<Invoker<T>> invokers, URL url, Invocation invocation) throws RpcException {System.out.println("执行负载均衡");return invokers.get(0);}
}

2、在resources目录下创建META-INF/dubbo文件夹，再创建org.apache.dubbo.rpc.cluster.LoadBalance文件，文件内容如下，这里的名称即为给WuLoadBalance定义的别名，然后通过等号指定我们刚刚创建的实现类

wu=wu.example.orderserver.lb.WuLoadBalance

3、使用时指定该别名即可

 @DubboReference(loadbalance = WuLoadBalance.NAME)private UserService userService;

如果本地运行没有执行到，这是因为打包的resouces目录没有更新，将target目录删除后重新运行即可

2. dubbo服务容错

2.1 8种服务容错策略

所谓服务容错，就是当服务调用失败后的处理策略。dubbo支持8种服务容错策略，也叫集群容错策略：
在这里插入图片描述

  • AvailableCluster 可用实例策略

调用目前可用的实例，但只调用其中一个，如果当前没有可用的实例，则抛出异常

@DubboReference(cluster = AvailableCluster.NAME)
private UserService userService;
  • BroadcastCluster 广播策略

广播调用所有实例，逐个调用，任意一台报错则报错，与ForkingCluster策略形成对比

@DubboReference(cluster = BroadcastCluster.NAME)
private UserService userService;
  • FailbackCluster 失败重试策略

调用实例发生异常后，一段时间后重新再调用，直到调用成功，retries用于控制重试次数，timeout为调用超时时间

@DubboReference(cluster = FailbackCluster.NAME, retries = 3, timeout = 10000)
private UserService userService;
  • FailfastCluster 快速失败策略

只发起一次调用，失败立即报错，一般用于非幂等性操作场景，也就是操作不允许重复的，比如用户付款

  • FailoverCluster 自动切换策略，默认策略

当出现失败，重试其它服务

  • FailsafeCluster 安全失败策略

出现异常时，直接忽略，与FailfastCluster的区别就是：FailsafeCluster并不抛出异常，而FailfastCluster会抛出异常

  • ForkingCluster 并行策略

并行调用多个实例，有一个成功则返回。通常用于实时性要求较高的读操作，缺点是会浪费更多的资源

  • MergeableCluster 分组策略

某些场景下同一个接口，但是我们会有不同的实现，我们就可以针对这些不同的实现做不同的分组，然后调用时声明分组来调用不同的实现，一般和group参数一起使用，该策略和tag属性都可以用来调用不同的实现，可以针对灰度发布、分组实现、新老版本替换的场景
比如：

// 调用分组为xxx或者yyy的其中一个接口@Reference(cluster = MergeableCluster.NAME, group = "xxx,yyy")private IUserService userService;// 同时在提供者中也声明group
@DubboService(group = "xxx")
public class UserServiceImpl implements UserService {...
}

2.2 自定义容错策略

1、自定义ClusterInvoker
创建继承 AbstractClusterInvoker 的子类，并重写 doInvoke 方法


import org.apache.dubbo.rpc.Invocation;
import org.apache.dubbo.rpc.Invoker;
import org.apache.dubbo.rpc.Result;
import org.apache.dubbo.rpc.RpcException;
import org.apache.dubbo.rpc.cluster.Directory;
import org.apache.dubbo.rpc.cluster.LoadBalance;
import org.apache.dubbo.rpc.cluster.support.AbstractClusterInvoker;import java.util.List;/*** @author benjamin_5* @Description* @date 2024/8/23*/
public class MyClusterInvoker<T> extends AbstractClusterInvoker<T> {public MyClusterInvoker(Directory<T> directory) {super(directory);}@Overrideprotected Result doInvoke(Invocation invocation, List<Invoker<T>> invokers, LoadBalance loadbalance) throws RpcException {// 使用loadbalance对象选择具体的实例Invoker<T> invoker = select(loadbalance, invocation, invokers, null);try {// 执行rpc调用return invokeWithContext(invoker, invocation);} catch (Throwable e) {if (e instanceof RpcException && ((RpcException) e).isBiz()) {throw (RpcException) e;}throw new RpcException(e.getMessage(), e);}}
}

2、自定义Cluster类
创建继承 AbstractCluster 的子类，并重写 doJoin 方法。举例如下。

import org.apache.dubbo.rpc.RpcException;
import org.apache.dubbo.rpc.cluster.Directory;
import org.apache.dubbo.rpc.cluster.support.AbstractClusterInvoker;
import org.apache.dubbo.rpc.cluster.support.wrapper.AbstractCluster;/*** @author benjamin_5* @Description* @date 2024/8/23*/
public class MyDubboCluster extends AbstractCluster {public static final String NAME = "my";@Overrideprotected <T> AbstractClusterInvoker<T> doJoin(Directory<T> directory) throws RpcException {// 创建具体的集群策略return new MyClusterInvoker<>(directory);}
}

3、在resources资源目录下，创建META-INF文件夹，再创建dubbo文件夹，创建org.apache.dubbo.rpc.cluster.Cluster文件，然后内容声明自定义策略的名称

比如我这里自定义MyDubboCluster策略的名称为“my”，则再说明其对应的策略类包名即可，这样目的是为了让服务能够找到自定义的策略类

my=wu.example.orderserver.invoker.MyDubboCluster

4、在服务引用中声明策略

 @DubboReference(cluster = MyDubboCluster.NAME)private UserService userService;

5、为了测试验证，我们还可以在MyClusterInvoker加一句打印测试语句，然后启动项目，调用接口查看转发效果

如下执行结果表示自定义的策略调用成功
在这里插入图片描述

3. dubbo服务降级（mock）

所谓服务降级就是在所调用服务因各类异常而调用不通或者报错时而进行的一个兜底措施。比如当并发高导致下游服务处理不及时，这是降级返回一个“服务繁忙，请稍后重试”之类的兜底措施，或者访问远程中央数据库不通时，兜底访问本地库，从而保证基本服务正常运行，或者

1、创建降级服务类（Mock类），声明要降级的接口类UserService

public class UserServiceMock implements UserService {@Overridepublic String getUserById(Integer id) {return "服务繁忙，请耐心等候";}@Overridepublic String getInfo() {return "服务繁忙，请耐心等候";}
}

2、使用时通过mock参数来指定降级类

@DubboReference(mock = "wu.example.orderserver.service.UserServiceMock")
private UserService userService;

3、我们将userService的实例停掉，模拟访问不通，然后访问调用接口，发现返回的是降级信息，则说明降级成功。
在这里插入图片描述

4. dubbo服务直连

某些场景下，我们业务不适合或者不能使用注册中心，这时就只能通过直连的方式来进行访问，而dubbo中设置服务直连也很简单，通过url参数即可

1、因为dubbo服务直连需要通过dubbo端口来进行通信，所以我们先指定服务提供者的dubbo端口

dubbo:application:name: user-serverprotocol: # 指定通信规则name: dubbo # 通信协议port: 20892 # dubbo协议端口，以供消费者访问，-1即为随机端口registry: # 注册中心id: zk-registryaddress: zookeeper://127.0.0.1:2181

2、在服务使用者里通过url声明地址

@DubboReference(url = "dubbo://localhost:20892")
private UserService userService;

如果有多个提供者的，用分号隔开

@DubboReference(url = "dubbo://localhost:20891;dubbo://localhost:20892")
private UserService userService;

3、如果需要配置负载均衡策略的使用loadbalance参数声明即可，用法与注册中心注册的服务负载均衡一致。

5. 总结

至此，我们针对dubbo各类常用配置的讲解即完成了，更多详细的配置大家可以参考官方文档，如有需要自定义配置的，可灵活利用dubbo的SPI机制（服务自定义拓展），dubbo中支持各类模块的自定义，具体也可参考官方文档说明：https://cn.dubbo.apache.org/zh-cn/docsv2.7/dev/impls/

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

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

使用 AI进行绘画初体验

使用 AI进行绘画初体验

大家好啊&#xff0c;我是董董灿。 AI 绘画的效果是真的不错&#xff0c;最近在查找AI相关技术文章时&#xff0c;总是会时不时的发现一些好玩的 AI 应用&#xff0c;而且大多数都是免费的。 今天就给大家介绍如何使用 MidJourney 来完成 AI 绘画的网站。 MidJourney 本身是…
阅读更多...
6种有效的时间序列数据特征工程技术（使用Python）

6种有效的时间序列数据特征工程技术（使用Python）

在商业分析中&#xff0c;"时间"是一个核心概念。我们基于时间组件来分析销售数据、收入、利润、增长&#xff0c;甚至进行预测。然而&#xff0c;对于初学者来说&#xff0c;这可能是一个复杂的主题。在处理时间敏感的数据集时&#xff0c;需要考虑时间序列数据的多…
阅读更多...
Unet改进12：添加PCONV||减少冗余计算和同时存储访问

Unet改进12：添加PCONV||减少冗余计算和同时存储访问

本文内容：添加PCONV 目录 论文简介 1.步骤一 2.步骤二 3.步骤三 4.步骤四 论文简介 为了设计快速的神经网络，许多工作都集中在减少浮点运算(FLOPs)的数量上。然而，我们观察到FLOPs的这种减少并不一定会导致类似程度的延迟减少。这主要源于低效率的每秒浮点操作数(FLOP…
阅读更多...
STM32——GPS模块（GY-NEO-6M）

STM32——GPS模块（GY-NEO-6M）

1连接 1-1 使用 USB-TTL 工具&#xff0c;安装好驱动&#xff0c;可以在”设备管理器看到对应COM”按照如下链接测试模块&#xff1a; USB-TTL GPS 模块 3.3V--------------------------------->VCC GND------------------------------>GND RXD--------------------…
阅读更多...
Linux安装Hadoop（单机版）详细教程

Linux安装Hadoop（单机版）详细教程

目录 一、JDK安装 1、下载JDK安装包 2、解压下载的JDK安装包 3、移动并重命名JDK包 4、配置Java环境变量 5、验证安装是否成功 二、Hadoop安装 1、下载Hadoop安装包 2、解压Hadoop安装包 3、配置Hadoop环境变量 4、修改配置文件 5、验证Hadoop是否安装成功 三&…
阅读更多...
使用3D数字人做视频

使用3D数字人做视频

用3D数字人做视频 漂亮精致 3D数字人定制4 动作流畅、音乐上的表现 thatgirl 支持私人定制模型 你愿意捐献所有的财产吗 想搭建这样的数字人的请和我们联系 使用3D数字人做视频https://www.jinshuangshi.com/forum.php?modviewthread&tid248 (出处: 金双石科技)
阅读更多...
力扣经典题目之-＞二叉树的前序遍历（中序后序同理）

力扣经典题目之-＞二叉树的前序遍历（中序后序同理）

一&#xff1a;题目 解释&#xff1a; 1&#xff1a; 题目的要求就是我们return 一个数组&#xff0c;该数组里面的元素及其顺序就是 前序遍历二叉树 的元素及其顺序 比如&#xff1a;示例1的树&#xff0c;前序遍历的顺序应该是1 2 3&#xff0c;那么return 的数组里面的元素…
阅读更多...
智慧高校迎新服务平台的设计与实现---附源码92489

智慧高校迎新服务平台的设计与实现---附源码92489

摘要 随着高校规模的不断扩大和新生人数的增加&#xff0c;传统的手工登记和管理方式已经无法满足高效、准确的需求。为了提升高校新生报到迎新工作的效率和质量&#xff0c;本研究设计开发了一套基于SSM框架的智慧高校迎新服务平台的设计与实现。系统通过信息技术的应用&#…
阅读更多...
12-使用gateway作为微服务网关

12-使用gateway作为微服务网关

本文介绍spring gateway的使用&#xff0c;包括配置文件的使用和调试跟踪&#xff0c;让大家了解spring gateway的基本用法。如果不了解什么是微服务网关&#xff0c;就先查查资料&#xff0c;网关相对来说是比较重要的微服务组件。 0、环境 springboot 2.4.2springcloud gat…
阅读更多...
Minkowski分形电路生成工具[程序附后]

Minkowski分形电路生成工具[程序附后]

此工具用于生成Minkowski分形电路&#xff0c;应用领域可参考分形电路的纪录片或CNKI论文。运行环境在Altium Designer中&#xff0c;可用于Altium Designer全系列的版本中。 程序界面如下图所示&#xff0c;可以支持外框和迭代次数的更改。 程序下载链接&#xff1a; Minkows…
阅读更多...
图片拼图怎么做？4个方法打造具有高级感的拼图作品

图片拼图怎么做？4个方法打造具有高级感的拼图作品

被阿勒泰的日落治愈了&#xff0c;旅行中的每一刻都值得珍藏。 这次的阿勒泰之行&#xff0c;我不仅带回了一堆美好的回忆&#xff0c;还有手机里满满的精彩瞬间。从壮丽的山川到静谧的湖泊&#xff0c;从晨曦初现到夜幕降临&#xff0c;每一帧都是大自然的馈赠。但是&#xf…
阅读更多...
三天速成数学建模国赛国奖全攻略

三天速成数学建模国赛国奖全攻略

这里写目录标题 国赛考点&#x1f5d2;️&#x1f5d2;️01 国赛是如何评奖的&#xff1f;02 国赛历年题型和模型算法1&#xff09;国赛赛题特点2&#xff09;历年国赛赛题类型 建模手三天快速提升计划✨✨01 第一天&#xff1a;模型分类及国赛常见模型的用法了解1&#xff09;…
阅读更多...
图形化编程/Scratch/编程猫角色素材免费分享1-10期合集

图形化编程/Scratch/编程猫角色素材免费分享1-10期合集

今天给大家带来一些业余整理的scratch等图形化编程软件可以使用的角色素材图片分享&#xff0c;都是PNG格式的透明图片&#xff0c;scratch软件可直接上传角色使用&#xff08;也支持编程猫等软件&#xff0c;因为素材是PNG格式&#xff0c;所有支持png格式的软件都可以使用&am…
阅读更多...
【 OpenHarmony 系统应用源码解析 】-- Launcher 初体验

【 OpenHarmony 系统应用源码解析 】-- Launcher 初体验

前言 最近因为业务需要&#xff0c;需要做一款 UI 定制的鸿蒙 Launcher&#xff0c;于是就开始了「找到代码」、「研究代码」、「魔改代码」的套路流程&#xff0c;仅以此文章作为知识备份和技术探讨所用&#xff0c;也希望能给其他小伙伴提供一些源码的解析思路&#xff0c;方…
阅读更多...
uniapp小程序怎么判断滑动的方向

uniapp小程序怎么判断滑动的方向

项目场景&#xff1a; 获取手机上手指滑动的距离超过一定距离 来操作一些逻辑 解决方案&#xff1a; 在uniapp中&#xff0c;可以通过监听触摸事件来判断滑动的方向。常用的触摸事件包括touchstart, touchmove, 和 touchend。通过这些事件的参数&#xff0c;可以计算出用户的滑…
阅读更多...
【Android】最好用的网络库：Retrofit

【Android】最好用的网络库：Retrofit

最好用的网络库&#xff1a;Retrofit 文章目录 最好用的网络库&#xff1a;RetrofitRetrofit的基本用法Retrofit的使用逻辑Retrofit的基本操作处理复杂的接口地址类型进阶删除提交header中指定参数 Retrofit构建器的最佳写法Retrofit的使用封装 Retrofit的基本用法 Retrofit是一…
阅读更多...
html2Canvas和jspdf导出长pdf

html2Canvas和jspdf导出长pdf

续使用html2canvas和jspdf导出pdf包含跨页以及页脚_jspdf.umd.min.js-CSDN博客我的这篇文章再写一种情况因为最近我也使用到了 具体的html2Canvas和jspdf的我就不说了&#xff0c;直接开始了&#xff0c; 在公共方法的文件夹中建立一个新的文件htmlToPdf.js用来写咱们得方法然…
阅读更多...
SpringBoot SSM vue在线作业考试系统

SpringBoot SSM vue在线作业考试系统

SpringBoot SSM vue在线作业考试系统 首页 图片轮播 作业信息 通知公告 登录注册 留言板 个人中心 我的收藏 后台管理 登录注册 个人中心 教师信息管理 学生信息管理 学院信息管理 专业信息管理 班级信息管理 作业信息管理 作业提交管理 通知公告管理 试卷管理 试题管理 系统…
阅读更多...
关于LLC知识14

关于LLC知识14

1、LLC必须工作在感性区 2、为了降低LLC进入容性区后MOS管的电流应力&#xff0c;必须要选择快管&#xff0c;对体二极管的反向恢复参数有要求&#xff1a;trr<200ns 3、对于上下管的死区时间不能太短&#xff0c;否则电容无法充放电完成&#xff0c;就无法实现ZVS导通 如…
阅读更多...
Nginx简单的安全性配置

Nginx简单的安全性配置

文章目录 引言I Nginx简单的安全性配置禁止特定的HTTP方法限制URL长度禁止某些用户代理限制请求速率连接限制禁止访问某些文件类型II 常见的安全规则防御CC攻击User-Agent过滤GET-URL过滤GET-参数过滤POST过滤（sql注入、xss攻击 ）引言 Nginx本身并不具备复杂的防火墙规则定制…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023