JAVA如何取消read方法阻塞

142次阅读

共计 1494 个字符，预计需要花费 4 分钟才能阅读完成。

Java 中的 read 方法通常是指 InputStream 类中的 read 方法，该方法用于从输入流中读取数据。当没有可读取的数据时，read 方法会阻塞等待数据的到达。如果需要取消 read 方法的阻塞，可以通过以下几种方式实现：

设置输入流的超时时间：可以使用 InputStream 的子类如 SocketInputStream、FileInputStream 的 setSoTimeout 方法来设置超时时间。在超过设定的超时时间后，read 方法会抛出 SocketTimeoutException 或 IOException 异常，可以捕获该异常来取消阻塞。

InputStream inputStream = socket.getInputStream();
inputStream.setSoTimeout(5000); // 设置超时时间为 5 秒 
try {int data = inputStream.read();
    // 读取数据 
} catch (SocketTimeoutException e) {// 超时处理 
} catch (IOException e) {// IO 异常处理 
}

使用非阻塞 IO：可以使用 NIO（New IO）提供的 Channel 和 Selector 来实现非阻塞的读取操作。Channel 类提供了非阻塞的 read 方法，可以通过 Selector 类来监听多个 Channel 的读就绪事件。

Selector selector = Selector.open();
SocketChannel socketChannel = SocketChannel.open();
socketChannel.configureBlocking(false); // 设置为非阻塞模式 
socketChannel.register(selector, SelectionKey.OP_READ); // 注册读就绪事件 
selector.select(5000); // 设置超时时间为 5 秒 
Set<SelectionKey> selectedKeys = selector.selectedKeys();
if (selectedKeys.isEmpty()) {// 超时处理 
} else {Iterator<SelectionKey> iterator = selectedKeys.iterator();
    while (iterator.hasNext()) {SelectionKey key = iterator.next();
        if (key.isReadable()) {SocketChannel channel = (SocketChannel) key.channel();
            ByteBuffer buffer = ByteBuffer.allocate(1024);
            channel.read(buffer);
            // 读取数据 
        }
        iterator.remove();}
}

使用线程中断：可以将读取输入流的过程放在一个单独的线程中，在需要取消阻塞的时候调用线程的 interrupt 方法来中断线程，从而取消阻塞。

Thread readThread = new Thread(() -> {try {while (!Thread.currentThread().isInterrupted()) {int data = inputStream.read();
            // 读取数据 
        }
    } catch (IOException e) {// IO 异常处理 
    }
});
readThread.start();

// 取消阻塞 
readThread.interrupt();