我在两个服务器之间使用rabbitMQGolang客户端作为发布消息，但是我经常收到bug：“客户端意外地关闭了TCP连接”。我的rabbitMQ客户端正在正常运行，但一段时间之后它就停止了。谁能帮我检查如何捕捉这个错误并重新连接/修复这个错误？非常感谢！
客户端RabbitMQ意外关闭TCP连接，如何捕获或修复它？
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
1条回答 默认 最新
- doubo4336 2017-08-03 14:08关注
- Try with increased connection timeout
- Check your firewall configuration
本回答被题主选为最佳回答 , 对您是否有帮助呢?解决评论 打赏无用 2举报 分享
- 2017-08-03 09:05回答 1 已采纳 Try with increased connection timeout Check your firewall configuration
- 2019-09-26 13:55回答 2 已采纳 运行这三行代码，注意修改用户名和密码 rabbitmqctl add_user root root rabbitmqctl set_user_tags root administrator ra
- 2022-10-23 22:01回答 3 已采纳 正常滴很用命令操作 rabbitmqctl add_user username passwd //添加用户，后面两个参数分别是用户名和密码 rabbitmqctl set_permissions -
- 2020-09-06 21:25架构师研究会的博客 如果你问自己是否Apache Kafka比RabbitMQ更好或RabbitMQ是否比Apache Kafka更可靠，我想在这里阻止你。本文将从更广泛的角度讨论这两种情况。它关注的是这两个系统提供的功能，并将指导您做出正确的决定，决定何时...
- 2022-08-24 11:55回答 5 已采纳 rabbitMQ是受自己的容器控制，不是受服务容器控制，启动服务连接正常，rabbitMQ会开启监控，如果连接失败，就不会开启监控，并不会影响服务启动
- 2023-03-28 22:55回答 2 已采纳 消费者会一直监听,如生产者启动就会消费消息 ConnectionFactory factory = new ConnectionFactory(); //cpolar
- 2021-10-16 14:09回答 1 已采纳 可以参考试试：
- 2022-04-17 20:22i大魔王Leo的博客 因此需要建立Channel(信道)，是由于TCP连接的创建和释放都是十分昂贵的，如果一个客户端每一个线程都需要与RabbitMQ服务器交互，且每一个线程都建立一个TCP连接，暂且不考虑TCP连接是否浪费，就连操作系统也没法承受...
- 2023-03-19 17:59回答 2 已采纳 参考GPT和自己的思路： 在Spring Boot中，可以通过在@RabbitListener注释中配置containerFactory属性来获取Channel对象。containerFactory属
- 2019-02-07 19:47回答 1 已采纳 but still getting only one message, not a pack of five. what i'm doing wrong? You don't under
- 2014-10-11 11:19回答 1 已采纳 Looking at the source for the library it appears as though you can call conn.Channel() as many tim
- 2022-06-28 11:09各个方面都自在的博客 关闭防火墙： systemctl stop firewalld（service可以省略） 浏览器输入：http://ip:15672（ip是对应启动了rabbitmq服务器的ip），注意：要先启动，否则没有对应的页面 没有对应页面返回的，浏览器自然显示找不到...
- 2016-08-04 09:08回答 2 已采纳 不一定要一致，只要兼容就可以了。
- 2022-02-25 20:10Abner_iii的博客 消费者连接到 RabbitMQ 服务器，并订阅到队列上。当消费者消费一条消息时，只是消费消息的消息体（payload）。在消息路由的过程中，消息的标签会丢弃，存入到队列中的消息只有消息体，消费者也只会消费到消息体，也...
- 2021-03-23 23:23张维鹏的博客 RabbitMQ消息队列常见面试题总结； 1、什么是消息队列？消息队列的优缺点？ 2、Kafka、ActiveMQ、RabbitMQ、RocketMQ的区别？ 3、如何保证消息不被重复消费？ 4、如何保证消息不丢失，进行可靠性传输？ 5、如何保证...
- 没有解决我的问题, 去提问
