小编ani*_*mar的帖子

我们在tomcat 6.0.35上运行activeMQ5.6作为嵌入式代理,并将消息传递选项设置为PERSISTENT.我们在其中一个消费者方面遇到OutOfMemory问题.由于耗时的工作,消费者很慢.我们过去8-10小时后就得到了OOM.在处理3000条消息之后,必须处理大约10000条消息并给予OOM,其余7000条消息保持待处理状态.消息大小非常小~1KB的xml格式.虽然我们在差异队列上有其他消费者非常快,并且还发布了大约10000条消息,并且消息大小非常高~100 KB但我们没有在该队列上获得OOM.虽然它是在同一个经纪人上设置的.

这是错误的堆栈跟踪和out activemq.xml文件

INFO [11/08/12 05:39:31] ActiveMQ会话任务-4开始上传Nam2011_08_prototype/gdfas/mnada/usa/uf3.7z.001到Amazon S3存储桶 - aws-s3-infotech线程中的异常"InactivityMonitor WriteCheck "java.lang.OutOfMemoryError:无法在java.util.conhurrent.ThreadPoolExecutor.addIfUnderMaximumPoolSize的java.lang.Thread.start(Thread.java:640)的java.lang.Thread.start0(本机方法)中创建新的本机线程(ThreadPoolExecutor.java:727)位于org.apache.activemq的org.apache.activemq.transport.AbstractInactivityMonitor.writeCheck(AbstractInactivityMonitor.java:142)的java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:657). transport.AbstractInactivityMonitor $ 2.run(AbstractInactivityMonitor.java:111)atg.apache.activemq.thread.SchedulerTimerTask.run(SchedulerTimerTask.java:33)at java.util.TimerThread.mainLoop(Timer.java:512)at java. util.TimerThread.run(Timer.java:462)

这是来自activemq.xml的快照

 <persistenceAdapter>
  <kahaDB directory="${activemq.data}/kahadb"/>
</persistenceAdapter>

<transportConnectors>
  <!-- <transportConnector name="openwire" uri="tcp://localhost:61616"/> -->
  <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
  <transportConnector name="stomp" uri="stomp://localhost:61613"/>
</transportConnectors>

<networkConnectors>
  <!-- by default just auto discover the other brokers -->
  <networkConnector name="defaultNetwork" uri="multicast://default"/>
  <!--
  <networkConnector name="host1 and host2" uri="static://(tcp://host1:61616,tcp://host2:61616)" failover="true"/>
  -->
</networkConnectors>

<systemUsage>
        <systemUsage>
            <memoryUsage>
                <memoryUsage limit="512 mb"/>
            </memoryUsage>
            <storeUsage>
                <storeUsage limit="100 gb"/>
            </storeUsage>
            <tempUsage>
                <tempUsage limit="50 gb"/>
            </tempUsage>
        </systemUsage>
    </systemUsage> …