支持两种使用方式：
- *使用示例1（自动识别）： - *
- * if (!syncLockManager.tryLock(externalSystemId)) {
- * return;
- * }
- * try {
- * // 执行同步逻辑
- * } finally {
- * syncLockManager.unlock(externalSystemId);
- * }
- *
- *
- * 使用示例2（显式锁类型 - 推荐用于跨服务协调）： - *
+ * 同步任务锁管理器 + *+ * 基于 {@link LocalLockManager} 实现，专用于同步任务的锁管理。 + * 提供类型安全的锁操作，通过 {@link SyncLockType} 避免字符串拼写错误。 + *
+ * + *设计说明：
+ *
使用示例： + *
{@code
* if (!syncLockManager.tryLock(SyncLockType.JENKINS_SYNC, externalSystemId)) {
- * return;
+ * return; // 已有同步任务在执行
* }
* try {
- * // 执行同步逻辑
+ * doSync();
* } finally {
* syncLockManager.unlock(SyncLockType.JENKINS_SYNC, externalSystemId);
* }
- *
+ * }
*/
@Slf4j
@Component
public class SyncLockManager {
- // 统一的锁存储
- private final ConcurrentHashMap推荐用于需要跨方法/跨服务协调的场景
+ * 尝试获取同步锁 * * @param lockType 锁类型 * @param params 锁参数（如 externalSystemId） - * @return true-获取成功，false-已被锁定 + * @return true-获取成功，false-锁已被持有 */ public boolean tryLock(SyncLockType lockType, Object... params) { - String lockKey = buildLockKey(lockType, params); - boolean acquired = locks.putIfAbsent(lockKey, true) == null; - - if (!acquired) { - log.warn("同步任务正在执行中，跳过本次同步: lockType={}, params={}", - lockType.getKey(), formatParams(params)); - } else { - log.debug("获取同步锁成功: lockType={}, params={}", - lockType.getKey(), formatParams(params)); - } - - return acquired; + String key = buildKey(lockType, params); + return localLockManager.tryLock(key); } /** - * 释放锁（显式指定锁类型） + * 释放同步锁 * * @param lockType 锁类型 - * @param params 锁参数（必须与tryLock时完全一致） + * @param params 锁参数（必须与 tryLock 时一致） */ public void unlock(SyncLockType lockType, Object... params) { - String lockKey = buildLockKey(lockType, params); - locks.remove(lockKey); - log.debug("同步任务完成，释放锁: lockType={}, params={}", - lockType.getKey(), formatParams(params)); + String key = buildKey(lockType, params); + localLockManager.unlock(key); } /** - * 检查锁是否被持有（显式指定锁类型） - * - * @param lockType 锁类型 - * @param params 锁参数 - * @return true-已被锁定，false-未锁定 + * 检查锁是否被持有 */ public boolean isLocked(SyncLockType lockType, Object... params) { - String lockKey = buildLockKey(lockType, params); - return locks.containsKey(lockKey); + String key = buildKey(lockType, params); + return localLockManager.isLocked(key); } /** - * 构建锁key（显式锁类型） + * 获取当前锁数量 */ - private String buildLockKey(SyncLockType lockType, Object... params) { + public long getLockCount() { + return localLockManager.getLockCount(); + } + + /** + * 获取所有锁状态（用于监控） + */ + public List适用于单方法独立锁场景，不需要跨服务协调
- * - * @param params 锁参数（如 externalSystemId, viewId等） - * @return true-获取成功，false-已被锁定 - */ - public boolean tryLock(Object... params) { - CallerInfo callerInfo = getCallerInfo(); - String lockKey = buildLockKey(callerInfo, params); - boolean acquired = locks.putIfAbsent(lockKey, true) == null; - - if (!acquired) { - log.warn("同步任务正在执行中，跳过本次同步: method={}, params={}", - callerInfo.getFullMethodName(), formatParams(params)); - } else { - log.debug("获取同步锁成功: method={}, params={}", - callerInfo.getFullMethodName(), formatParams(params)); - } - - return acquired; - } - - /** - * 释放锁（自动识别调用者） - * - * @param params 锁参数（必须与tryLock时完全一致） - */ - public void unlock(Object... params) { - CallerInfo callerInfo = getCallerInfo(); - String lockKey = buildLockKey(callerInfo, params); - locks.remove(lockKey); - log.debug("同步任务完成，释放锁: method={}, params={}", - callerInfo.getFullMethodName(), formatParams(params)); - } - - /** - * 检查锁是否被持有（自动识别调用者） - * - * @param params 锁参数 - * @return true-已被锁定，false-未锁定 - */ - public boolean isLocked(Object... params) { - CallerInfo callerInfo = getCallerInfo(); - String lockKey = buildLockKey(callerInfo, params); - return locks.containsKey(lockKey); - } - - /** - * 获取当前锁数量（用于监控） - * - * @return 当前持有的锁数量 - */ - public int getLockCount() { - return locks.size(); - } - - /** - * 获取调用者信息（通过栈追踪，智能跳过Spring代理层） - * - * @return 调用者信息 - */ - private CallerInfo getCallerInfo() { - StackTraceElement[] stackTrace = Thread.currentThread().getStackTrace(); - - // 从栈顶开始遍历，跳过本类和Spring的代理/拦截器类 - // 栈结构示例： - // 0: Thread.getStackTrace() - // 1: SyncLockManager.getCallerInfo() - // 2: SyncLockManager.tryLock/unlock/isLocked() - // 3+: 可能是Spring代理类或真实调用者 - - for (int i = 3; i < stackTrace.length; i++) { - StackTraceElement element = stackTrace[i]; - String className = element.getClassName(); - String methodName = element.getMethodName(); - - // 跳过 Spring 和 JDK 的内部类/代理类 - if (shouldSkipFrame(className, methodName)) { - continue; - } - - // 找到真正的业务调用者 - String simpleClassName = className.substring(className.lastIndexOf('.') + 1); - return new CallerInfo(simpleClassName, methodName, className + "." + methodName); - } - - // 兜底：使用unknown - return new CallerInfo("Unknown", "unknown", "Unknown.unknown"); - } - - /** - * 判断是否应该跳过该栈帧 - * - * @param className 类名 - * @param methodName 方法名 - * @return true-跳过，false-不跳过 - */ - private boolean shouldSkipFrame(String className, String methodName) { - // 跳过 CGLIB 动态代理类（所有包含$$的类都是CGLIB代理） - if (className.contains("$$")) { - return true; - } - - // 跳过 JDK 动态代理 - if (className.startsWith("jdk.proxy") || className.startsWith("com.sun.proxy")) { - return true; - } - - // 跳过 Spring AOP 拦截器 - if (className.contains("AsyncExecutionInterceptor") || - className.contains("TransactionInterceptor") || - className.contains("CglibAopProxy") || - className.contains("ReflectiveMethodInvocation") || - className.contains("DynamicAdvisedInterceptor")) { - return true; - } - - // 跳过线程池和任务执行器 - if (className.contains("ThreadPoolExecutor") || - className.contains("FutureTask") || - className.contains("CompletableFuture")) { - return true; - } - - // 跳过 Java 反射 - if (className.startsWith("java.lang.reflect") || - className.startsWith("jdk.internal.reflect")) { - return true; - } - - // 跳过 lambda 表达式的合成方法 - if (methodName.contains("lambda$")) { - return true; - } - - return false; - } - - /** - * 构建锁的唯一key - * - * @param callerInfo 调用者信息 - * @param params 参数列表 - * @return 锁key - */ - private String buildLockKey(CallerInfo callerInfo, Object... params) { - StringBuilder key = new StringBuilder(callerInfo.getFullMethodName()); - for (Object param : params) { - key.append(":").append(param != null ? param : "null"); - } - return key.toString(); - } - - /** - * 格式化参数用于日志输出 - * - * @param params 参数列表 - * @return 格式化字符串 - */ - private String formatParams(Object... params) { - if (params.length == 0) { - return "[]"; - } - - StringBuilder sb = new StringBuilder("["); - for (int i = 0; i < params.length; i++) { - if (i > 0) { - sb.append(", "); - } - sb.append(params[i]); - } - sb.append("]"); - return sb.toString(); - } - - /** - * 调用者信息 - */ - private static class CallerInfo { - private final String simpleClassName; - private final String methodName; - private final String fullMethodName; - - public CallerInfo(String simpleClassName, String methodName, String fullMethodName) { - this.simpleClassName = simpleClassName; - this.methodName = methodName; - this.fullMethodName = fullMethodName; - } - - public String getSimpleClassName() { - return simpleClassName; - } - - public String getMethodName() { - return methodName; - } - - public String getFullMethodName() { - return fullMethodName; - } - } } diff --git a/backend/src/main/java/com/qqchen/deploy/backend/deploy/service/impl/RepositoryBranchServiceImpl.java b/backend/src/main/java/com/qqchen/deploy/backend/deploy/service/impl/RepositoryBranchServiceImpl.java index 11ae01f5..8cc0b078 100644 --- a/backend/src/main/java/com/qqchen/deploy/backend/deploy/service/impl/RepositoryBranchServiceImpl.java +++ b/backend/src/main/java/com/qqchen/deploy/backend/deploy/service/impl/RepositoryBranchServiceImpl.java @@ -16,8 +16,9 @@ import com.qqchen.deploy.backend.deploy.service.IRepositoryBranchService; import com.qqchen.deploy.backend.framework.enums.ResponseCode; import com.qqchen.deploy.backend.framework.exception.BusinessException; import com.qqchen.deploy.backend.framework.service.impl.BaseServiceImpl; -import com.qqchen.deploy.backend.deploy.dto.RepositorySyncHistoryDTO; +import com.qqchen.deploy.backend.deploy.lock.SyncLockType; import com.qqchen.deploy.backend.deploy.service.IRepositorySyncHistoryService; +import com.qqchen.deploy.backend.deploy.dto.RepositorySyncHistoryDTO; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.springframework.orm.ObjectOptimisticLockingFailureException; @@ -200,15 +201,15 @@ public class RepositoryBranchServiceImpl extends BaseServiceImpl使用示例： + *
{@code
+ * // 方式1：try-finally（推荐）
+ * if (lockManager.tryLock("jenkins-sync", systemId)) {
+ * try {
+ * doSync();
+ * } finally {
+ * lockManager.unlock("jenkins-sync", systemId);
+ * }
+ * }
+ *
+ * // 方式2：使用 AutoCloseable
+ * try (var lock = lockManager.lock("jenkins-sync", systemId)) {
+ * if (lock.isAcquired()) {
+ * doSync();
+ * }
+ * }
+ * }
+ */
+@Slf4j
+@Component
+public class LocalLockManager {
+
+ /**
+ * 默认锁超时时间：5分钟
+ */
+ private static final Duration DEFAULT_TIMEOUT = Duration.ofMinutes(5);
+
+ /**
+ * 最大锁数量
+ */
+ private static final int MAX_LOCK_SIZE = 10000;
+
+ /**
+ * 锁存储（key -> 锁持有者信息），Caffeine 自动过期
+ */
+ private Cache