问题描述
我正在尝试解决这个 ActiveMQ Artemis 错误。
似乎偶尔的消息对于 SimpleString
来说太大了,并且没有发送,而是进入了 DLQ。
java.lang.indexoutofboundsexception: Error reading in simpleString,length=1366648 is greater than readableBytes=127646@ClientLargeMessageImpl[messageID=578576793,durable=true,address=AuthCorrespondence.sendmail,userID=7f72137c-c3a3-11eb-87f7-0242c0a8e003,properties=TypedProperties[__AMQ_CID=b3f70eb1-be3c-11eb-87f7-0242c0a8e003,_AMQ_LARGE_SIZE=127651,_AMQ_ROUTING_TYPE=1]]
at org.apache.activemq.artemis.jms.client.ActiveMQMessageConsumer.getMessage(ActiveMQMessageConsumer.java:234)
at org.apache.activemq.artemis.jms.client.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:132)
at org.springframework.jms.support.destination.JmsDestinationAccessor.receiveFromConsumer(JmsDestinationAccessor.java:130)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveMessage(AbstractPollingMessageListenerContainer.java:416)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:302)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:255)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncmessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1168)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncmessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1160)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncmessageListenerInvoker.run(DefaultMessageListenerContainer.java:1057)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.indexoutofboundsexception: Error reading in simpleString,length=1366648 is greater than readableBytes=127646
at org.apache.activemq.artemis.api.core.SimpleString.readSimpleString(SimpleString.java:183)
at org.apache.activemq.artemis.api.core.SimpleString.readSimpleString(SimpleString.java:171)
at org.apache.activemq.artemis.api.core.SimpleString.readNullableSimpleString(SimpleString.java:158)
at org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper.readNullableSimpleString(ChannelBufferWrapper.java:69)
at org.apache.activemq.artemis.reader.TextMessageUtil.readBodyText(TextMessageUtil.java:37)
at org.apache.activemq.artemis.jms.client.ActiveMQTextMessage.dobeforeReceive(ActiveMQTextMessage.java:112)
at org.apache.activemq.artemis.jms.client.ActiveMQMessageConsumer.getMessage(ActiveMQMessageConsumer.java:228)
... 11 more
我能看到的最可能的问题是 readableBytes=127646
和 _AMQ_LARGE_SIZE=127651
之间的相似性。
从文档来看,这个 _AMQ_LARGE_SIZE 是大消息的阈值,应该是 2GB,而这个消息是什么,1.36MB?
怎么回事?
编辑:
[root@6dcbad102045 large-messages]# pwd
/opt/amq/broker/data/large-messages
[root@6dcbad102045 large-messages]# ls -l
total 13828
-rw-r--r-- 1 root root 6451200 Sep 14 2020 194154444.msg
-rw-r--r-- 1 root root 4198400 Nov 5 2020 266358970.msg
-rw-r--r-- 1 root root 1843200 Nov 13 2020 277265384.msg
-rw-r--r-- 1 root root 1433600 Apr 28 12:36 522483226.msg
-rw-r--r-- 1 root root 102400 Jun 2 15:07 578576791.msg
-rw-r--r-- 1 root root 127651 Jun 3 09:46 579961682.msg
我在 Fuse/Osgi 中。 2.6.3.redhat-00015 用于 ActiveMQ Artemis JMS 客户端 Osgi。 2.21.5 用于骆驼-amqp。我无法弄清楚它是什么 Artemis 版本。有 1000 多个成功交付。只有 6 次失败。
解决方法
2.6.3.redhat-00015
版本对应于 AMQ 7.2.3,在这一点上已经很老了。当前的 AMQ 版本是 7.8.1。我强烈建议您升级,因为您可能会遇到一个已经修复的错误。
您可能可以通过增加最小大消息大小(例如,在核心客户端 URL 上使用 minLargeMessageSize
或在您的 AMQP amqpMinLargeMessageSize
上使用 acceptor
}})。值得一提的是,堆栈跟踪表明在抛出异常时正在使用核心 JMS 客户端(即不是 AMQP)。
最后,值得注意的是,默认的最小大邮件大小为 100 KB,而不是 the documentation 中所述的 2 GB。