dubbo为consumer端的代理对象实现了EchoService接口。

使用示例:

<dubbo:reference id="hello" interface="com.zhang.HelloService" check="false" />
EchoService echoService = (EchoService) appCtx.getBean("hello");
Object str = echoService.$echo("zhang");

原理:

public interface EchoService {
Object $echo(Object message);
}
//AbstractProxyFactory
public <T> T getProxy(Invoker<T> invoker) throws RpcException {
Class<?>[] interfaces = null;
String config = invoker.getUrl().getParameter("interfaces");
if (config != null && config.length() > 0) {
String[] types = Constants.COMMA_SPLIT_PATTERN.split(config);
if (types != null && types.length > 0) {
interfaces = new Class<?>[types.length + 2];
interfaces[0] = invoker.getInterface();
interfaces[1] = EchoService.class;
for (int i = 0; i < types.length; i ++) {
interfaces[i + 1] = ReflectUtils.forName(types[i]);
}
}
}
if (interfaces == null) {
//加入了EchoService接口
interfaces = new Class<?>[] {invoker.getInterface(), EchoService.class};
}
//JavassistProxyFactory和JdkProxyFactory分别实现EchoService接口
return getProxy(invoker, interfaces);
}

provider在EchoFilter中处理$echo请求:

@Activate(group = Constants.PROVIDER, order = -110000)
public class EchoFilter implements Filter {
public Result invoke(Invoker<?> invoker, Invocation inv) throws RpcException {
if(inv.getMethodName().equals(Constants.$ECHO)
        && inv.getArguments() != null && inv.getArguments().length == 1)
return new RpcResult(inv.getArguments()[0]);
return invoker.invoke(inv);
}
}

最新文章

  1. 《Java编程思想》学习笔记(二)——类加载及执行顺序
  2. 关于WEB Service&amp;WCF&amp;WebApi实现身份验证之WebApi篇
  3. 浅谈CommandBehavior枚举的独特之处
  4. html5实战2
  5. javascript平时小例子⑥(简易计算器的制作)
  6. Android TextView结合SpannableString使用
  7. js学习--DOM操作详解大全二(window对象)
  8. -_-#【Better Code】字符串匹配
  9. Android 百度地图 SDK v3.0.0 (一)
  10. Draggable(拖动)组件
  11. iOS 视图调试器(Debug View Hierarchy) 之 初试牛刀
  12. 手机自动化测试:Appium源码之api(1)
  13. Thread in Java
  14. ●POJ 1509 Glass Beads
  15. bzoj 1899: [Zjoi2004]Lunch 午餐
  16. 11_Android中HttpClient的应用,读取网络xml及xml解析流,Handler的应用,LayoutInflater的使用,SmartImageView的使用
  17. noi.ac#309 Mas的童年(子集乱搞)
  18. ubuntu16.04 使用kinectv2跑Elasticfusion
  19. Redis:MySQL算老几?
  20. 20155334 《网络攻防》 Exp6 信息搜集与漏洞扫描

热门文章

  1. Lombok让pojo变得更优雅
  2. 深入JAVA注解之方法注解
  3. switch to hexo !
  4. inotify工具安装配置
  5. 20165211 2017-2018-2 《Java程序设计》第6周学习总结
  6. BZOJ 3529 数表(莫比乌斯+树状数组)
  7. rvm 安装ruby环境报错curl: (35) error:14094410:SSL routines:ssl3_read_bytes:sslv3 alert handshake failure
  8. The superclass &quot;javax.servlet.http.HttpServlet&quot; was not found on the Java Build Path 解决方法
  9. 怎样借助Python爬虫给宝宝起个好名字--python 学习
  10. React Native控件之Switch开关