如何在Netty 4中通道关闭之前在ReadTimeoutHandler上写入通道
与Netty 3相比，Netty 4中ReadTimeoutHandler的行为似乎发生了变化。在Netty 4，当超时触发时，Netty不仅引发ReadTimeoutExceptionReadTimeoutException，通道未关闭。
我有一个用例，我需要在超时时向通道写入消息。这不能再做了，因为当处理抛出的ReadTimeoutException的代码到达时，通道已经关闭。
关于如何在Netty 4中使用此用例，有什么提示/想法吗？基本上是在Netty关闭频道之前，在ReadTimeoutException上写入频道？
共有1个答案
我认为您可能希望使用IdleStateHandler，它在处理不同类型的空闲事件方面更加灵活。
-
关闭通道的意思是该通道将不再允许写入数据。这个方法可以让通道数据的接受端知道数据已经全部发送完成了。 package main import "fmt" // 在这个例子中，我们使用通道jobs在main函数所在的协程和一个数据 // 接收端所在的协程通信。当我们数据发送完成后，我们关闭jobs通道 func main() { jobs := make(chan int, 5) d
-
我的I/O流如下： < li >客户端向通道发送数据# 1 < li >服务器(处理程序)根据客户端数据从数据库接收数据，并将其发送给客户端 < li >客户端向通道发送数据# 2 < li >服务器(处理程序)根据客户端数据再次从数据库接收数据，并将其发送回客户端，然后关闭通道 如果首次在通道中读取花费的时间太长，则读取超时处理程序将按预期触发异常。但是，如果第一次读取没问题（= 足够快），并且
-
我所尝试的 我尝试将我的域添加到以下部分https://www.elastic.co/guide/en/cloud-on-k8s/current/k8s-http-settings-tls-sans.html#k8s-elasticsearch-http-service-san 我曾尝试使用openssl生成自签名证书，但没有成功。尝试本地连接将返回以下错误消息。 curl-u“弹性:$passw
-
在使用Hibernate和Jpa的spring boot应用程序中，我需要在saveAll（）之前关闭select，以提高高记录数的性能。 我找到了一个使用JPQL的方法，性能很好（在30s内删除+保存10k条记录），但我希望继续使用hibernate和JPA。 我的期望是，当我运行用Java编写的代码时，我必须删除一个表的所有记录，然后保存另一个表的所有记录。当我以经典的方式（deleteAll
-
YouTube频道可以有几个“相关”频道的列表。例如，音乐频道有相关的流派频道：嘻哈、流行、摇滚、乡村等。 音乐频道：http://www.youtube.com/channel/UC-9-kyTW8ZkZNDHQJ6FgpwQ 音乐频道相关频道:http://www . YouTube . com/Channel/UC-9-kytw 8 zkzndhqj 6 fg pwq/Channels 我可
-
下面的最小示例（针对我遇到的问题）将在通过同一通道发送的第二个命令时失败，错误为“channel closed”。 该方案应： 连接到RabbitMQ 打开RabbitMQ通道 声明simpe队列（名为“test”） 绑定到队列（名为“测试”） 发布消息（“你好，世界！”） 成功发布消息后，请稍候，然后发布另一条消息 为什么或RabbitMQ本身会关闭通道（而不是连接或我错过了什么）？