JMS 和消息驱动 EJB Bean

Question

我对消息驱动的 EJB 有疑问。 我也有包含 MessageDrivenBean 的应用程序 Web 服务和 EJB 应用程序。

为了向 JMS 发送消息，我使用 ObjectMessage： 这是我的代码：

        Connection connection = connectionFactory.createConnection();
        Session session = connection.createSession(false, 1);
        MessageProducer messageProducer = session.createProducer(queue);
        ObjectMessage outMessage = session.createObjectMessage();
        outMessage.setObject(((Serializable) operation));
        LOGGER.debug("Sending message...");
        messageProducer.send(outMessage);
        LOGGER.debug("Sending message: done.");
        messageProducer.close();
        session.close();
        connection.close();

当我调用我的网络服务时，我也会调用这个方法。消息到达 MDB 并开始处理。这是我的 MDB 代码：

    @MessageDriven(mappedName = "jms/cbsDestination", activationConfig = {
        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
})
    public class OperationsBackgroundService implements MessageListener {
          //Some code....
         public void onMessage(Message message) {
    LOGGER.debug("Got message: " + message.toString());
    if (message instanceof ObjectMessage) {

        ObjectMessage objectMessage = (ObjectMessage) message;
        Operation operation = null;
    }

一切正常，我收到消息，它开始处理并按我的预期结束。

但问题是： 当我向 MDB 发送第一条消息时，它开始处理它（确定），然后，当第一条消息正在处理时，我向 MDB 发送第二条消息，它也开始处理它。我知道 JMS 的特点是，如果我发送一条消息并且该消息正在处理，其他消息就会等待，直到第一个消息被处理。或者我在这里遗漏了什么？请帮忙。也许我忘记设置一些属性？

谢谢我提前。

Answer 1

您的应用程序服务器创建了多个 OperationsBackgroundService 实例，并将每个实例注册为使用者。每个消费者一次只能处理一条消息，但是当有 2 个消费者时，可以同时处理 2 条消息。这是一个功能，而不是一个错误。

如果您想实现单线程处理，只需告诉您的应用程序服务器为每个 MDB 只创建一个使用者即可。请参阅您的应用程序服务器文档以了解如何进行配置。