問題タブ [em-http-request]

何が起こるかを正確に示す要点を作成しました。
https://gist.github.com/4418148
Ruby の 'net/http' ライブラリと 'socksify/http' を使用するバージョンをテストしたところ、完全に機能しましたが、EventMachine バージョンが予期しない結果を返す場合。
Tor Browser の応答は正しいですが、EventMachine を使用すると正しくありません!

応答を返しますが、プロキシの有無にかかわらず、ブラウザー、net/http 経由で要求を送信したときに返された応答と同じではありません。

便宜上、ここにも貼り付けます。

説明をいただければ幸いです。

RabbitMQ キューのメッセージを取得しています。各メッセージは、リクエストしたい URL です。現在、AMQP gem を使用してキューをサブスクライブし、EventMachine を使用しているため、em-http-request ライブラリを使用して http 要求を作成しています。ここのドキュメントによると: https://github.com/igrigorik/em-http-request/wiki/Parallel-Requests 以下は非同期の http-requests を発行します:

したがって、RabbitMQ キューをサブスクライブすると、次のコードが得られます。

これにより、em-http-request ドキュメントで説明されている方法と同様に、新しい変数が動的に作成され、新しい http リクエストが作成されます。しかし、リクエストが実際に非同期で行われているかどうかをテストする方法はありますか? get リクエストが発生するたびにコンソールに書き込み、応答を待たずにそれらが次々と発生するのを確認できるようにすることはできますか?

1 秒あたりの呼び出し数が制限された API があります (100 秒あたり 100 リクエスト)。em-http-request を (理想的には Redis で) 利用して、そのような呼び出しを可能な限り最速で行うにはどうすればよいですか (API レート制限を超えないようにするには?)。

シナトラと並列の em-http-request を扱うのは初めてです。そして、1つの結果に結合/マージする方法と、EventMachine.stopのタイミングがわかりませんか? . このことを考慮：

UDP パケットをリッスンしている EventMachine を実行しています。UDP パケットを受信するたびに、REST 呼び出しを使用してデータをデータベースに転送したいと考えています。receive_dataメソッドが REST 呼び出しを介してデータを転送する EM::Connection サブクラスを作成しました。

データの頻度は非常に高いため、リクエスト間の接続を再利用し (「キープアライブ」を使用)、可能であればパイプラインも使用したいと考えています。異なる通話間で接続を共有するにはどうすればよいでしょうか?

現在、私の UDPHandler は次のようになっています。

このクラスは次のように呼び出されます。

request オブジェクトをクラス変数にすることも考えましたが、eventmachines のコンテキストではそれは良い考えではないと思います。またはそれは？

Ruby EventMachine と em-http-request を使用して、異なるスレッドからトリガーされた並列 HTTP同期要求を実行したいと考えています。

アイデアは、EM.next_tick のおかげで、単一のリアクターを独自のスレッドで実行し、HTTP 要求をイベント キューで完了するようにプッシュすることです。

すべての呼び出しのパターンは次のようになります

リクエストを同期させるために、ファイバーを使用しようとしましたが、失敗しました。要求が接続に失敗するか、要求は完了しますがイベント ループを終了しません。

コールバックで EM.stop を呼び出したくありません。これは、並行して実行されている他のリクエストが台無しになるためです。また、リアクターを実行したいときに、これ以上リクエストを処理する必要がないと判断するまでリアクターを停止することにもなります。

EventMachine と em-http-request をこの方法で使用しようとしている人はいますか? EventMachine はこのユースケースをサポートできますか?