关于ActiveMQ消息队列不消费的思考

对于某些消息队列中间件标榜自己吞吐量高一直无法理解，一直觉得，不同的消息队列实现，吞吐量不会差太多，不管是多是少总不会差一个量级上，，一丁点差距没有值得称道的地方。

直到我用了ActiveMQ，才终于明白，标榜吞吐量高，全是同行衬托的，ActiveMQ的实现上一定有一个不大的Bug。这个Bug源于我发现的一个现象，ActiveMQ管理界面上可以看队列中还有7条消息等待多时仍然迟迟没有消费。将线程Dump下来后发现，Java消费者线程却全部卡在了读取消息的位置

   java.lang.Thread.State: RUNNABLEat java.net.SocketInputStream.socketRead0(Native Method)at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)at java.net.SocketInputStream.read(SocketInputStream.java:171)at java.net.SocketInputStream.read(SocketInputStream.java:141)at sun.security.ssl.InputRecord.readFully(InputRecord.java:465)at sun.security.ssl.InputRecord.readV3Record(InputRecord.java:593)at sun.security.ssl.InputRecord.read(InputRecord.java:532)at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:983)- locked <0x00000000d5a90800> (a java.lang.Object)at sun.security.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:940)at sun.security.ssl.AppInputStream.read(AppInputStream.java:105)- locked <0x00000000d5a90948> (a sun.security.ssl.AppInputStream)at org.apache.http.impl.io.SessionInputBufferImpl.streamRead(SessionInputBufferImpl.java:139)at org.apache.http.impl.io.SessionInputBufferImpl.fillBuffer(SessionInputBufferImpl.java:155)at org.apache.http.impl.io.SessionInputBufferImpl.read(SessionInputBufferImpl.java:208)at org.apache.http.impl.io.ChunkedInputStream.read(ChunkedInputStream.java:191)at org.apache.http.conn.EofSensorInputStream.read(EofSensorInputStream.java:137)at java.util.zip.InflaterInputStream.fill(InflaterInputStream.java:238)at java.util.zip.InflaterInputStream.read(InflaterInputStream.java:158)at java.util.zip.GZIPInputStream.read(GZIPInputStream.java:117)at org.apache.http.client.entity.LazyDecompressingInputStream.read(LazyDecompressingInputStream.java:73)at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)- locked <0x00000000d5a84118> (a java.io.InputStreamReader)at java.io.InputStreamReader.read(InputStreamReader.java:184)at java.io.Reader.read(Reader.java:140)at org.apache.http.util.EntityUtils.toString(EntityUtils.java:247)at org.apache.http.util.EntityUtils.toString(EntityUtils.java:273)

长达5分钟多钟的idle状态，直到报了多次Read timed out错误后才重新开始消费

