Redis Pub / Sub：イントロガイド

• チャットルームでメッセージをリッスンするアプリ。
• 通知をSlackに転送するアプリ
• モバイルクライアントは、リアルタイムで何が起こっているかを確認するために使用されていました
• 後で分析するためにイベントを記録するログサービス

pub / subパターンは、サブスクライバーについてあまり考えないようにするのに役立ちます。 パブリッシャーで作業する場合 、 およびその逆。上記の例では、いくつかのサブスクライバーが1つのパブリッシャーからのメッセージに関心を持っていることを想像できます。サブスクライバーは、すべてを聞きたいと思うかもしれません。 出版社。

pub / subでは、パブリッシャーはサブスクライバーについて知る必要はありません。メッセージをチャネルにプッシュします。 （トピックと呼ばれることもあります 他のシステムでは）そしてmoveson。メッセージが公開されたときにそのチャネルでたまたまリッスンしているサブスクライバーは、メッセージを受信します。

サブスクライバーは、1つ以上のチャネルをリッスンし、メッセージが着信したときにそれに反応するように設計されています。サブスクライバーが公開されたメッセージのペースに追いつかない場合、一部のメッセージを見逃します。これは便利な設計です。システムを低速のサブスクライバーの容量を超えて拡張できます。パブリッシャーは、サブスクライバーの動作によって速度が低下することなく、迅速に移行できます。

Pub / subの目標：ワークロードではなく配信のスケーリング

Pub / subは、スケーリングソフトウェアで使用されるパターンです。どのようなスケーリングが役立つかを理解することが重要です。重要な違いは、pub/subandメッセージのキューイングです。 。

キューイングパターンでは、キュー（またはリスト In Redis）は、ワーカーのプールがリストからアイテムをポップして処理している間、処理されるメッセージをバッファリングします。このモデルでは、ワーカーのプールのサイズをスケーリングすると、各メッセージが1人のワーカーにのみ渡されるため、キューを処理する速度がスケーリングされます。すべてのワーカーは、特定のメッセージをまったく同じ方法で処理します。

一方、pub / subでは、システムはすべてのチャンネルのメッセージをすべてのサブスクライバーに配信しようとします。これは多対多のパターンであり、さまざまなサブスクライバーがメッセージに対して独自の処理を行います。1つは永続的なログに書き込み、1つはSlackチャネルに送信し、もう1つはローカルセールスオフィスでベルを鳴らします。

つまり、pub/subはメッセージdeliveryをスケーリングします 、およびキューイングはメッセージをスケーリングしますワークロード処理 。 Redisは、これらの両方の目標に頻繁に使用されます。 Redisを使用したキューイングの一般的な例については、Sidekiqを参照してください。

Redis pub/subの詳細

Pub / subは非常に長い間存在しているパターンであり、コアパターンは同じですが、特定の機能は実装ごとに大幅に異なります。

Redis pub / subは、軽量で高速な実装です。その設計を最もよく理解するには、ないいくつかの機能を確認すると便利です。 Redis pub / subの一部：

• 永続性や値のキャッシュはありません
• 配達保証はありません
• クラスターの最適化はありません…まだ

永続性なし：「しかし、チャットルームのようだと思った…」

ディスクに書き込まれる可能性のあるほとんどのRedis操作とは異なり、Redispub/subは非永続的です。公開されたメッセージはサブスクライバーに直接渡されてからドロップされ、Redisのメモリやディスク上にレコードは保持されません。

これは、Redis pub/subがチャットルームの実装によく使用されると聞いた新しいユーザーにとっては混乱を招く可能性があります。私たちの多くは、Slackのようなツールをチャットルームと考えています。ログインして最近のメッセージを確認してから、すべての新しいメッセージを受信します。実際、「最近のメッセージを表示する」はpub / subの一部ではなく、別の方法で処理する必要があります。 Pub / subは、新しいメッセージの配信のみを容易にします。この意味で、pub / subはライブストリームのようなものです。オンにすると情報を取得し始めますが、オンにする前に何が起こったのかについては何も学びません。余談ですが、インターネットリレーチャット（IRC）は、履歴やメッセージの保持が組み込まれていないpub / subモデルを使用します。そのため、チャットルームのメタファーは非常に一般的です。

実際、Redisとpub/subを使用してチャットルームを実装することもできます。そうすることで、メッセージが公開されるだけでなく、リストにもプッシュされるようになります。 ユーザーがメッセージ履歴を確認できるようにします。