开源问答 技术问答
正文

socket通讯对rabbitmq ack的影响

三十回头 发布于 2017/02/28 10:04
阅读 169
收藏 0
答案 2
Socket
开发四年只会写业务代码，分布式高并发都不会还做程序员？->>>   

对方socket接口关闭时，消费者通过rabbitmq取出消息并进行socket通讯报错了，有try catch的操作，这个时候就会出现unack的消息，通过rabbitmq界面看到unack和total里面都有消息，而且不断地在增加，重启项目以后就没有unack的消息了，求大神们帮忙看看，不胜感激！

收藏 (0)
举报
加载中
最多投票 最新
0
你我他有个梦
你我他有个梦
2017/02/28 22:12

1.有可能是发布确认的问题，首先如果确认消费到了消息，那么如果还是unack，那么说明broker未确认消息，发布者客户端未接收到basic.ack，但是应该是会有日志记录，重启之后应该可以看到unack的消息。可以参考：https://my.oschina.net/lzhaoqiang/blog/670749

2.有可能是线程池的问题，也就是说你创建的channel数量多于了线程池的数量了，channel无法处理消息

评论 (1) 引用此答案 举报
三十回头
三十回头
2017/03/06 10:47
怎么确定下是线程池的问题 或者怎么看线程池
回复 举报
0
三十回头
三十回头
2017/03/06 10:48

引用来自“lzhaoqiang”的评论

1.有可能是发布确认的问题，首先如果确认消费到了消息，那么如果还是unack，那么说明broker未确认消息，发布者客户端未接收到basic.ack，但是应该是会有日志记录，重启之后应该可以看到unack的消息。可以参考：https://my.oschina.net/lzhaoqiang/blog/670749

2.有可能是线程池的问题，也就是说你创建的channel数量多于了线程池的数量了，channel无法处理消息

十分感谢，大致是有方向了！

评论 (0) 引用此答案 举报
三十回头
三十回头
最近登录：04/11 15:23
全部

三十回头的其他提问

项目启动rabbitmq报错Failed to check/redeclare auto-delete queue(s)
0 回答
47 阅读
dump jvm 线程栈问题：java.lang.OutOfMemoryError: unable to create new native thread
0 回答
24 阅读
sharding-jdbc 如何动态实现物理表的配置
1 回答
349 阅读
Sharding JDBC: 标准分片策略（StandardShardingStrategy）+ComplexShardingStrategy
0 回答
1K+ 阅读
XXL-job分片问题
1 回答
1K+ 阅读

类似问题

RabbitMQ在分布式系统的应用
0 回答
1611 阅读
RabbitMQ在分布式系统的应用
2 回答
771 阅读
spring+rabbitmq结合，消息接收成功，但解析内容失败。抛出异常。rabbitmq会一直推送咋办啊，啥时候会到unack队列中呢
2 回答
1816 阅读
rabbitmq socket连接
2 回答
1033 阅读
netty 和 rabbitmq 问题 （层次/关系/区别/结合）
0 回答
1968 阅读
用 MongoDB 取代 RabbitMQ
2 回答
10808 阅读
请教rabbitmq的几个问题
0 回答
611 阅读
请教有关RabbitMQ消息确认的问题！
4 回答
8829 阅读
关于rabbitmq的两个问题[说法/持久化]
6 回答
2972 阅读
pika连接RabbitMQ，消费者总报连接关闭
1 回答
1115 阅读
NET下RabbitMQ实践[配置篇]
0 回答
282 阅读
centos6.9 rabbitmq安装后无法启动
0 回答
510 阅读
支持插件的消息中间件【msg broker with plugin】
0 回答
506 阅读
spring如何配置连接两台Rabbitmq服务器呢？
3 回答
910 阅读
spring boot RabbitMQ 问题
3 回答
1338 阅读
返回顶部
顶部