延遲消息隊列
利用 expire keyspace notification
Redis 過期時,會向特定的消息隊列發送消息,監聽該消息隊列
- 在 redis.conf 修改 notify-keyspace-events "Ex",重啟 Redis;或者直接利用 config set notify-keyspace-events "Ex"
- 設置定時任務的 key,key 包含了你在過期那一刻所需要的所有數據
- psubscribe keyspace@*:expired,* 為所有數據庫
- 過期會收到 key,處理
優點:
- 很直觀,簡單粗暴
- 性能相對於 Sorted Set 版本高,不用輪詢
缺點:
- 如果沒人監聽隊列,數據就丟了,比如重啟服務器的情況
- 消息重復需要處理
Sorted Set,用時間戳作為 Score
Sorted Set,用時間戳作為 Score,Member 為你想處理的數據內容
- 設置定時任務,ZAdd,Member 為數據,Score 為定時任務需要執行時刻的時間戳
- 每隔一段時間輪詢該 Sorted Set,最大值為當前時間戳,ZRangeByScore key -inf curTimestamp
- 取出來的值,記得立刻刪除,再做處理
優點:
- 不會丟數據
缺點:
- 由於輪詢性能有損耗(不能說低)
- 需要做並發控制,多個實例同時輪詢到相同的數據
Tip: 刪除返回行數為 0 時,可以認為已經被別人處理;同時,可以 sleep 一些時間,使得不同服務器執行定時任務的時間錯開,類似於擁塞控制
消息隊列
讓我想一想
搜索引擎
分布式鎖
首先加鎖必須是原子的,釋放鎖必須要有定時機制,所以滿足條件一般采用 setnx lock EX 1
綜合評分系統
比如一門考試,課程 A 分數高優先錄取(分數范圍 0 - 1000),課程 B 分數高第二錄取(分數范圍 0 - 100),加入存了兩個 Sorted Set,分別為 ScoreA 和 Score B,那么怎么求出最高分方便?
總分評價 = A * 1000 + B,用 Redis 就是 ZUnionStore 得出結果