建站
咨詢
售后
建站咨詢
新聞中心
問題描述
煙臺(tái)網(wǎng)站制作公司哪家好，找創(chuàng)新互聯(lián)！從網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、響應(yīng)式網(wǎng)站建設(shè)等網(wǎng)站項(xiàng)目制作，到程序開發(fā)，運(yùn)營(yíng)維護(hù)。創(chuàng)新互聯(lián)成立于2013年到現(xiàn)在10年的時(shí)間，我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn)，來保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)。
將帶有定時(shí)任務(wù)的項(xiàng)目部署在單臺(tái)測(cè)試環(huán)境上，完全沒問題。生產(chǎn)上是兩臺(tái)集群服務(wù)器，項(xiàng)目部署上去發(fā)現(xiàn)定時(shí)任務(wù)的模塊同時(shí)在兩臺(tái)機(jī)器上各執(zhí)行了一遍，這將會(huì)導(dǎo)致其他意外的發(fā)生。
解決方案----redis分布式鎖
使用redis分布式鎖，為定時(shí)任務(wù)唯一指定的key加鎖，并設(shè)置鎖超時(shí)時(shí)間。當(dāng)觸發(fā)定時(shí)任務(wù)時(shí)，一臺(tái)服務(wù)的任務(wù)進(jìn)入切面，通過setNX(key,value)方法為唯一的key加鎖，如果當(dāng)前key不存在，將放入緩存，并返回true,通過expire(key,second)設(shè)置鎖超時(shí)時(shí)間，結(jié)束后跳出執(zhí)行定時(shí)任務(wù)方法。第二臺(tái)服務(wù)任務(wù)進(jìn)入時(shí)，設(shè)置鎖的時(shí)候發(fā)現(xiàn)該鎖已存在于緩存，并返回false，不跳轉(zhuǎn)到執(zhí)行定時(shí)任務(wù)方法。
核心代碼
1.分布式鎖切面
@Aspect
@Slf4j
@Component
public?class?CacheLockAspect?{
?private?static?final?String?LOCK_VALUE?=?"locked";
?@Autowired
?private?RedisConnection?connection;
?@Around("execution(*?*.*(..))?&&?@annotation(com.common.annotation.CacheLock)")
?public?void?cacheLockPoint(ProceedingJoinPoint?pjp)?{
?Method?cacheMethod?=?null;
?for?(Method?method?:?pjp.getTarget().getClass().getMethods())?{
?if?(null!=method.getAnnotation(CacheLock.class)){
?cacheMethod?=?method;
?break;
?}
?}
?try?{
?String?lockKey?=?cacheMethod.getAnnotation(CacheLock.class).lockedPrefix();
?long?timeOut?=?cacheMethod.getAnnotation(CacheLock.class).expireTime();
?if(null?==?lockKey){
?throw?new?ManagerException(ErrorMsgEnum.LOCK_NAME_EMPTY);
?}
?if?(connection.setNX(lockKey.getBytes(),LOCK_VALUE.getBytes()))?{
?connection.expire(lockKey.getBytes(),timeOut);
?log.info("method:{}獲取鎖:{},開始運(yùn)行！",cacheMethod,lockKey);
?pjp.proceed();
?return;
?}
?log.info("method:{}未獲取鎖:{},運(yùn)行失??！",cacheMethod,lockKey);
?}?catch?(Throwable?e)?{
?log.error("method:{},運(yùn)行錯(cuò)誤！",cacheMethod,e);
?throw?new?ManagerException(ErrorMsgEnum.LOCK_JOB_ERROR,e);
?}
?}
}2.手寫方法級(jí)注解
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public?@interface?CacheLock?{
?String?lockedPrefix()?default?"";?//redis?鎖key的前綴
?long?expireTime()?default?10;?//key在redis里存在的時(shí)間，1000S
}3.定時(shí)任務(wù)服務(wù)
@Slf4j
@Service
public?class?TimeTaskService?{
?/**
?*?執(zhí)行定時(shí)任務(wù)
?**/
?@Scheduled(cron?=?"0?0?1?*?*??")
?@CacheLock(lockedPrefix?=?"TimeTaskService",expireTime=30)
?public?void?executeTask()?{
?System.out.println("hello?world!");
?}
}
文章標(biāo)題：redis分布式鎖解決集群服務(wù)器定時(shí)任務(wù)重復(fù)執(zhí)行問題
URL標(biāo)題：http://www.dlmjj.cn/article/poeegj.html
