遠心分離機は勢いを増しています

こんにちは



数か月前、私はオープンソースのCentrifugeプロジェクトについて記述したHabréの記事を公開しました。 これは、接続されているクライアントに（主にWebブラウザーから）メッセージをリアルタイムで送信するサーバーであることを思い出させてください。 Pythonで書かれています。



それ以来、私は自由な時間にプロジェクトに取り組み続け、蓄積した私の考えや変更を共有する準備ができました。







当初、遠心分離機はオリジナルのプロジェクトでした。 既存のアナログの機能を再現することについてあまり心配することなく、私は自分にとって正しいと思われるコードを書きました。 その結果、メッセージが顧客に配信され、すべてが機能しましたが、！ これをすべて使用するのは便利でしたか？ いや！



6月下旬、 Serge Kovalによるすばらしい記事（ PythonおよびリアルタイムWeb ）に出会いました。 驚いたことに、その時点で私はフェイの存在について知りませんでした。 この記事は、この素晴らしいプロジェクトと、現在の状態のCentrifugeがリアルタイムのWebアプリケーションを開発する際の生活を大幅に簡素化しないという事実の理解をもたらしました。



それ以来、私はユーザビリティーに目を向け 、 pusher.com 、 pubnub.comおよびFayeに目を向けて遠心分離機を起草してきました。



より成熟した高度なアナログがすでに存在する場合、なぜゼロからコードを記述する必要があるのか​​という疑問は避けられません。 いくつかの理由があります。

• これは面白いです。 このプロジェクトでは現在、Tornado、ZeroMQ、Redis、SockJS、Bootstrap 3を使用しています。
• Pusher.comとPubnub.comはクラウドサービスです。常に可能であるとは限りません/ is_sense /サードパーティに依存したいです。 サーバー側に変更を加えることができません。
• Pythonに類似物は見つかりませんでした（おそらく知っていますか？）、FayeバックエンドはRubyまたはNodeJSです。 チャンネルのサブスクリプションを承認するには、これらの言語で拡張機能を作成する必要があります。 Webアプリケーションのバックエンド言語からより独立したソリューションを作成して、必要な機能をすぐに使用できるようにしたかったのです。
• アナログにはない機能。 これは、チャネルの動作を決定する名前空間の存在です。 プロジェクト、その設定、およびチャネル内のメッセージをリアルタイムで監視する機能を管理するためのWebインターフェイス。

次に、遠心分離機に関する前の記事の執筆以降に発生した変更について説明します。



プロジェクト、名前空間、およびその設定の構造は、標準のPythonライブラリの一部であるデータベースであるSQLiteにデフォルトで保存されるようになりました。 したがって、1台のマシンでCentrifugeプロセスを開始するとき、以前のようにPostgreSQLまたはMongoDBをインストールする必要はなくなりました。 遠心分離機は中小規模のプロジェクトで使用するために設計されているため、1台のマシンで十分なはずなので、これは重要かつ必要な変更だと思います。



少し先に進んで、構成ファイルに記述されている構造で遠心分離機を起動します。 同時に、Webインターフェイスから動的に変更を行って保存する機能は失われますが、外部ストレージへの依存関係はありません。 この機能は、開発にも非常に役立ちます。



プレゼンスと履歴のサポートが登場しました-現在、チャンネルに現在接続しているユーザーを見つけたり、チャンネルに送信された最新のメッセージを受信したりできます。 Redisはこのデータを保存するために使用されます。 Redisが構成されていない場合、クライアントはデータを使用できなくなり、何も壊れません。



質問です。 現在、Centrifugeはプロセスのいくつかの間の通信にZeroMQ PUB / SUBソケットを使用しています。 おそらく、Redisは接続されたクライアントとメッセージ履歴に関する情報のリポジトリとしてゲームに参入したため、ZeroMQの代わりにCentrifugeプロセス間の通信にPUB / SUB機能を使用する価値がありますか？ 私が見た唯一のベンチマークでは、ZeroMQはRedisよりもパフォーマンスが優れています。

したがって、現時点ではすべてをそのままにしておきました。 ただし、これは物議を醸す重要なポイントです。



今でも、クライアントをチャネルに接続（切断）する（チャネルから）メッセージを受信できます。 すてきなこと。



最後に、おそらく最も重要なこと-javascriptクライアントが登場しました-Centrifugeプロトコルのラッパーです。 Oliver Caldwellによって書かれたEvent Emitterに基づいています。 現在、ブラウザからの遠心分離機との対話は非常に簡単です。 このようなもの：

var centrifuge = new Centrifuge （ {

//認証設定

} ） ;



遠心分離機。 on （ 'connect' 、 関数 （ ） {

//確立された遠心分離機への接続



varサブスクリプション=遠心分離機。 subscribe （ 'python：django' 、 function （ message ） {

//チャネルから新しいメッセージを受信したときに呼び出される関数

} ） ;



サブスクリプション。 on （ 'ready' 、 関数 （ ） {

サブスクリプション。 存在 （ 関数 （メッセージ） {

//チャネルに接続しているクライアントに関する情報を受け取りました

} ） ;

サブスクリプション。 履歴 （ 関数 （メッセージ） {

//最新のチャンネル投稿の履歴

} ） ;

サブスクリプション。 on （ 'join' 、 function （メッセージ） {

//新しいクライアントがチャネルに接続するときに呼び出されます

} ） ;

サブスクリプション。 on （ 'leave' 、 function （メッセージ） {

//クライアントがチャネルから切断すると呼び出されます

} ） ;

} ） ;



} ） ;



