Redis Pub/Sub入門：パブリッシュ/サブスクライブ型メッセージングシステムの使い方 – Redisチュートリアル

このチュートリアルでは、Redisデータストアをパブリッシュ/サブスクライブ（Publish/Subscribe）型のメッセージングシステムとして活用する方法について解説します。

Redis Pub/Subシステムとは

Redisは、パブリッシュ/サブスクライブ（Pub/Sub）というメッセージングパラダイムを実装しています。このモデルでは、メッセージの送信者（パブリッシャー）は、特定の受信者（サブスクライバー）に直接メッセージを送るようには設計されていません。代わりに、パブリッシャーは特定の「チャネル」に対してメッセージを送信（パブリッシュ）します。その際、どの受信者が、あるいはそもそも受信者が存在するかどうかを意識する必要はありません。

一方、メッセージを受け取りたい受信者（サブスクライバー）は、1つ以上のチャネルを購読（サブスクライブ）することで関心を登録します。すると、そのチャネルにパブリッシュされたメッセージだけを受信できます。このときも、誰がメッセージを送ったのかを知る必要はありません。

Redisの用語では、チャネルへメッセージを発行する送信者をパブリッシャー（Publisher）、1つ以上のチャネルを購読してメッセージを受け取る受信者をサブスクライバー（Subscriber）と呼びます。メッセージの中身は任意で、単純なテキストでも、タスクに関する情報でも構いません。サブスクライバーはいくつでもチャネルを購読でき、パブリッシャーも任意のチャネルにメッセージを発行できます。

このようにパブリッシャーとサブスクライバーが疎結合（デカップリング）されていることで、システムのスケーラビリティと柔軟性が大きく向上します。

なお、RedisのPub/Sub機能は、Redisのキーバリューデータベースとはまったく関係がありません。データベース番号を含め、どのレベルでも干渉しません。たとえば、パブリッシャーがDBインデックス10上でメッセージを発行した場合でも、DBインデックス1上のサブスクライバーはそのメッセージを受信できます。

Redis Pub/Subの主要コマンド一覧

Redis Pub/Subに関連する重要なコマンドは以下のとおりです。

実行例

ここでは、redis-cliの3つの異なるインスタンスを使って、Redis Pub/Subシステムの動作を確認します。1つ目のクライアントはC1とC2の2つのチャネルを購読し、残りの2つのクライアントはそれぞれC1とC2のチャネルにメッセージを発行します。

1. 1つ目のクライアントがC1とC2のチャネルを購読

2. 2つ目のクライアントがC1チャネルに「Hello」を発行

3. 3つ目のクライアントがC2チャネルに「World」を発行

4. 1つ目のクライアントがC1とC2から配信されたメッセージを表示

このように、購読しているクライアントは、各チャネルに発行されたメッセージをリアルタイムで受け取れていることがわかります。

参考文献

1. Pub/Subコマンド公式ドキュメント

この記事が役に立った場合は、ぜひコメント欄でご感想をお聞かせください。また、他の方へのシェアも歓迎します。

次の記事 → Jedisライブラリを使ったRedis Pub/Subの実装例