我们在尝试为我们的应用程序实现 SftpConnections 池时遇到了一些问题。

我们目前正在使用 SSHJ (Schmizz) 作为传输库，并且面临一个我们根本无法在开发环境中模拟的问题(但该错误在生产环境中不断随机显示，有时会在三天后出现，有时只需要 10 分钟)。

问题是，当尝试通过 SFTP 发送文件时，线程在 schmizz 的 TransportImpl 类的 init 方法中被锁定:

   @Override
    public void init(String remoteHost, int remotePort, InputStream in, OutputStream out)
            throws TransportException {
        connInfo = new ConnInfo(remoteHost, remotePort, in, out);

    try {

        if (config.isWaitForServerIdentBeforeSendingClientIdent()) {
            receiveServerIdent();
            sendClientIdent();
        } else {
            sendClientIdent();
            receiveServerIdent();
        }


        log.info("Server identity string: {}", serverID);

    } catch (IOException e) {
        throw new TransportException(e);
    }

    reader.start();
}

isWaitForServerIdentBeforeSendingClientIdent 对我们来说是 FALSE，所以首先客户端(我们)发送我们的标识，如日志中所示:

“客户端身份字符串:blabla”

然后轮到receiveServerIdent了:

    private void receiveServerIdent() throws IOException 
{
        final Buffer.PlainBuffer buf = new Buffer.PlainBuffer();
        while ((serverID = readIdentification(buf)).isEmpty()) {
            int b = connInfo.in.read();
            if (b == -1)
                throw new TransportException("Server closed connection during identification exchange");
            buf.putByte((byte) b);
        }
    }

线程永远不会取回控制权，因为服务器永远不会回复其身份。似乎代码卡在了这个 While 循环中。没有超时，也没有抛出 SSH 异常，我的客户端一直在等待，线程陷入死锁。

这是 readIdentification 方法的实现:

private String readIdentification(Buffer.PlainBuffer buffer)
        throws IOException {
    String ident = new IdentificationStringParser(buffer, loggerFactory).parseIdentificationString();
    if (ident.isEmpty()) {
        return ident;
    }

    if (!ident.startsWith("SSH-2.0-") && !ident.startsWith("SSH-1.99-"))
        throw new TransportException(DisconnectReason.PROTOCOL_VERSION_NOT_SUPPORTED,
                                     "Server does not support SSHv2, identified as: " + ident);

    return ident;
}

似乎 ConnectionInfo 的输入流从不读取数据，就好像服务器关闭了连接(即使如前所述，没有抛出异常)。

我试图通过使协商饱和、连接时关闭套接字、在握手时使用 conntrack 终止已建立的连接来模拟此错误，但一点运气都没有，所以任何帮助都是HIGHLY不胜感激。

: )

最佳答案

我打赌下面的代码会产生问题:

String ident = new IdentificationStringParser(buffer, loggerFactory).parseIdentificationString();
if (ident.isEmpty()) {
    return ident;
}

如果 IdentificationStringParser.parseIdentificationString() 返回空字符串，它将返回给调用方方法。调用方方法将继续调用 while ((serverID = readIdentification(buf)).isEmpty())，因为字符串始终为空。打破循环的唯一方法是如果调用 int b = connInfo.in.read(); 返回 -1... 但是如果服务器继续发送数据(或重新发送数据)这条件永远不会满足。

如果是这种情况，我会添加某种人工方法来检测这种情况，例如:

private String readIdentification(Buffer.PlainBuffer buffer, AtomicInteger numberOfAttempts)
        throws IOException {
    String ident = new IdentificationStringParser(buffer, loggerFactory).parseIdentificationString();

    numberOfAttempts.incrementAndGet();


    if (ident.isEmpty() && numberOfAttempts.intValue() < 1000) { // 1000 
        return ident;
    } else if (numberOfAttempts.intValue() >= 1000) {
        throw new TransportException("To many attempts to read the server ident").

    }

    if (!ident.startsWith("SSH-2.0-") && !ident.startsWith("SSH-1.99-"))
        throw new TransportException(DisconnectReason.PROTOCOL_VERSION_NOT_SUPPORTED,
                                     "Server does not support SSHv2, identified as: " + ident);

    return ident;
}

这样您至少可以确认是这种情况，并且可以进一步挖掘 .parseIdentificationString() 返回空字符串的原因。

关于java - 从未收到 SSH 服务器标识 - 握手死锁 [SSHJ]，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/41630341/