ApiServlet

首先从整体上看下ApiServlet,Outline视图如下,

一、注意@Inject依赖的是javax.inject.jar,它和spring的@Autowired的区别在于使用它时变量不用生成相应的set方法。

二、CloudStack所有的请求都会被ApiSerlet拦截处理,进入到doGet()或者doPost()方法,然后统一交由processRequest()处理。

三、processRequestInContext()方法:

1、更多的是日志记录和异常信息处理(auditTrailSb变量);

2、utf8Fixup(req,params)对请求参数进行统一的UTF-8解码;

3、对Session的处理(isNew)和命令权限的审核(verifyRequest(params,userId));

4、如果不是登录(log)和注销(logout)操作,则会转由ApiServer的handleRequest()方法处理。

四:***Response()方法生成响应。

ApiServer

一、ApiServer继承自ManageBase,实现了HttpRequestHandler和ApiServerService接口。

二、ApiServer重点是queueCommand(BaseCmd cmdObj,Map<String,String> params)方法,该方法决定命令被序列化还是被分派。

如何处理命令取决于cmd的超类,如果超类是:

BaseCmd:cmd会被调配到ApiDispatcher执行、序列化和返回。

BaseAsyncCreatedCmd:cmd参数会被处理然后调用其create()方法,然后和BaseAsyncCmd流程一样。

BaseAsyncCmd:cmd会被处理并当做异步任务(AsyncJob)提交,job相关的信息是序列化的,然后返回。

三、verifyRequest()方法里调用checkCommandAvailable(User user,Strnig commandName)检查命令对该用户是否可用,这里自动注入List<APIChecker>  _apiAccessCheckers,在spring-server-core-misc-context.xml里我们可以看到<property name=“apiAccessCheckers” value=”#{apiCheckersRegistry.registered}”/>。

四、继承自HttpRequestHandler的handle()方法只处理来自8096端口的OTW请求。

ApiDispatcher

一、Q:CloudStack前端传到后台的参数在后台是如何处理并使用的?
     A:1、参数最终是被封装到请求对应的Cmd对象中再供其他地方使用的。
        2、在ApiDispatcher类dispatch方法会调用processParameters(BaseCmd cmd,Map<String,String> params)方法,processParameters(BaseCmd cmd,Map<String,String> params)方法中通过List<Field> fields = ReflectUtil.getAllFieldsForClass(cmd.getClass(),BaseCmd.class)得到预先定义在Cmd中的参数字段。然后遍历fields,通过setFieldValue(field,cmd,paramObj,parameterAnnotation)利用Java的反射机制解析到对应的Cmd对象中。

通过修改Cmd中的参数字段,就可以操控在数据库里添加的字段。

二、处理完参数后cmd.execute()执行命令。

GenericDaoBase

一、cglib proxy的使用

protected Class<T> _entityBeanType;
...
protected Enhancer _enhancer;
protected Factory _factory;
...
protected final static CallbackFilter s_callbackFilter = new UpdateFilter();
...
Callback[] callbacks = new Callback[] { NoOp.INSTANCE, new UpdateBuilder(this) };_enhancer = new Enhancer();
_enhancer.setSuperclass(_entityBeanType);
_enhancer.setCallbackFilter(s_callbackFilter);
_enhancer.setCallbacks(callbacks);
_factory = (Factory)_enhancer.create();

这里UpdateFilter类实现cglib里的CallbackFilter接口

public class UpdateFilter implements CallbackFilter {@Overridepublic int accept(Method method) {String name = method.getName();return (name.startsWith("set") || name.startsWith("incr") || name.startsWith("decr")) ? 1 : 0;}
}

当method以set/incr/decr开始时,返回1,否则返回0。返回1时就使用cglib自带的空拦截器NoOp.INSTANCE,返回0即update操作时就会调用UpdateBuilder拦截器。

UpdateBuilder实现了MethodInterceptor接口的intercept方法:

public class UpdateBuilder implements MethodInterceptor {protected Map<String, Ternary<Attribute, Boolean, Object>> _changes;protected HashMap<Attribute, Object> _collectionChanges;protected GenericDaoBase<?, ?> _dao;protected UpdateBuilder(GenericDaoBase<?, ?> dao) {_dao = dao;_changes = new HashMap<String, Ternary<Attribute, Boolean, Object>>();}@Overridepublic Object intercept(Object object, Method method, Object[] args, MethodProxy methodProxy) throws Throwable {String name = method.getName();if (name.startsWith("set")) {String field = methodToField(name, 3);makeChange(field, args[0]);} else if (name.startsWith("incr")) {makeIncrChange(name, args);} else if (name.startsWith("decr")) {makeDecrChange(name, args);}return methodProxy.invokeSuper(object, args);}   ...}

关于cglib这部分的应用可参考这篇博文http://www.blogjava.net/stone2083/archive/2008/03/16/186615.html。

二:数据库操作JDBC的使用

主要看searchIncludingRemoved()方法里的关键代码:

