【锁】定时任务推送数据-redission加锁实例优化-Toy模板网

这篇具有很好参考价值的文章主要介绍了【锁】定时任务推送数据-redission加锁实例优化。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

redission 加锁代码-有问题

    /**
     * 收货入库物料标签(包装码)推送接口
     *
     * @throws Exception
     */
    public void synReceiveMaterialTags() throws Exception {
        String tag = DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss");
        String key = RedisKeyPre.synReceiveMaterialTagsLock;
        RLock rLock = redissonClient.getLock(key);
        try {
            // 尝试加锁，最多等待3秒，上锁以后1200秒自动解锁,没有Watch Dog,1200s后自动释放
            boolean res = rLock.tryLock(3, 1200, TimeUnit.SECONDS);
            if (!res) {
                Log.info(LogBuilder.builder().business("synReceiveMaterialTags:" + tag + ":获取锁失败,稍后重试").build());
                return;
            } else {
                wmsSyncService.synReceiveMaterialTags();
            }
        } catch (Exception e) {
            Log.error(LogBuilder.builder().business("synReceiveMaterialTags error:" + e).build());
        } finally {
            releaseLock(rLock);
        }
    }

    private void releaseLock(RLock rLock) {
        if (rLock.isLocked() && rLock.isHeldByCurrentThread()) {
            rLock.unlock();
        }
    }

rLock.tryLock(3, 1200, TimeUnit.SECONDS)表示尝试获取锁，最多等待3秒，锁的持有时间为1200秒（20分钟），超过持有时间后锁会自动释放。这样可以避免锁被长时间占用，提高代码的健壮性和性能。

如果不需要等待时间和自动释放时间，可以将tryLock()方法的参数调整为rLock.tryLock()，这样会立即尝试获取锁，如果锁不可用，则立即返回结果。但是需要注意，这样可能会导致线程频繁尝试获取锁，增加系统负载和竞争，需要根据具体情况进行评估和调整。

【锁】定时任务推送数据-redission加锁实例优化,java,spring boot,spring,redis

优化代码

这段代码存在一些问题：

异常处理不够详细：在synReceiveMaterialTags方法中，捕获了异常并记录了错误日志，但没有对异常进行具体的处理。建议根据实际情况，对异常进行适当的处理，例如回滚事务、发送通知等。
锁的释放方式不正确：在releaseLock方法中，使用isLocked和isHeldByCurrentThread方法来判断锁是否被当前线程持有，并进行解锁操作。然而，这种方式可能存在并发问题，因为在判断锁状态和解锁之间，其他线程可能已经获取了锁并修改了锁状态。建议使用try-finally语句来确保锁的正确释放，无论是否发生异常。
日志记录不规范：在日志记录中，使用了字符串拼接的方式来构建日志信息。建议使用日志框架，如Log4j或Slf4j，来记录日志，并使用占位符或参数化日志的方式，以提高性能和可读性。

优化后的代码示例：

public void synReceiveMaterialTags() {
	String tag = DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss");
	String key = RedisKeyPre.synReceiveMaterialTagsLock;
	RLock rLock = redissonClient.getLock(key);
	try {
		// 尝试加锁，最多等待3秒，上锁以后1200秒自动解锁,没有Watch Dog,1200s后自动释放
		boolean res = rLock.tryLock(3, 1200, TimeUnit.SECONDS);
		if (!res) {
			Log.info("synReceiveMaterialTags:{}:获取锁失败,稍后重试", tag);
		return;
		} else {
		wmsSyncService.synReceiveMaterialTags();
		}
	} catch (Exception e) {
	Log.error("synReceiveMaterialTags error:{}", e);
	// 异常处理逻辑
	} finally {
		try {
		rLock.unlock();
		} catch (IllegalStateException e) {}
		// 锁已经