首页 > TAG信息列表 > Invoker

Dubbo源码(八) - 负载均衡

前言 本文基于Dubbo2.6.x版本，中文注释版源码已上传github：xiaoguyu/dubbo 负载均衡，英文名称为Load Balance，其含义就是指将负载（工作任务）进行平衡、分摊到多个操作单元上进行运行。 例如：在Dubbo中，同一个服务有多个服务提供者，每个服务提供者所在的机器性能不一致。如果流量均匀分摊，则

Maven基础知识（5）- Maven 自动化构建

Maven 自动化构建是一种方案，即当某个项目构建完成后（特别是有代码更新的情况下），所有依赖它的相关项目也应该开始构建过程，以确保这些项目的稳定运行。Maven 的自动化构建主要通过如下两种方案实现：    (1) 使用 maven-invoker-plugin 插件。    (2) 使用持续集成（CI）服务器自动管

Dubbo是如何进行远程服务调用的？（源码流程跟踪）

首先会分析Dubbo是如何进行远程服务调用的，如果不了解dubbo的服务暴露和服务调用，请去看前两篇dubbo的文章，然后后面我还会说一下dubbo的SPI机制 当我们在使用@reference 注解的时候，来调用我们的提供者的Service对象的时候，Dubbo中的服务调用是怎么实现的 Dubbo的远程服务调用 （1）

Dubbo Fliter机制(十)

在对服务者调用流程的讲解中，最后invoker调用链是 RegisterDirectory$InvokerDelegate.invoke(InvokerWrapper.invoke)  ->  ListenerInvokerWraper.invoke  -> ProtocolFilterWrapper.invoke  -> DubboInvoke.invoke 接下来将重点介绍该流程，其中包括一系列的filter   Invoker

Dubbo 负载均衡与集群容错(十一)

负载均衡 Dubbo支持的负载均衡有如下策略：默认是随机 权重随机（random），实现类RandomLoadBalance 权重轮询(roundrobin)，实现类RoundRobinLoadBalance 最少活跃（leastactive）负载策略，实现类LeastActiveLoadBalance 一致性hash(consistenthash)  实现类ConsistentHashLoadBalance 在Abs

MySql-函数、存储过程、触发器

1.函数 CREATE DEFINER=`april_admin`@`%` FUNCTION `my_func`() RETURNS int(11) BEGIN #Routine body goes here... INSERT INTO student (`name`) VALUES ("名字"); RETURN 0; END 函数必须有返回值 2.存储过程 CREATE DEFINER=`april_admin`@`%` PROCEDURE `insert_stud

dubbo源码分析第二十二篇一dubbo负载均衡-ConsistentHashLoadBalance及一致性hash算法

ConsistentHashLoadBalance 原理图 第一步: 基于网络地址hash构建虚拟一致性hash表 获取接口与方法名 每个方法构建一致性hash选择器 通过选择器选择一个Invoker 基于调用方法参数值hash获取hash结果 选择器选择Invoker的依据: 方法的参数值hash以及参与hash的方法参数数

第四章：（6）原理之 Dubbo 服务调用流程

