高负载生产环境下，Quarkus中每个HTTP请求创建JMSContext是否可行？

1. 每次HTTP请求创建JMSContext的方式不可行 #

在高负载生产环境中，这种做法会引发严重性能问题。因为每次创建JMSContext本质是新建JMS连接和会话，这个过程涉及TCP握手、协议协商等开销极大的操作。高并发场景下，短时间内会产生大量连接创建请求，不仅会耗尽Broker端的连接资源，还会导致服务端CPU、网络资源被占满，最终引发服务响应变慢甚至不可用。

2. 必须使用连接池机制 #

连接池是高负载场景下JMS使用的标配。Quarkus的JMS扩展（比如quarkus.activemq-artemis、quarkus.qpid-jms）默认集成了连接池能力，会预先创建并维护一批可用的JMS连接和会话。当请求过来时，直接从池中复用已有实例，避免重复创建的开销，能大幅提升系统的并发处理能力和稳定性。

你可以通过Quarkus配置项调整连接池参数，比如：

• quarkus.activemq-artemis.pool.max-connections：设置池内最大连接数
• quarkus.activemq-artemis.pool.idle-timeout：设置空闲连接的超时回收时间
• quarkus.activemq-artemis.pool.block-if-full：当池满时是否阻塞等待可用连接

3. 不能使用单个JMSContext处理所有请求 #

JMSContext不是线程安全的，多个线程同时操作同一个实例会引发并发问题，比如消息发送错乱、会话状态异常、甚至抛出运行时异常。正确的做法是依赖Quarkus的依赖注入，每次请求获取池化的JMSContext实例（Quarkus会自动保证线程安全的分配），然后针对不同的业务需求发送到对应的队列。

举个简单的代码示例：

import jakarta.inject.Inject;
import jakarta.jms.JmsContext;
import jakarta.ws.rs.POST;
import jakarta.ws.rs.Path;
import jakarta.ws.rs.core.Response;

@Path("/requests")
public class RequestResource {

    @Inject
    JmsContext jmsContext;

    @POST
    @Path("queue1")
    public Response sendToQueue1(RequestPayload payload) {
        jmsContext.createProducer().send(jmsContext.createQueue("requestQueue1"), payload);
        return Response.accepted().build();
    }

    @POST
    @Path("queue2")
    public Response sendToQueue2(RequestPayload payload) {
        jmsContext.createProducer().send(jmsContext.createQueue("requestQueue2"), payload);
        return Response.accepted().build();
    }
}

总结 #

高负载生产环境下，禁止每次请求创建JMSContext，必须依赖Quarkus自带的JMS连接池能力，通过依赖注入获取池化的JMSContext实例来处理消息发送需求，同时避免使用单个JMSContext处理多线程请求。

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