IBM WebSphere与JMS/ActiveMQ集成：消息发布实现方式问询

两种方案均可行，可按需选择 #

你既可以通过直接添加依赖库到应用类路径的方式实现，也可以通过WebSphere控制台配置JNDI资源来完成，以下是具体说明：

方案一：直接添加依赖库，无需WebSphere JNDI配置 #

完全不需要在WebSphere控制台做任何JNDI相关配置，只需要把所需依赖包加入应用类路径即可实现消息发送：

• 依赖包要求：将activemq-client.jar（ActiveMQ核心客户端）、activemq-jms-pool.jar（可选，用于连接池），以及Spring JMS相关的spring-jms.jar、spring-context.jar（如果用spring-jms）打包到Web应用的WEB-INF/lib目录，或者非Web应用的类路径目录下。
• 代码实现示例：
  • 原生JMS写法：

    // 初始化ActiveMQ连接工厂
    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://activemq-server:61616");
    connectionFactory.setUserName("your-username");
    connectionFactory.setPassword("your-password");
    
    // 创建连接、会话、生产者并发送消息
    Connection connection = connectionFactory.createConnection();
    connection.start();
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    Destination queue = session.createQueue("test-queue");
    MessageProducer producer = session.createProducer(queue);
    
    TextMessage message = session.createTextMessage("Hello from WebSphere to ActiveMQ");
    producer.send(message);
    
    // 关闭资源
    producer.close();
    session.close();
    connection.close();
    

  • Spring JMS写法（Java配置）：

    @Configuration
    @EnableJms
    public class ActiveMQConfig {
        @Bean
        public ActiveMQConnectionFactory activeMQConnectionFactory() {
            ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory();
            factory.setBrokerURL("tcp://activemq-server:61616");
            factory.setUserName("your-username");
            factory.setPassword("your-password");
            return factory;
        }
    
        @Bean
        public JmsTemplate jmsTemplate() {
            JmsTemplate template = new JmsTemplate();
            template.setConnectionFactory(activeMQConnectionFactory());
            template.setDefaultDestinationName("test-queue");
            return template;
        }
    }
    

    之后在业务类中注入JmsTemplate，直接调用send()方法即可发送消息。

方案二：通过WebSphere控制台配置JNDI资源 #

如果希望利用WebSphere的JMS资源管理能力（比如统一配置连接池、集中管理认证信息），可以采用这种方式：

1. 将ActiveMQ客户端库部署为WebSphere的共享库，并关联到你的应用。
2. 在WebSphere控制台中配置JMS连接工厂和JMS目的地，指定ActiveMQ的Broker地址、用户名密码等信息。
3. 在应用中通过JNDI查找获取资源，再发送消息：

   InitialContext ctx = new InitialContext();
   ConnectionFactory connFactory = (ConnectionFactory) ctx.lookup("java:comp/env/jms/ActiveMQConnFactory");
   Destination queue = (Destination) ctx.lookup("java:comp/env/jms/TestQueue");
   
   // 后续消息发送逻辑同原生JMS示例
   

注意事项 #

• 采用方案一时，要注意WebSphere自带的JMS API可能与ActiveMQ客户端库存在版本冲突，可通过设置应用类加载器优先级高于服务器类加载器来避免。
• 使用Spring JMS时，需确保Spring版本与ActiveMQ客户端版本兼容。

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