flowable 清除流程本地缓存

flowable 或者 activity 修改流程图属性后，需要清除本地缓存，可以用以下方法来实现。

一、清除缓存 Cmd

package indi.tudan.modules.flowable.common.cmd;

import indi.tudan.common.core.utils.StringUtils;
import org.flowable.common.engine.impl.interceptor.Command;
import org.flowable.common.engine.impl.interceptor.CommandContext;
import org.flowable.common.engine.impl.persistence.deploy.DeploymentCache;
import org.flowable.engine.impl.persistence.deploy.DeploymentManager;
import org.flowable.engine.impl.persistence.deploy.ProcessDefinitionCacheEntry;
import org.flowable.engine.impl.util.CommandContextUtil;
import org.flowable.engine.repository.Deployment;

import java.io.Serializable;

/**
 * 清除流程缓存
 *
 * @author wangtan
 * @date 2021-12-29 10:11:25
 * @since 1.0.0
 */
public class DeploymentCacheCmd implements Command<Deployment>, Serializable {
    

    private static final long serialVersionUID = 1L;
    private final String definitionId;

    public DeploymentCacheCmd(String definitionId) {
    
        this.definitionId = definitionId;
    }

    @Override
    public Deployment execute(CommandContext commandContext) {
    

        DeploymentManager deploymentManager = CommandContextUtil.getProcessEngineConfiguration().getDeploymentManager();
        DeploymentCache<ProcessDefinitionCacheEntry> deploymentCache = deploymentManager.getProcessDefinitionCache();

        if (StringUtils.isNotBlank(definitionId)) {
    

            // 清除指定缓存
            deploymentCache.remove(definitionId);

        } else {
    

            // 清除全部缓存
            deploymentCache.clear();

        }

        return null;

    }

}dContextUtil.getProcessEngineConfiguration().getDeploymentManager();

        DeploymentCache<ProcessDefinitionCacheEntry> deploymentCache = deploymentManager.getProcessDefinitionCache();
        deploymentCache.remove(definitionId);

        return null;
        
    }
    
}

其中 StringUtils 参考

package indi.tudan.common.core.utils;

import java.util.regex.Matcher;
import java.util.regex.Pattern;

/**
 * 字符串处理工具类
 *
 * @author wangtan
 * @date 2019-10-27 13:43:20
 * @since 1.0.0
 */
public class StringUtils {
    

    /**
     * Don't let anyone else instantiate this class
     */
    private StringUtils() {
    
    }

    /**
     * 获取字符串
     *
     * @param object 待处理数据
     * @return 处理后的字符串
     * @date 2019-10-26 17:31:49
     */
    public static String getStr(Object object) {
    
        if (ObjectUtils.isNotNull(object)) {
    
            return String.valueOf(object);
        } else {
    
            return "";
        }
    }

    /**
     * 字符串是否为空
     *
     * @param cs 字符串
     * @return boolean
     * @date 2019-10-26 17:31:14
     */
    public static boolean isBlank(CharSequence cs) {
    
        int strLen;
        if (cs != null && (strLen = cs.length()) != 0) {
    
            for (int i = 0; i < strLen; ++i) {
    
                if (!Character.isWhitespace(cs.charAt(i))) {
    
                    return false;
                }
            }
        }
        return true;
    }

    /**
     * 字符串是否不为空
     *
     * @param cs 字符串
     * @return boolean
     * @date 2019-10-26 17:31:07
     */
    public static boolean isNotBlank(CharSequence cs) {
    
        return !isBlank(cs);
    }

    /**
     * 若字符串为空，则返回 defaultString
     *
     * @param string        字符串
     * @param defaultString 默认字符串
     * @return String
     * @author wangtan
     * @date 2019-09-06 13:53:42
     * @since 1.0.0
     */
    public static String orElse(String string, String defaultString) {
    
        return isBlank(string) ? defaultString : string;
    }

    /**
     * 去除所有空白符
     *
     * @param str 字符串
     * @return
     * @date 2020-07-21 19:55:39
     * @since 1.0.0
     */
    public static String replaceBlank(String str) {
    
        String dest = null;
        if (str == null) {
    
            return dest;
        } else {
    
            Pattern p = Pattern.compile("\\s*|\t|\r|\n");
            Matcher m = p.matcher(str);
            dest = m.replaceAll("");
            return dest;
        }
    }

}

二、如何调用

@Autowired
protected ManagementService managementService;

// 清除某个流程的缓存
// 此处的 xxxxxxxxxxxx 只是示例，请根据实际传流程定义Id
managementService.executeCommand(new DeploymentCacheCmd("xxxxxxxxxxxx"));

// 清除全部缓存
managementService.executeCommand(new DeploymentCacheCmd(""));