Java 远程调用 Shell 的方法

在 Java 中实现远程调用 Shell 有多种方式,以下是几种常见的方法：

使用 SSH 连接远程服务器并执行命令

使用 JSch 库

JSch 是一个流行的 Java 实现的 SSH2 协议库,可以用来远程执行命令。

import com.jcraft.jsch.*;
public class RemoteShellExecutor {
    public static void main(String[] args) {
        String host = "remote.host.com";
        String username = "username";
        String password = "password";
        int port = 22;
        JSch jsch = new JSch();
        Session session = null;
        ChannelExec channel = null;
        try {
            // 创建 SSH 会话
            session = jsch.getSession(username, host, port);
            session.setPassword(password);
            session.setConfig("StrictHostKeyChecking", "no");
            session.connect();
            // 执行命令
            String command = "ls -l /tmp";
            channel = (ChannelExec) session.openChannel("exec");
            channel.setCommand(command);
            // 获取输入流读取命令输出
            InputStream in = channel.getInputStream();
            InputStream err = channel.getExtInputStream();
            channel.connect();
            // 读取命令输出
            byte[] buffer = new byte[1024];
            while (true) {
                while (in.available() > 0) {
                    int i = in.read(buffer, 0, 1024);
                    if (i < 0) break;
                    System.out.print(new String(buffer, 0, i));
                }
                while (err.available() > 0) {
                    int i = err.read(buffer, 0, 1024);
                    if (i < 0) break;
                    System.err.print(new String(buffer, 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 e) {
                    e.printStackTrace();
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (channel != null) channel.disconnect();
            if (session != null) session.disconnect();
        }
    }
}

添加 Maven 依赖

<dependency>
    <groupId>com.jcraft</groupId>
    <artifactId>jsch</artifactId>
    <version>0.1.55</version>
</dependency>

使用 RMI (Remote Method Invocation)

RMI 是 Java 的远程方法调用机制,可以调用远程对象的方法。

服务器端代码

import java.rmi.Remote;
import java.rmi.RemoteException;
public interface RemoteShellService extends Remote {
    String executeCommand(String command) throws RemoteException;
}
public class RemoteShellServiceImpl implements RemoteShellService {
    @Override
    public String executeCommand(String command) throws RemoteException {
        try {
            Process process = Runtime.getRuntime().exec(command);
            BufferedReader reader = new BufferedReader(
                new InputStreamReader(process.getInputStream()));
            StringBuilder output = new StringBuilder();
            String line;
            while ((line = reader.readLine()) != null) {
                output.append(line).append("\n");
            }
            return output.toString();
        } catch (IOException e) {
            throw new RemoteException("Command execution failed", e);
        }
    }
}

客户端代码

import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
public class RemoteShellClient {
    public static void main(String[] args) {
        try {
            Registry registry = LocateRegistry.getRegistry("remote.host.com", 1099);
            RemoteShellService service = (RemoteShellService) registry.lookup("RemoteShellService");
            String result = service.executeCommand("ls -l /tmp");
            System.out.println(result);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

使用 HTTP API 调用

如果远程服务器提供了 HTTP API 接口，可以通过 HTTP 请求来执行命令。

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
public class HttpRemoteShell {
    public static void main(String[] args) {
        try {
            String url = "http://remote.host.com/api/shell";
            String command = "ls -l /tmp";
            URL obj = new URL(url + "?command=" + command);
            HttpURLConnection con = (HttpURLConnection) obj.openConnection();
            con.setRequestMethod("GET");
            BufferedReader in = new BufferedReader(
                new InputStreamReader(con.getInputStream()));
            String inputLine;
            StringBuilder response = new StringBuilder();
            while ((inputLine = in.readLine()) != null) {
                response.append(inputLine);
            }
            in.close();
            System.out.println(response.toString());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

安全注意事项

1. 避免直接执行用户输入：永远不要直接执行来自不可信来源的命令，这可能导致命令注入攻击
2. 使用认证：确保远程调用有适当的认证机制
3. 限制权限：执行命令的用户应具有最小必要权限
4. 记录审计日志：记录所有远程执行的命令和结果
5. 加密传输：使用 SSH 或 HTTPS 等加密协议传输数据

替代方案

对于生产环境,考虑使用更安全的替代方案：

• 使用 Ansible、SaltStack 等配置管理工具
• 使用专门的远程执行服务如 Apache Rundeck
• 使用容器编排工具如 Kubernetes 的远程执行能力

方法各有优缺点，选择哪种方法取决于你的具体需求、安全要求和现有基础设施。