wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update - 测试分布式锁

Browse Source
This commit is contained in:
wangli 2024-07-02 09:41:00 +08:00
parent 439a2ceac5
commit 67865c8be0
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/interceptor/CustomLockProcessInstanceInterceptor.java
View File

@ -1,6 +1,7 @@
package cn.axzo.workflow.core.engine.interceptor; package cn.axzo.workflow.core.engine.interceptor;
import cn.axzo.workflow.core.engine.cmd.AbstractCommand; import cn.axzo.workflow.core.engine.cmd.AbstractCommand;
import liquibase.pro.packaged.T;
import org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor; import org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor;
import org.flowable.common.engine.impl.interceptor.Command; import org.flowable.common.engine.impl.interceptor.Command;
import org.flowable.common.engine.impl.interceptor.CommandConfig; import org.flowable.common.engine.impl.interceptor.CommandConfig;
@ -58,7 +59,7 @@ public class CustomLockProcessInstanceInterceptor extends AbstractCommandInterce
} finally { } finally {
log.info("finally unlock threadName: {}, token: {}", Thread.currentThread().getName(), token); log.info("finally unlock threadName: {}, token: {}", Thread.currentThread().getName(), token);
if (token != null) { if (token != null) {
unlock(abstractCommand.getProcessInstanceId(), token); unlock(KEY_PREFIX + abstractCommand.getProcessInstanceId(), token);
} }
} }
} }
@ -141,16 +142,22 @@ public class CustomLockProcessInstanceInterceptor extends AbstractCommandInterce
try { try {
Long result = (Long) conn.scriptingCommands().eval(unlockScript.getBytes(Charset.forName("UTF-8")), Long result = (Long) conn.scriptingCommands().eval(unlockScript.getBytes(Charset.forName("UTF-8")),
ReturnType.INTEGER, 1, keysAndArgs); ReturnType.INTEGER, 1, keysAndArgs);
if (result != null && result > 0) if (result != null && result > 0) {
return true; return true;
} else {
throw new IllegalStateException("unLock ProcessInstance fail");
}
} catch (Exception e) { } catch (Exception e) {
log.warn("unlock error: {}", e.getMessage(), e); log.warn("unlock error: {}", e.getMessage(), e);
// unlock(name, token); try {
return false; Thread.sleep(1000L);
} catch (InterruptedException ex) {
// ignore
}
return unlock(name, token);
} finally { } finally {
RedisConnectionUtils.releaseConnection(conn, factory); RedisConnectionUtils.releaseConnection(conn, factory);
} }
return false;
} }