分布式锁测试类

分布式锁

&＃64;Scheduled是加了定时任务&＃xff0c;仅为场景使用分布式锁。
1、配置pom文件


com.baomidoulock4j-redisson-spring-boot-starter2.2.2



2、test测试代码

import com.baomidou.lock.LockInfo;
import com.baomidou.lock.LockTemplate;
import com.baomidou.lock.executor.RedissonLockExecutor;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.springframework.scheduling.annotation.Scheduled;import javax.annotation.Resource;
import java.time.LocalDate;/*** &＃64;author: samxie* &＃64;create: 2022/5/27* &＃64;Description:* &＃64;FileName: TimeLockTest* &＃64;History:* &＃64;自定义内容&＃xff1a;*/
&＃64;Slf4j
public class TimeLockTest {&＃64;Resourceprivate LockTemplate lockTemplate;&＃64;Scheduled(cron &＃61; "0/1 0/5 * * * ?")&＃64;Scheduled(fixedRate &＃61; 5 * 60 * 100L)public void sysncGoalImplemendtationStartUpd() {//获取锁LockInfo lockInfo &＃61; null;try {/*** String key, long expire, long acquireTimeout, Class executor*/String key &＃61; "goalImplTaskLock";long expire &＃61; 50000;//加锁lockInfo &＃61; this.lockTemplate.lock(key, expire, 0L, RedissonLockExecutor.class);LocalDate now &＃61; LocalDate.now();System.out.println("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;进入实现业务");//要干的业务service...} catch (Throwable throwable) {log.error("&＃61;&＃61;error:{}", throwable);} finally {//释放锁this.lockTemplate.releaseLock(lockInfo);}}&＃64;Testpublic void test() {sysncGoalImplemendtationStartUpd();}
}