Dubbo解析及原理

逃离我推掉我的手 2023-10-07 13:09 19阅读 0赞

1.Dubbo是一种分布式服务框架（WebService不是分布式），dubbo除了可以提供服务之外，还可以实现软负载均衡。的还提供了两个功能,Monitor监控中心和调用中心，这两个是可选的，需要单独配置

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzYjgyMzM2OTY_size_16_color_FFFFFF_t_70][]

2.服务提供者先启动start，然后注册register服务，消费者订阅服务，如果没有订阅到自己想获得的服务，他不断的尝试订阅，新的服务注册到注册中心后，注册中心会将这些服务通过notify到消费者。

3.Monitor是一个监控，消费端和服务端通过异步的方式发送消息至Monitor，消费端和服务端会将信息存放在本地磁盘，平均1min会发送一次信息。Monitor在整个架构中是可选的，需单独配置，Monitor挂掉不会影响服务的使用。

4.Dubbo集群访问策略：随机、轮询、最小活跃调用数、一致性Hash（相同参数的请求总是发到同一个提供者）

5、Dubbo适合小数据量大并发的服务调用，以及服务消费端机器数远大于服务提供者机器的情况。

Dubbo基本原理如下：

（1）服务端一个线程调用远程接口，生成一个唯一ID（UUID）

（2）将方法调用信息（接口名称、方法名称、参数列表等）和处理结果的回调对象callback，全部封装在一起，组成一个object对象，向ConcurrentHashMap里面put(ID,object)

(3)将ID和打包的方法信息封装成一个coonRequest对象，使用IoSession.writer(connRequest)异步发送出去

（4）当前线程使用callback的get（）方法，试图获取远程返回的结果，在get（）内部，使用synchronized获取回调对象callback的锁，先检测是否已经获取到结果，如果没有，调用callback的wait（）方法，释放callback上的锁，让当前线程等待

（5）服务端接收到请求并处理后，将结果发送给客户端，客户端socket链接上，分析结果，通过ID从ConcurrentHashMap里get（ID），从而找到callback

（6）监听线程使用synchronized获取回调对象callback的锁，调用callback的notifyAll（），唤醒前面处于等待状态的线程继续执行

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzYjgyMzM2OTY_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200418181039507.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzYjgyMzM2OTY=,size_16,color_FFFFFF,t_70