`
miraclerz
  • 浏览: 100118 次
社区版块
存档分类
最新评论

mq 内存溢出

 
阅读更多

      项目总是运行几天就自动挂了,内存溢出,拿工具指令发现是mq占内存越来越多,并无回收,怀疑代码有问题,导致java垃圾回收一直没能回收到这几个mq类

 

 

于是查了下底层代码,既然是这个ActiveMQTextMessage 久居不下,就看下是哪里用的这个,发现所有的消息都是来是ActiveMQTextMessage 类的,一般来说消息发完,或者消费完,这个类就直接处理无效状态,会给垃圾回收的了。但是看这情况是没有回收的,于是再往里看一下,发现 message.setConnection(this.connection);这一句,网上很多例子是直接这样发完就行了,因为他们的connection是临时产生的,发完,connection是直接关闭的,而我们的框架里connection是共用的,也就是connection是重复利用,并不是用一次关一次的,这样message里就一直存在着活着的connection,怀疑是这个问题导致ActiveMQTextMessage 不能给回收,于是在发完消息和接收处理完消息后面直接把ActiveMQTextMessage  的实例置为null。再测试,发现ActiveMQTextMessage 不再久居不下了,问题得到解决!

 

 

 

 

  • 大小: 54.2 KB
0
0
分享到:
评论

相关推荐

    apache-apollo-1_mqtt_MQTT测试_coaloyj_MQTTjava_apache-apollo-1.7.1

    Apache Apollo是Apache软件基金会的一个项目,它是一个高性能的消息中间件,尤其适合企业级的应用场景。在本案例中,我们关注的是Apollo与MQTT(Message Queuing Telemetry Transport)协议的结合,这使得它成为...

    学习文档MQ+Redis

    - **GC友好的代码**:编写避免内存溢出、减少垃圾产生的代码,如合理使用引用、及时释放不再使用的资源、避免大量临时对象等。 本学习文档包含的资料如"JVM运行时数据区.pdf"和"JVM内存管理_GC模型_编写GC友好的...

    RabbitMQ消费者C#源码

    RabbitMQ是一款开源的消息队列系统,它基于AMQP(Advanced Message Queuing Protocol)协议,广泛应用于分布式系统中,用于实现异步任务处理、解耦系统组件以及提供高可用性。在C#环境下,我们可以使用RabbitMQ的...

    MQ安装配置教程

    3. **性能问题**:优化配置文件中的内存管理选项,避免内存溢出等问题的发生。 #### 六、总结 通过以上步骤,我们完成了ActiveMQ在Linux环境下的安装配置工作。消息队列作为现代软件架构中的重要组成部分,在实际...

    MQ配置和编程最佳实践.doc

    - **队列深度和消息大小**:MAXDEPTH和MAXMSGL应根据实际需求设定,防止队列溢出或处理性能下降。 3. **通道配置** - **运行模式**:长连接或触发模式取决于通道使用频率,触发通道通常适用于一次性任务。 - **...

    阿里canal中间件

    4. **灵活的插件机制**: 支持多种数据同步协议,如MQ、Kafka、RabbitMQ等,用户可以根据实际需求选择合适的插件进行数据推送。 5. **多目的地同步**: 一个Canal实例可以同时向多个目的地同步数据,适用于构建复杂的...

    activityMQ

    在使用非持久化消息时,尤其需要注意消息的及时处理,避免内存溢出导致的写文件操作,影响系统的性能和消息的发送速度。 持久化消息虽然可靠性高,但在某些情况下可能会导致性能瓶颈,特别是消息的存储和检索速度...

    BlazeDS+Spring+activeMQ outofmemory

    标题 "BlazeDS+Spring+activeMQ outofmemory" 指的是在使用BlazeDS、Spring和ActiveMQ集成的环境中遇到了内存溢出问题。BlazeDS是一个开放源码的服务器端技术,它允许双向通信,使Flex或AJAX客户端能够与Java后端...

    Rabbit MQ.ppt

    若启用手动ack,消费者处理完消息后需确认,否则可能导致内存溢出。 2. **Work 模式**:多个消费者竞争同一队列中的消息,适用于资源竞争场景,如抢红包或任务调度。 3. **Publish/Subscribe 模式**:消息通过交换机...

    MQ消息堆积终极解决方案【RabbitMQ】.docx

    一旦队列长度超出限制,将可能导致MQ服务内存溢出,进而引发整个服务的崩溃。 #### 解决方案探讨 针对这一问题,文档中提出了几种可能的解决方案,并对它们进行了分析: 1. **消息推送校验模式** - **思路**:...

    tomcat2WAS9.rar

    spring4.3.x、CXF3.2.x框架部署到Websphere9,在TOMCAT8.5跑没问题,到WAS9上各种冲突,框架用的jar和工具都...框架使用sping4.3.x,CXF3.2.x,Mybatis3.4,集成了xml读取,poi用来excel写入,easyexcel读取防止内存溢出

    c c++内存分配大小实例讲解.docx

    在C++编程语言中,内存管理是一个关键概念,...例如,合理使用动态内存可以避免栈溢出,而理解成员函数和静态成员的存储位置有助于正确地设计和实现类。在编写C++程序时,应时刻考虑内存管理,以提高程序效率和稳定性。

    大型国企内部Java面试题

    JVM:涉及常用的内存泄漏、内存溢出、MAT、jstack的分析案例 Linux:涉及开发中常用的命令,如telnet、curl、wget、netstat Redis:集群底层原理、持久化内部机制等 多线程、集合等 内容过多,就不一一例举。整理...

    基于集群的负载均衡方案

    问题分析阶段发现,事件接收过多可能导致服务器效率下降,网络接收速度超过处理速度会导致内存溢出,以及事件处理速度受限于内存拷贝和图片上传过程。 为了解决这些问题,提出的解决方案是采用数据分流的负载均衡...

    redis做消息队列

    在本场景中,Redis作为消息队列使用,替代了传统的Kafka队列,以实现顺序消费和防止高并发时的内存溢出问题。 Redis支持多种数据结构,如字符串、哈希、列表、集合和有序集合等,这些数据结构可以巧妙地应用于消息...

    2023一线互联网大厂Java面试题集

    - 栈内存溢出通常发生在递归调用过深或局部变量过多导致栈空间耗尽。 10. **JVM内存结构**: - JVM内存分为堆内存(包括新生代、老年代和永久代/元空间)、栈内存和方法区。新生代进一步划分为Eden和两个Survivor...

    详解Node.js amqplib 连接 Rabbit MQ最佳实践

    每个`connection`都会占用大约100kb的内存,过多的连接可能导致内存溢出,从而影响服务稳定性。因此,应尽量重用`connection`和`channel`,而非频繁开关。每次开关`channel`或`connection`都会产生额外的TCP包,这会...

    ActiveMQ笔记

    - **消息分页**: 当消息量过大时,ActiveMQ会自动进行分页管理,防止内存溢出。 - **安全性**: 提供用户认证和访问控制,保障消息的安全传输。 5. **安装与配置** - 下载ActiveMQ二进制包并解压。 - 修改配置...

    excel技术,Java架构师面试资料

    它提供了简单易用的API,可以方便地进行Excel的读写操作,尤其适合大数据量的场景,避免了内存溢出的问题。 7. **导入**:这个标签可能指的是数据导入功能,比如从Excel文件导入数据到数据库或系统中。在Java环境中...

    java读取超大文本文件

    - 如果文件非常大,建议采用分块读取的方式避免一次性加载过多数据导致内存溢出。 #### 2. 使用`RandomAccessFile`与`FileChannel`结合`MappedByteBuffer` 对于需要随机访问或文件特别大的情况,推荐使用`...

Global site tag (gtag.js) - Google Analytics