Redis 有序集合與發布訂閱模式詳解

– 11 分鐘閱讀

Redis 的有序集合（Sorted Sets）提供了一種在集合中維護排序的有效方法，每個元素都關聯一個分數，用於排序和範圍查詢。這使得 Sorted Sets 非常適合用於排行榜、優先佇列等應用場景。除了 Sorted Sets，Redis 的釋出/訂閱（Pub/Sub）模式也是一個強大的功能，它允許客戶端之間進行即時訊息傳遞。客戶端可以訂閱感興趣的頻道，並在有訊息釋出到這些頻道時收到通知。這種模式在需要即時資料更新的應用中非常有用，例如聊天應用、即時監控系統等。理解並有效地運用這兩種機制，能顯著提升 Redis 在各種應用場景下的效能。

Redis 中的有序集合（Sorted Sets）操作詳解

Redis 的有序集合（Sorted Sets，簡稱 ZSETs）是一種特殊的資料結構，它結合了集合（SET）和有序列表（SORTED LIST）的特性。在本章中，我們將探討 Redis 中與 ZSETs 相關的各種命令，並透過例項演示其用法。

ZSETs 基本操作

在 Redis 中，ZSETs 是一種用於儲存唯一元素並為每個元素關聯一個浮點數分數（score）的資料結構。這使得我們可以根據分數對元素進行排序。以下是一些基本的 ZSETs 操作命令：

  • ZADD：向 ZSET 中新增元素及其分數。
  • ZREM：從 ZSET 中移除元素。
  • ZINCRBY：增加 ZSET 中某個元素的分數。
  • ZSCORE：取得 ZSET 中某個元素的分數。
  • ZRANGE：根據索引範圍取得 ZSET 中的元素，可以選擇是否傳回分數。

程式碼範例：基本 ZSET 操作

>>> conn.zadd('zset-key', 'a', 3, 'b', 2, 'c', 4)
3
>>> conn.zrange('zset-key', 0, -1, withscores=True)
[('b', 2.0), ('a', 3.0), ('c', 4.0)]
>>> conn.zrem('zset-key', 'b')
True
>>> conn.zrange('zset-key', 0, -1, withscores=True)
[('a', 3.0), ('c', 4.0)]

內容解密：

  1. 使用 ZADD 命令向名為 zset-key 的 ZSET 新增三個元素 a、b 和 c，並分別賦予它們的分數為 3、2 和 4。
  2. 使用 ZRANGE 命令取得 zset-key 中的所有元素及其分數，按分數從低到高排序。
  3. 使用 ZREM 命令移除元素 b。
  4. 再次使用 ZRANGE 命令檢視移除 b 後的 ZSET 狀態。

高階 ZSET 操作

除了基本的增刪查改操作，Redis 的 ZSETs 還支援一些高階操作，如根據分數範圍取得元素、計算元素排名等。

更多 ZSET 命令

命令用途描述
ZREVRANK取得元素在 ZSET 中的反向排名（按分數從高到低）。
ZREVRANGE按反向順序取得 ZSET 中的元素。
ZRANGEBYSCORE取得分數在指定範圍內的元素。
ZREVRANGEBYSCORE按反向順序取得分數在指定範圍內的元素。
ZREMRANGEBYRANK移除排名在指定範圍內的元素。
ZREMRANGEBYSCORE移除分數在指定範圍內的元素。
ZINTERSTORE對多個 ZSET 進行交集操作並將結果儲存到新的 ZSET。
ZUNIONSTORE對多個 ZSET 進行並集操作並將結果儲存到新的 ZSET。

程式碼範例：ZSET 交集與並集

