Activiti源码 ProcessEngineConfiguration

by yan 20220223

ProcessEngineConfiguration 类图

public void init() {initConfigurators();configuratorsBeforeInit();initHistoryLevel();initExpressionManager();if (usingRelationalDatabase) {initDataSource();}initAgendaFactory();initHelpers();initVariableTypes();initBeans();initScriptingEngines();initClock();initBusinessCalendarManager();initCommandContextFactory();initTransactionContextFactory();initCommandExecutors();initServices();initIdGenerator();initBehaviorFactory();initListenerFactory();initBpmnParser();initProcessDefinitionCache();initProcessDefinitionInfoCache();initKnowledgeBaseCache();initJobHandlers();initJobManager();initAsyncExecutor();initTransactionFactory();if (usingRelationalDatabase) {initSqlSessionFactory();}initSessionFactories();initDataManagers();initEntityManagers();initHistoryManager();initJpa();initDeployers();initDelegateInterceptor();initEventHandlers();initFailedJobCommandFactory();initEventDispatcher();initProcessValidator();initDatabaseEventLogging();configuratorsAfterInit();}// command executors// public void initCommandExecutors() {initDefaultCommandConfig();initSchemaCommandConfig();initCommandInvoker();initCommandInterceptors();initCommandExecutor();}public void initDefaultCommandConfig() {if (defaultCommandConfig == null) {defaultCommandConfig = new CommandConfig();}}public void initSchemaCommandConfig() {if (schemaCommandConfig == null) {schemaCommandConfig = new CommandConfig().transactionNotSupported();}}public void initCommandInvoker() {if (commandInvoker == null) {if (enableVerboseExecutionTreeLogging) {commandInvoker = new DebugCommandInvoker();} else {commandInvoker = new CommandInvoker();}}}public void initCommandInterceptors() {if (commandInterceptors == null) {commandInterceptors = new ArrayList<CommandInterceptor>();if (customPreCommandInterceptors != null) {commandInterceptors.addAll(customPreCommandInterceptors);}commandInterceptors.addAll(getDefaultCommandInterceptors());if (customPostCommandInterceptors != null) {commandInterceptors.addAll(customPostCommandInterceptors);}commandInterceptors.add(commandInvoker);}}public Collection<? extends CommandInterceptor> getDefaultCommandInterceptors() {List<CommandInterceptor> interceptors = new ArrayList<CommandInterceptor>();interceptors.add(new LogInterceptor());CommandInterceptor transactionInterceptor = createTransactionInterceptor();if (transactionInterceptor != null) {interceptors.add(transactionInterceptor);}if (commandContextFactory != null) {interceptors.add(new CommandContextInterceptor(commandContextFactory, this));}if (transactionContextFactory != null) {interceptors.add(new TransactionContextInterceptor(transactionContextFactory));}return interceptors;}public void initCommandExecutor() {if (commandExecutor == null) {CommandInterceptor first = initInterceptorChain(commandInterceptors);commandExecutor = new CommandExecutorImpl(getDefaultCommandConfig(), first);}}public CommandInterceptor initInterceptorChain(List<CommandInterceptor> chain) {if (chain == null || chain.isEmpty()) {throw new ActivitiException("invalid command interceptor chain configuration: " + chain);}for (int i = 0; i < chain.size() - 1; i++) {chain.get(i).setNext(chain.get(i + 1));}return chain.get(0);}public abstract CommandInterceptor createTransactionInterceptor();// DataSource// ///public void initDataSource() {if (dataSource == null) {if (dataSourceJndiName != null) {try {dataSource = (DataSource) new InitialContext().lookup(dataSourceJndiName);} catch (Exception e) {throw new ActivitiException("couldn't lookup datasource from " + dataSourceJndiName + ": " + e.getMessage(), e);}} else if (jdbcUrl != null) {if ((jdbcDriver == null) || (jdbcUsername == null)) {throw new ActivitiException("DataSource or JDBC properties have to be specified in a process engine configuration");}log.debug("initializing datasource to db: {}", jdbcUrl);PooledDataSource pooledDataSource = new PooledDataSource(ReflectUtil.getClassLoader(), jdbcDriver, jdbcUrl, jdbcUsername, jdbcPassword);if (jdbcMaxActiveConnections > 0) {pooledDataSource.setPoolMaximumActiveConnections(jdbcMaxActiveConnections);}if (jdbcMaxIdleConnections > 0) {pooledDataSource.setPoolMaximumIdleConnections(jdbcMaxIdleConnections);}if (jdbcMaxCheckoutTime > 0) {pooledDataSource.setPoolMaximumCheckoutTime(jdbcMaxCheckoutTime);}if (jdbcMaxWaitTime > 0) {pooledDataSource.setPoolTimeToWait(jdbcMaxWaitTime);}if (jdbcPingEnabled) {pooledDataSource.setPoolPingEnabled(true);if (jdbcPingQuery != null) {pooledDataSource.setPoolPingQuery(jdbcPingQuery);}pooledDataSource.setPoolPingConnectionsNotUsedFor(jdbcPingConnectionNotUsedFor);}if (jdbcDefaultTransactionIsolationLevel > 0) {pooledDataSource.setDefaultTransactionIsolationLevel(jdbcDefaultTransactionIsolationLevel);}dataSource = pooledDataSource;}if (dataSource instanceof PooledDataSource) {// ACT-233: connection pool of Ibatis is not properly// initialized if this is not called!((PooledDataSource) dataSource).forceCloseAll();}}if (databaseType == null) {initDatabaseType();}}// myBatis SqlSessionFactory// public void initTransactionFactory() {if (transactionFactory == null) {if (transactionsExternallyManaged) {transactionFactory = new ManagedTransactionFactory();} else {transactionFactory = new JdbcTransactionFactory();}}}public void initSqlSessionFactory() {if (sqlSessionFactory == null) {InputStream inputStream = null;try {inputStream = getMyBatisXmlConfigurationStream();Environment environment = new Environment("default", transactionFactory, dataSource);Reader reader = new InputStreamReader(inputStream);Properties properties = new Properties();properties.put("prefix", databaseTablePrefix);String wildcardEscapeClause = "";if ((databaseWildcardEscapeCharacter != null) && (databaseWildcardEscapeCharacter.length() != 0)) {wildcardEscapeClause = " escape '" + databaseWildcardEscapeCharacter + "'";}properties.put("wildcardEscapeClause", wildcardEscapeClause);//set default propertiesproperties.put("limitBefore" , "");properties.put("limitAfter" , "");properties.put("limitBetween" , "");properties.put("limitOuterJoinBetween" , "");properties.put("limitBeforeNativeQuery" , "");properties.put("orderBy" , "order by ${orderByColumns}");properties.put("blobType" , "BLOB");properties.put("boolValue" , "TRUE");if (databaseType != null) {properties.load(getResourceAsStream("org/activiti/db/properties/"+databaseType+".properties"));}Configuration configuration = initMybatisConfiguration(environment, reader, properties);sqlSessionFactory = new DefaultSqlSessionFactory(configuration);} catch (Exception e) {throw new ActivitiException("Error while building ibatis SqlSessionFactory: " + e.getMessage(), e);} finally {IoUtil.closeSilently(inputStream);}}}