一、服务调用流程 　　1、服务引用完成之后，会返回一个代理对象。   　　2、通过 debug，会来到 InvokerInvocationHandler 的 invoker 方法 @Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { String methodName

第四章：（2）原理之 Dubbo 框架设计

Dubbo 框架设计 一、整体设计 　　　　 　　图例说明： 　图中左边淡蓝背景的为服务消费方使用的接口，右边淡绿色背景的为服务提供方使用的接口，位于中轴线上的为双方都用到的接口。 　图中从下至上分为十层，各层均为单向依赖，右边的黑色箭头代表层之间的依赖关系，每一层都可以剥离上

函数防抖、节流

函数防抖（debounce）：当频繁持续触发事件时，如果在设定时间间隔内重复触发事件，每次触发时间就重新开始计时，直至指定时间间隔内没有再触发事件，事件处理函数才会执行一次。函数节流（throttle）：当频繁持续触发事件时，保证每隔指定时间调用一次事件处理函数，指定间隔内只会调用一次。 debounce限

Dubbo服务消费者Consumer启动流程(五)

在看完上篇的服务提供者启动流程之后，再来看消费者的启动流程就简单很多了，其大体的设计流程是差不多的。服务消费者的启动主要调用ReferenceConfig#get(), get方法跟服务提供者的export方法类似，主要关注checkAndUpdateSubConfigs和init方法。   ReferenceConfig#checkAndUpdateSub

Dubbo的Random负载均衡

Random负载均衡是按照权重设置随机概率做负载均衡的。这种负载均衡算法并不能精确地平均请求，但是随着请求数量的增加，最终结果是大致平均的。计算步骤如下 1.计算总权重并判断每个Invoker的权重是否一样。遍历整个Invoker列表，求和总权重。遍历过程中，会对比每个Invoker的权重，判

Dubbo之Cluster负载均衡

目录Dubbo版本负载均衡AbstractLoadBalanceRandomLoadBalanceRoundRobinLoadBalanceLeastActiveLoadBalanceConsistentHashLoadBalance自定义负载均衡 Dubbo版本 Dubbo版本2.6.7 负载均衡 当服务提供方是集群时，为了避免大量请求一直集中在一个或者几个服务提供方机器上，需要做

Dubbo集群容错之Cluster

1. 前言 线上服务很少会单机部署，它不满足互联网三高架构的需求。服务一旦挂了，高可用就无从谈起，另外Dubbo单机默认最大200的并发处理也不满足所谓的高并发、高性能。所以，作为一款优秀的分布式服务框架，Dubbo是支持集群容错的。 ​ Dubbo整个集群容错层的实现在dubbo-cluster模

Dubbo系列笔记之服务引用过程，不服不行，华为笔试Java编程题

// 是否为泛化接口 if (!ProtocolUtils.isGeneric(generic)) { String revision = Version.getVersion(interfaceClass, version); if (revision != null && revision.length() > 0) { map.put(REVISION_KEY, revision); } // 获取接口的方法列表，加入 map String[] methods =

Dubbo服务调用源码分析

RPC调用：客户端将服务调用接口、方法名、方法类型参数和方法参数值进行序列化传输到服务端，服务端反序列读取信息进行代理调用。 总结： (1)客户端启动时会从注册中心拉取和订阅相应的服务列表，Cluster会把拉取的服务列表合成一个Invoker。 (2)Directory#list获取providers地址(已

第7章：Dubbo集群容错

第7章：Dubbo集群容错 Dubbo容错机制对上层透明（上层看不到具体的实现） 1.容错机制概述 1.1 Failover Cluster接口上有SPI注解@SPI(FailoverCluster.NAME)，即默认实现是Failover 使用for循环实现重试，for循环次数就是重试的次数。具体流程如下： 校验。如果for循环次数大于1，即有过1次

Dubbo解析之集群容错机制

在上一章节，我们曾提到这样一个问题： 当调用服务失败后，我们怎么处理当前的请求？抛出异常亦或是重试？ 为了解决这个问题，Dubbo 定义了集群接口 Cluster 以及 Cluster Invoker。集群 Cluster 用途是将多个服务提供者合并为一个 Cluster Invoker，并将这个 Invoker 暴露给服务消费者。这样

Dubbo漫谈之微服务治理

前面几篇文章结合rpc框架的基础需求，讲解了Dubbo中对于这些需求的抽象。Dubbo现在能够被如此多的线上应用所采用，跟最近几年微服务的广泛推广有很大的关系。微服务绝不仅仅是把服务拆小，改成远程调用这么简单，必须有配套的服务治理的功能，比如监控、熔断限流等。这篇文章就来分解下Dubb

Dubbo漫谈之走向集群

服务集群 一个系统从本地调用转成远程调用，原因有很多种。最主要的两个，一个是功能解耦，另外一个就是高可用。为了解决高可用问题，通常再服务部署的时候，都会部署多套，以防止单个服务压力过大或者网络分区等单点故障导致服务不可用，也就是我们常说的集群。  路由 当服务提供方部署成集群

Dubbo之从服务消费端说起

既然Dubbo是一个RPC框架，我们就从分解一个RPC框架开始，然后把Dubbo中的模块和代码对应到RPC的每个部分上。 RPC框架分解 本地调用 本地进程内调用就不用多讲了，我们每天写的代码大部分都是这个 EchoService service = new EchoServiceImpl(); service.sayHello("Dubbo");

深度分析Dubbo SPI源码，扩展Dubbo Validation (groups)

前言 架构是网关直接通过泛化调用Dubbo服务，不同于web Controller使用spring mvc模块来做到参数注解校验。不过不用担心Dubbo也考虑到了这一点，基于SPI机制提供了ValidationFilter 那我们就来看看他是如何实现的。 Dubbo源码实现 Dubbo SPI定义 你可能要问问了什么是Dubbo SPI，

JBoss中间件漏洞

目录 一、JBoss是什么？ 二、安装环境 1. Jdk 2. 下载JBoos4、6，并进行配置 三、 反序列漏洞 1. HttpInvoker 组件（CVE-2017-12149） 2. JMXInvokerServlet组件（CVE-2015-7501） 3. JBossMQ（CVE-2017-7504） 4. EJBInvokerServlet组件（CVE-2013-4810） 四、 War后门文件部署 1. admin-cosole（爆

中间件漏洞 -- JBoss

中间件漏洞记录--5         jBoss是一个基于J2EE的开发源代码的应用服务器。 JBoss代码遵循LGPL许可，可以在任何商业应用中免费使用。JBoss是一个管理EJB的容器和服务器，支持EJB1.1、EJB 2.0和EJB3的规范。但JBoss核心服务不包括支持servlet/JSP的WEB容器，一般与Tomcat或J

DUBBO源码分析五---服务引用

"2021SC@SDUSC" 1. 简介 上一篇文章详细分析了服务导出的过程，本篇文章我们趁热打铁，继续分析服务引用过程。在 Dubbo 中，我们可以通过两种方式引用远程服务。第一种是使用服务直连的方式引用服务，第二种方式是基于注册中心进行引用。服务直连的方式仅适合在调试或测试服务的场景下