今天在测试自己写的Rabbitmq的demo的时候出现了这么一个问题：
系统异常
其中显示问题原因在于channel已经被关闭导致，抛出异常。但是信息同时显示reply-code=200, reply-text=OK，这说明生产者一端的消息已经成功被消费者接收，初步判断异常与生产者一端无关。后来我检查了代码，发现了这么一个问题，
附上我的代码：
Producer（这段代码是在《Rabbit MQ实战指南》的基础上修改的）
Consumer
从代码中可以看到，在消费者一端线程等待了一秒之后会关闭channel和connection，而此时还有消息没有被消费完，导致程序发生异常。解决方法是将代码改为TimeUnit.SECONDS.sleep(1000)，让消费者一端有足够时间处理消息。
结果如图所示
程序不再发生异常
今天在测试自己写的Rabbitmq的demo的时候出现了这么一个问题： 其中显示问题原因在于channel已经被关...
spring cloud task 启动报错 context has been closed already 解决办法
message can not send, because channel is closed：可能需要重启ser...
SMTPServerDisconnected: Connection unexpectedly closed: T...
The opposite of manipulate may be a word that is closed t...
Lesson 1 When's it due? 什么时候截止？ It's due tomorrow. What t...
With her eyes closed, she sat listening to the wind and t...
⒈ ——Thought is already is late, exactly is the earliest t...
Due to the manifold recommendations, I began watching t...
don't forgive you as I really can't though I already trie...
本文标题："channel is already closed due t
本文链接：https://www.haomeiwen.com/subject/qihxtqtx.html
网友评论