我有一个Java应用程序,里面有发送器和接收器,还有ActiveMQ Queue 发送方创建消息并将其发送到队列,使用者使用来自队列的消息。 每次我发送一条消息时,它都会被序列化并保留其内容 ByteSequence 对于消息,队列获取该消息,而使用者使用它,但是,我发现每次向队列发送消息时, 字节序 没有从记忆中清除,最终我得到 OutOfMemoryException
ByteSequence
字节序
OutOfMemoryException
在消息被发送到队列之后,不应该从生产者中删除它吗?
谢谢!
好吧,似乎Q使用的预取默认值是1000,这导致了消费者获得OOM异常,因为每个消息的处理时间太长,预取只得到很快的填充。