Java JSch实现向Linux运行的Perl脚本输入参数问题

我完全懂你遇到的卡点——当Perl脚本运行到需要手动输入的环节时，程序直接僵住，不知道怎么把输入传递给远程运行的脚本对吧？其实核心问题是JSch的ChannelExec不会自动处理交互式输入，咱们得手动接管输入流，把需要的内容主动发送给远程进程。下面给你一步步拆解解决方案，附完整代码示例：

关键思路 #

1. 获取远程进程的输入流：ChannelExec的getOutputStream()方法返回的流，就是咱们用来向远程Perl脚本写入输入的通道（别搞混，这个流是"输出"到远程进程，对应远程进程的标准输入）。
2. 异步处理远程输出：如果只写输入不读输出，远程进程的输出缓冲区满了也会卡住，所以必须开线程单独读取stdout和stderr。
3. 动态匹配输入时机：通过读取远程脚本的输出提示（比如"请输入密码:"），再发送对应的输入，比盲目提前写入更可靠。

完整代码示例 #

package test_jar;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;

public class RemotePerlRunner {
    public static void main(String[] args) {
        // 替换成你的服务器信息和脚本路径
        String host = "your_linux_host";
        String user = "your_username";
        String password = "your_password";
        String perlScript = "/opt/scripts/your_interactive_script.pl";

        try {
            // 1. 建立SSH会话
            JSch jsch = new JSch();
            Session session = jsch.getSession(user, host, 22);
            session.setPassword(password);
            // 生产环境建议去掉这行，改用密钥认证
            session.setConfig("StrictHostKeyChecking", "no");
            session.connect();

            // 2. 创建执行通道
            ChannelExec channel = (ChannelExec) session.openChannel("exec");
            channel.setCommand("perl " + perlScript);

            // 3. 获取向远程脚本写输入的流
            BufferedWriter inputWriter = new BufferedWriter(
                new OutputStreamWriter(channel.getOutputStream(), "UTF-8")
            );

            // 4. 开线程读取远程脚本的标准输出（用来捕获输入提示）
            new Thread(() -> {
                try {
                    InputStream stdout = channel.getInputStream();
                    BufferedReader stdoutReader = new BufferedReader(new InputStreamReader(stdout, "UTF-8"));
                    String line;
                    while ((line = stdoutReader.readLine()) != null) {
                        System.out.println("[远程输出] " + line);
                        
                        // 根据脚本的输入提示，发送对应内容
                        if (line.contains("Enter your username:")) {
                            inputWriter.write("my_test_user\n");
                            inputWriter.flush(); // 必须刷新，不然数据会留在缓冲区
                        } else if (line.contains("Enter your password:")) {
                            inputWriter.write("my_test_pass\n");
                            inputWriter.flush();
                        }
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }).start();

            // 5. 开线程读取远程脚本的错误输出
            new Thread(() -> {
                try {
                    InputStream stderr = channel.getErrStream();
                    BufferedReader stderrReader = new BufferedReader(new InputStreamReader(stderr, "UTF-8"));
                    String line;
                    while ((line = stderrReader.readLine()) != null) {
                        System.err.println("[远程错误] " + line);
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }).start();

            // 6. 启动通道并等待执行完成
            channel.connect();
            while (!channel.isClosed()) {
                Thread.sleep(1000);
            }
            System.out.println("脚本执行完成，退出码: " + channel.getExitStatus());

            // 7. 关闭资源
            inputWriter.close();
            channel.disconnect();
            session.disconnect();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

重要注意事项 #

• 流的编码：如果你的Perl脚本有中文提示，一定要指定UTF-8编码，避免乱码导致无法匹配输入提示。
• 生产环境安全：不要跳过主机密钥检查，建议改用SSH密钥认证替代密码登录，更安全。
• 强制刷新缓冲区：每次调用write()后必须调用flush()，否则输入内容会留在本地缓冲区，远程进程永远收不到。
• 异步读取的必要性：JSch的输入输出流是阻塞的，如果主线程卡在读取输出，就没法处理输入；反过来如果卡在写输入，输出缓冲区满了也会导致远程进程挂起。

内容的提问来源于stack exchange，提问作者Panderas