Redis 7のSharded Pub/Subは、複數(shù)のスレッドにメッセージトラフィックを配布することにより、Pub/Subスケーラビリティを向上させます。従來(lái)のRedis Pub/Subは、高負(fù)荷の下でボトルネックになる可能性のあるシングルスレッドモデルによって制限されていました。シャード付きパブ/サブを使用すると、チャネルは特定のI/Oスレッドに割り當(dāng)てられたシャードに分割されます。各スレッドは、割り當(dāng)てられたシャードのメッセージ配信を処理し、競(jìng)合を削減し、パフォーマンスを向上させます。キーポイントは次のとおりです。1）ハッシュによるチャネル間マッピング。 2）構(gòu)成可能な數(shù)のシャード。 3）シャード付きサブスクリプションのSSUBScribeの使用。 4）パブリッシュ中の自動(dòng)シャード。リアルタイムチャットシステムやIoTプラットフォームなど、多くのチャネルを備えたアプリケーションに最適です。それを使用するには、購(gòu)読をssubscribeに置き換えますが、パブリッシュは変更されていません。クライアントはシャードに明示的にオプトインする必要があり、両方のモードは移行中に共存できます。

Redis 7のSharded Pub/Subは、従來(lái)のRedis Pub/Sub Systemの制限の1つであるスケーラビリティに対処する新機(jī)能です。 Redisをリアルタイムメッセージングに使用していて、特に高負(fù)荷の下で複數(shù)のチャネルまたはパターンを持っている場(chǎng)合、パフォーマンスの問(wèn)題にヒットしたことがあるかもしれません。 Sharded Pub/Subは、メインスレッドを介してすべてをルーティングする代わりに、利用可能なすべてのイベントループ（またはスレッド）にPub/Sub Trafficを広げることで役立ちます。

なぜそれが必要だったのか

Redisは常にコマンドを処理するためにシングルスレッドモデルを使用してきました。これは、物事をシンプルに保ちますが、大量のパブ/サブメッセージを処理するときにボトルネックになる可能性があります。以前のバージョンでは、RedisがスレッドI/O Enabledでコンパイルされたとしても、すべてのPUB/サブオペレーションがメインスレッドを通過(guò)しました。つまり、多くのサブスクライバーにメッセージを公開(kāi)または配信することで、他の操作をブロックする可能性があります。

Redis 7では、これは変更されます。

シャードされたパブ/サブはどのように機(jī)能しますか？

Sharded Pub/Subの背後にある核となるアイデアは、シャードです。複數(shù)のスレッドにわたってメッセージ配信の責(zé)任を分配します。これがどのように機(jī)能しますか：

• Redisは、チャネルを「Shards」と呼ばれる論理グループに分割します。
• 各シャードは、特定のI/Oスレッドに割り當(dāng)てられます。
• クライアントがチャネルにサブスクライブすると、サブスクリプションはそのチャネルの原因となるシャード（およびスレッド）に登録されます。
• チャネルに公開(kāi)されたメッセージは、同じスレッドで処理および配信され、クロススレッド同期オーバーヘッドを避けます。

このようにして、RedisはCPUコアの數(shù)が増えるにつれてPUB/サブパフォーマンスをより効果的に拡張できます。

いくつかの重要なポイント：

• チャネル名は、ハッシュ機(jī)能を使用してシャードにマッピングされます。
• シャードの數(shù)は、 redis.conf （ pubsub_shard_streams_per_node ）で構(gòu)成できます。
• 加入者は、 shardsubscribedに登録されたチャネルからメッセージを受信します。そのためには別のコマンドがあります： SSUBSCRIBE 。

いつ使用する必要がありますか？

Sharded Pub/Subの使用を検討する必要があります。

• アプリケーションは多數(shù)のチャネルを使用します。
• パブ/サブの使用量が多いため、パフォーマンスのボトルネックが発生します。
• メッセージの配布だけでインスタンスを追加することなく、レディスを水平にスケーリングする必要があります。

次のようなアプリケーションで特に便利です。

• 多くの部屋やトピックを備えたリアルタイムチャットシステム。
• 多くのユーザーに更新を放送する通知サービス。
• 各デバイスが獨(dú)自のチャネルにステータス更新を公開(kāi)するIoTプラットフォーム。

ユースケースが多くのサブスクライバーを持ついくつかのチャネルしか関與していない場(chǎng)合、標(biāo)準(zhǔn)のPub/Subはまだ問(wèn)題ない場(chǎng)合があります。ただし、チャネルの數(shù)のスケーリングを開(kāi)始したり、メッセージごとに低いレイテンシが必要になると、シャードが適切になります。

シャード付きパブ/サブの使用方法

シャード付きPub / Subを使用するのは簡(jiǎn)単ですが、クラシックSUBSCRIBE / PUBLISHフローとは異なります。これがあなたがする必要があることです：

• シャード付きの方法でチャネルを購(gòu)読するには、 SUBSCRIBE代わりにSSUBSCRIBE使用します。
• シャードチャンネルに公開(kāi)するには、 PUBLISHを使用します。シャードは、チャネル名に基づいて自動(dòng)的に処理されます。
• 登録解除するには、 SUNSUBSCRIBEを使用してください。

例：

 ＃シャードチャネルを購(gòu)読します
client1> subscribe mychannel

＃メッセージを公開(kāi) - 正しいスレッドで処理される
client2> MyChannel「Hello Sharded World」を公開(kāi)

留意してください：

• クライアントは、シャードを利用するには、 SSUBSCRIBE明示的に使用する必要があります。
• クラシックSUBSCRIBEとSSUBSCRIBE 、同じ接続で混合することはできません。
• Redis 7に更新されていないツールまたはクライアントは、変更されていない限り、Sharded Pub/Subを使用しません。

また、Redis 7は両方のモードをサポートしているため、アプリの部分を徐々に移行して、従來(lái)のモデルに他のサブスクリプションを維持しながら、シャード付きサブスクリプションを使用できます。

最終的な考え

Redis 7のSharded Pub/Subは、Redisのリアルタイムメッセージング機(jī)能に非常に必要なスケーラビリティの改善をもたらします。さまざまなスレッドにチャネルを割り當(dāng)てることにより、Redisはシンプルさや信頼性を犠牲にすることなく、はるかに高いスループットを処理できます。

特にPUB/サブヘビー環(huán)境でRedisを大規(guī)模に使用している場(chǎng)合、この機(jī)能をアップグレードして試す価値があります。

それは基本的にそれです - それほど複雑ではありませんが、メッセージングプラットフォームとしてのRedisにとって間違いなく大きな前進(jìn)です。

以上がRedis 7のSharded Pub/Subとは何ですか？の詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國(guó)語(yǔ) Web サイトの他の関連記事を參照してください。