流程模型缓存
模型缓存处理核心功能:建立
json
与java
流程对象模型ProcessModel
的映射关系,减少对json
模型解析的性能损耗。
模型解析接口
模型解析接口
ProcessModelCache
主要实现分为部署流程模型
实时流程模型
两种类型。
流程定义实体类
FlwProcess
部署流程模型,主要存储建模的模板模型
该模型可以随时调整。扩展流程实例实体类
FlwExtInstance
实时流程模型,存储正在执行实例的模型
支持动态调整增减
节点。
java
public interface ProcessModelCache {
/**
* 流程模型缓存KEY
*/
String modelCacheKey();
/**
* 流程模型内容
*/
String getModelContent();
/**
* JSON BPM 模型
*/
default ProcessModel model() {
String modelContent = this.getModelContent();
Assert.isEmpty(modelContent, "The process modelContent is Empty.");
// 流程引擎上下文调用模型解析器解析,该方法会自动调用缓存实现
return FlowLongContext.parseProcessModel(modelContent, this.modelCacheKey(), false);
}
}
- 修改数据库模型,即时生效需要调用缓存失效逻辑。
java
// 使缓存失效
FlowLongContext.invalidateProcessModel(flwExtInstance.modelCacheKey());
流程缓存接口
该接口为
flowlong
的全局缓存,默认FlowSimpleCache
实现类为ConcurrentHashMap
本地实现, 目前缓存配合流程模型解析器
注入FlowLongContext
流程引擎上下文。
java
public interface FlowCache {
/**
* 根据关键字缓存对象
*
* @param key 缓存关键字
* @param value 缓存对象
* @param duration 有效时长(单位秒)小于等于 0 不处理
*/
void put(String key, Object value, long duration);
/**
* 从缓存中获取对象
*
* @param key 缓存关键字
* @return 缓存对象
*/
<T> T get(String key);
/**
* 根据关键字删除缓存对象
*
* @param key 缓存关键字
*/
void remove(String key);
}
提示!
在分布式应用场景下,建议使用分布式缓存实现接管,例如 redis
实现等。