草庐IT

importantMessage

全部标签

java - 如何使 Spring JMSListener 爆发到最大并发线程数?

我有一个使用ActiveMQ5.10版的SpringJMS应用程序。我正在执行一个简单的并发测试。我正在使用SpringBoot、当前版本和注释来配置JMSListener和消息生成器。消息生产者只是尽可能快地将消息扔到队列中。消息监听器从队列中拉取消息,但在收到消息后hibernate1秒——模拟消息监听器在收到消息后需要做的一些工作。我将JMSListener设置为100-1000个并发线程。如果我同时启动消息生产者和消费者(都在自己的JVM中运行),消费者永远不会超过最小配置线程,即使最大范围设置为1000。如果我让生产者先启动并将几千条消息放入队列,然后启动1个或多个消费者实例