社区所有版块导航
Python
python开源   Django   Python   DjangoApp   pycharm  
DATA
docker   Elasticsearch  
aigc
aigc   chatgpt  
WEB开发
linux   MongoDB   Redis   DATABASE   NGINX   其他Web框架   web工具   zookeeper   tornado   NoSql   Bootstrap   js   peewee   Git   bottle   IE   MQ   Jquery  
机器学习
机器学习算法  
Python88.com
反馈   公告   社区推广  
产品
短视频  
印度
印度  
Py学习  »  MQ

发送消息后未清除ActiveMQ消息内容

egb mahajne • 5 年前 • 697 次点击  

我有一个Java应用程序,里面有发送器和接收器,还有ActiveMQ Queue 发送方创建消息并将其发送到队列,使用者使用来自队列的消息。 每次我发送一条消息时,它都会被序列化并保留其内容 ByteSequence 对于消息,队列获取该消息,而使用者使用它,但是,我发现每次向队列发送消息时, 字节序 没有从记忆中清除,最终我得到 OutOfMemoryException

在消息被发送到队列之后,不应该从生产者中删除它吗?

谢谢!

Python社区是高质量的Python/Django开发社区
本文地址:http://www.python88.com/topic/30868
 
697 次点击  
文章 [ 1 ]  |  最新文章 5 年前
egb mahajne
Reply   •   1 楼
egb mahajne    5 年前

好吧,似乎Q使用的预取默认值是1000,这导致了消费者获得OOM异常,因为每个消息的处理时间太长,预取只得到很快的填充。