JSch コマンド出力の読み取りの問題について
JSch を使用して提供された Java コードで、読み取り中にプログラムがハングする状況が発生しました。コマンド出力をキャプチャするために使用されるリーダー ストリームから。この記事では、この問題の原因と解決策について説明します。
問題分析
根本的な問題は、実行されたコマンドによって生成された出力を継続的に消費しないことから発生します。 JSch コマンドは出力を内部バッファに蓄積します。バッファが消費される前にいっぱいになると、バッファがクリアされるのを待ってコマンドがハングするデッドロックが発生する可能性があります。
解決策
これを解決するには、コマンドが完了するのを待っている間でも、コマンドの標準出力ストリームと標準エラー ストリームの両方を継続的に読み取る必要があります。これにより、出力バッファがいっぱいになることがなく、コマンドがハングすることがなくなります。
サンプル コード
このソリューションを組み込んだコードの拡張バージョンを次に示します。
<code class="java">ChannelExec channel = (ChannelExec)session.openChannel("exec"); channel.setCommand(...); // Set the command to execute ByteArrayOutputStream outputBuffer = new ByteArrayOutputStream(); ByteArrayOutputStream errorBuffer = new ByteArrayOutputStream(); InputStream in = channel.getInputStream(); InputStream err = channel.getExtInputStream(); channel.connect(); byte[] tmp = new byte[1024]; while (true) { while (in.available() > 0) { int i = in.read(tmp, 0, 1024); if (i < 0) break; outputBuffer.write(tmp, 0, i); } while (err.available() > 0) { int i = err.read(tmp, 0, 1024); if (i < 0) break; errorBuffer.write(tmp, 0, i); } if (channel.isClosed()) { if ((in.available() > 0) || (err.available() > 0)) continue; System.out.println("exit-status: " + channel.getExitStatus()); break; } try { Thread.sleep(1000); } catch (Exception ee) { } } System.out.println("output: " + outputBuffer.toString("UTF-8")); System.out.println("error: " + errorBuffer.toString("UTF-8")); channel.disconnect();</code>
この例では、while ループはコマンド (channel.isClosed()) のステータスを監視しながら出力ストリーム (in および err) を継続的に読み取ります。これにより、コマンドが大量のデータを生成する場合でも、すべての出力が確実にキャプチャされます。
以上が出力の読み取り中に JSch コマンドがハングするのはなぜですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。