私がやろうとしているのは、Netty を使用して Web サーバーを実装し、HDFS への大きなファイルのアップロードを HDFS ファイルとして保存することです。
私の基本的なワークフローは次のとおりです。
エンド ユーザーが HTTP PUT/POST リクエスト (ペイロードは 1GB など) を私の Netty サーバーに送信します。
サーバーは HTTP 接続を受け入れ、メソッド/URI/ヘッダーを解析します
サーバーは DFSClient で HDFS を呼び出し、ファイルを作成してハンドルを取得します (DFSClient.create はブロッキング呼び出しです)。
サーバーは HTTP 要求で残りのアップストリームを受信し、チャンクごとに HDFS ハンドルに書き込みます (各チャンクを HDFS ハンドルに書き込むことはブロッキング コールです)。
サーバーは HDFS ハンドルを閉じ、クライアントに応答を返します (HDFS ハンドルを閉じると呼び出しがブロックされます)
上記の手順を実行する際に問題が発生しています。Netty でブロック呼び出しを効率的に行う (イベント ループ全体をできるだけブロックしない) 最善の方法がわからないためです。
上記のロジックを実装する正しい方法を誰かに教えてもらえますか? よろしくお願いします！