一、前言

前面dubbo整体架构分析里面我们讲解了服务提供者暴露一个服务的详细过程是，首先具体服务的实现类转换为了Invoker对象，然后Invoker在转换为Exporter,本文就来讲解第二步转换。 阅读全文

一、前言

前面dubbo整体架构分析里面我们讲解了服务提供者暴露一个服务的详细过程是，首先具体服务的实现类转换为了Invoker对象，然后Invoker在转换为Exporter,本文就来讲解第一步转换。

阅读全文

一、前言

在Spring AOP中可以使用多个切面对指定类的方法进行增强，在Dubbo中也提供了类似的功能，在dubbo中你可以指定多个Wrapper类对指定的扩展点的实现类的方法进行增强 阅读全文

一、前言

为了方便开发及测试，一般需要绕过注册中心，只测试指定ip的服务提供者，这时候服务消费方和服务提供方就是点对点直联方式。这时候服务消费方会忽略注册中心的提供者列表。另外直连方式以服务接口为单位，假如A 接口配置点对点，不影响 B 接口从注册中心获取列表。 阅读全文

一、前言

在Dubbo中接口类并不能唯一确定一个服务，在dubbo中接口+服务分组+版本号才能唯一确定一个服务，本文就来讲解下服务分组和版本号的使用。 阅读全文

一、前言

dubbo-monitor主要用来统计服务的调用次调和调用时间的监控中心，服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心，监控中心则使用数据绘制图表来显示。 阅读全文

一、前言

工欲善其事，必先利其器，前面通过几篇文章简单的介绍了如何使用Dubbo搭建一个简单的分布式系统，在接下来的的一段时间就来研究Dubbo原理设计，本文作为原理设计的开篇先整体介绍下dubbo的架构。 阅读全文

一、前言

开源的Dubbo的服务管理控制台是阿里巴巴内部裁剪版本，开源部分主要包含：路由规则，动态配置，服务降级，访问控制，权重调整，负载均衡，等管理功能。 阅读全文

一、前言

前面我们讲解基于Spring和基于dubbo api方式搭建一个简单的分布式系统时候服务消费端是引入了一个sdk的，这个SDK是个二方包，里面存放了服务提供端提供的所有接口类以及接口使用的入参和出参的pojo类，服务消费端则使用JDK代理对接口进行代理。

泛化接口调用方式主要用于服务消费端没有 API 接口类及模型类元（比如入参和出参的pojo类）的情况，参数及返回值中的所有POJO 均用 Map 表示。 阅读全文

一、前言

前面时间基于Spring的xml配置的方式搭建了一个简单的包含服务提供（Provider），服务注册中心（Registry），服务消费（Consumer）的分布式系统。本节我们不使用Spring配置方式，使用DUBBO提供的API来做。 阅读全文

一、前言

随着阿里巴巴开源的分布式RPC框架Dubbo成为Apache开源卵化器项目，Dubbo有火了一把。在接下来的一段时间本公众号将会时不时的发布一些dubbo使用与原理剖析的文章。

image.png

dubbo架构如上图，本文作为一个开始先讲讲使用dubbo搭建一个简单的含有服务提供（Provider），服务注册中心（Registry），服务消费（Consumer）的分布式系统。 阅读全文

一、前言

本文来讲解遇到的一个有意思的与定时器相关的生产消费模型，模型如下图：

• 生产者是一个定时器线程，使用ScheduledThreadPoolExecutor的scheduleAtFixedRate控制每间隔3s投递一个元素到队列1，2，3（使用offer方法）。比如第1s放入一个元素到队列1，2，3，这时候每个队列里面有一个元素。然后第4s在放入一个元素到队列1，2，3，如果没有消费线程的时候这时候每个队列里面有2个元素.
• 队列为有界阻塞队列（ArrayBlockingQueue），队列元素的大小设置为6个元素。
• 消费者是一个定时器线程，使用ScheduledThreadPoolExecutor的scheduleAtFixedRate控制每间隔1s轮询取出每个队列里面全部元素（使用poll方法）。比如第1s取出队列1里面的全部元素，第2s取出队列2里面的元素，第3s取出队列3里面的元素，第4s取出队列1里面的元素….
  并且如果发现当前队列为空则会结束当前s的任务，然后等下1s到了的时候从下一个队列开始取。
• 消费线程启动后，生产线程才启动，生产者和消费者线程优先级相同
• 消费线程和生产线程里面没有耗时操作，或者耗时都不超过1s。这个保证定时器任务不会被延迟执行。

问题：每个队列里面最多时候会有几个元素？

阅读全文