WildFly环境下在RxJava处理器中发送JMS消息遇到问题

你碰到的问题本质上是EJB容器上下文与RxJava线程的隔离——EJB的依赖注入（包括JMS资源的@Resource注解）只在容器管理的线程和Bean实例中生效，而RxJava的流运行在独立的线程池（比如Schedulers.io()）里，这些线程不在EJB容器的上下文范围内，自然没法使用注解注入的JMS资源。

下面是针对WildFly 8 + Java 7环境的具体解决方案：

1. 手动通过JNDI获取JMS资源 #

既然容器自动注入走不通，我们可以直接通过JNDI lookup获取JMS ConnectionFactory和目标队列/主题，这是最直接的办法。WildFly 8中默认的JMS ConnectionFactory的JNDI名称是java:jboss/DefaultJMSConnectionFactory，你自己定义的队列/主题的JNDI名可以在standalone.xml配置文件中找到（比如java:/jms/queue/MyQueue）。

示例工具类代码：

import javax.jms.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class JmsSenderUtil {
    private static ConnectionFactory connectionFactory;
    private static Destination targetDestination;

    // 静态初始化，只执行一次资源查找
    static {
        try {
            Context ctx = new InitialContext();
            // 查找全局JMS连接工厂
            connectionFactory = (ConnectionFactory) ctx.lookup("java:jboss/DefaultJMSConnectionFactory");
            // 查找你的目标队列/主题
            targetDestination = (Destination) ctx.lookup("java:/jms/queue/YourQueue");
        } catch (NamingException e) {
            throw new RuntimeException("Failed to lookup JMS resources", e);
        }
    }

    public static void sendMessage(String messageContent) throws JMSException {
        // Java 7支持try-with-resources，自动关闭JMS资源（Connection/Session/Producer）
        try (Connection conn = connectionFactory.createConnection();
             Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
             MessageProducer producer = session.createProducer(targetDestination)) {
            
            TextMessage message = session.createTextMessage(messageContent);
            producer.send(message);
        }
    }
}

2. 在RxJava处理器中调用工具类 #

现在你可以直接在RxJava的事件处理逻辑（比如subscribe()或者doOnNext()）里调用这个工具类的方法：

yourObservable
    .subscribeOn(Schedulers.io())
    .observeOn(Schedulers.io())
    .subscribe(new Action1<YourEvent>() {
        @Override
        public void call(YourEvent event) {
            try {
                // 发送JMS消息
                JmsSenderUtil.sendMessage("Processed event ID: " + event.getId());
            } catch (JMSException e) {
                // 按需处理发送异常，比如日志记录或重试
                e.printStackTrace();
            }
        }
    });

3. 关键注意事项 #

• 事务处理：如果你的JMS发送需要参与EJB事务，可以手动获取UserTransaction管理事务：

  UserTransaction ut = (UserTransaction) new InitialContext().lookup("java:jboss/UserTransaction");
  ut.begin();
  try {
      JmsSenderUtil.sendMessage("Transactional message content");
      ut.commit();
  } catch (Exception e) {
      ut.rollback();
      throw new RuntimeException("JMS transaction failed", e);
  }
  

• 线程安全：WildFly的ConnectionFactory本身是线程安全且池化的，所以可以静态初始化复用；但Connection、Session和MessageProducer是线程不安全的，因此每次发送都要创建新实例（上面的try-with-resources已经自动完成资源销毁）。
• Java 7兼容性：确保使用RxJava 1.x版本（RxJava 2+要求Java 8），代码遵循Java 7语法规范（比如避免Lambda表达式，用匿名内部类实现RxJava接口）。

为什么原来的EJB注解方式不行？ #

EJB容器的依赖注入是基于容器管理的Bean生命周期和线程上下文的：当你在EJB中用@Resource注入ConnectionFactory时，容器会在Bean实例化时完成注入，并且只有在调用EJB方法的线程（被容器拦截、管理的线程）中，这些注入的资源才是有效的。而RxJava的线程由自身线程池管理，不属于EJB容器的上下文范围，因此注入的字段会是null，或调用时抛出IllegalStateException（上下文不存在）。

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