Spring与activemq整合，消费者的消费速度非常慢

0 0

Spring与activemq整合，消费者的消费速度非常慢5

我使用spring与activemq整合发送消息，发送速度可以达到10000/s,但是消费者的消费速度却是非常慢，求给位大神帮忙！！！这是我配置文件的内容：<bean id="innerNgbfJmsFactory" class="org.apache.activemq.ActiveMQConnectionFactory">

<property name="brokerURL" value="${ngbf.jms.provider.url}" />

<property name="dispatchAsync" value="true" />

</bean>


<bean id="ngbfJmsSenderFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
destroy-method="stop">
<property name="connectionFactory" ref="innerNgbfJmsFactory" />

</bean>


<bean id="ngbfJmsReveiverFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
destroy-method="stop">
<property name="connectionFactory" ref="innerNgbfJmsFactory" />


</bean>


<bean id="ngbfJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="ngbfJmsSenderFactory" />
<property name="messageConverter" ref="ngbfMessageByteConvert" />

</bean>


<bean id="ngbfMessageConvert" class="com.kingstar.ngbf.s.jms.MessageUnitConvert" />
<bean id="ngbfMessageTextConvert" class="com.kingstar.ngbf.s.jms.MessageUnitTextConvert" />
<bean id="ngbfMessageByteConvert" class="com.kingstar.ngbf.s.jms.MessageUnitByteConvert" />

<bean id="ngbfDefaultMessageListenerAdapter"
class="org.springframework.jms.listener.adapter.MessageListenerAdapter"
abstract="true">
<property name="defaultListenerMethod" value="handleMessage" />
<property name="messageConverter" ref="ngbfMessageByteConvert" />
</bean>




<bean id="ngbfDefaultQueueMessageListener" parent="ngbfDefaultMessageListenerAdapter">
<constructor-arg>
<bean class="com.kingstar.ngbf.s.jms.MessageUnitQueueListener" />
</constructor-arg>
</bean>



<bean id="ngbfDefaultTopicMessageListener" parent="ngbfDefaultMessageListenerAdapter">
<constructor-arg>
<bean class="com.kingstar.ngbf.s.jms.MessageUnitTopicListener" />
</constructor-arg>
</bean>

<bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
<property name="corePoolSize" value="10" />
        <property name="maxPoolSize" value="100"/>
        <property name="queueCapacity" value="1000"/>
        <property name="keepAliveSeconds" value="300"/>
</bean>


<bean id="ngbfDefaultQueueListenerContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer"
lazy-init="false">
<property name="connectionFactory" ref="ngbfJmsReveiverFactory" />
<property name="destinationName" value="NGBF.Queue" />
    <property name="pubSubDomain" value="false" />


<property name="messageListener" ref="ngbfDefaultQueueMessageListener" />


<property name="maxMessagesPerTask" value="-1"/>
<property name="concurrentConsumers" value="10" />
<property name="maxConcurrentConsumers" value="100" />
<property name="idleTaskExecutionLimit" value="2" />
    <property name="receiveTimeout" value="10000" />
<property name="cacheLevel" value="3"/>
<property name="taskExecutor" ref="taskExecutor"/>
</bean>
<bean id="ngbfDefaultQueueListener" parent="ngbfDefaultQueueListenerContainer">
<property name="messageSelector" value="${ngbf.jms.queue.selector}" />

<property name="destinationName" value="NGBF.Queue" />
</bean>