java nio 捕获异常_java nio channel抛出ClosedByInterruptException的情况

红太狼 2022-11-03 05:27 135阅读 0赞

java nio里的channel是实现自InterruptibleChannel接口的，这个接口的注释里有说明，当正在操作这个channel的线程被其他线程中断，则会close这个channel，当前(被中断的)线程抛出一个ClosedByInterruptException异常。

我们今天在排查一个问题时，用户线程执行了下面的调用过程(从上往下)：

org.apache.catalina.connector.CoyoteOutputStream.flush ---》

org.apache.tomcat.util.net.NioChannel.write ---》

sun.nio.ch.SocketChannelImpl.write ---》

java.nio.channels.spi.AbstractInterruptibleChannel.end // 这里抛出异常

来看一下这个sun.nio.ch.SocketChannelImpl.write 方法内部，它的详细代码可以看这里) 这里简化一些：

public int write(ByteBuffer buf) throws IOException \{

...

synchronized (writeLock) \{

...

try \{

begin();

...

\} finally \{

...

end(n > 0 || (n == IOStatus.UNAVAILABLE));

...

\}

\}

\}

主要看一下它里面的begin和end，先看end方法，异常抛出的地方：

protected final void end(boolean completed)

throws AsynchronousCloseException

\{

blockedOn(null);

Thread interrupted = this.interrupted;

if (interrupted != null && interrupted == Thread.currentThread()) \{

interrupted = null;

throw new ClosedByInterruptException();

\}

if (!completed && !open)

throw new AsynchronousCloseException();

\}

可以看到ClosedByInterruptException异常抛出的前提是当前线程被标记为已中断的；而这个判断是在begin方法里做的：

protected final void begin() \{

if (interruptor == null) \{

interruptor = new Interruptible() \{

public void interrupt(Thread target) \{

synchronized (closeLock) \{

if (!open)

return;

open = false;

interrupted = target;

try \{

AbstractInterruptibleChannel.this.implCloseChannel();

\} catch (IOException x) \{ \}

\}

\}\};

\}

blockedOn(interruptor);

Thread me = Thread.currentThread();

if (me.isInterrupted()) // 检测当前线程是否已中断

interruptor.interrupt(me);

\}

在begin方法里，检查当前线程如果是中断状态，用引用记录起来(为了后边比较使用)，并关闭了channel。

现在用scala模拟一下这个异常：

$ cat server

import java.nio.\_

import java.net.\_

import java.nio.channels.\_

val serverSock = ServerSocketChannel.open()

serverSock.socket().bind(new InetSocketAddress(54321))

val ch:SocketChannel = serverSock.accept()

println("ok,received")

Thread.currentThread().interrupt() //中断当前线程

try\{

ch.socket().getOutputStream().write(200)

\}catch\{

case e:Throwable => println(e)

\}

上面的这段脚本，用nio模拟了一个server等待客户端的链接，当链接过来的时候，中断当前线程，然后继续channel进行处理的时候会捕获到ClosedByInterruptException异常。

启动上面的脚本

$ scala server

在另一个终端下模拟一次client请求：

$ telnet localhost 54321

这时会看到server端的输出信息：

$ scala server

ok,received

java.nio.channels.ClosedByInterruptException

发表评论取消回复

表情：

评论列表（有 0 条评论，135人围观）

还没有评论，来说两句吧...

相关阅读

相关 java nio channel

Java NIO 通道类似于流，但又有一下不同： 1、既可以从通道中读取数据，也可以写数据到通道中。java .io 中的流是单向性。 2、通道数据读取可以异步。 3、通

淩亂°似流年/ 2023年10月17日 08:21/ 0 赞/ 122 阅读

相关【Java NIO】之 Channel

下面以一个实例介绍 Channel 的各种用法 -------------------- / 一、通道（Channel）：用于源节点与目标节点的连接。在 Ja

た入场券/ 2023年02月23日 05:16/ 0 赞/ 4 阅读

相关 java nio 捕获异常_java nio channel抛出ClosedByInterruptException的情况

java nio里的channel是实现自InterruptibleChannel接口的，这个接口的注释里有说明，当正在操作这个channel的线程被其他线程中断，则会clos

红太狼/ 2022年11月03日 05:27/ 0 赞/ 136 阅读

相关 Java NIO Channel

Java NIO 通道（Channel） Java NIO的Channel和流（Streams）很相似，但是也有一些区别： Channel是双向的，你可以从Cha

逃离我推掉我的手/ 2022年09月26日 01:52/ 0 赞/ 217 阅读

相关 Java NIO之Channel

Java NIO之Channel -------------------- 介绍定义 Channel(管道):A channel represents

妖狐艹你老母/ 2022年09月25日 00:28/ 0 赞/ 51 阅读

相关 Java NIO系列（二） Channel

Java NIO的通道类似流，但又有些不同：既可以从通道中读取数据，又可以写数据到通道。但流的读写通常是单向的。通道可以异步地读写。通道中的数据总是要先读到一个

向右看齐/ 2022年06月11日 08:21/ 0 赞/ 177 阅读

相关 Java - NIO之Channel（FileChannel）

一、关于Channel Java NIO的通道（Channel）类似流，但又有些不同：既可以从通道中读取数据，又可以写数据到通道。但流的读写通常是

向右看齐/ 2022年06月05日 00:54/ 0 赞/ 296 阅读

相关 Java NIO 之Channel

定义用于源节点和目标节点之间的连接。nio中负责缓冲区中数据传输，Channel本地并不存储数据，而是配合缓冲区进行数据传输。你可以把它理解成io中的流。结

偏执的太偏执、/ 2022年05月22日 11:19/ 0 赞/ 254 阅读

相关 Java NIO（三）——Channel

本文转自：https://blog.csdn.net/a953713428/article/details/62420813 通道（Channel）是java.nio的

朴灿烈づ我的快乐病毒、/ 2022年05月20日 08:05/ 0 赞/ 200 阅读

相关 Java NIO入门（二）Channel

文章目录通道（Channel）什么是通道（Channel） Channel常用方法

叁歲伎倆/ 2022年04月02日 05:16/ 0 赞/ 275 阅读