問題タブ [reactor]

リアクター ループ内で複数のリッスン ソケット「サーバー」を起動する場合 - リアクター ループがブロックされるため、リッスン ソケット コールバックの 1 つでブロックが発生し、他のソケットが新しい接続の受け入れを停止すると想定しても安全ですか?

リスニングソケットごとに個別のルビープロセスを開始するのがベストプラクティスですか、それともこのユースケースをより適切に処理するための代替手段はありますか?

製品.NetReactorを使用して、製品の1つを難読化します。このツールは非常に同意しているため、悪意を持ってexeファイルに反映しようとすると、ゴミが返されるだけでなく、アプリケーションがクラッシュする可能性があります。これは良いことだと主張することもできますが（悪意のある人はコードを見ることができません）、プロファイラーやアンチウイルスなど、（パフォーマンスの問題を保護して見つけるために）良い意図を反映しようとするツールを時々目にします。当然のことながら、そのようなツールはコードを表示することも許可されるべきではありませんが、.NETまたは.NET Reactorツールで、適切な強度のツールへの難読化によって保護されているとしてexeにフラグを立てることは、これを検出でき、反映されない可能性があります。 。または、コードで自分が反映されていることを認識し、このexeを反映できないというメッセージを表示することは可能ですか（単にクラッシュするよりもはるかにユーザーフレンドリーです）

Twisted リアクターについていくつか質問があります。

1/ 原子炉をクラッシュ/停止/終了させるエラーはどのようなものですか? どのようなエラーが発生しないでしょうか?

2/ 2 つのリアクターがあり、それぞれが異なるプロトコルを実行しています。私はプロトコルAとBを持っています。

1 つのリアクターは、入力を処理するたびにプロトコル A の新しいインスタンスを作成します。プロトコル A のインスタンスにエラーが発生した場合、そのエラーはインスタンスにのみ影響し、リアクターはスムーズに動作し続けます。

もう一方のリアクターは、プロトコル B の 1 つのインスタンスのみを実行します (具体的には、標準 IO を処理するために使用します)。単純に次のようになります。

入力が何らかの形でプロトコル B にエラーを与えると、リアクター全体に影響します。その場合、原子炉は実際に停止しますか？

3/ 上記の 2 番目のリアクターの場合、エラーが検出された場合、プロトコル B の新しいインスタンスを作成して古いインスタンスを置き換えることは可能ですか?

私はReactorパターン（同時）を理解しようとしていますが、多くの例で彼らは「ワーカースレッド」について話しています。ワーカースレッドとは何ですか？それらは「通常の」スレッドとどのように異なりますか？そして、リアクターパターンにおけるそれらの役割は何ですか？

IRC ボットをローカル サーバーに実装しようとしています。私が使用しているボットは、Eric Florenzano のブログにあるものと同じです。これは簡略化されたコードです（実行する必要があります）

クライアント ファクトリに startedConnection メソッドを追加しました。これにより、適切なアドレス: ホストに到達して出力されます。次に、切断して clientConnectionLost に入り、次のエラーを出力します。

適切に動作している場合、コマンドの最初の引数として指定された適切なチャネルにログインする必要があります (たとえば、python module2.py botwar. は channel #botwar. になります)。チャネル内のいずれかが何かを送信すると、「こんにちは」と応答する必要があります。

サーバーでNGIRCを実行していますが、mIRC またはその他の IRC クライアントから接続すると動作します。

断続的に切断される理由について解決策を見つけることができません。理由についての助けをいただければ幸いです。ありがとうございました！

Cでlibevを使用して小さなWebサーバーを作成する場合、リアクターをブロックせずにファイルを提供する(開く、準備ができている、ソケットに書き込む)ための最良の戦略は何ですか?

一度にいくつかのブロックを読み取るようにいくつかの推奨事項がありますが、これが正しいアプローチであるかどうかはわかりません。

ありがとう、

twisted とその deferredGenerator を使ってクローラーを書きます。以下は私の質問に関するコードです:

そして、私はジェネレーターを使用します

私の質問は: 関数 'getPage' がタイムアウト エラーを取得した場合、エラーを処理してエラー ページを再度クロールするにはどうすればよいですか? 一度 getPage に addErrback を追加して getPage を呼び戻したいと思ったのですが、reactor の実行中に新しいイベントを受信しなくなったようです。

同じ質問に出くわした人はいますか？私はあなたの助けに感謝します

Ruby Grape を使用して API を作成していますが、次の問題に直面しています。新しい GET リクエストがあると、大量のデータが要求され、時間がかかります。その間、Reactor はブロックされ、リクエストが完了するまで新しいリクエストを処理できません。コードは非常に単純です。

get_users は TCP で別のシステムに接続し、JSON に変換された大量のデータを取得します。これは、サードパーティの gem を使用して行われます。この種の状況を処理するための最良の選択肢は何でしょうか?

私は、呼び出されたときに、ねじれたリアクター内のいくつかの並列コードの実行を単純に開始するセロリタスクを持っています。説明するためのサンプル (実行可能ではない) コードを次に示します。

(簡単にするために、タスクがワーカーによって受信されたときにリアクターが既に実行されていると仮定してください。ワーカー@worker_process_init.connectが起動するとすぐにシグナルを使用して、別のスレッドでリアクターを開始しました)

を呼び出すrun_task.delay()と、タスクはすぐに終了します (終了を待たずrun_task_in_reactor()に、リアクターで実行をスケジュールするだけなので)。そして、run_task_in_reactor()最終的に実行されると、do_something()またはdo_something_more()例外がスローされる可能性がありますが、これは見過ごされます。

pikaたとえば、キュ​​ーから消費するために使用して、内部で ACK を使用しdo_something_more()て、ワーカーにタスクの正しい完了を通知させることができます。ただし、セロリ内では、これは不可能のようです (または、少なくとも、同じ効果を達成する方法がわかりません)。

また、使用しているサードパーティ コードの要件であるため、リアクターを削除できません。同じ結果を達成する他の方法も高く評価されます。