Spring Boot虚拟线程结合ActiveMQ Classic线程固定问题求助

问题场景 #

我使用启用了虚拟线程的Spring Boot 3.2.5，通过ActiveMQ 5.18.4客户端连接外部ActiveMQ Classic Broker。使用JmsTemplate.sendAndReceive()方法向请求队列发送消息，并通过@JmsListener从响应队列获取返回结果。每次发送消息时都会收到线程固定警告，日志如下：

2024-05-18 15:06:39.916  INFO 29496 --- [omcat-handler-5] c.b.i.m.impl.OFSActiveMQProducer         : Producer: Sending message to queue Q.ENQ.IN.DEV with correlationID 85ea6e1a-56fd-4e94-b822-f5c44e363408
Thread[#52,ForkJoinPool-1-worker-1,5,CarrierThreads]
    org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:2045) <== monitors:1
2024-05-18 15:06:40.047  INFO 29496 --- [ntContainer#0-1] c.b.iraq.messaging.EnqActiveMQConsumer   : Enq Consumer: Received message from queue Q.ENQ.OUT.DEV with Id: 85ea6e1a-56fd-4e94-b822-f5c44e363408 
2024-05-18 15:06:40.253  INFO 29496 --- [omcat-handler-5] c.b.i.m.impl.OFSActiveMQProducer         : Producer: Successfully received message from consumer for Q.ENQ.IN.DEV with ID: 85ea6e1a-56fd-4e94-b822-f5c44e363408

查阅文档未找到ActiveMQ是否支持虚拟线程的说明，请问是否有办法解决该线程固定问题，或者发送JMS消息时允许该情况是否可行？

问题原因 #

ActiveMQ 5.x客户端的核心实现（如ActiveMQSession）依赖同步监视器（synchronized块）和原生线程绑定逻辑，而虚拟线程遇到监视器锁时会被固定到载体线程（Carrier Thread）上，无法实现轻量级切换，这就是日志中线程固定警告的来源。ActiveMQ 5.x设计早于Java虚拟线程推出，官方未做适配。

解决方案 #

1. 隔离JMS操作到平台线程池 #

将JMS发送/接收操作强制放到平台线程池执行，避免虚拟线程被固定。Spring Boot中可自定义平台线程池，结合异步执行：

// 定义平台线程池
@Bean(name = "jmsPlatformThreadPool")
public TaskExecutor jmsPlatformThreadPool() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(8);
    executor.setMaxPoolSize(16);
    executor.setThreadNamePrefix("jms-platform-");
    executor.setDaemon(true);
    executor.initialize();
    return executor;
}

// 在生产者中使用平台线程执行sendAndReceive
@Autowired
private JmsTemplate jmsTemplate;

@Autowired
@Qualifier("jmsPlatformThreadPool")
private TaskExecutor platformThreadPool;

public Message receiveResponse(String queueName, Message requestMsg) throws ExecutionException, InterruptedException {
    Future<Message> future = platformThreadPool.submit(() -> jmsTemplate.sendAndReceive(queueName, requestMsg));
    return future.get();
}

2. 升级到ActiveMQ Artemis客户端 #

ActiveMQ Artemis（下一代ActiveMQ）的客户端完全兼容虚拟线程，实现上避免了不必要的线程绑定和同步监视器。只需替换依赖：

<!-- 移除ActiveMQ 5.x客户端依赖 -->
<!-- <dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-all</artifactId>
    <version>5.18.4</version>
</dependency> -->

<!-- 添加Artemis客户端依赖 -->
<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>artemis-jms-client</artifactId>
    <version>2.33.0</version>
</dependency>

调整连接配置为Artemis格式后，Spring Boot会自动适配JmsTemplate和@JmsListener。

3. 忽略警告（临时方案） #

若业务对性能要求不高，线程固定的影响在可接受范围内，可直接忽略警告。线程固定不会导致功能异常，仅损失虚拟线程的部分性能优势。可通过JVM参数关闭警告：

-Djdk.virtualThreadScheduler.threadpinning.warning=false

关于"是否允许该情况"的结论 #

从功能角度，线程固定不会导致消息发送/接收失败，业务可正常运行。但从性能角度，若系统依赖虚拟线程的高并发能力，线程固定会占用载体线程，降低整体吞吐量。建议根据业务规模选择方案：小流量场景可忽略，大流量场景优先隔离平台线程或升级Artemis客户端。

内容的提问来源于stack exchange，提问作者William N