使用 EJB 3 发送 JMS 消息时的事务划分

Question

在我的Java EE应用程序中，我实现了一个异步数据库记录器作为MDB，它通过JMS接收XML消息并将其写入数据库。

在另一个 MDB 中，我使用以下代码创建一条日志消息并将它们发送到记录器 MDB 的输入队列：

    public static void log(String correlId, String message, String data) throws Exception{

            SysLogEntry sysLogEntry = new SysLogEntry();
            sysLogEntry.setCorrelId(correlId);
            sysLogEntry.setDatetimeCreate(new Date());
            sysLogEntry.setMessage(message);
            sysLogEntry.setData(data);

            ConnectionFactory jmsConnectionFactory = (ConnectionFactory)initialContext.lookup(JMS_CONNECTION_FACTORY_JNDI_NAME);
            Destination logEventDestination = (Destination) initialContext.lookup(LOG_EVENT_DESTINATION_JNDI_NAME);

            JmsUtils.sendMsgToDestination(JaxbUtils.toString(sysLogEntry, jaxbContext), jmsConnectionFactory, logEventDestination, false, Session.AUTO_ACKNOWLEDGE);

        }

public static void sendMsgToDestination(String payload, ConnectionFactory connFactory, Destination destination, boolean sessionTransacted, int acknowledgeMode) throws JMSException{
        if(payload == null)
            throw new IllegalArgumentException("Message payload is null");
        if(connFactory == null)
            throw new IllegalArgumentException("Connection factory is null");
        if(destination == null)
            throw new IllegalArgumentException("Message destination is null");

        Connection connection = null;
        try{
            connection = connFactory.createConnection();
            Session session = connection.createSession(sessionTransacted, acknowledgeMode);
            MessageProducer messageProducer = session.createProducer(destination);
            TextMessage textMessage = session.createTextMessage();
            textMessage.setText(payload);
            messageProducer.send(textMessage);
        } finally {
            if(connection != null){
                try{
                    connection.close();
                } catch (JMSException ignore){

                }
            }
        }
    }

哪里

• SysLogEntry 是一个带有 JAXB 注释的类，我用它来序列化
• JMS_CONNECTION_FACTORY_JNDI_NAME是 XA 连接工厂的 JNDI 名称

但是，每次回滚创建日志消息的事务时，日志消息都不会放入记录器输入队列。

有人可以告诉我我的代码出了什么问题吗？我考虑过使用一个单独的无状态会话 bean，它将启动一个新的事务来生成日志消息，但这种方法有一个缺点：在 EJB 内部，我可以轻松地让容器注入记录器 bean，但我也有非 EJB 对象，我想在其中执行异步日志记录。

我的应用程序服务器是Weblogic 10.3.3

Answer 1

我将创建一个单独的 Bean 来记录消息，并注释 sendMessage 以启动自己的和独立的事务：

java prettyprint-override">@Stateless
public class SenderBean  {

@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
public sendMsgToDestination(String payload, ConnectionFactory connFactory, Destination destination, boolean sessionTransacted, int acknowledgeMode) throws JMSException{
        ...
        Connection connection = null;
        try(
           connection = connFactory.createConnection();
           Session session = connection.createSession(sessionTransacted, acknowledgeMode);
        ){
            MessageProducer messageProducer = session.createProducer(destination);
            TextMessage textMessage = session.createTextMessage();
            textMessage.setText(payload);
            messageProducer.send(textMessage);
        }
    }

然后我会使用这个 BEAN 进行日志记录，即使您的调用方事务被回滚，它也会将消息写入队列

Answer 2

可以将包含静态日志方法的类的静态成员分配给无状态 EJB 代理的实例。代理本身只是将调用路由到实例池中的空闲 Bean，因此可以静态共享它。

但。。。启动新事务只是为了逃避当前事务听起来很浪费。特别是如果频繁记录此异步记录器，您可能希望以不同的方式执行此操作。

使用一个简单的Java SE执行器池和几个线程，然后向该池提交工作（一个可运行）。在这个可运行代码中，您仍然可以发送 JMS 消息，保持现有代码不变。当池中的线程接听工作时，事务上下文将丢失，但这正是您首先需要的。

Answer 3

如果发生系统异常（或 sessionContext.setRollbackOnly），则全局事务将由容器回滚（如果使用容器管理的事务）。这意味着对全局事务中登记的 XA 感知资源的任何操作都将回滚。

在您的情况下，这包括要发送到记录器的待处理消息。这个被删除，因为事务被回滚。

在您的情况下，如果您使用非 XA 连接工厂，这应该就足够了。这样，消息应该立即发送（在记录器甚至有帮助的情况下）。因此，发送仅在跨越 JMS 发送任务的本地事务中运行。

至于非 EJB 对象：您可以使用非 XA 连接工厂将发送功能提取到普通的 Java 类（= 不是 EJB）中，并从 EJB 和普通类中使用它。