WebSocket 频繁爆出异常

[looveh]

做了个 WebSocket 连接，客户端通过定时发送心跳。但是时间一长发现还是会自动断开，心跳时间是 30s 一次，ng 也做了如下配置：

proxy-read-timeout：'3600'
proxy-send-timeout：'3600'

有没有大佬出现过这种情况？ 错误如下：

 java.io.EOFException: null

 	at org.apache.tomcat.util.net.NioEndpoint$NioSocketWrapper.fillReadBuffer(NioEndpoint.java:1345)

 	at org.apache.tomcat.util.net.NioEndpoint$NioSocketWrapper.read(NioEndpoint.java:1255)

 	at org.apache.tomcat.websocket.server.WsFrameServer.onDataAvailable(WsFrameServer.java:75)

 	at org.apache.tomcat.websocket.server.WsFrameServer.doOnDataAvailable(WsFrameServer.java:183)

 	at org.apache.tomcat.websocket.server.WsFrameServer.notifyDataAvailable(WsFrameServer.java:162)

 	at org.apache.tomcat.websocket.server.WsHttpUpgradeHandler.upgradeDispatch(WsHttpUpgradeHandler.java:156)

 	at org.apache.coyote.http11.upgrade.UpgradeProcessorInternal.dispatch(UpgradeProcessorInternal.java:60)

 	at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:59)

 	at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:893)

 	at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1707)

 	at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)

 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)

 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)

 	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)

 	at java.base/java.lang.Thread.run(Thread.java:829)

补充一下，目前的状态是前端和后端都会互相做心跳，前端还有断线重连机制。因为某些业务需要达到 100%到达率。所以任何异常都有可能导致消息推送失败。不知道从哪里下手了😰😰😰

[coderxy]

断开很正常吧？ 中间任何一个环节网络波动啥的都会导致断开， 做好重连不就行了？

[opengps]

公网环境下，通信要做的就是断线自动重连，而不是一个连接用到老

[stinkytofu]

也可以找一个成熟的库, 库内部维护连接, 就不用操那么心了

[skcy]

如果是浏览器 tab 在非激活状态，或者电脑休眠的时候，浏览器内定时器 会触发 任务 延时机制，可尝试 webworker (休眠依然无解)

[nothingistrue]

EOFException 是异常到达流尾部，这不一定是连接被断开了，你可能更需要关注 IO 流的生命周期，或者缓冲区的配置。

至于心跳，它更应该当作被断开的感知器，不应该作为连接维持的保证器。

[gkinxin]

@stinkytofu 有什么库推荐一下呢

[stinkytofu]

@gkinxin #6 EMQX

[Parva]

裸 websocket 手撸心跳？找些库、协议套一套吧

[coyove]

如果是浏览器的话，tab 切换，进入后台，safari 节能模式，都可能导致 websocket 不可用。这样的策略是无法预知的，只能做好重连

[mmdsun]

这是原生 websocket 吗？
我用 spring +STOM 很稳，spring 也推荐了客户端
https://docs.spring.io/spring-framework/reference/web/websocket/stomp.html

[0xsui]

建议你用 SocketIO ，比自己写的更完善，更稳定

[looveh]

@coderxy 前后端都有做数据流动，防止断线。但是有时候还是会有这种错误，而我们现在有个需求走这里，并且还需要送达率 100%😭

[looveh]

@opengps 有重连的哦，但是断开那瞬间如果有消息通过就丢了，我们的业务是消息需要 100%到达

[looveh]

@mmdsun 后面可能会改，现在就是要满足现有需求

[looveh]

@mmdsun 不过这个我看了一下，看不太明白😂太菜了

[looveh]

@coyove 重连是有做的

[coderxy]

@looveh 很正常，应该中间有很多环节都有可能把你的连接断掉， 要保证送达，该做的是离线消息。

[looveh]

@coderxy 离线消息怎么做😳

[coderxy]

@looveh 消息发送时入库，接收方断线重连时获取离线消息

[looveh]

@coderxy 我们这个消息实时性很高的😂必须实时推到

[coderxy]

@looveh 实时性非常高就不应该用 tcp ， 可以学游戏用 udp ，只要网络不是太废都能近实时送达。

[looveh]

@coderxy 😂其实是这个服务已经存在了，刚好有这样的业务，并且刚好有这样一个推送的服务，所以就直接用上了。目前正在考虑使用 stomp 替换

[looveh]

@mmdsun 大佬。用 stomp 的时候我发现每次订阅都是自动生成新的 Queue ，然后用我的订阅地址做 routingkey 关联。这样的话是不是意味着我如果有 1w 个用户(用户登录订阅)同时登录，就会在 mq 生成 1w 个队列？这怎么扛得住呢