问题：
如何在客户端EventSource关闭的反应流http连接上处理ClosedChannel异常。关闭（）？
宋涵衍
我正在关注Quarkus-反应指南入门，并在使用服务器发送的事件的示例中与ClosedChannel异常进行斗争。resteasy资源处理程序使用vert。引擎盖下的x和netty以及反应流的SmallRye Mutiny库。
资源处理程序以1秒的间隔生成count条消息。
@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);
}
}
消息会根据请求发送到客户端。客户端是嵌入到html页面中的简单javascript函数：
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE html>
<html><head>
<meta charset="UTF-8" />
<title>SSE with Vert.x - Quarkus</title>
<script type="application/javascript">
var eventSource = new EventSource("/hello/stream/5/testname");
eventSource.onmessage = function(event) {
console.log(event.data);
var container = document.getElementById("container");
var paragraph = document.createElement("p");
paragraph.innerHTML = event.data;
container.appendChild(paragraph);
}
</script>
</head>
<body>
<input type="button" onclick="stop()" value="stop sse"/>
<div id="container"></div>
</body>
</html>
在客户端，所有工作都按预期进行。事件被处理，单击停止按钮（当事件到达时）关闭事件源。
但在服务器端，它会导致此异常：
2020-05-09 10:26:33,341 WARN [io.net.cha.AbstractChannelHandlerContext] (vert.x-eventloop-thread-13) Failed to mark a promise as failure because it has failed already: DefaultChannelPromise@241d306c(failure: java.nio.channels.ClosedChannelException), unnotified cause: java.nio.channels.ClosedChannelException
at io.netty.channel.AbstractChannel$AbstractUnsafe.newClosedChannelException(AbstractChannel.java:957)
at io.netty.channel.AbstractChannel$AbstractUnsafe.write(AbstractChannel.java:865)
at io.netty.channel.DefaultChannelPipeline$HeadContext.write(DefaultChannelPipeline.java:1367)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:715)
at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:762)
at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:788)
at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:756)
at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:765)
at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:788)
at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:756)
at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:765)
at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:788)
at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:756)
at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:765)
at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:788)
at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:756)
at io.vertx.core.net.impl.ConnectionBase.write(ConnectionBase.java:124)
at io.vertx.core.net.impl.ConnectionBase.lambda$queueForWrite$2(ConnectionBase.java:215)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:834)
: io.netty.util.IllegalReferenceCountException: refCnt: 0, decrement: 1
at io.netty.util.internal.ReferenceCountUpdater.toLiveRealRefCnt(ReferenceCountUpdater.java:74)
at io.netty.util.internal.ReferenceCountUpdater.release(ReferenceCountUpdater.java:138)
at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:100)
at io.netty.handler.codec.http.DefaultHttpContent.release(DefaultHttpContent.java:92)
at io.netty.util.ReferenceCountUtil.release(ReferenceCountUtil.java:88)
at io.netty.channel.AbstractChannel$AbstractUnsafe.write(AbstractChannel.java:867)
at io.netty.channel.DefaultChannelPipeline$HeadContext.write(DefaultChannelPipeline.java:1367)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:715)
at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:762)
at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:788)
at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:756)
at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:765)
at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:788)
at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:756)
at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:765)
at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:788)
at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:756)
at io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:765)
at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:788)
at io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:756)
at io.vertx.core.net.impl.ConnectionBase.write(ConnectionBase.java:124)
at io.vertx.core.net.impl.ConnectionBase.lambda$queueForWrite$2(ConnectionBase.java:215)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:834)
我应该如何适当地避免或处理此异常？
共有1个答案
柏高丽
变通方法
在pom中添加quarkus undertow作为依赖项后，警告消失。xml
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-undertow</artifactId>
</dependency>
这个想法是在对错误报告的回应中提到的。
类似资料：
-
我有一个servlet，它以XML格式响应。 客户端通过HttpSurlConnection连接到这个servlet。现在，如果客户端不调用会有问题吗？ 非常感谢。
-
socket.io 0.9 node.js 0.10.15 速递3.3.4 即：调用 --服务器端 --客户端
-
问题内容： 如何关闭客户端的套接字连接？ 我在用： socket.io 0.9 node.js 0.10.15 express3.3.4 即：呼叫 -服务器端 - 客户端 如果加载测试页，则需要来自服务器的一些值（getInitData）。 在第一页上，我获取一次数据，在重新加载或第二遍上，我获取两次数据，依此类推。 重新加载页面以及离开页面后，服务器端的连接将自动关闭。 但是在客户端，连接仍然打
-
我刚刚开始使用hazelcast[3.3.1]。根据hazelcast应用程序和客户端教程，我创建了一个hazelcast应用程序实例和一个客户端（使用eclipse IDE）。 从客户端，我能够将对象添加到地图并成功获取它们。但是，我在实例的控制台上看到以下警告，它们似乎警告客户端断开连接。这是每个客户端get/put的正常行为吗？ 在退出客户端程序之前，是否有适当的方法断开客户端与实例的连接？
-
故事是这样的，我有一个远程服务器和一个防火墙后面的客户端。客户端由netty实现，它将建立一个与远程服务器的保活连接。如果200秒内通道中没有消息传输，防火墙将重置连接到远程服务器端的连接，但客户端没有收到任何tcp数据包（例如RST包），因此客户端认为此连接是活的，而事实并非如此。那么如何在防火墙错误处理此保活连接之前强制关闭不寻常的连接呢？顺便说一句：我无法配置防火墙
-
我遇到了一个有趣的问题，HTTP 1.1 POST请求的TCP连接在请求之后立即关闭（即，在服务器可以发送响应之前）。 关于测试环境的一些细节： 客户端-Windows XP、Internet Explorer 8、Flash player 12。 服务器-Java 7 在上述行为之前，我们有几个长期存在的TCP连接，每个都被重用用于多个HTTP请求；我们打开一个长轮询，当这个轮询完成时，打开另一