dubbo、dubbox坑集合

1、加载顺序
http://blog.csdn.net/snowcity1231/article/details/51240091
出现空指针的原因是：spring mvc扫描的时候根本无法识别@Reference ，同一方面，dubbo的扫描也无法识别Spring @Controller
，所以两个扫描的顺序要排列好，

如果先扫了controller，这时候把控制器都实例化好了，再扫dubbo的服务，就会出现空指针。

将springMVC的配置与dubbo配置写在一个配置文件中，注意顺序

<mvc:annotation-driven />

<dubbo:application name="dubbo-consumer" owner="programmer" organization="dubbox" />

<dubbo:registry address="zookeeper://127.0.0.1:2181"/>

<dubbo:consumer timeout="30000" />

<dubbo:annotation package="com.dubbo.controller" />

<context:component-scan base-package="com.dubbo.controller" />

2、异步坑
http://blog.csdn.net/windrui/article/details/52150345

场景描述：客户端远程异步调用ServiceA，ServiceA在处理客户端请求的过程中

需要远程同步调用ServiceB，ServiceA从ServiceB的响应中取数据时，得到的是null，对就是这个坑。

使用DEBUG模式，分析Dubbo源码得到问题的起因。
分析过程如下：
客户端和服务端通信，配置使用netty进行网络传输，通过
NettyHandler进行具体的消息收发操作，所以从此入手进行源码分析。
client到ServiceA的远程方法异步调用，会在RpcContext(RpcContext是一个临时状态记录器，
当接收到RPC请求，或发起RPC请求时，RpcContext的状态都会变化。比如：A调B，B再调C，则B机器上，在B调C之前，
RpcContext记录的是A调B的信息，在B调C之后，RpcContext记录的是B调C的信息)的attachments(Map结构)属性中添加async=true的键值对，
同时也会在RpcInvocation的attachments(Map结构)中添加async=true的键值对。
经过一系列的Filter，程序运行到AbstractInvoker的invoke方法，注意该方法中的如下代码段，
Map<String, String> context = RpcContext.getContext().getAttachments();
if (context != null) {
invocation.addAttachmentsIfAbsent(context);
}
这里会把当前RpcContext中的attachments添加到调用ServiceB的RpcInvocation中，这时候async=true已经添加了，接着执行如下代码段，
if (getUrl().getMethodParameter(invocation.getMethodName(), Constants.ASYNC_KEY, false)){
invocation.setAttachment(Constants.ASYNC_KEY, Boolean.TRUE.toString());
}
上面代码判断调用ServiceB的URL中是否含有async=true，如果有将设置async=true到RpcInvocation的attachments中，这时候是不包含的。
继续跟踪代码，运行到DubboInvoker中，调用doInvoke方法，该方法中有如下的代码段，boolean isAsync = RpcUtils.isAsync(getUrl(), invocation)，
这个isAsync方法具体声明如下，
public static boolean isAsync(URL url, Invocation inv) {
boolean isAsync ;
//如果Java代码中设置优先.
if (Boolean.TRUE.toString().equals(inv.getAttachment(Constants.ASYNC_KEY))) {
isAsync = true;
} else {
isAsync = url.getMethodParameter(getMethodName(inv), Constants.ASYNC_KEY, false);
}
return isAsync;
}
上面方法首先判断RpcInvocation的attachments中async=true是否成立，如果成立则这是一次异步调用，否则判断请求URL中async=true是否成立，
如果成立则是一次异步调用，否则是一次同步调用，根据上面传递的参数，此时isAsync方法返回的是true，ServiceA同步调用ServiceB变成了异步调用，
继续看下面的异步调用，代码段如下，
else if (isAsync) {
ResponseFuture future = currentClient.request(inv, timeout) ;
RpcContext.getContext().setFuture(new FutureAdapter<Object>(future));
return new RpcResult();
}
这里直接返回了一个RpcResult对象，没有数据内容，所以到这里，这个案子也就破了，ServiceA想从响应中取目标数据得到的当然是null。

再延伸一下，如果ServiceB再同步调用ServiceC，这是可以正常同步调用的，因为ServiceA调用完ServiceB后，
ConsumerContextFilter的invoke方法会清除attachements，所以ServiceB可以正常同步调用ServiceC了。

