如何处理客户端调用EventSource.close()引发的ClosedChannelException？

这个问题我之前在做Quarkus SSE开发的时候也碰到过，其实本质就是客户端主动断开连接后，服务器端还在尝试往已经关闭的Netty通道里写数据，才抛出了ClosedChannelException和后续的引用计数异常。咱们来一步步解决它：

问题原因分析 #

当你点击停止按钮调用eventSource.close()时，客户端会主动断开HTTP SSE连接，但你的Mutiny Multi流还在按照每秒一次的频率生成消息。Netty尝试向已经关闭的通道写入数据时，就会触发ClosedChannelException，而后续的IllegalReferenceCountException是这个错误引发的连锁反应——Netty尝试释放一个已经被释放的ByteBuf。

解决方案 #

1. 先确保客户端正确关闭EventSource #

首先完善你的前端stop函数，避免重复关闭或者操作已关闭的实例：

function stop() {
    if (eventSource && eventSource.readyState !== EventSource.CLOSED) {
        eventSource.close();
        eventSource = null;
        console.log("SSE connection closed gracefully");
    }
}

2. 服务器端捕获并处理ClosedChannelException #

这是最根本的解决方法，利用Mutiny的异常处理机制，在Multi流上直接忽略这个预期内的异常：

@Path("/hello")
public class ReactiveGreetingResource {
    @GET
    @Produces(MediaType.SERVER_SENT_EVENTS)
    @SseElementType(MediaType.TEXT_PLAIN)
    @Path("/stream/{count}/{name}")
    public Multi<String> greetingsAsStream(@PathParam int count, @PathParam String name) {
        return Multi.createFrom().ticks().every(Duration.ofSeconds(1))
               .onItem().apply(n -> String.format("hello %s - %d", name, n))
               .transform().byTakingFirstItems(count)
               // 捕获ClosedChannelException并忽略它，避免日志告警
               .onFailure(ClosedChannelException.class).ignore();
    }
}

ignore()方法会在遇到指定异常时终止流，并且不会将异常向上抛出，这样服务器就不会打印那些烦人的WARN日志了。

如果你需要在连接关闭时做一些资源清理，可以结合onTermination回调：

return Multi.createFrom().ticks().every(Duration.ofSeconds(1))
        .onItem().apply(n -> String.format("hello %s - %d", name, n))
        .transform().byTakingFirstItems(count)
        .onTermination().invoke(() -> {
            // 这里可以添加资源清理逻辑，比如关闭定时器、释放连接等
            System.out.println("SSE stream terminated");
        })
        .onFailure(ClosedChannelException.class).ignore();

3. （可选）通过日志配置屏蔽警告 #

如果不想修改代码，也可以通过Quarkus的日志配置来屏蔽这个特定的警告。在application.properties中添加：

# 将Netty AbstractChannelHandlerContext的日志级别设为ERROR，屏蔽WARN级别的关闭通道警告
quarkus.log.category."io.netty.channel.AbstractChannelHandlerContext".level=ERROR

不过这只是治标不治本的方法，推荐还是从代码层面处理异常，这样更符合响应式编程的规范。

总结 #

最推荐的方案是第二种：在Mutiny Multi流上添加onFailure(ClosedChannelException.class).ignore()，同时确保客户端正确关闭EventSource。这样既解决了异常问题，也能让流的生命周期和连接状态保持一致。

内容的提问来源于stack exchange，提问作者JanPl