如何使用Java JSch执行Docker特定命令？附SSH连接代码尝试

我需要实现通过Java JSch执行Docker特定命令的功能，目前已完成远程服务器的SSH连接，代码如下：

import java.io.InputStream;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;
public class JSchExampleSSHConnection {
 public static void main(String[] args) {
 String host="hostname";
 String user="sshuser";
 String password="sshpwd";
 String command1="ls";
 try{
 java.util.Properties config = new java.util.Properties();
 config.put("StrictHostKeyChecking", "no");
 JSch jsch = new JSch();
 Session session = jsch.getSession(user, host, 22);
 session.setPassword(password);
 session.setConfig(config);
 session.connect();
 System.out.println("Connected");

 Channel channel = session.openChannel("exec");
 ((ChannelExec)channel).setCommand(command1);
 channel.setInputStream(null);
 ((ChannelExec)channel).setErrStream(System.err);

 InputStream in=channel.getInputStream();
 channel.connect();

 byte[] tmp=new byte[1024];
 while(true){
   while(in.available()>0){
     int i=in.read(tmp, 0, 1024);
     if(i<0)break;
     System.out.print(new String(tmp, 0, i));
   }
   if(channel.isClosed()){
     System.out.println("exit-status: "+channel.getExitStatus());
     break;
   }
   try{Thread.sleep(1000);}catch(Exception ee){}
 }
 channel.disconnect();
 session.disconnect();
 System.out.println("Disconnected");
 }catch(Exception e){
   e.printStackTrace();
 }
 }
}

请指导如何扩展该代码以执行Docker特定命令。

其实扩展起来很简单，核心就是把原来的ls命令换成Docker相关指令，同时注意几个关键细节，我给你一步步拆解：

1. 替换为Docker命令 #

直接把代码里的command1改成你需要的Docker命令就行，比如：

• 查看运行中的容器：docker ps --format 'table {{.ID}}\t{{.Names}}\t{{.Status}}'
• 查看本地镜像：docker images
• 启动指定容器：docker start your-container-id
• 如果需要sudo权限（很多服务器上Docker需要sudo才能执行），可以写成sudo docker ps，但要确保SSH用户能免密执行sudo（后面会说怎么配置）。

2. 处理命令的输入输出 #

你的原始代码已经处理了标准输出和错误输出，完全可以复用。不过要注意：

• 大部分常用Docker命令都是非交互式的，用ChannelExec就足够了；
• 如果要执行像docker exec -it <container> bash这种交互式命令，ChannelExec不支持，得换成ChannelShell（后面有示例）。

3. 完整示例代码 #

这里给你一个修改后的完整代码，以执行docker ps为例：

import java.io.InputStream;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;

public class JSchDockerExecutor {
    public static void main(String[] args) {
        String host = "your-hostname";
        String user = "sshuser";
        String password = "sshpwd";
        // 替换成你需要的Docker命令，这里是格式化查看运行容器
        String dockerCommand = "docker ps --format 'table {{.ID}}\\t{{.Names}}\\t{{.Status}}'";
        // 如果需要sudo权限，改成下面这行（前提是用户已配置免密sudo）
        // String dockerCommand = "sudo docker ps --format 'table {{.ID}}\\t{{.Names}}\\t{{.Status}}'";

        try {
            java.util.Properties config = new java.util.Properties();
            config.put("StrictHostKeyChecking", "no");
            JSch jsch = new JSch();
            Session session = jsch.getSession(user, host, 22);
            session.setPassword(password);
            session.setConfig(config);
            session.connect();
            System.out.println("Connected to remote server");

            Channel channel = session.openChannel("exec");
            ((ChannelExec) channel).setCommand(dockerCommand);
            channel.setInputStream(null);
            ((ChannelExec) channel).setErrStream(System.err);

            InputStream in = channel.getInputStream();
            channel.connect();
            System.out.println("Executing command: " + dockerCommand);

            byte[] tmp = new byte[1024];
            while (true) {
                while (in.available() > 0) {
                    int i = in.read(tmp, 0, 1024);
                    if (i < 0) break;
                    System.out.print(new String(tmp, 0, i));
                }
                if (channel.isClosed()) {
                    int exitStatus = channel.getExitStatus();
                    System.out.println("\nCommand exit status: " + exitStatus);
                    // 0表示命令执行成功，非0则失败
                    if (exitStatus != 0) {
                        System.err.println("Docker command execution failed!");
                    }
                    break;
                }
                try {
                    Thread.sleep(500); // 缩短轮询间隔，更快获取输出
                } catch (Exception ee) {
                    ee.printStackTrace();
                }
            }

            channel.disconnect();
            session.disconnect();
            System.out.println("Disconnected from remote server");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

4. 关键注意事项 #

关于sudo权限 #

如果远程用户执行Docker命令需要sudo，一定要在服务器上配置免密sudo，否则代码会卡住等待输入密码。配置方法：

1. 远程服务器上执行sudo visudo
2. 添加一行：sshuser ALL=(ALL) NOPASSWD: /usr/bin/docker（替换sshuser为你的SSH用户名，只允许免密执行docker命令，更安全）
3. 保存退出即可。

交互式Docker命令处理 #

如果要执行docker exec -it <container> /bin/bash这种交互式命令，需要改用ChannelShell，示例代码片段如下：

// 替换原来的ChannelExec部分
Channel channel = session.openChannel("shell");
OutputStream out = channel.getOutputStream();
// 关联本地输入流（也可以自己构造输出流发送命令）
channel.setInputStream(System.in);
channel.connect();

// 发送交互式Docker命令
String interactiveCmd = "docker exec -it my-container echo hello\n";
out.write(interactiveCmd.getBytes());
out.flush();

// 读取输出的逻辑和之前一致
InputStream in = channel.getInputStream();
byte[] tmp = new byte[1024];
while (true) {
    while (in.available() > 0) {
        int i = in.read(tmp, 0, 1024);
        if (i < 0) break;
        System.out.print(new String(tmp, 0, i));
    }
    if (channel.isClosed()) {
        System.out.println("\nExit status: " + channel.getExitStatus());
        break;
    }
    Thread.sleep(500);
}

命令转义 #

如果Docker命令包含特殊字符（比如空格、引号），要注意在Java字符串中转义，比如用双引号包裹，或者转义特殊字符，确保命令在远程服务器能正确解析执行。

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