增加一次处理的出队消息的数量（ActiveMQ）答案

【问题标题】：Increase number of dequeued messages processed at a time (ActiveMQ)增加一次处理的出队消息的数量（ActiveMQ）
【发布时间】：2018-09-08 01:24:57
【问题描述】：

我有一个在 JBoss AS7 中运行的 MDB，它使用 ActiveMQ JCA 资源适配器使用来自远程 ActiveMQ 5.6 代理的消息。

生产者代码：

public void sendMessage(IDeliveryMessage message) throws Exception {

    Connection conn = null;
    Session session = null;
    MessageProducer producer = null;

    try {
        // Setup the connection & session
        ConnectionFactory cf = NamedObjectLocator.getConnectionFactory();
        conn = cf.createConnection();
        Destination destination = NamedObjectLocator.getDestination();
        session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
        conn.start();
        // Send a text message
        producer = session.createProducer(destination);
        ObjectMessage om = session.createObjectMessage(message);

        String id = System.currentTimeMillis()+"";
        om.setJMSCorrelationID(id);
        System.out.println("Producer: " + id);

        producer.send(om);

    } catch (Exception e) {
        throw new Exception(e.getMessage(), e);
    } finally {
        if (producer != null) {
            producer.close();
        }
        if (session != null) {
            session.close();
        }
        if (conn != null) {
            conn.stop();
            conn.close();
        }
    }
}

消费者代码：

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.Message;
import javax.jms.MessageListener;

