SSLEngine 并关闭

Question

我已经实现了一个帮助程序模块，它允许我从与 SSL 一起使用的通道获取干净的数据并将加密数据写入其中：这是相关的接口（我在该类中还有一些非抽象方法，所以不说对我来说“DataProvider 应该是一个接口”;))：

public abstract class DataProvider {
    // Notify the bytes read from the net
    public abstract void readFromNet(ByteBuffer b);
    // Gets the bytes to write into the net
    public abstract void writeToNet(ByteBuffer b);
    // Add a message to send
    public abstract boolean addMessage(byte[] data);
    // Obtains the application data received
    public abstract byte[] getReceivedApplicationData();
    // True if there is something to actually send over the wire
    public abstract boolean dataToSend();
    // True if we should close the channel
    public abstract boolean shouldClose();
    // Notify our intention to shut down the connection
    public abstract void shutDown(SelectionKey sk);
    // Set the interest op set for the channel
    public abstract void setInterestOps(SelectionKey sk);
}

我有一个 SSL 抽象基类的实现。 在测试该实现时，我编写了两个函数：在一个函数中，我接收带有 SocketChannel 的消息，并且用于发送数据的 SSLSocket 关闭连接，在另一个函数中，我用 SocketChannel 发送消息来启动关闭连接。 现在，问题是用于接收数据的 SSLSocket 没有关闭，即使我已经发出了这些步骤：

1. engine.closeOutbound()
2. engine.wrap()
3. channel.write(data)（是的，我确信我已将使用wrapp()获得的所有数据发送到
4. 用于读取入站close_notify的通道的选择

问题是选择器卡在第四步中

（SSLSocket关闭连接）我不这样做。有一个问题。

请注意，我已经将 shouldClose 实现为：

return engine.isOutboundDone() && engine.isInboundDone();

所以我需要传入 close_notify 才能关闭，即使我已经初始化了关闭（我不知道这是否正确：最终我可以更改它） return engine.isOutboundDone())

这是我的 SSLSocket 端代码：

Socket toRead = socket.accept();
toRead.setSoTimeout(0);
InputStream is = toRead.getInputStream();
ByteArrayOutputStream bos = new ByteArrayOutputStream();
String read = "";
byte[] barray = new byte[1024];
while (read.length() < toSend.length() * 2) {
    int bytesRead = is.read(barray);
    bos.write(barray, 0, bytesRead);
    read = new String(bos.toByteArray());
}
assertEquals(toSend + toSend, read);
assertTrue(toRead.isClosed());

最初

我认为这是因为没有与 toRead 关联的“后台”线程，所以。我应该对其进行读/写操作，以便使用传入的 close_notify，然后最终关闭套接字，但即使这样也无济于事。

任何想法？

Answer 1

很晚的答案，但如果您已经发送了一个，则不需要等待 close_notify，请参阅 RFC 2246。但是您应该收到一个。 您没有说明您在 close_notify 上选择的具体情况。

注意您的代码没有意义。 仅当您关闭套接字时，该套接字才会被关闭。 isClosed() 指的是套接字，而不是连接。

Answer 2

我建议在第一个断言之前添加 is.close(); 。

请注意，我建议的这段小代码不会关闭套接字。 它应该关闭输入流。