使用Spring的JMSTAME将消息发送到ActiveMQ Artemis非常慢

Question

我只能向Apache Artemis发布大约1600个小字符串MSGS/sec。我已经尝试了两台机器，并获得了相同的性能。我期望的速度更快。那是一个线程的预期发送速度吗？我应该与几个线程并行化发送吗？

经纪人和出版应用程序在同一主机上。没有听众订阅该主题。我正在使用：

• JMS API
• APACHE ARTEMIS 2.20.0
• JAVA 18 64位
• Oracle Linux 8
• Spring Boot 2.6.5

Spring Boot application.properties include：

spring.jms.pub-sub-domain=true

broke> broker.xml has：

<persistence-enabled>false</persistence-enabled>

Spring的JMstemplate是这样的设置（这是错误的）：

import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.messaginghub.pooled.jms.JmsPoolConnectionFactory;
import org.springframework.jms.core.JmsTemplate;
 ...
JmsPoolConnectionFactory poolingFactory = new JmsPoolConnectionFactory();
poolingFactory.setConnectionFactory(new ActiveMQConnectionFactory());
jmsTemplate = new JmsTemplate(poolingFactory);

要发布消息，我只是在循环中调用此消息：

jmsTemplate.convertAndSend(jmsQueue, message);

在弹簧中设置JMstemplate这样的工作：

@Autowired
JmsTemplate jmsTemplate;

@PostConstruct
void setup() {
        JmsPoolConnectionFactory poolingFactory = new JmsPoolConnectionFactory();
        poolingFactory.setConnectionFactory(new ActiveMQConnectionFactory());
        jmsTemplate.setConnectionFactory(poolingFactory);
}

Answer 1

我认为您正在使用 Spring 的 JmsTemplate 遇到 长期存在的反模式。简而言之，它每次发送消息时都会创建和关闭 JMS 连接、会话和生产者。它并非设计用于与裸露的 javax.jms.ConnectionFactory 实现一起使用。它旨在与提供某种池化的实现一起使用。

作为概念验证，我启动了 ActiveMQ Artemis 2.20.0 的新实例，并在 broker.xmlfalse 设置代码>.然后我运行以下命令：

$ ./artemis producer --destination topic://foo --threads 50 --message-count 100000

该命令将启动 50 个线程，每个线程将使用核心 JMS 客户端向 JMS 主题 foo 发送 100,000 条消息，总共 5,000,000 条消息。在我的笔记本电脑上，该命令在大约 40.6 秒内完成，平均速率为 122,980.1 条消息/秒，这比您看到的 1,600 条消息要快得多。

ActiveMQ Artemis 具有非阻塞架构，旨在大规模最大化吞吐量，因此仅运行几个线程并不是测试性能的好方法。我建议修改您的“测试”以使用具有更多线程的池连接工厂，或者可能使用代理附带的命令行工具。 此池是从 ActiveMQ 项目中分叉出来的，并且经过了实际测试。您还可以使用 Spring 的 CachingConnectionFactory 一个简单的解决方案。

您可能还对新的性能工具感兴趣刚刚与 ActiveMQ Artemis 2.21.0 一起发布。