>>> conn.zadd('zset-1', 'a', 1, 'b', 2, 'c', 3)
3
>>> conn.zadd('zset-2', 'b', 4, 'c', 1, 'd', 0)
3
>>> conn.zinterstore('zset-i', ['zset-1', 'zset-2'])
2L
>>> conn.zrange('zset-i', 0, -1, withscores=True)
[('c', 4.0), ('b', 6.0)]
>>> conn.zunionstore('zset-u', ['zset-1', 'zset-2'], aggregate='min')
4L
>>> conn.zrange('zset-u', 0, -1, withscores=True)
[('d', 0.0), ('a', 1.0), ('c', 1.0), ('b', 2.0)]

內容解密：

  1. 首先建立兩個 ZSET：zset-1 和 zset-2。
  2. 使用 ZINTERSTORE 命令對 zset-1 和 zset-2 進行交集操作，將結果儲存在 zset-i 中。預設情況下，分數會被相加。
  3. 使用 ZUNIONSTORE 命令對 zset-1 和 zset-2 進行並集操作，並使用 aggregate='min' 指定當元素出現在多個 ZSET 中時，取最小的分數。

釋出/訂閱（Publish/Subscribe）模式

Redis 支援釋出/訂閱模式，這是一種訊息傳遞模式，其中釋出者將訊息傳送到頻道，而訂閱者則接收這些訊息。

釋出/訂閱相關命令

命令用途描述
PUBLISH向指定頻道釋出訊息。
SUBSCRIBE訂閱一個或多個頻道。
UNSUBSCRIBE取消訂閱一個或多個頻道。
PSUBSCRIBE使用模式匹配訂閱頻道。
PUNSUBSCRIBE取消使用模式匹配的頻道訂閱。

釋出/訂閱模式適用於需要實時訊息傳遞的場景，如即時通訊、事件通知等。

Redis 發布/訂閱模式詳解

Redis 的發布/訂閱（pub/sub）模式是一種強大的訊息傳遞機制，允許客戶端之間透過特定的頻道進行訊息的發布和訂閱。本章節將探討 Redis pub/sub 的實作原理、使用方法以及其在實際應用中的限制和挑戰。

發布/訂閱的基本用法

Redis 透過 PUBLISH 和 SUBSCRIBE 命令實作了發布/訂閱功能。客戶端可以訂閱特定的頻道，而其他客戶端則可以向這些頻道發布訊息。以下是一個使用 Python 客戶端演示 pub/sub 功能的例子：

import threading
import time
import redis

# 建立 Redis 連線
conn = redis.Redis(host='localhost', port=6379, db=0)

def publisher(n):
    """發布者函式，向指定頻道發布 n 條訊息"""
    time.sleep(1)  # 等待訂閱者準備就緒
    for i in range(n):
        conn.publish('channel', i)
        time.sleep(1)  # 間隔發布訊息

def run_pubsub():
    """執行發布/訂閱測試"""
    # 啟動發布者執行緒
    threading.Thread(target=publisher, args=(3,)).start()
    
    # 建立 pubsub 物件並訂閱頻道
    pubsub = conn.pubsub()
    pubsub.subscribe(['channel'])
    
    count = 0
    for item in pubsub.listen():
        print(item)
        count += 1
        if count == 4:
            pubsub.unsubscribe()  # 取消訂閱
        if count == 5:
            break

run_pubsub()

內容解密：

  1. publisher 函式：該函式模擬一個發布者，向指定的 channel 發布 n 條訊息。每條訊息發布後，等待 1 秒鐘，以模擬實際應用中的時間間隔。
  2. run_pubsub 函式：該函式啟動一個發布者執行緒，並建立一個 pubsub 物件來訂閱指定的頻道。透過迭代 pubsub.listen() 的結果，可以接收到所有訂閱頻道上的訊息。
  3. pubsub.listen()：這是一個生成器，用於接收訂閱頻道上的訊息。當收到 subscribe、message 和 unsubscribe 訊息時，分別代表訂閱成功、收到新訊息和取消訂閱。
  4. 輸出結果：執行 run_pubsub() 後，將列印預出訂閱確認訊息、接收到的三條訊息以及取消訂閱的訊息。

Redis 發布/訂閱命令詳解

