A-A+

Flowable6 – 自定义缓存(2)

2020年12月13日技术, 默认暂无评论阅读 2,732 次

接上一篇的自定义缓存，这次具体说说如何自定义缓存，以及使用了Redis后，我是如何能够让它正常运行。

首先，自定义缓存需要实现一个接口，代码如下：

public class ProcessDefinitionRedisCache implements DeploymentCache<ProcessDefinitionCacheEntry> {

    @Override
    public ProcessDefinitionCacheEntry get(String id) {
    }

    @Override
    public boolean contains(String id) {
    }

    @Override
    public void add(String id, ProcessDefinitionCacheEntry processDefinitionCacheEntry) {
    }

    @Override
    public void remove(String id) {
    }

    @Override
    public void clear() {
    }

    @Override
    public Collection<ProcessDefinitionCacheEntry> getAll() {
    }

    @Override
    public int size() {
    }
}

然后，需要使用自定义的缓存替代原生的缓存：

configuration.setProcessDefinitionCache(new ProcessDefinitionRedisCache());

上一篇说过，即使实现了这个接口，但是由于BpmnModel和Process不能简单的序列化和反序列化，导致无法正常运行。

我试了很多办法，最后只能每次取缓存的时候调用ParsedDeployment来实现。

首先，加入缓存的时候，把Deployment加入缓存，因为Deployment支持序列化，并且可以一同将流程定义的XML加入缓存，就像这样：

@Override
public void add(String id, ProcessDefinitionCacheEntry processDefinitionCacheEntry) {
    redisTemplate.opsForValue().set(id + "_def", processDefinitionCacheEntry.getProcessDefinition());

    DeploymentEntity deployment = CommandContextUtil.getDeploymentEntityManager().findById(processDefinitionCacheEntry.getProcessDefinition().getDeploymentId());
    redisTemplate.opsForValue().set(id + "_dly", deployment);
}

然后，在取出缓存的时候，调用ParsedDeployment来获得BpmnModel和Process。

@Override
public ProcessDefinitionCacheEntry get(String id) {
    Object objectDef = redisTemplate.opsForValue().get(id + "_def");
    JSONObject jsonDef = (JSONObject) objectDef;
    Object objectDeployment = redisTemplate.opsForValue().get(id + "_dly");
    JSONObject jsonDeployment = (JSONObject) objectDeployment;

    ProcessDefinitionEntity processDefinitionEntity = jsonDef.toJavaObject(ProcessDefinitionEntityImpl.class);

    DeploymentEntity deployment = jsonDeployment.toJavaObject(DeploymentEntityImpl.class);

    ParsedDeploymentBuilderFactory factory = CommandContextUtil.getProcessEngineConfiguration().getParsedDeploymentBuilderFactory();
    ParsedDeployment parsedDeployment = factory
            .getBuilderForDeploymentAndSettings(deployment, null)
            .build();

    BpmnModel bpmnModel = parsedDeployment.getBpmnModelForProcessDefinition(parsedDeployment.getAllProcessDefinitions().get(0));
    Process process = parsedDeployment.getProcessModelForProcessDefinition(parsedDeployment.getAllProcessDefinitions().get(0));
    ProcessDefinitionCacheEntry cacheEntry = new ProcessDefinitionCacheEntry(processDefinitionEntity, bpmnModel, process);

    return cacheEntry;
}