遠心分離機。 on （ 'disconnect' 、 関数 （ ） {

//遠心分離機への接続が失われます

} ） ;



遠心分離機。 接続 （ ） ;

この例では、認証設定は船外に残されています（それらについてはドキュメントで確認できます ）。 また、チャネルの名前にも注意してください。これは、接続する前に管理インターフェースで作成する必要があるネームスペース名で構成されます。この場合はpython



です。 チャンネル名自体は後に示されます-この場合、それはdjango



です。 名前空間は、それに属するすべてのチャネルの設定を決定します。 プロジェクトの設定では、デフォルトのネームスペースを選択できます。JavaScriptコードでは、ネームスペースの名前を明示的に指定できません。 つまり、python名前空間がプロジェクトのデフォルトである場合、次のように記述できます。

遠心分離機。 on （ 'connect' 、 関数 （ ） {

varサブスクリプション=遠心分離機。 subscribe （ 'django' 、 function （ message ） {

コンソール。 ログ （メッセージ） ;

} ） ;

} ） ;

この種のアプリケーションでの認可は、おそらく最も難しい部分です。 前述したように、Fayeは特定のチャネルへのアクセスを保護するためにNodeJSまたはRubyで拡張機能を記述する必要があります。 プライベートチャンネルのPusher.comは、次のスキームを提供します。







プライベートチャネルにサブスクライブしようとすると、AJAX要求がチャネル名とともにアプリケーションのバックエンドに送信されます。 アクセスが許可されている場合は、署名付きの応答を返す必要があります。応答は、チャンネル名とともにプッシャーに直接送信されます。 ここでの利点は、ほとんどの場合、AJAXリクエストを受信した時点のアプリケーションに現在のユーザーのオブジェクトが既に含まれていることです（たとえば、Djangoではrequest.user



）。



遠心分離機のアプローチは少し異なります。 現在のユーザーの識別子は、接続時に1回送信されます。プロジェクトIDとトークンとともにjavascriptクライアントを構成するときに指定します。 トークンは、プロジェクトの秘密鍵（アプリケーションのバックエンドのみが知る必要がある）、プロジェクトID、およびユーザーIDに基づいて生成されるHMACです。 トークンは、送信されたプロジェクトIDとユーザーIDの正当性を検証するために必要です。 将来的には、プライベートチャネルにサブスクライブするときに、Centrifugeは文字列のユーザーID、名前空間名、およびチャネル名を使用してアプリケーションにPOSTリクエストを送信します。 したがって、承認ハンドラー関数で最初に行うことは、IDによってユーザーオブジェクトを取得する必要があることです。



承認に関するもう1つの重要な点は、複数のチャネルにサブスクライブするために、クライアント側でsubscribe



機能を数回呼び出す必要があることです。 チャネルがプライベートである場合、そのような各サブスクリプションはアプリケーションへのPOSTリクエストにつながります。 改善したい動作が最適化されていません。 しかし、同じpusher.comは、そのようなケースはまれではあるが顧客の要件の1つであると認識しており、まだこの問題を完全には解決していません。 ここで私はまだ正しい解決策を探しています。



誰もキャンセルしていないプライベートデータを保護する別の方法に注目したいと思います。 たとえば、アプリケーションユーザーごとに個別のプライベートチャネルを作成するには、秘密キーとユーザーIDに基づいて推測しにくいチャネル名を生成できます。 この場合、少なくともあなたの顧客がプライベートチャンネルの名前を共有する利益をもたらさない限り、追加の許可なしで行うことはかなり可能です:)



チャンネルに投稿する前に、カスタムの非同期関数（トルネードデコレータ@coroutine



フレーム化）を追加することができます。 この関数内では、Noneを返すなど、メッセージに対して何でもできます。これにより、メッセージの発行をキャンセルします。 ただし、公開後に呼び出されるハンドラーを追加する同様の機会があるため、おそらくこれは誰にとってもほとんど役に立ちません。 これはかなり低レベルの介入であり、PythonとTornadoの知識が必要です。



最も単純な場合の遠心分離機のインストールは、virtualenv内の1つのpip install centrifuge



コマンドになります。 ただし、ZeroMQ（libzmq3）とPostgreSQLのdevパッケージをマシンにインストールする必要があります（PostgreSQLサーバー自体はオプションです）。 PYPIからのインストール中に発生する可能性のある問題とその解決方法については、ドキュメントに記載されています 。 1つのプロセスは、 centrifuge



コマンドによってcentrifuge



されます。 ただし、戦闘環境を実行するには、重要なセキュリティ設定が含まれているため、構成ファイルが必要です。 また、複数のプロセスを開始する場合は、追加のコマンドラインオプションを使用せずに実行することはできません。



ドキュメントのこのセクションでは 、Centrifugeの仕組み、起動オプション、ブラウザから接続するときに指定するアドレスなどを可能な限り詳細に説明しようとしました。 英語で、本当に。



まだ負荷テストを実行していません。 私はすぐにベンチマークに入ることを望みます。 フェイと比較するのは面白いです、PYPYでローンチするのは面白いです。 もちろん、あらゆる種類のエラー耐性に取り組み続け、Pythonコードとjavascriptクライアントを改善する必要があります。 今すぐ参加しよう！



ご清聴ありがとうございました！