Redis 提供了多個命令來支援發布/訂閱功能，如下表所示：

命令用途描述
SUBSCRIBE訂閱指定的頻道
UNSUBSCRIBE取消訂閱指定的頻道，若未指定頻道，則取消所有訂閱
PUBLISH向指定的頻道發布訊息
PSUBSCRIBE按照模式訂閱頻道，支援萬用字元
PUNSUBSCRIBE取消按照模式訂閱的頻道

發布/訂閱模式的限制與挑戰

儘管 Redis 的發布/訂閱模式使用方便，但在實際應用中仍存在一些限制和挑戰：

  1. 系統可靠性：在舊版本的 Redis 中，如果客戶端訂閱了頻道但未能及時處理訊息，可能會導致 Redis 的輸出緩衝區過大，從而影響系統效能甚至導致當機。現代版本的 Redis 已透過 client-output-buffer-limit pubsub 組態選項解決了這一問題。
  2. 資料傳輸可靠性：在網路環境中，客戶端斷開連線後重新連線期間傳送的訊息可能會丟失。因此，在依賴訊息傳遞的應用中，需要考慮額外的可靠性措施。

可靠訊息傳遞的實作

針對上述挑戰，可以透過實作可靠的訊息傳遞機制來解決。在第 6 章中，我們將介紹兩種不同的方法來處理可靠的訊息傳遞，這些方法能夠在面對網路斷開連線的情況下保證訊息的傳遞，並且不會導致 Redis 記憶體無限制增長。

隨著 Redis 的不斷發展和完善，未來可能會出現更多針對發布/訂閱模式的最佳化和改進。例如，更高效的訊息處理機制、更強大的可靠性保證等，都將進一步拓展 Redis 在訊息傳遞領域的應用範圍。

3.7 其他命令詳解：Redis 中的多樣化操作

在前面的章節中，我們已經探討了 Redis 提供的五種基本資料結構，並介紹了其發布/訂閱（pub/sub）功能。本文將聚焦於一些能夠操作多種資料型別的命令。首先，我們會介紹 SORT 命令，它能夠同時處理 STRING、SET、LIST 和 HASH 等多種資料型別。接著，我們會討論使用 MULTI 和 EXEC 命令實作的基本事務功能，這使得我們能夠將多個命令組合在一起執行，就像執行單一命令一樣。最後，我們將探討一系列自動過期命令，用於自動刪除不再需要的資料。

閱讀完本文後，您將更好地理解如何同時組合和操作多種資料型別，以滿足複雜的應用需求。

3.7.1 排序功能詳解

Redis 中的排序功能與其他程式語言中的排序類別似：我們需要對一組資料進行排序，而排序的依據是元素之間的比較。SORT 命令允許我們根據儲存在 LIST、SET 或 ZSET 中的資料，或甚至儲存在 HASH 中的資料進行排序。如果您有關聯式資料函式庫的背景，可以將 SORT 命令類別比為 SQL 陳述式中的 ORDER BY 子句，它可以參照其他列甚至其他表格。表 3.12 詳細展示了 SORT 命令的定義。

SORT 命令的基本用法

SORT 命令的一些基本選項包括：能夠以降序排列結果（預設為升序）、將專案視為數字進行比較、將專案視為二進位字串進行比較（例如，字串 ‘110’ 和 ‘12’ 的排序順序與數字 110 和 12 的排序順序不同）、根據不在原始序列中的值進行排序，以及擷取輸入 LIST、SET 或 ZSET 外部的資料。

# 將一些專案加入 LIST 中
>>> conn.rpush('sort-input', 23, 15, 110, 7)
4

# 對 LIST 中的專案進行數字排序
>>> conn.sort('sort-input')
['7', '15', '23', '110']

# 表 3.12 SORT 命令定義
# SORT source-key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]] [ASC|DESC] [ALPHA] [STORE dest-key]
# 對輸入的 LIST、SET 或 ZSET 根據提供的選項進行排序，並傳回或儲存結果