数据源相关

Mybatis SqlSessionFactoryTransactionFactory、 datasource 构建过程:
transactionFactory+dataSource -》Environment+properties -》Configuration-》SqlSessionFactory

Activiti DbSqlSession、DbSqlSessionFactory：
SqlSessionFactory -》DbSqlSessionFactory-》DbSqlSession-》Session

initSqlSessionFactory
以下为Activiti 构造 initSqlSessionFactory时，完成Mybatis 的 DefaultSqlSessionFactory的过程。

Activiti源码 ProcessEngineConfiguration相关推荐

activiti源码编译
分享牛原创(尊重原创转载对的时候第一行请注明,转载出处来自分享牛http://blog.csdn.net/qq_30739519) activiti源码编译,近期有人问activiti 源码编译的一 ...
activiti源码解析重磅来袭
activiti源码解析视频课程大概80课,会一直更新...,目前录制完毕的视频如下: 第2课:Activiti源码获取以及编译第3课:流程引擎配置类的作用,配置方式.开关属性技巧.手动构建.Act ...
Activiti源码分析（框架、核心类。。。）
Activiti源码分析(框架.核心类...) 目录概述 activiti源码分析(一)设计模式总结: 相关工具如下: 分析: 小结: 参考资料和推荐阅读 LD is tigger foreve ...
Activiti源码之建造者模式 Builder
建造者模式介绍建造者模式(Builder Pattern)使用多个简单的对象一步一步构建成一个复杂的对象.这种类型的设计模式属于创建型模式,它提供了一种创建对象的最佳方式. 一个 Builder 类 ...
Activiti源码之 DataManager EntityManager
by yan 20211223 阅读了Activiti 相关源码,记录下对DataManager & EntityManager的理解. DataManager 是一层相对底层的抽象,主要负责 ...
Activiti源码解读之TaskService
activiti-5.17.0源码解读之TaskService 源码路径:activiti-5.17.0\modules\activiti-engine\src\main\java\org\activ ...
activiti源码解析系列8 - 任务完成命令类
我们在完成任务的时候都执行了哪些操作呢? 主要涉及删除表(默认非级联): ACT_RU_TASK ACT_RU_IDENTITYLINK ACT_RU_VARIABLE 主要看一个CompleteTa ...
activiti源码学习之命令模式
什么是命令模式? 大都很熟悉的设计模式,此问题不在本文介绍范围内. activiti中的命令模式 activiti使用命令模式作为基础开发模型.把每个操作都封装为一个命令,降低代码的耦合度,避免臃肿的 ...
Activiti源码之Command与 CommandInterceptor
by yan 20220228 Activiti 命令拦截器执行过程 Activiti每发执行一个Command时都会经过一个责任链模式的命令拦截器(采用命令模式实现的拦截器),执行一系列的Comm ...

Activiti源码 ProcessEngineConfiguration

数据源相关

Activiti源码 ProcessEngineConfiguration相关推荐

最新文章

热门文章