@MessageDriven(name = "OutBoundMDB", activationConfig = {
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
        @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/OutboundIntegrationQueue")})
public class OutBoundMDB implements MessageListener {

    public static final long serialVersionUID = 8609676375853959140L;

    public void onMessage(Message message) {
        try {

            System.out.println("Consumer: " + message.getJMSCorrelationID());

            Thread.sleep(20000L);

        } catch (Exception e) {
            LogManager.logError(e);
        }

    }

}

JBoss Standalone.xml：

<subsystem xmlns="urn:jboss:domain:resource-adapters:1.0">
    <resource-adapters>
        <resource-adapter>
            <archive>
                activemq-rar.rar
            </archive>
            <transaction-support>XATransaction</transaction-support>
            <config-property name="ServerUrl">
                tcp://localhost:61616
            </config-property>
            <connection-definitions>
                <connection-definition class-name="org.apache.activemq.ra.ActiveMQManagedConnectionFactory" jndi-name="java:/JmsXA" enabled="true" use-java-context="true" pool-name="ActiveMQConnectionFactoryPool" use-ccm="true">
                    <xa-pool>
                        <min-pool-size>1</min-pool-size>
                        <max-pool-size>20</max-pool-size>
                    </xa-pool>
                </connection-definition>
            </connection-definitions>
            <admin-objects>
                <admin-object class-name="org.apache.activemq.command.ActiveMQQueue" jndi-name="java:/queue/OutboundIntegrationQueue" enabled="true" use-java-context="true" pool-name="ActiveMQQueue.OutboundIntegrationQueue">
                    <config-property name="PhysicalName">queue/OutboundIntegrationQueue</config-property>
                </admin-object>
            </admin-objects>
        </resource-adapter>
    </resource-adapters>
</subsystem>

现在打印的日志显示队列一次只能出列大约 8 到 10 条消息。由于我在消费者代码中让线程休眠了 20 秒，因此它只能处理大约 20 秒。 10 条消息，然后是 20 秒的间隔，然后是接下来的 10 条消息。以下是显示结果的日志：

2018-03-29 14:29:37,214 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348177214
2018-03-29 14:29:37,225 INFO  [stdout] (default-threads - 23) Consumer: 1522348177214
2018-03-29 14:29:37,433 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348177433
2018-03-29 14:29:37,437 INFO  [stdout] (default-threads - 24) Consumer: 1522348177433
2018-03-29 14:29:37,744 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348177744
2018-03-29 14:29:37,762 INFO  [stdout] (default-threads - 25) Consumer: 1522348177744
2018-03-29 14:29:37,956 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348177956
2018-03-29 14:29:37,958 INFO  [stdout] (default-threads - 26) Consumer: 1522348177956
2018-03-29 14:29:38,207 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348178207
2018-03-29 14:29:38,213 INFO  [stdout] (default-threads - 27) Consumer: 1522348178207
2018-03-29 14:29:38,413 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348178413
2018-03-29 14:29:38,421 INFO  [stdout] (default-threads - 28) Consumer: 1522348178413
2018-03-29 14:29:38,647 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348178647
2018-03-29 14:29:38,656 INFO  [stdout] (default-threads - 29) Consumer: 1522348178647


2018-03-29 14:29:38,856 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348178856
2018-03-29 14:29:39,060 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348179060
2018-03-29 14:29:39,265 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348179265
2018-03-29 14:29:39,583 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348179583
2018-03-29 14:29:39,872 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348179872
2018-03-29 14:29:40,143 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348180142
2018-03-29 14:29:40,451 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348180451
2018-03-29 14:29:40,716 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348180716
2018-03-29 14:29:41,041 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348181041
2018-03-29 14:29:41,254 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348181254
2018-03-29 14:29:41,447 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348181447
2018-03-29 14:29:41,682 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348181682
2018-03-29 14:29:41,911 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348181911
2018-03-29 14:29:42,098 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348182098
2018-03-29 14:29:42,300 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348182300
2018-03-29 14:29:42,497 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348182497
2018-03-29 14:29:42,834 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348182833
2018-03-29 14:29:43,043 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348183043
2018-03-29 14:29:43,257 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348183257
2018-03-29 14:29:43,459 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348183459
2018-03-29 14:29:43,669 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348183669
2018-03-29 14:29:43,936 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348183936
2018-03-29 14:29:44,133 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348184132
2018-03-29 14:29:44,329 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348184329
2018-03-29 14:29:44,551 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348184551
2018-03-29 14:29:44,789 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348184789
2018-03-29 14:29:45,012 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348185012
2018-03-29 14:29:45,274 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348185274
2018-03-29 14:29:45,473 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348185473
2018-03-29 14:29:45,721 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348185721
2018-03-29 14:29:46,104 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348186104
2018-03-29 14:29:46,388 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348186388
2018-03-29 14:29:46,586 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348186586
2018-03-29 14:29:46,789 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348186789
2018-03-29 14:29:46,985 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348186985
2018-03-29 14:29:47,178 INFO  [stdout] (http-/0.0.0.0:8080-3) Producer: 1522348187178

20 SECONDS DELAY


2018-03-29 14:29:57,771 INFO  [stdout] (default-threads - 32) Consumer: 1522348179265
2018-03-29 14:29:57,772 INFO  [stdout] (default-threads - 30) Consumer: 1522348178856
2018-03-29 14:29:57,775 INFO  [stdout] (default-threads - 33) Consumer: 1522348179583
2018-03-29 14:29:57,782 INFO  [stdout] (default-threads - 31) Consumer: 1522348179060
2018-03-29 14:29:57,784 INFO  [stdout] (default-threads - 34) Consumer: 1522348179872
2018-03-29 14:29:58,226 INFO  [stdout] (default-threads - 35) Consumer: 1522348180142


AGAIN 20 SECONDS DELAY


2018-03-29 14:30:17,790 INFO  [stdout] (default-threads - 36) Consumer: 1522348180451
2018-03-29 14:30:17,806 INFO  [stdout] (default-threads - 37) Consumer: 1522348180716
2018-03-29 14:30:17,807 INFO  [stdout] (default-threads - 39) Consumer: 1522348181254
2018-03-29 14:30:17,812 INFO  [stdout] (default-threads - 40) Consumer: 1522348181447
2018-03-29 14:30:17,815 INFO  [stdout] (default-threads - 44) Consumer: 1522348182300
2018-03-29 14:30:17,830 INFO  [stdout] (default-threads - 42) Consumer: 1522348181911
2018-03-29 14:30:17,833 INFO  [stdout] (default-threads - 43) Consumer: 1522348182098
2018-03-29 14:30:17,842 INFO  [stdout] (default-threads - 38) Consumer: 1522348181041
2018-03-29 14:30:17,848 INFO  [stdout] (default-threads - 41) Consumer: 1522348181682
2018-03-29 14:30:18,233 INFO  [stdout] (default-threads - 45) Consumer: 1522348182497




2018-03-29 14:30:37,793 INFO  [stdout] (default-threads - 36) Consumer: 1522348182833
2018-03-29 14:30:37,810 INFO  [stdout] (default-threads - 37) Consumer: 1522348183043
2018-03-29 14:30:37,815 INFO  [stdout] (default-threads - 39) Consumer: 1522348183459
2018-03-29 14:30:37,818 INFO  [stdout] (default-threads - 40) Consumer: 1522348183669
2018-03-29 14:30:37,855 INFO  [stdout] (default-threads - 38) Consumer: 1522348183257
2018-03-29 14:30:37,859 INFO  [stdout] (default-threads - 41) Consumer: 1522348183936
2018-03-29 14:30:37,867 INFO  [stdout] (default-threads - 47) Consumer: 1522348184329
2018-03-29 14:30:37,869 INFO  [stdout] (default-threads - 46) Consumer: 1522348184132
2018-03-29 14:30:37,871 INFO  [stdout] (default-threads - 48) Consumer: 1522348184551






2018-03-29 14:30:57,804 INFO  [stdout] (default-threads - 50) Consumer: 1522348185012
2018-03-29 14:30:57,804 INFO  [stdout] (default-threads - 49) Consumer: 1522348184789
2018-03-29 14:30:57,816 INFO  [stdout] (default-threads - 37) Consumer: 1522348185274
2018-03-29 14:30:57,821 INFO  [stdout] (default-threads - 39) Consumer: 1522348185721
2018-03-29 14:30:57,827 INFO  [stdout] (default-threads - 40) Consumer: 1522348186104
2018-03-29 14:30:57,861 INFO  [stdout] (default-threads - 38) Consumer: 1522348185473
2018-03-29 14:30:57,864 INFO  [stdout] (default-threads - 41) Consumer: 1522348186388
2018-03-29 14:30:57,873 INFO  [stdout] (default-threads - 47) Consumer: 1522348186789
2018-03-29 14:30:57,876 INFO  [stdout] (default-threads - 46) Consumer: 1522348186586
2018-03-29 14:30:57,881 INFO  [stdout] (default-threads - 48) Consumer: 1522348186985

我希望一次将 Dequeued 消息的数量（现在大约 10 个）增加到 50 个或更多。

【问题讨论】：

您如何处理消息（例如 MDB、独立 MessageConsumer、独立 MessageListener 等）？你有多少消费者？您是否将 ActiveMQ 配置为嵌入在 JBoss AS7 中运行还是独立运行？
您是如何处理这些消息的？ MDB ...您有多少消费者？ 1 ...您是否将 ActiveMQ 配置为嵌入在 JBoss AS7 中运行还是独立运行？没有嵌入到 Jboss 中，它独立运行。
如果你有一个在 JBoss AS7 中运行的 MDB 使用来自远程 ActiveMQ 5.x 代理的消息，那么我假设 MDB 正在使用 ActiveMQ JCA 资源适配器。如果正确，MDB 的激活配置是什么？如果没有，请详细说明 JBoss AS7 和 ActiveMQ 代理之间的连接是如何配置的。此外，不要用您自己的 cmets 来回答这些 cmets，您实际上应该使用额外的详细信息编辑您的原始问题，以便问题更全面且更容易回答。
我已经改写了整个问题 - 希望这能更好地解释我的问题，并可能帮助我找到解决方案。谢谢！

标签： java jboss activemq

【解决方案1】：

看看the ActiveMQ JCA RA activation specification documentation。您几乎可以肯定需要调整 maxSessions 和 maxMessagesPerSession 以适应您的性能目标。

您可能还需要调整由容器维护的池中 MDB 实例的数量（即本例中的 JBoss EAP）。在您的服务器配置中搜索mdb-strict-max-pool。默认情况下，它从服务器的 CPU 计数派生池大小，但您可以使用 max-pool-size 显式设置它。我相信推导使用公式：Runtime.getRuntime().availableProcessors() * 4（见here）。

【讨论】：