背景

功能描述：會(huì)議開始前五分鐘通過(guò)消息提醒參會(huì)人員怖糊。

為什么用redis：其實(shí)算是一個(gè)前期調(diào)研的失誤，之前一直使用的是阿里的RocketMQ悬钳，后面公司把RocketMQ做了升級(jí)塞蹭，升級(jí)到了5.x版本。但是官方并未提供對(duì)應(yīng)的node版sdk门坷。當(dāng)然再使用舊版本或者其他消息隊(duì)列服務(wù)都是不現(xiàn)實(shí)的宣鄙。只能通過(guò)一寫其他方案來(lái)實(shí)現(xiàn)。

預(yù)選方案：當(dāng)時(shí)調(diào)研了三四種方案默蚌，比作了優(yōu)缺點(diǎn)對(duì)比冻晤，最終綜合考量選擇了redis key的方式。

1. 方案一：最簡(jiǎn)單的利用node-schedule庫(kù)绸吸，去指定一個(gè)時(shí)間執(zhí)行任務(wù)鼻弧，該方案任務(wù)只存在內(nèi)存之中，一旦服務(wù)重啟锦茁，之前的定時(shí)任務(wù)就會(huì)消失攘轩。這顯然是不合適的。

2. 方案二：把任務(wù)存到數(shù)據(jù)庫(kù)中蜻势，然后在代碼中輪詢?nèi)ゲ閹?kù)撑刺，查詢到指定時(shí)間范圍的執(zhí)行就去執(zhí)行。但是該方案會(huì)有時(shí)間誤差握玛，主要看輪詢頻率够傍。

3. 方案三：通過(guò)redis的key過(guò)期事件監(jiān)聽實(shí)現(xiàn)定時(shí)任務(wù)，代碼中提前監(jiān)聽好事件挠铲，當(dāng)key過(guò)期時(shí)就會(huì)執(zhí)行監(jiān)聽函數(shù)冕屯。該方案既沒(méi)有明顯的時(shí)間誤差（具體特別小的誤差有沒(méi)有并未調(diào)研），也不用擔(dān)心服務(wù)重啟的問(wèn)題拂苹。因?yàn)槿蝿?wù)相當(dāng)于是存在redis中的安聘。

代碼實(shí)現(xiàn)

接下來(lái)我們就用redis key的方式來(lái)實(shí)現(xiàn)一下定時(shí)任務(wù)：

1. 首先需要運(yùn)維同事幫忙設(shè)置一下redis的配置項(xiàng)notify-keyspace-event Ex，這里設(shè)置成Ex即可瓢棒，E表示鍵事件通知浴韭，x表示過(guò)期事件（默認(rèn)情況下收不到通知）。想了解其他值可以自行擴(kuò)展脯宿。

2. 在項(xiàng)目啟動(dòng)后念颈，創(chuàng)建redis監(jiān)聽。
   先創(chuàng)建一個(gè)工廠函數(shù)用于生成redis client

   const redis = require('redis');
   async function initRedisClient(){
       return await redis.createClient({
           url: 'redis://xxxx'
       });
   }
   

   事件監(jiān)聽：

   async function subRedisKey(){
       // 創(chuàng)建一個(gè)用于監(jiān)聽事件的client
       let redisSubClient = initRedisClient()
       await redisSubClient.connect()
       // 訂閱數(shù)據(jù)庫(kù)0的key expired事件
       redisSubClient.subscribe('__keyevent@0__:expired', (e) => {
           // e就是過(guò)期的key连霉，去做自己的業(yè)務(wù)邏輯
       }
   }
   

3. 在創(chuàng)建會(huì)議的時(shí)候通過(guò)設(shè)置一個(gè)key榴芳，并設(shè)置其過(guò)期時(shí)間為會(huì)議開始前5分鐘即可嗡靡。需要注意的是key種需要包含需要使用到的數(shù)據(jù)和唯一性標(biāo)識(shí)，因?yàn)檫^(guò)期后就拿不到value中的數(shù)據(jù)了窟感，所以不能存在value中讨彼。同時(shí)還要根據(jù)key知道對(duì)應(yīng)的會(huì)議是哪個(gè)。

   async function createMeeting(data){
       // 創(chuàng)建一個(gè)用于創(chuàng)建key的client
       const redisClient = initRedisClient();
       await redisClient.connect()
       // key自己定義柿祈，value可以隨意設(shè)置
       redisClient.PSETEX(`redis_key_${data.id}__${data}`, 指定時(shí)間毫秒值, '')
   }
   

   當(dāng)然哈误，如果會(huì)議開始時(shí)間發(fā)生了修改或者會(huì)議被刪除，也可以刪除對(duì)應(yīng)的key來(lái)清除沒(méi)用的任務(wù)谍夭。

   redisClient.DEL(key)
   

分布式問(wèn)題解決

通過(guò)一頓敲代碼黑滴，功能算是實(shí)現(xiàn)了，但是還有一個(gè)重要的問(wèn)題紧索。就是在分布式情況下袁辈，會(huì)出現(xiàn)多次通知的情況。因?yàn)榉植际绞峭瑫r(shí)啟動(dòng)了多個(gè)服務(wù)珠漂。然后redis key的過(guò)期事件相當(dāng)于是廣播式的晚缩。多個(gè)服務(wù)監(jiān)聽了事件，就會(huì)多個(gè)服務(wù)同時(shí)觸發(fā)事件監(jiān)聽媳危。就出現(xiàn)了多次通知的問(wèn)題荞彼。

為了解決該問(wèn)題，一般情況下就會(huì)想到利用鎖的性質(zhì)待笑。接下來(lái)嘗試查到的第一個(gè)方法：GETSET鸣皂。該方法第一次執(zhí)行，因?yàn)橹皼](méi)有set過(guò)暮蹂，所以會(huì)返回null寞缝。一但設(shè)置了之后再執(zhí)行就會(huì)返回設(shè)置的值。

監(jiān)聽函數(shù)中：

const value = await redisClient.GETSET('key', 1);
// 如果返回值是1就表示某一臺(tái)服務(wù)器已經(jīng)執(zhí)行過(guò)仰泻，直接退出荆陆。反之，執(zhí)行通知操作集侯。
if(value){
    return;;
}
// todo 執(zhí)行通知

測(cè)試之后發(fā)現(xiàn)被啼，該方法并不行，兩臺(tái)服務(wù)GETSET得到的值都是null棠枉，依舊都會(huì)通知浓体。接下來(lái)嘗試第二個(gè)方法INCR。該方法會(huì)將key的值增加一辈讶，如果key不存在則會(huì)先初始化為0再增一汹碱。

監(jiān)聽函數(shù)中：

const value = await redisClient.INCR('key');
// 如果返回值大于1就表示某一臺(tái)服務(wù)器已經(jīng)執(zhí)行過(guò)，直接退出荞估。反之咳促，執(zhí)行通知操作。
if(value > 1){
    return;;
}
// todo 執(zhí)行通知

測(cè)試結(jié)果：該方法可行勘伺。任務(wù)完成跪腹！