使用JSch通过SSH连接iLO并交互式操作虚拟串口

import com.jcraft.jsch.*;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Properties;
import java.util.Scanner; // 用于模拟用户输入或发送预定义命令

public class JSchInteractiveVSP {

    public static void main(String[] args) {
        // SSH连接参数 (iLO凭据)
        String host = "10.10.100.209";
        String user = "administrator";
        String password = "2xR3M0t3$$"; 

        // VSP会话中的服务器凭据 (需要根据实际情况修改)
        String serverUsername = "your_server_username"; 
        String serverPassword = "your_server_password";

        Session session = null;
        ChannelShell channel = null;
        InputStream in = null;
        OutputStream out = null;
        Scanner scanner = null; 

        try {
            // 配置JSch会话
            Properties config = new Properties();
            config.put("StrictHostKeyChecking", "no"); // 生产环境请务必启用主机密钥检查

            JSch jsch = new JSch();
            session = jsch.getSession(user, host, 22);
            session.setPassword(password);
            session.setConfig(config);
            session.connect(30000); // 设置连接超时30秒
            System.out.println("SSH连接到iLO成功.");

            // 打开Shell通道
            channel = (ChannelShell) session.openChannel("shell");
            in = channel.getInputStream(); // 获取输入流，用于读取服务器输出
            out = channel.getOutputStream(); // 获取输出流，用于向服务器发送命令
            channel.connect(30000); // 设置通道连接超时30秒
            System.out.println("Shell通道已开启.");

            // 发送进入VSP会话的命令
            String vspCommand = "vsp\n"; // 注意：命令末尾需要换行符
            out.write(vspCommand.getBytes());
            out.flush();
            System.out.println("已发送 'vsp' 命令，等待VSP会话启动...");

            // 模拟交互式通信循环
            scanner = new Scanner(System.in); // 使用System.in进行手动交互测试
            byte[] buffer = new byte[1024];
            StringBuilder responseBuffer = new StringBuilder(); // 用于累积和分析服务器响应
            long lastActivity = System.currentTimeMillis();
            final long IDLE_TIMEOUT = 5 * 60 * 1000; // 5分钟空闲超时

            while (true) {
                // 读取服务器输出
                while (in.available() > 0) {
                    int i = in.read(buffer, 0, 1024);
                    if (i < 0) break;
                    String received = new String(buffer, 0, i);
                    System.out.print(received); // 实时打印服务器输出
                    responseBuffer.append(received); // 累积响应以供分析
                    lastActivity = System.currentTimeMillis();

                    // 自动化响应逻辑示例：根据服务器提示发送凭据
                    // 注意：实际应用中可能需要更复杂的正则表达式匹配和状态机来处理各种提示
                    if (responseBuffer.toString().contains("Username:") && !responseBuffer.toString().contains("login successful")) {
                        System.out.println("\n[自动化]: 检测到'Username:'提示，发送服务器用户名.");
                        out.write((serverUsername + "\n").getBytes());
                        out.flush();
                        responseBuffer.setLength(0); // 清空缓冲区，避免重复匹配
                        Thread.sleep(500); // 稍作等待，给服务器处理时间
                    } else if (responseBuffer.toString().contains("Password:") && !responseBuffer.toString().contains("login successful")) {
                        System.out.println("\n[自动化]: 检测到'Password:'提示，发送服务器密码.");
                        out.write((serverPassword + "\n").getBytes());
                        out.flush();
                        responseBuffer.setLength(0); // 清空缓冲区
                        Thread.sleep(500);
                    }
                    // 可以在此处添加更多逻辑来发送其他命令，例如 "ls -l\n" 或 "exit\n"
                    // if (responseBuffer.toString().contains("your_prompt>") && !sent_command_flag) {
                    //    out.write("ls -l\n".getBytes());
                    //    out.flush();
                    //    sent_command_flag = true;
                    // }
                }

                // 检查通道是否已关闭
                if (channel.isClosed()) {
                    System.out.println("\nShell通道已关闭. Exit-status: " + channel.getExitStatus());
                    break;
                }

                // 允许从控制台输入命令 (用于测试)
                if (System.in.available() > 0) {
                    String line = scanner.nextLine();
                    out.write((line + "\n").getBytes());
                    out.flush();
                    lastActivity = System.currentTimeMillis();
                } else {
                    // 避免CPU占用过高，稍作延迟
                    Thread.sleep(100);
                }

                // 空闲超时检查
                if (System.currentTimeMillis() - lastActivity > IDLE_TIMEOUT) {
                    System.out.println("\n会话空闲超时，断开连接.");
                    break;
                }
            }

        } catch (JSchException e) {
            System.err.println("JSch连接或通道错误: " + e.getMessage());
            e.printStackTrace();
        } catch (Exception e) {
            System.err.println("通信过程中发生错误: " + e.getMessage());
            e.printStackTrace();
        } finally {
            // 确保所有资源被正确关闭
            if (scanner != null) {
                scanner.close();
            }
            if (channel != null) {
                channel.disconnect();
                System.out.println("Shell通道已断开.");
            }
            if (session != null) {
                session.disconnect();
                System.out.println("SSH会话已断开.");
            }
            System.out.println("资源清理完成.");
        }
    }
}