如何使用redis解決負(fù)載均衡定時(shí)任務(wù)重復(fù)執(zhí)行問題

本篇文章為大家展示了如何使用redis解決負(fù)載均衡定時(shí)任務(wù)重復(fù)執(zhí)行問題，內(nèi)容簡明扼要并且容易理解，絕對能使你眼前一亮，通過這篇文章的詳細(xì)介紹希望你能有所收獲。

原理：redis里邊 setnx方法進(jìn)行設(shè)置時(shí)，如果key已存在，則不添加，key不存在，則進(jìn)行添加；同時(shí)因?yàn)閞edis是單線程的所以不存在安全問題

代碼部分邏輯： 1、以定時(shí)任務(wù)的任務(wù)id作為key,任意字符串值（這里使用"true"）作為value,設(shè)置進(jìn)redis

2、通過redis中setnx(添加一個(gè)key，如果key已存在，則不添加)判斷該任務(wù)是否執(zhí)行,如果result為true,則未執(zhí)行,為false則已執(zhí)行,定時(shí)任務(wù)直接return

3、為上邊的key設(shè)置一個(gè)緩存存活時(shí)間（放置代碼執(zhí)行過程出現(xiàn)問題，導(dǎo)致緩存未刪除，從而導(dǎo)致定時(shí)任務(wù)只執(zhí)行一次，建議設(shè)置時(shí)間遠(yuǎn)小于定時(shí)任務(wù)時(shí)間間隔）

4、定時(shí)任務(wù)內(nèi)容執(zhí)行完畢后，刪除之前設(shè)置的緩存，同時(shí)關(guān)閉redis連接（保證一次定時(shí)任務(wù)執(zhí)行完之后再執(zhí)行下次定時(shí)任務(wù)）

具體代碼如下

JobKey key=jobExecutionContext.getJobDetail().getKey();
String taskId=key.getName();//redis中setnx(添加一個(gè)key，如果key已存在，則不添加)判斷該任務(wù)是否執(zhí)行,如果result為true,則未執(zhí)行,為false則已執(zhí)行,定時(shí)任務(wù)直接returnRedisConnection connection=redisTemplate.getConnectionFactory().getConnection();boolean setNXResult=  connection.setNX(taskId.getBytes(),"true".getBytes());if(!setNXResult){   return;
}
run();
connection.del(taskId.getBytes());
connection.close();

上述內(nèi)容就是如何使用redis解決負(fù)載均衡定時(shí)任務(wù)重復(fù)執(zhí)行問題，你們學(xué)到知識或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識儲備，歡迎關(guān)注億速云行業(yè)資訊頻道。