dubbo超时时间设置 dubbo超时时间设置优先级

在dubbo框架内所有的日志输出都是通过 LoggerFactory这个静态工厂类来获得Logger的对象实体，并且抽离了一个LoggerAdapter用于对接第三方日志框架，所以就有了JDKLoggerAdapter,Log4jLoggerAdapter,SLF4JLoggerAdapter等一些实现子类，分别对接了不同Log第三方实现。既然dubbo能够支持这么多log实现，那么这些实现在dubbo中优先级是在呢么样的呢？这里的优先级是只未配置指定的logger提供方的情况下，由dubbo框架自己选择。优先级如下：

上面说的有和没有是指你的项目classpath下面有没有对应的jar包，如果有则表示支持对应的日志实现。下面粘贴出Dubbo选择日志提供方的代码：

[ja] view plaincopy

static GenericImplFilter中有很多其他逻辑，比如泛化调用使用的序列化协议，正常接口走泛化调用的模式，我们只需要设置attachment的那部分。{

String logger = System.getProperty("dubbo.application.logger");

if ("slf4j".equals(logger)) {

setLoggerAdapter(new Slf4jLoggerAdapter());

} else if ("jcl".equals(logger)) {

setLoggerAdapter(new JclLoggerAdapter());

} else if ("log4j".equals(logger)) {

setLoggerAdapter(new Log4jLoggerAdapter());

} else if ("jdk".equals(logger)) {

} else {

try {

setLoggerAdapter(new Log4jLoggerAdapter());

} catch (Throwable e1) {

try {

setLoggerAdapter(new Slf4jLoggerAdapter());

} catch (Throwable e2) {

try {

setLoggerAdapter(new JclLoggerAdapter());

} catch (Throwable e3) {

}}

}}

[html] view plaincopy

value="[%d{MMdd HH:mm:ss SSS} %-5p] [%t] %c{3} - %m%n" />

Dubbo的分布式事务怎么解决

目前比较多的解决方案有几个：

一、结合MQ消息中间件实现的可靠消息最终一致性

三、努力通知型方案

种方案：可靠消息最终一致性，需要业务系统结合MQ消息中间件实现，在实现过程中需要保证消息的成功发送及成功消费。即需要通过业务系统控制MQ的消息状态

第二种方案：TCC补偿性，分为三个阶段TRYING-CONFIRMING-CANCELING。每个阶段做不同的处理。

TRYING阶段主要是对业务系统进行检测及资源预留

CONFIRMING阶段是做业务提交，通过TRYING阶段执行成功后，再执行该阶段。默认如果TRYING阶段执行成功，CONFIRMING就一定能成功。

CANCELING阶段是回对业务做回滚，在TRYING阶段中，如果存在分支事务TRYING失败，则需要调用CANCELING将已预留的资源进行释放。

第三种方案：努力通知xing型，这种方案主要用在与第三方系统通讯时，比如：调用微信或支付宝支付后的支付结果通知。这种方案也是结合MQ进行实现，例如：通过MQ发送请求，设置通知次数。达到通知次数后即不再通知。

微服务初体验（二）：使用Nacos作为配置中心并集成Dubbo

接着打开Nacos的服务的web页面，打开配置管理->配置列表，点击右侧新增按钮，进行新增。

Data ID： bootstrap.yml配置文件中spring:application:name对应的名称 ；

Group：指定分组（便于不同环境下的项目配置管理，因为笔者这里属于测试，所以填写的是和上文中的配置文件中group对应的test一致）；

描述：针对于该配置的描述二、你的项目当前使用的是非Log4j来提供日志输出 这种情况，默认是看不到dubbo的日志输出的，除非出现异常，被你当前系统的日志框架拦截住了。我这里就拿当前使用最多的日志框架logback来做示例。我们知道logback天生和slf4j进行了集成，所以要在项目里面使用logback，调用slf4j暴露的接口就可以。所以要把dubbo的日志输出切换到logback，也就变成了切换到slf4j了。一下列举出几种情况来切换。；

配置格式：配置文件的格式，要和Data ID中的后缀格式一致（这里笔者用的是yml，那么下面就选择yaml，注意该位置也可以选择properties，但是必须和上面bootstrap.yml文件中的file-extension的值相匹配）；

配置内容：具体的配置内容（这里笔者将项目中的application.yml中的配置全部拷贝至其中）；

测试启动consumer服务，在application.yml中为空的时候，项目启动端口还是如Nacos配置中的9011，说明项目依赖Nacos的配置中心成功，其他服务如法炮制即可：

新增一个测试Controller，然后加上@RefreshScope注解，表明该Controller中的配置数据为自动刷新 。

编辑Nacos中的配置文件consumer新增相关参数type: test，访问Controller，返回test。效果如下图：

将Nacos中consumer.yml文件的type: test修改为type: prod，在不重启项目的情况下重新访问对应的controller，效果如下图：

因为Dubbo是属于各个服务之间都要公用的依赖，所以将其引入cloud-common当中，详细的版本可以去 mvnreitory 搜索合适自己项目的

引入依赖后需要编写消费者服务中的配置文件，将Dubbo服务注册至Nacos，新增如下内容，其中subscribed-servs指的是生产者服务，prot：-1指的是端口随机，registry:address:指的是Dubbo对应的注册中心那这里就应该设置为Nacos

接下来新增接口服务，项目类型为Men项目，在项目中新增一个接口。并在cloud-provider（生产者）和cloud-consumer（消费者）pom.xml文件中都引入该模块

在生产者实际服务中实现该接口对应的方法

在服务消费者的Controller中引入该Serv，并在该Serv上加入@Reference注解，注意在引入jar包的时候选择带有Dubbo的，不要使用Jdk原生的

dubbo version: 2.6.0, current host: 192.168.245.1

在Dubbo的配置文件中，可以通过 dubbo.protocol.host 属性来设置当前主机的IP地址。可以在 dubbo.properties 或者 dubbo.xml 中进行配置。具体作步骤如下：

在配置文件中加入如下配置：

dubbo.protocol.host=your_ip_address

将 your_ip_address 替换为当前主机的IP地址。

保存配置文件并重新启动Dubbo服务。

这样就可以将Dubbo服务绑定到指定的IP地址上，供客户端调用。

dubbo泛化调用使用及原理解析

通常我们想调用别人的dubbo服务时，我们需要在项目中引入对应的jar包。而泛化调用的作用是，我们无需依赖相关jar包，也能调用到该服务。

这个特性一般使用在类项目中，在业务开发中基本不会使用。

设我现在要调用下面的接口服务

在xml文件做以下配置

然后注入使用

在两种调用方式中，我们都需要使用被调用接口的字符串参数生成GenericServ，通过GenericServ的$invoke间接调用目标接口的接口。

可以看到泛化调用的一个复杂性在于$invoke的第三个参数的组装，下面介绍几种复杂入参的调用方式

首先丰富提供者接口

与入参相似，虽然$invoke的返回定义为Object，实际上针对不同类型有不同的返回。

泛化调用和直接调用在消费者者端，在 使用上的区别 是，我们调用服务时使用的接口为GenericServ，方法为$invoker。在 底层的区别 是，消费者端发出的rpc报文发生了变化。

设置generic=true后，RefereceConfig的inteceClass会被强制设置为GenericServ

这也使得我们的

生成的是GenericServ的只是我们使用方式上的变化，更为核心的是，底层发送的rpc报文发生了什么变化。

那么我们通过直接调用与泛化调用ByeServ的bye方法在报文上有啥区别呢？

我一开始以为报文中的path是GenerServ，其实并没有，path就是我们调用的目标方法。

path来源？？？todo

而报文中的方法名，方法参数类型以及具体参数，还是按照GenerServ的$invoke方法入参传递的。

这么个二合一的报文，发送到提供者那边，它估计也会很懵逼，我应该怎么执行？

所以针对泛化调用报文还会把generic=true放在attchment中传递过去

具体逻辑在GenericImplFilter中。

知道消费者端报文发生了什么变化，那么接下来就去看提供者端如何处理这个改造后的报文。

总结一下ReferenceConfig中inteceClass和inteceName的区别？(这道面试题好像不错)

inteceClass用于指定生成的接口

inteceName用于指定发送rpc报文中的path(告诉服务端我要调用那个服务)

消费者泛化调用的rpc报文传递到提供者还不能直接使用，虽然path是对的，但是实际的方法名，参数类型，参数要从rpc报文的参数中提取出来。

在提供者这边，针对泛化调用的逻辑全部封装到了GenericFilter，解耦的非常好。

注意第4个条件，一开始很疑惑，后来发现rpc报文中的path是目标接口的，这边invoker.getIntece()返回的肯定就是实际接口了

这边有个疑问，为什么这边还要再次反序列化一次，netty不是有decoder么？？

嗯，你别忘了，针对一个POJO你传过来是一个Map，从Map转换为POJO需要这边进一步处理。

这边需要注意一下！！针对接口的泛化调用，抛出的异常都会经过GenericException包装一下。

从功能上来看，泛化调用提供了在没有接口依赖情况下进行的解决方案，丰富框架的使用场景。

从设计上来看，泛化调用的功能还是通过扩展的方式实现的，侵入性不强，值得学习借鉴。

dubbo 中使用 ThreadLocal 隐患

在 Dubbo 中使用 ThreadLocal ，如果采用默认的设置，每次 Dubbo 调用结束，Dubbo 处理响应线程并不会被销毁， 而是归还到线程池中。而从 ThreadLocal 源码可以看出，每次我们设置的值其实会存在位于 Thread 中 ThreadLocalMap 变量中。

这就导致，下次如果 Dubbo 处理响应恰好继续使用到这个线程，该线程就能调用到上次响应中设置在 ThreadLocal 设置的值。这就引起内存泄露，可能还会导致业务上异常。其实并不止在 Dubbo 中，该案例还会发生在 web项目中，只要相关使用线程池的，都有可能发生。

dubbo 默认采用单一长连接加线程池方式处理调用。

默认采取 Dispatcher=all 的分发策略，所有消息都派发到线程池，包括请求，响应，连接，断开，心跳等。

线程池在缺省配置为固定大小线程池，启动时建立线程，不关闭，一直持有。

使用 Threadlocal，我们需要注意几点：

dubbo.protocol.threads = 5000

调整线程池类型配置是

调整处理编写消费者服务中测试Dubbo调用的接口，进行测试，测试结果如下图：方式配置是

dubbo.protocol.dispatcher = message

或者

Dubbo与Spring的融合机制

我们都知道Dubbo可以与Spring进行融合，那是怎么进行融合的呢？

我先介绍一下文档中是如何实现与Spring融合的，然后再从底层分析一下。

Serv注解暴露服务

增加应用配置信息

Reference注解引用服务

增加应用配置信息

调用服务

上面是整体融合Spring的案例，接下来分析 Serv 注解和 Reference 注解是怎么实现的。

当用户使用注解 @DubboComponentScan 时，会激活 DubboComponentScanRegister ，同时生成 ServAnnotationBeanPostProcessor 和 ReferenceAnnotationBeanPostProcessor , ServAnnotationBeanPostProcessor 处理器实现了 BeanDefinitionRegistryPostProcessor 接口，Spring容器会在所有Bean注册之后回调 tProcessBeanDefinitionRegistry 方法。

在这个方法里先提取用户配置的扫描包名称，然后委托Spring对所有符合包名的class文件做字节码分析，然后扫描Dubbo的注解@Serv作为过滤条件，将扫描的服务创建 BeanDefinitionHolder ，用于生成 ServBean 定义，注册 ServBean 的定义并做数据绑定和解析。

这时我们注册了 ServBean 的定义，但是还没有实例化。

ServcBean 的结构如下：

只包含 afterPropertiesSet() 方法，继承该接口的类，在初始化Bean的时候会执行该方法。在构造方法之后调用。

ApplicationContextAware

Spring容器会检测容器中的所有Bean，如果发现某个Bean实现了 ApplicationContextAware 接口，Spring容器会在创建该Bean之后，自动调用该Bean的 setApplicationContextAware() 方法，调用该方法时，会将容器本身作为参数传给该方法。

ApplicationListener

当Spring容器初始化之后，会发布一个ContextRefreshedEvent，实现ApplicationListener接口的类，会调用 onApplicationEvent() 方法。

重要的接口主要是这几个，那么执行的先后顺序是怎样的呢？

如果某个类实现了ApplicationContextAware接口，会在类初始化完成后调用setApplicationContext（）方法进行作

首先会执行 ApplicationContextAware 中的 setApplicationContextAware() 方法。

这里主要是将Spring的上下文引用保存到 SpringExtensionFactory 中，里面有个set，保存所有的Spring上下文。这里实现了Dubbo与Spring容器的相连，在SPI机制中利用 ExtensionLoader.getExtension 生成扩展类时，会有一个依赖注入的过程，即调用 injectExtension() 方法，它会通过反射获取类的所有方法，然后遍历以set开头的方法，得到set方法的参数类型，再通过ExtensionFactory寻找参数类型相同的扩展类实例。

如果某个类实现了InitializingBean接口，会在类初始化完成后，并在setApplicationContext（）方法执行完毕后，调用afterPropertiesSet（）方法进行作

然后会调用 InitializingBean 的 afterPropertiesSet() 方法。

会调用 ApplicationListene 中的 onApplicationEvent 方法。

此时 ServBean 开始暴露。 具体的暴露流程之前已经介绍容量。

在Dubbo中处理 ReferenceBean 是通过 ReferenceAnnotionBeanPostProcessor 处理的，该类继承了 InstantiationAwareBeanPostProcessor ，用来解析@Reference注解并完成依赖注入。

InstatiationAwareBeanPostProcessor

tProcessBeforeInstantiation 方法： 在实例化目标对象执行之前，可以自定义实例化逻辑，如返回一个对象。

tProcessAfterInitialization 方法：Bean实例化完成后执行的后处理作，所有初始化逻辑、装配逻辑之前执行。

tProcessPropertyValues 方法： 完成其他定制的一些依赖注入和依赖检查等，可以增加属性和属性值修改。

新版本出现了改动，采用 AnnotationInjectedBeanPostProcessor 来处理。

AnnotationInjectedBeanPostProcessor 是 ReferenceAnnotationBeanPostProcessor 的父类，它实现InstantiationAwareBeanPostProcessorAdapter的tProcessPropertyValues方法,这个是实例化的后置处理,这个方式是在注入属性时触发,就是要在注入@Reference的接口时候,要将接口封装成的实例注入到Spring容器中.

主要分为两步：

1） 获取类中标注的@Reference注解的字段和方法。

2）反射设置字段或方法对应的引用

最重要的是第二步，通过 inject 方法进行反射绑定。

里面最主要的就是对生成的ReferenceBean设置一个对象。

服务引用的触发时机有两个：

一种是ReferenceBean初始化的时候；另一种是ReferenceBean对应的服务被注入到其他类中时引用。