一、Dubbo服务注册和发现的流程1、容器启动2、服务提供者连接注册中心将接口信息保存到注册中心中3、服务消费者从注册中心订阅所需要的服务并缓存本地4、服务提供方有变更时注册中心将提供一份新的列表给消费者并缓存在消费者端5、消费者根据接口地址调用服务提供者6、监听器定时监听接口的调用次数和调用时长二、dubbo支持哪些协议dubbodubbo默认推荐的协议单一长连接和NIO异步通讯适用于高并发小数据量的请求以及消费者远大于提供者tcp传输协议Hessian序列化rmi基于java标准的rmi协议实现传输参数和返回参数都需要实现Serializable接口使用java标准序列化方式采用阻塞式短连接tcp传输协议可传文件webservice基于webservice的远程调用协议多个短连接基于Http传输同步传输http基于http表单提交的远程调用协议使用spring的HttpInvoke实现多个短连接传输协议httphession集成Hession服务基于Http通讯采用Servlet暴露服务Dubbo内嵌Jetty作为服务器时的默认实现多个短连接同步Http传输Hessian序列化传入参数较大可传文件memcache:基于memcache实现的RPC协议redis基于redis实现的RPC协议三、Dubbo有哪些注册中心zookeeper基于zookeeper的watch机制实现数据变更官方推荐使用redis基于redis的订阅/发布形式实现数据变更multicastsimple四、Dubbo的注册中心挂掉消费者还能调用吗可以Dubbo启动时消费者会从注册中心拉取一份接口的信息缓存在本地每次调用时都会根据本地缓存的地址进行调用五、Dubbo提供了哪些负载均衡策略Random LoadBanance随机选取提供者策略当调用越频繁分布越平均RoundRobin LoadBanance随机轮训提供者策略平均分布但是存在请求积累问题LeastActive LoadBanance最少活跃调用策略活跃数是指调用前后计数差使慢机器调用最少比如同时有A和B两个服务两个服务内部都维护了一个计数器当A处理一个请求的时候计数器1此时还未处理完等处理完请求之后计数器-1若此时B服务响应较快很快就处理完请求了此时A的计数器为1B的计数器为0那么下一个请求过来的时候会发到B服务器上ConstantHash LoadBanance一致性hash策略使相同参数请求总是发送到统一提供者当有一台宕机了后可以基于虚拟节点分发至其他提供者上六、Dubbo的集群容错方法有哪些Failover Cluster失败自动切换当出现失败重试其他服务器通常用于读操作默认重试2次Failfast Cluster快速失败只发起一次调用当出现失败的时候立即报错通常用于非幂等性的写操作比如新增记录Failsafe Cluster失败安全当出现异常时直接忽略通常应用于写入日志操作Failback Cluster失败自动恢复当出现失败时后台记录请求定时重发。通常用于消息通知等操作Forking Cluster并行调用多个服务器只要有一个成功则返回适用于实时性很高的读操作但是会对服务器造成很大压力可以通过forks 2来设置最大并行数Broadcast Cluster广播调用所有提供者只要有一个失败则都失败通常应用于通知所有的提供者更新本地缓存等操作七、Dubbo提供了哪些序列化方式默认使用Hessian序列化还提供了fastjson、Dubbo以及java自带序列化八、Dubbo超时时间设置dubbo推荐在服务提供者端设置超时时间因为服务提供者更能清楚的知道自己服务的特性若是在消费者端设置了超时时间则以消费者端的设置为准因为消费者端设置更加灵活当超时之后dubbo默认会重试两次九、服务上线如何兼容旧版本通过版本号version来进行过渡不同版本号的服务注册到注册中心版本号不同的服务相互之间不引用十、当一个服务有多个不同的实现时如何操作通过对不同的实现通过group分组来区分不同的分组有不同的响应服务的提供者和消费者指向同一个分组即可十一、当开发过程中多个开发人员同时将接口注册到同一个注册中心时会发生什么如何解决可能会出现调用的服务在对方电脑上有以下两个方式解决1、每个开发人员的接口设置各自的分组项目之间调用互不影响2、可以通过设置点对点直连的方式在消费者端指定到本地的服务地址dubbo:reference idxxxService interfacecom.alibaba.xxx.XxxService urldubbo://localhost:20880 /十二、Dubbo服务之间的调用是阻塞的吗Dubbo默认是同步等待结果阻塞的支持异步调用Dubbo是基于NIO的非阻塞式实现并行调用调用过程如下1、工作线程调用findUser方法2、IO线程负责调用对象的服务端3、IO线程setFuture到RpcContent中4、工作线程读取Future的值若为空则调用wait方法等待6、服务端响应结果到调用者7、IO线程将返回结果set到future中并唤醒工作线程8、工作线程读取future并返回十三、Dubbo分布式事务分布式事务的实现主要有以下五种方案1、XA方案2、TCC方案3、本地消息表4、可靠消息最终一致性方案5、最大努力通知方案基于XA协议的两阶段提交XA分为两部分事务管理器和本地资源管理器本地资源管理器由各个数据库实现而事务管理器作为一个管理者管理着所有本地资源管理器的提交和回滚所有的参与者准备执行事务并锁住资源参与者ready时向事务管理器发送就绪的指令当所有的参与者都达到就绪时事务管理器向所有的参与者发送commit命令缺点效率低下准备节点的成本很大性能差提交前发生故障难以恢复TCC方案TCC方案分为Try和Confirm、Cancel一般在try里面锁住资源资源校验Confirm里面确认执行业务操作Cancel里面取消执行业务操作github上面有基于tcc的java实现tcc-transaction可靠消息最终一致性方案:基于RocketMQ实现分布式事务解决最终事务一致性方案为什么不采用kafka等消息中间件呢因为考虑到发送消息和处理业务没办法保证同时成功所以基于RocketMQ的预发消息和确认消息来实现以转账为例A转账给B所以A需要减100元B需要加100元1、先发送B100元的预发消息到RocketMQ中此时该条消息只存在commitLog中在consumeQueue中不可见也就无法被消费2、在执行扣款逻辑若扣款成功则发送确认消息到RocketMQ中3、若扣款失败则预发消息不会被确认也就无法被消费4、若扣款成功、发送确认消息失败则通过状态回查的方式来确定消息状态也就是RocketMQ会定时遍历commitlog中的消息来确认该消息最终是commit还是rollback如果发现本地业务为执行失败则rollback如果执行成功就commit5、如何进行状态回查可以在本地设计一个事务状态表记录transactional事务的状态若业务执行成功则为success为业务执行失败则为fail十四、Dubbo提供哪些可供配置的参数1、dubbo:service/ 服务提供者暴露服务配置定义服务的元信息。 2、dubbo:reference/ 服务消费者引用服务配置。 3、dubbo:protocol/ 服务提供者协议配置用于配置提供服务的协议信息协议由提供方指定消费方被动接受。如果需要支持多协议可以声明多个 dubbo:protocol 标签并在 dubbo:service 中通过 protocol 属性指定使用的协议。 4、dubbo:application/ 应用配置用于配置当前应用信息不管该应用是提供者还是消费者其中name属性是必填项当前应用名称用于计算当前注册中心应用之间的依赖关系注意消费者和提供者的应用名称不能一样。 5、dubbo:module/ 模块配置用于配置当前模块信息可选其中name属性是必填项表示模块名称用于当前注册中心计算模块间的依赖关系。 6、dubbo:registry/ 注册中心配置用于配置连接注册中心相关信息。 7、dubbo:monitor/ 监控中心配置用于配置连接监控中心相关信息可选。 8、dubbo:provider/ 提供方的缺省值当ProtocolConfig和ServiceConfig某属性没有配置时采用此缺省值可选。 9、dubbo:consumer/ 消费方缺省配置当ReferenceConfig某属性没有配置时采用此缺省值可选。 10、dubbo:method/ 方法配置用于ServiceConfig和ReferenceConfig指定方法级的配置信息。该标签作为dubbo:server或dubbo:reference的子标签可以设置一些参数比如loadbalance、retries、timeout 11、dubbo:argument/ 用于指定方法参数配置。十五、dubbo的SPI机制例子基于dubbo的spi机制扩展负载均衡策略。整个过程可以概括为三个核心步骤实现接口、配置 SPI 文件、引用使用。核心步骤详解编写自定义实现类首先你需要创建一个 Java 类来实现 Dubbo 的 LoadBalance 接口。通常我们会继承 AbstractLoadBalance 抽象类因为它帮我们处理了很多公共逻辑如权重计算我们只需要实现核心的 doSelect 方法。场景举例 假设我们需要一个策略总是优先选择 IP 地址最小的那个服务提供者常用于测试环境强制指定机器。packagecom.example.dubbo.extend;importorg.apache.dubbo.common.URL;importorg.apache.dubbo.rpc.Invocation;importorg.apache.dubbo.rpc.Invoker;importorg.apache.dubbo.rpc.RpcException;importorg.apache.dubbo.rpc.cluster.loadbalance.AbstractLoadBalance;importjava.util.List;// 1. 继承 AbstractLoadBalancepublicclassMinIpLoadBalanceextendsAbstractLoadBalance{OverrideprotectedTInvokerTdoSelect(ListInvokerTinvokers,URLurl,Invocationinvocation)throwsRpcException{// 2. 实现你的核心算法逻辑// 这里演示找出 IP 地址字符串排序最小的 Invokerreturninvokers.stream().min((i1,i2)-{Stringip1i1.getUrl().getHost();Stringip2i2.getUrl().getHost();returnip1.compareTo(ip2);}).orElse(invokers.get(0));// 如果为空返回第一个兜底}}创建 SPI 配置文件 (关键步骤)这是实现“热插拔”的关键。你需要告诉 Dubbo 框架“我有一个新的负载均衡算法它的名字叫 minip对应的类是 MinIpLoadBalance”。文件路径在项目的资源目录 src/main/resources 下创建文件夹 META-INF/dubbo/。文件名必须是接口的全限定名即 org.apache.dubbo.rpc.cluster.LoadBalance。文件内容采用 keyvalue 格式。key 是你将来在配置中使用的名字value 是类的全限定名。文件内容示例# 文件路径:src/main/resources/META-INF/dubbo/org.apache.dubbo.rpc.cluster.LoadBalanceminipcom.example.dubbo.extend.MinIpLoadBalance注意minip 这个名字是你自己定义的后面配置时就要用这个名字。3. 配置并使用自定义策略完成上述两步后你的自定义算法就已经被 Dubbo 识别了。接下来只需要在服务引用时指定使用它。方式一XML 配置在消费者的 dubbo:reference 标签中指定 loadbalance 属性dubbo:reference iddemoServiceinterfacecom.example.DemoServiceloadbalanceminip/方式二注解配置如果你使用的是 Spring Boot 或注解开发可以直接在 DubboReference 或 Reference 注解中指定DubboReference(loadbalanceminip)privateDemoServicedemoService;进阶更复杂的场景如机房优先除了简单的 IP 排序你可能需要根据业务元数据如机房信息来路由。Dubbo 的 URL 参数机制非常强大你可以在实现类中读取这些参数。场景 消费者优先调用同机房的提供者如果同机房不可用再降级调用其他机房。publicclassZoneAwareLoadBalanceextendsAbstractLoadBalance{OverrideprotectedTInvokerTdoSelect(ListInvokerTinvokers,URLurl,Invocationinvocation){// 1. 获取当前消费者所在的机房假设通过 URL 参数传入 zoneshanghaiStringconsumerZoneurl.getParameter(zone,default);// 2. 筛选出同机房的提供者ListInvokerTsameZoneInvokersinvokers.stream().filter(invoker-consumerZone.equals(invoker.getUrl().getParameter(zone))).collect(Collectors.toList());// 3. 如果同机房有机器就在同机房里随机选或轮询否则降级到所有机器里选if(!sameZoneInvokers.isEmpty()){returndoRandom(sameZoneInvokers);}returndoRandom(invokers);}// ... 省略 doRandom 具体实现}配置使用// 在引用服务时透传当前机房的 zone 参数DubboReference(loadbalancezoneAware,parametersParameter(keyzone,valueshanghai))privateUserServiceuserService;总结要在 Dubbo 下使用自定义负载均衡写代码实现 LoadBalance 接口。配文件在 META-INF/dubbo/org.apache.dubbo.rpc.cluster.LoadBalance 文件中注册别名。改配置在 Reference 或 XML 中设置 loadbalance“你的别名”。这种方式完全解耦你甚至可以打包成一个独立的 jar 包引入到项目中即可生效无需修改 Dubbo 框架本身的任何代码。