public List<T> searchIncludingRemoved(SearchCriteria<T> sc, final Filter filter, final Boolean lock,final boolean cache, final boolean enable_query_cache) {String clause = sc != null ? sc.getWhereClause() : null;...final StringBuilder str = createPartialSelectSql(sc, clause != null, enable_query_cache);...addJoins(str, joins);...List<Object> groupByValues = addGroupBy(str, sc);addFilter(str, filter);final TransactionLegacy txn = TransactionLegacy.currentTxn();...final String sql = str.toString();PreparedStatement pstmt = null;final List<T> result = new ArrayList<T>();try {pstmt = txn.prepareAutoCloseStatement(sql);...final ResultSet rs = pstmt.executeQuery();while (rs.next()) {result.add(toEntityBean(rs, cache));}return result;...}

在这里我们可以看到最终执行的sql,以及它是如何拼接出来的。

转载于:https://www.cnblogs.com/charles-dxb/p/3673546.html

CloudStack核心类ApiServlet、ApiServer、ApiDispatcher、GenericDaoBase源码分析相关推荐

  1. 4hutool源码分析:DateUtil(时间工具类)-格式化时间(万字长文源码分析,学大佬如何写代码)

    技术活,该赏 点赞再看,养成习惯 看本篇文章前,建议先对java源码的日期和时间有一定的了解,如果不了解的话,可以先看这篇文章: 万字博文教你搞懂java源码的日期和时间相关用法 关联文章: huto ...

  2. 【Linux 内核】实时调度类 ② ( 实时调度实体 sched_rt_entity 源码分析 | run_list、timeout、watchdog_stamp、time_slice 字段 )

    文章目录 一.sched_rt_entity 源码分析 1.run_list 字段 2.timeout 字段 3.watchdog_stamp 字段 4.time_slice 字段 5.back 字段 ...

  3. 类ThreadLocal的使用与源码分析

    变量值的共享可以使用public static的形式,所有的线程都使用同一个变量.如果每个线程都有自己的共享变量,就可以使用ThreadLocal.比如Hibernat的session问题就是存在Th ...

  4. jQuery源码分析系列

    声明:本文为原创文章,如需转载,请注明来源并保留原文链接Aaron,谢谢! 版本截止到2013.8.24 jQuery官方发布最新的的2.0.3为准 附上每一章的源码注释分析 :https://git ...

  5. 【Zookeeper】源码分析之持久化(三)之FileTxnSnapLog

    一.前言 前面分析了FileSnap,接着继续分析FileTxnSnapLog源码,其封装了TxnLog和SnapShot,其在持久化过程中是一个帮助类. 二.FileTxnSnapLog源码分析 2 ...

  6. [转]jQuery源码分析系列

    文章转自:jQuery源码分析系列-Aaron 版本截止到2013.8.24 jQuery官方发布最新的的2.0.3为准 附上每一章的源码注释分析 :https://github.com/JsAaro ...

  7. spring--aop_1_源码分析之JdkDynamicAopProxy实现

    aop 实现有两种方式 1. ProxyFactoryBean方式: 这种方式是通过配置实现 2. ProxyFactory方式:这种方式是通过编程实现 这里说 ProxyFactoryBean ,先 ...

  8. caffe源码分析-layer

    本文主要分析caffe layer层,主要内容如下: 从整体上说明下caffe的layer层的类别,以及作用 通过proto定义与类Layer简要说明下Layer的核心成员变量; Layer类的核心成 ...

  9. Netty学习十七:源码分析之HashWheelTimer

    一.常见定时任务实现 定时器的使用场景包括:成月统计报表.财务对账.会员积分结算.邮件推送等,它一般有三种表现形式:按固定周期定时执行.延迟一定时间后执行.指定某个时刻执行. 定时器的本质是设计一种数 ...

  10. java集合(6):TreeMap源码分析(jdk1.8)

    前言 TreeMap的基本概念: TreeMap集合是基于红黑树(Red-Black tree)的 NavigableMap实现.该集合最重要的特点就是可排序,该映射根据其键的自然顺序进行排序,或者根 ...

最新文章

  1. 函数重载(overload)
  2. 【Linux环境】阿里云CPU使用率 100% ECS 同时连接数峰值 25k+ 问题排查无果(附阿里云重新初始化云盘详细步骤)
  3. solarwinds ipam功能说明手册
  4. sql oltp_内存中的OLTP系列– SQL Server 2014上的数据迁移指南过程
  5. 一文看懂深度学习新王者「AutoML」:是什么、怎么用、未来如何发展?
  6. 超级PK:Sybase与Oracle的十二场性能比拼
  7. 《剑指offer》面试题——把数组排成最小的数
  8. Hibernate HQL基础
  9. Delphi7·ProgressBar控件
  10. 【软件工具】--- 软件安装管家目录
  11. Stellarium0.9.0新功能
  12. 遥感学习笔记(八)——遥感影像
  13. C盘Temp文件夹的内容可以删掉
  14. 5种赚钱方式,设计师加薪不用靠老板!
  15. 历史 微信开发者工具_不用微信开发者工具也能调试微信页面
  16. 基础的网络服务器开发
  17. 微信图片防盗链笔记(转:破解微信图片防盗链)
  18. 扬州大学c语言上级作业链表,一道关于结构体和单向链表的C语言编程题求助各位大佬!!!...
  19. 托管注入深入研究 (《黑客防线》2008.12)
  20. mysql sdo geometry_Oracle 关于WKT构造SDO_GEOMETRY的问题。详解

热门文章

  1. 保持 SSH 连接,防止长时间未动作断线
  2. 编译安装libmemcached库报错
  3. 解决eclipse无法启动:Failed to create the Java Virtual Machine
  4. Vue.js 安装及其环境搭建,webpack-simple支持热更新
  5. Python的包(Packages)
  6. [转]Chrome 错误代码:ERR_UNSAFE_PORT
  7. js获取浏览器和设备相关width(屏幕的宽度)
  8. Java多线程——线程安全问题
  9. iOS programming Code Snippet Library
  10. AlarmManager.setRepeating将不再准确