問題タブ [asynchttpclient]

次のコードがあります

問題は、GetUrl メソッド (HttpClient の GetStringAsync を使用) が TaskCacelledException をスローすることですが、GetUrl2 メソッド (WebClient の DownloadStringTaskAsync を使用) は正しく実行されます。これは が原因using statementですか? 私は何が欠けていますか？

編集。この例では、これがコンソール アプリケーションであるため、タスクで Result を呼び出しています。たとえば、イベント ハンドラーで結果を待機するのが最善であることがわかっています。

Java アプリがあり、newrelic エージェント バージョン 3.12 を使用して監視しています。AsyncHttpClient を使用して、アプリケーションで外部 HTTP 呼び出しを行います。そして、ここに私が使用する AsyncHttpClient バージョンの詳細があります

com.ning

async-http-クライアント

1.7.24

newrelic は、AsyncHttpClient を使用して行った発信呼び出しのメトリクスをキャプチャしていません。newrelic の Java エージェントは AsyncHttpClient をサポートしていると思います。私は何が欠けていますか？

こんにちは、ここの指示に従いました: http://hc.apache.org/httpclient-3.x/logging.htmlサイトで見つけることができる唯一のログの指示だったので、それでもログをオンにすることができませんでしたhttpasyncclient の場合。非同期ではなく、典型的なhttpclientで機能します。ありがとう。

プロジェクトの目的のために、開発には Java 1.6 を使用する必要があります。非同期クライアント jar ファイルを使用してプロジェクトに組み込み、非同期機能を実現し、Java 1.6 を使用して JAR を開発およびエクスポートしました。この jar は、Java 7 で実行されている別の Web プロジェクトのビルド パスに含まれています。Java 7 64 ビットおよび tomcat7 64 ビットで正常に動作しています。ただし、Java 7 32 ビットおよび tomcat7 32 ビットを使用すると、次のエラーが表示されます。

プロジェクトで次のjarを使用しました

この例外を解決する方法はありますか? 提案をありがとう。

asyncのメソッドを呼び出しているにもかかわらず、このコードがブロックされて同期的に実行されるため、何か間違ったことをしているに違いありませんGetStringAsync。どんな助けでも、理由を理解するのに本当に役立ちます:

これは、 httpclient.GetStringAsync ブロッキングの下に投稿されたコードの更新バージョンです。

問題は、タスクがキャンセルされたにもかかわらず、キャンセルがいつ行われたかAwait Task.WhenAll(tasks)ですfinally。キャンセルを押すとタスクのキャンセルが表示され、接続が 0 に減少することもわかりますが、最終的な推測でWhenAllはまだいくつかのタスクが実行されていると考えられます。

コードは次のとおりです。

更新: @I3arnon の提案に基づいて質問を変更しました。

しかし、現在、以下のコードには 3 つの問題があります。

1. TransformBlock署名と本文の場所がわからないため、コードはコンパイルされません。オブジェクトが作成されていないため、内部に配置loadすると、呼び出されたときに null 例外が発生します。

2. 複数の URL を並行して起動する方法

3. CancellationTokenが拡張機能に渡されますが、ジョブを実行する内部メソッドには渡されないため、キャンセルを確実に行うにはどうすればよいでしょうか。

Apache の HttpAsyncClient を使用して、着信要求を別のサーバーにプロキシまたはリレーしています。簡単なケースが機能しています（以下のサンプルコード）。

問題は、Future<HttpResponse>が応答をメモリに保持し、読み取りが完了するまで待機してから完了することです。非常に大きな応答本文を持つ呼び出しがいくつかあるので、私がやりたいのは、応答全体をメモリに保持せずに、本文のコンテンツを受信したときに渡すだけの「パイプライン」または「ゼロコピー」戦略です。

Apache Http Client はZeroCopyPostと を提供しますが、これらはストリーム (つまり、応答の OutputStream) ではなくZeroCopyConsumer動作します。Files

リモート応答からのバイトを元の応答に直接戻すコードを作成するにはどうすればよいですか?

これまでの私のコード:

これを行うための直接的なサンプル コードを見つけるのに苦労していますが、コメントにリンクされているサンプルは、さらに多くのことを教えてくれます。答えはAsyncByteConsumerを使用することに沿っていると思います

私は正しい軌道に乗っていますか？ゼロコピー戦略を使用して、中継された応答から元の応答にボディバイトを渡すように拡張するにはどうすればよいですか?

次のコードがあります。

「myaddress」が利用できない状況をキャッチしたい。プログレスがアクティブなときに HttpSendProgress メソッドが呼び出されるため、このメソッドをチェックインできません。「myaddress」が利用可能かどうかを確認する方法。前回 HttpSendProgress がいつ呼び出されたかを確認するために、もう 1 つのスレッドを開始するという考えがあります。しかし、おそらく標準的な方法はありますか？