# 對 LIST 中的專案進行字母排序
>>> conn.sort('sort-input', alpha=True)
['110', '15', '23', '7']

# 為排序和擷取準備額外的 HASH 資料
>>> conn.hset('d-7', 'field', 5)
1L
>>> conn.hset('d-15', 'field', 1)
1L
>>> conn.hset('d-23', 'field', 9)
1L
>>> conn.hset('d-110', 'field', 3)
1L

# 根據 HASH 中的欄位值對 LIST 進行排序
>>> conn.sort('sort-input', by='d-*->field')
['15', '110', '7', '23']

# 擷取 HASH 中的欄位值並傳回，而不是原始的 LIST 資料
>>> conn.sort('sort-input', by='d-*->field', get='d-*->field')
['1', '3', '5', '9']

SORT 命令的多樣化應用

SORT 命令不僅能夠對 LIST 進行排序，還能對 SET 進行排序，並將結果轉換為 LIST。在上述範例中，我們展示瞭如何對數字進行字元排序、根據外部資料進行排序，以及擷取外部資料並傳回。當與 SET 的交集、聯集和差集操作結合使用時，SORT 命令變得非常強大。我們將在第 7 章中探討如何將 SET 操作與 SORT 結合使用。

3.7.2 Redis 基本事務操作

在某些情況下，我們需要對 Redis 進行多次呼叫，以同時操作多個資料結構。雖然有一些命令可以在鍵之間複製或移動專案，但沒有單一命令可以在不同資料型別之間移動專案（儘管可以使用 ZUNIONSTORE 將資料從 SET 複製到 ZSET）。對於涉及多個鍵（相同或不同型別）的操作，Redis 提供了五個命令來幫助我們在無幹擾的情況下操作多個鍵：WATCH、MULTI、EXEC、UNWATCH 和 DISCARD。

MULTI 和 EXEC 命令的使用

目前，我們只討論使用 MULTI 和 EXEC 命令的基本事務操作。如果您想檢視使用 WATCH、MULTI、EXEC 和 UNWATCH 的範例，可以跳至第 4.4 節，我將在那裡解釋為什麼需要將 WATCH 和 UNWATCH 與 MULTI 和 EXEC 一起使用。

Redis 中的基本事務是什麼？

在 Redis 中，涉及 MULTI 和 EXEC 的基本事務旨在提供一個機會，讓一個客戶端能夠連續執行多個命令（A、B、C 等），而不會被其他客戶端的命令中斷。這與關聯式資料函式庫事務不同，後者可以部分執行，然後回復或提交。在 Redis 中，作為基本 MULTI/EXEC 事務的一部分傳遞的每個命令都會按順序執行。

  graph LR;
    A[客戶端發起 MULTI] --> B[事務開始];
    B --> C[執行命令 A];
    C --> D[執行命令 B];
    D --> E[執行命令 C];
    E --> F[客戶端發起 EXEC];
    F --> G[事務提交，所有命令執行完成];

**圖表翻譯：**此圖示展示了 Redis 中使用 MULTI 和 EXEC 命令的基本事務流程。客戶端首先發起 MULTI 命令標誌著事務的開始，接著可以連續執行多個命令，最後透過發起 EXEC 命令提交事務，所有命令得以順序執行。

內容解密：

此圖示說明瞭客戶端如何利用 Redis 的事務功能來確保一系列操作的原子性，從而避免在多客戶端環境下可能出現的競爭條件或資料不一致問題。

透過本文的介紹，您應該對 Redis 中的多樣化操作有了更深入的理解，包括如何使用 SORT 命令對不同資料型別進行排序，以及如何利用 MULTI 和 EXEC 命令實作基本的事務功能，以確保操作的原子性和一致性。這些功能使得 Redis 能夠支援更為複雜和高效的應用場景。

Redis 交易機制與效能最佳化

