主體思路:
使用redis 鍵在多長時(shí)間后過期爪幻,(在過期時(shí)間點(diǎn))通知訂閱消費(fèi)端執(zhí)行定時(shí)郵件發(fā)送并更新發(fā)送結(jié)果梨水。
redis的鍵過期事件也是一種 發(fā)布/訂閱模型
- 修改redis配置文件勤揩,使其支持鍵事件過期通知
$ vi /usr/local/redis/etc/redis.conf
修改 notify-keyspace-events 的參數(shù)為 "Ex", 并重新啟動redis
- 使用下面代碼為訂閱端, 檢測key過期后的異步通知彼硫。
$redis = new Redis();
$redis->connect("127.0.0.1",6379);
$redis->auth("XXX");
$redis->setOption(Redis::OPT_READ_TIMEOUT,-1); // 使其守護(hù)進(jìn)程不會出現(xiàn)超時(shí)錯(cuò)誤
$redis->psubscribe(["__keyevent@0__:expired"],function(Redis $redis,string $pattern,string $channel,string $expireKey){
var_dump($pattern); // __keyevent@0__:expired
var_dump($channel); // __keyevent@0__:expired
var_dump($expireKey); // 返回 過期的 key呛谜,實(shí)際業(yè)務(wù)中括丁,希望每一個(gè)定時(shí)郵件的key都是唯一的荞下,
//否則正在執(zhí)行的key業(yè)務(wù),如果一個(gè)同樣的key在執(zhí)行時(shí)過期史飞,則不會執(zhí)行
// todo 業(yè)務(wù)代碼繼續(xù)...
});
- 具體實(shí)現(xiàn)步驟
3,1 . 發(fā)送定時(shí)郵件時(shí)尖昏,將要發(fā)送的定時(shí)郵件保存到mysql中,并在定時(shí)郵件發(fā)送表中創(chuàng)建是否已經(jīng)發(fā)送的標(biāo)識字段 is_send构资,該字段由redis鍵空間訂閱端執(zhí)行發(fā)送更新抽诉。
3,2 . 發(fā)送定時(shí)郵件時(shí),使用php 操作redis設(shè)置一個(gè)過期key (重點(diǎn)說明:這個(gè)key必須要是唯一的過期key,該業(yè)務(wù)中過期的key吐绵,已經(jīng)在訂閱端執(zhí)行過的迹淌,不能再使用),業(yè)務(wù)設(shè)計(jì)中最好帶上上一步的mysql主鍵key 己单。
$redis->setex(string "delayMail:{$mysqlPriKeyId}",int 定時(shí)發(fā)送時(shí)間-time(),1);
3,3 . 由于在定時(shí)郵件未發(fā)送之前唉窃,用戶可能會刪除該定時(shí)郵件或修改定時(shí)郵件發(fā)送時(shí)間。此時(shí)需要調(diào)用php的redis刪除原來的key纹笼,并重新設(shè)置key并設(shè)置新的過期時(shí)間
if($redis->exist("delayMail:{$mysqlPriKeyId}")){
$redis->del("delayMail:{$mysqlPriKeyId}");
// 如果用戶是 修改定時(shí)郵件發(fā)送時(shí)間纹份,則需要重新設(shè)置key
$redis->setex(string "delayMail:{$mysqlPriKeyId}",int 新的定時(shí)發(fā)送時(shí)間-time(),1);
}