java.net.SocketTimeoutException: Read timed outat java.net.SocketInputStream.socketRead0(Native Method) ~[?:1.8.0_161]at java.net.SocketInputStream.socketRead(SocketInputStream.java:116) ~[?:1.8.0_161]at java.net.SocketInputStream.read(SocketInputStream.java:171) ~[?:1.8.0_161]at java.net.SocketInputStream.read(SocketInputStream.java:141) ~[?:1.8.0_161]at sun.security.ssl.InputRecord.readFully(InputRecord.java:465) ~[?:1.8.0_161]at sun.security.ssl.InputRecord.readV3Record(InputRecord.java:593) ~[?:1.8.0_161]at sun.security.ssl.InputRecord.read(InputRecord.java:532) ~[?:1.8.0_161]at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:983) ~[?:1.8.0_161]at sun.security.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:940) ~[?:1.8.0_161]at sun.security.ssl.AppInputStream.read(AppInputStream.java:105) ~[?:1.8.0_161]at org.apache.http.impl.io.SessionInputBufferImpl.streamRead(SessionInputBufferImpl.java:139) ~[httpcore-4.4.1.jar:4.4.1]at org.apache.http.impl.io.SessionInputBufferImpl.fillBuffer(SessionInputBufferImpl.java:155) ~[httpcore-4.4.1.jar:4.4.1]at org.apache.http.impl.io.SessionInputBufferImpl.read(SessionInputBufferImpl.java:208) ~[httpcore-4.4.1.jar:4.4.1]at org.apache.http.impl.io.ChunkedInputStream.read(ChunkedInputStream.java:191) ~[httpcore-4.4.1.jar:4.4.1]at org.apache.http.conn.EofSensorInputStream.read(EofSensorInputStream.java:137) ~[httpclient-4.4.1.jar:4.4.1]at java.util.zip.InflaterInputStream.fill(InflaterInputStream.java:238) ~[?:1.8.0_161]at java.util.zip.InflaterInputStream.read(InflaterInputStream.java:158) ~[?:1.8.0_161]at java.util.zip.GZIPInputStream.read(GZIPInputStream.java:117) ~[?:1.8.0_161]at org.apache.http.client.entity.LazyDecompressingInputStream.read(LazyDecompressingInputStream.java:73) ~[httpclient-4.4.1.jar:4.4.1]at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284) ~[?:1.8.0_161]at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326) ~[?:1.8.0_161]at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178) ~[?:1.8.0_161]at java.io.InputStreamReader.read(InputStreamReader.java:184) ~[?:1.8.0_161]at java.io.Reader.read(Reader.java:140) ~[?:1.8.0_161]at org.apache.http.util.EntityUtils.toString(EntityUtils.java:247) ~[httpcore-4.4.1.jar:4.4.1]at org.apache.http.util.EntityUtils.toString(EntityUtils.java:273) ~[httpcore-4.4.1.jar:4.4.1]

关于ActiveMQ消息队列不消费的思考相关推荐

SpringBoot集成ActiveMq消息队列实现即时和延迟处理
原文链接:https://blog.csdn.net/My_harbor/article/details/81328727 一.安装ActiveMq 具体安装步骤:自己谷歌去二.新建springbo ...
消息队列的消费幂等性如何保证
参考大佬文章:消息队列的消费幂等性如何保证这里先介绍下幂等性: 幂等性: 一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同比如:一条数据或者一个请求,重复发起多次,我们要确保对 ...
redis list 实现消息队列多线程消费
redis list 实现消息队列多线程消费 redis list 实现消息队列多线程消费 redis list 实现消息队列多线程消费利用redis list 命令: Redis Brpop ...
activemq nodejs stomp 重连机制_5分钟优劣分析 Kafka、RabbitMQ、RocketMQ、ActiveMQ消息队列...
一.资料文档 Kafka:中,有kafka作者自己写的书,网上资料也有一些. rabbitmq:有一些不错的书,网上资料多. zeromq:少.没有专门写zeromq的书,网上的资料多是一些代码的实现 ...
ActiveMQ消息队列安装和使用
ActiveMQ ActiveMQ介绍什么是ActiveMQ ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线.ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规 ...
SpringBoot整合activeMQ消息队列手动签收（Session.CLIENT_ACKNOWLEDGE）为什么失效啊？
今天在家隔离办公,不太忙,然后就琢磨起来消息队列activeMQ的消息事务来解决分布式事务,但是奈何在SpringBoot整合activeMQ时,其消费者手动签收消息时出现了问题-->当acti ...
ActiveMQ消息队列的使用及应用
目录: 一:JMQ的两种消息模式1.1:点对点的消息模式1.2:订阅模式二:点对点的实现代码2.1:点对点的发送端2.2:点对点的接收端三:订阅/发布模式的实现代码3.1:订阅模式的发送端3.2 ...
activeMQ消息队列（xml方式）
一.项目搭建(spring+activeMQ环境) 导包: <dependency><groupId>org.apache.acti ...
消息队列篇—详谈ActiveMQ消息队列模式的分析及使用
2019独角兽企业重金招聘Python工程师标准>>> 消息队列(Message Queue)是分布式系统中重要的组件,通用使用场景可以简单地描述为当不需要立即获得结果,但是并发量需 ...

关于ActiveMQ消息队列不消费的思考

关于ActiveMQ消息队列不消费的思考相关推荐

最新文章

热门文章