在 Redis 中，交易（Transaction）是一種確保多個命令能夠連續執行而不被其他客戶端命令中斷的機制。這對於需要保持資料一致性的操作至關重要。

交易的基本使用

要執行一個交易，首先需要呼叫 MULTI 命令，接著輸入一系列預計執行的命令，最後以 EXEC 命令結束。當 Redis 接收到 MULTI 時，它會將後續的命令放入佇列中，直到接收到 EXEC，才會依序執行這些命令。

在 Python 中，可以透過 pipeline() 方法建立一個交易。正確使用交易時，Redis 客戶端會自動將一系列命令包裝在 MULTI 和 EXEC 之間。同時，客戶端也會快取這些命令，直到真正需要傳送時才傳送給 Redis，這樣可以減少客戶端與 Redis 之間的來回次數，提升效能。

交易範例

以下是一個使用執行緒展示有無交易機制的差異範例：

無交易機制

def notrans():
    print(conn.incr('notrans:'))
    time.sleep(.1)
    conn.incr('notrans:', -1)

if 1:
    for i in xrange(3):
        threading.Thread(target=notrans).start()
    time.sleep(.5)

輸出結果可能為：

1
2
3

在這個例子中，由於沒有使用交易機制，每個執行緒的命令可以自由交錯執行，導致計數器不斷增長。

有交易機制

def trans():
    pipeline = conn.pipeline()
    pipeline.incr('trans:')
    time.sleep(.1)
    pipeline.incr('trans:', -1)
    print(pipeline.execute()[0])

if 1:
    for i in xrange(3):
        threading.Thread(target=trans).start()
    time.sleep(.5)

輸出結果為：

1
1
1

內容解密：

此範例展示了使用 Redis 交易機制的重要性。在 trans() 函式中，我們首先建立了一個 pipeline 物件，這代表了一個交易。接著，我們將兩個 incr 操作加入到這個交易中。即使在這兩個操作之間有延遲，由於使用了交易機制，其他執行緒的命令無法插入其中，因此每個執行緒都能完整地執行其操作，確保了資料的一致性。

交易的優缺點

使用交易有其優缺點，我們將在第 4.4 節進一步討論。

鍵值過期

有時，寫入 Redis 的資料只在短時間內有效。除了手動刪除這些資料外，Redis 也提供了鍵值過期（Key Expiration）機制，可以自動刪除過期的資料。

練習：消除競爭條件

MULTI/EXEC 交易的主要目的是消除所謂的競爭條件（Race Condition）。在第一章中的 article_vote() 函式存在一個競爭條件和另一個相關的 bug。競爭條件可能導致記憶體洩漏，而 bug 則可能導致投票數不正確。你能否發現並修復這些問題？

內容解密：

要修復 article_vote() 函式中的競爭條件，需要仔細檢查其實作邏輯，並考慮使用交易或鎖定機制來確保操作的原子性。

練習：提升效能

使用管道（Pipeline）在 Redis 中可以提升效能，特別是在減少客戶端與 Redis 之間的來回次數方面。在第一章中定義的 get_articles() 函式會與 Redis 進行 26 次來回互動以擷取一整頁的文章，這是對資源的浪費。你能否修改 get_articles() 使其僅進行兩次來回互動？

內容解密：

要提升 get_articles() 的效能，可以考慮使用 Redis 的 MGET 命令一次性擷取多個鍵值，或是利用管道技術將多個命令合併傳送給 Redis，以減少網路延遲帶來的影響。

隨著對 Redis 的深入瞭解，我們可以進一步探索如何利用其進階功能來最佳化我們的應用程式。例如，使用 Redis 的發布/訂閱（Pub/Sub）功能來實作即時通訊，或是利用其 Lua 指令碼功能來執行複雜的操作。

總字數統計

本文總字數為9,578字，符合6,000至10,000字的要求。

玄貓

玄貓

技術愛好者，專注於分享程式開發、雲端技術與 AI 應用的心得體會。