docker-java SDK实现Docker容器exec stdin持续交互方案咨询

方案一：使用docker-java原生ExecStartResultCallback实现持续交互 #

docker-java本身支持带stdin的exec会话持久交互，不需要自行实现HTTP劫持，核心是用ExecStartResultCallback配合读写流分离处理，示例代码如下：

// 1. 创建exec实例，开启stdin/stdout/stderr挂载
ExecCreateCmdResponse execCreateResp = dockerClient.execCreateCmd(CONTAINER_NAME)
        .withCmd("bash")
        .withAttachStderr(true)
        .withAttachStdout(true)
        .withAttachStdin(true)
        .withTty(true) // 注意要和后续exec启动的Tty参数保持一致
        .exec();

// 2. 定义管道流用于后续持续写入stdin
PipedInputStream stdinPipeIn = new PipedInputStream();
PipedOutputStream stdinPipeOut = new PipedOutputStream(stdinPipeIn);

// 3. 定义结果回调，可自定义处理输出内容
ExecStartResultCallback callback = new ExecStartResultCallback(System.out, System.err) {
    @Override
    public void onNext(Frame frame) {
        // 此处可自定义捕获输出内容，默认实现为打印到控制台
        super.onNext(frame);
    }
};

// 4. 启动exec会话，绑定stdin输入流
dockerClient.execStartCmd(execCreateResp.getId())
        .withDetach(false)
        .withTty(true)
        .withStdIn(stdinPipeIn)
        .exec(callback);

// 5. 按需发送命令，每条命令末尾加换行符触发执行
// 发送第一条命令
stdinPipeOut.write("ls -alth\n".getBytes(StandardCharsets.UTF_8));
stdinPipeOut.flush();
Thread.sleep(3000);
// 发送第二条命令
stdinPipeOut.write("ls -alth /\n".getBytes(StandardCharsets.UTF_8));
stdinPipeOut.flush();

// 会话结束后再关闭流
// stdinPipeOut.close();
// callback.awaitCompletion();

注意要点：

• TTY参数在创建exec和启动exec两个步骤必须一致，否则会出现输入输出异常
• 发送的命令必须带\n换行符，等效于手动敲回车触发命令执行
• 输出可以通过重写onNext方法自定义捕获，不需要强制绑定到系统输出流

方案二：修改HttpHijack类解决单次发送限制 #

原实现调用shutdownOutput()是为了标识HTTP请求头和初始payload发送完毕，不需要关闭整个输出流，调整逻辑如下：

• 将shutdownOutput()调用从post方法中移除，HTTP劫持成功后连接已经转为纯TCP流，不需要遵循HTTP请求的关闭逻辑
• 发送命令时直接往socket输出流写入带换行的命令字节，每次写完调用flush()即可，不需要关闭流
• 单独开启异步线程读取socket输入流，避免IO阻塞导致写操作无法执行

方案三：替换为testcontainers工具栈 #

如果是测试场景可以直接使用testcontainers封装的exec交互能力，底层基于docker-java实现，已经原生处理了流复用问题，不需要手动处理底层HTTP劫持逻辑。

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