优化JSch ChannelExec：解决nc命令连接不关闭问题

import com.jcraft.jsch.*;
import java.io.ByteArrayOutputStream;

public class JSchNetcatClient {

    private Session session; // 假设session已通过JSch连接并认证

    public JSchNetcatClient(Session session) {
        this.session = session;
    }

    /**
     * 执行远程nc请求并获取响应。
     *
     * @param request 要发送给nc命令的请求字符串。
     * @return nc命令的响应字符串。
     * @throws JSchException 如果JSch操作失败。
     * @throws InterruptedException 如果线程在等待过程中被中断。
     */
    public String doRequest(String request) throws JSchException, InterruptedException {
        ChannelExec channel = null;
        ByteArrayOutputStream responseStream = null;
        String responseString = null;

        try {
            channel = (ChannelExec) session.openChannel("exec");
            responseStream = new ByteArrayOutputStream();

            // 使用nc -q 1 参数，确保nc在EOF后1秒关闭连接
            // 注意：request字符串应避免包含可能干扰shell的特殊字符，必要时进行转义
            String command = "nc -q 1 127.0.0.1 8008 <<< '" + request + "'";
            channel.setCommand(command);
            channel.setOutputStream(responseStream);
            channel.setErrStream(responseStream); // 也捕获错误流，以便调试

            channel.connect(); // 连接通道

            // 等待通道断开连接
            while (!channel.isClosed()) { // 使用isClosed()更准确地判断通道是否关闭
                Thread.sleep(100); // 短暂休眠，避免CPU空转
            }

            responseString = responseStream.toString();
        } finally {
            if (channel != null) {
                channel.disconnect(); // 确保通道最终被断开
            }
            if (responseStream != null) {
                try {
                    responseStream.close();
                } catch (Exception e) {
                    // 忽略关闭流时的异常
                }
            }
        }
        return responseString;
    }

    // 示例用法
    public static void main(String[] args) {
        JSch jsch = new JSch();
        Session session = null;
        try {
            // 假设你已经设置好主机、用户名、密码等信息
            // jsch.addIdentity("/path/to/your/private/key"); // 如果使用密钥认证
            session = jsch.getSession("username", "your_remote_host", 22);
            session.setPassword("your_password"); // 如果使用密码认证
            session.setConfig("StrictHostKeyChecking", "no"); // 生产环境不建议设置为no
            session.connect(30000); // 连接超时30秒

            JSchNetcatClient client = new JSchNetcatClient(session);
            String requestData = "(47.6861,-70.3343) (48.2191,-68.9323) 100000";
            System.out.println("发送请求: " + requestData);
            String response = client.doRequest(requestData);
            System.out.println("收到响应: " + response);

        } catch (JSchException | InterruptedException e) {
            e.printStackTrace();
        } finally {
            if (session != null && session.isConnected()) {
                session.disconnect();
            }
        }
    }
}