对于上面的问题，解决办法有三个：
1.方法调用两次
ServiceA调用ServiceB的地方写两次一样的调用，这个方法原理就像ServiceB调用ServiceC一样，即清除attachements，这个方法最简单，
但是可能对不了解的人来说，这块业务代码写重复了，会不小心删除掉，而且从写代码的角度来说，这个很鸡肋，所以不推荐。
2.修改Dubbo源码
修改AbstractInvoker第137行，改成每次都对async进行实际赋值，
boolean isAsync = getUrl().getMethodParameter(invocation.getMethodName(), Constants.ASYNC_KEY, false);
invocation.setAttachment(Constants.ASYNC_KEY, String.valueOf(isAsync));
3.自定义Filter
实现com.alibaba.dubbo.rpc.Filter，在RpcContext中清除这个async，
@Activate(group = {Constants.PROVIDER})
public class AsyncFilter implements Filter {
@Override
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
RpcContext.getContext().getAttachments().remove(Constants.ASYNC_KEY);
return invoker.invoke(invocation);
}
}
同时在src/main/resources/META-INF/dubbo/下添加com.alibaba.dubbo.rpc.Filter文件，内容文件如下：

asyncFilter=com.abc.filter.AsyncFilter

3、添加rest服务

<dubbo:protocol name="${dubbo.protocal.name}" port="${dubbo.protocol.port}" payload="83886080" default="true"/>
<!--新增rest 协议--default=false>
<dubbo:protocol name="rest" server="tomcat" port="9090" default="false"/>

dubbo、dubbox坑集合相关推荐

【分布式事务】tcc-transaction分布式TCC型事务框架搭建与实战案例(基于Dubbo/Dubbox)...
一.背景有一定分布式开发经验的朋友都知道,产品/项目/系统最初为了能够快速迭代上线,往往不太注重产品/项目/系统的高可靠性.高性能与高扩展性,采用单体应用和单实例数据库的架构方式快速迭代开发:当产品 ...
dubbo/dubbox部署资料收集
dubbo/dubbox部署资料收集最近由于项目需要要部署bubbox,dubbo,在找资料过程中用的的一些网址如下,后来由于取消没有实际应用,以备今后再用 http://dubbo.io/Admi ...
html tabl自动生成序列号,Element-UI使用与爬坑集合
目录 Element-UI使用与爬坑集合一.Element-UI各UI控件属性使用加不加冒号(:)整理二.el-menu组件作为route-view时候,刷新页面后,默认active状态(defa ...
又踩到Dubbo的坑，但是这次我笑不出来
前言直入主题,线上应用发现,偶发性出现如下异常日志当然由于线上具体异常包含信息量过大,秉承让肥朝的粉丝没有难调试的代码的原则,我特意抽取了一个复现的demo放在了git,让你不在现场,一样享受到 ...
分布式服务框架 dubbo/dubbox 入门示例(转)
dubbo是一个分布式的服务架构,可直接用于生产环境作为SOA服务框架. 官网首页:http://dubbo.io/ ,官方用户指南 http://dubbo.io/User+Guide-zh.htm ...
dubbo+zookeeper坑坑坑
昨夜公司发版程序,有个dubbo服务打死都调不通,一直报错如下: Will not attempt to authenticate using SASL(unknow error) Connected ...
分布式服务框架 dubbo/dubbox 入门示例
dubbo是一个分布式的服务架构,可直接用于生产环境作为SOA服务框架. 官网首页:http://dubbo.io/ ,官方用户指南 http://dubbo.io/User+Guide-zh.htm ...
dubbo/dubbox(一)源码编译
以下内容在window7环境下编译并测试通过. 使用的当当网dubbox版本, 下载https://github.com/dangdangdotcom/dubbox 1.本机先安装github on ...
分布式服务框架Dubbo/Dubbox入门示例
本文为转载作者:菩提树下的杨过出处:http://yjmyzz.cnblogs.com dubbo是一个分布式的服务架构,可直接用于生产环境作为SOA服务框架. 官网首页:http://dubbo ...

dubbo、dubbox坑集合

dubbo、dubbox坑集合相关推荐

最新文章

热门文章