JMS 消息传递信息的 Java 实现示例

在 Java 中使用 JMS 进行消息传递是一种常见的企业应用集成方式。以下是一个简单的代码示例，用于演示如何在 Java 中实现 JMS 消息传递功能。

import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;

public class JMSExample {
    public static void main(String[] args) throws JMSException {
        // 创建连接工厂
        ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection connection = factory.createConnection();
        connection.start();

        // 创建会话
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 创建目标 (队列)
        Destination destination = session.createQueue("TestQueue");

        // 创建生产者并发送消息
        MessageProducer producer = session.createProducer(destination);
        TextMessage message = session.createTextMessage("Hello, JMS!");
        producer.send(message);

        System.out.println("消息发送成功!");

        // 清理资源
        producer.close();
        session.close();
        connection.close();
    }
}

该示例代码展示了如何通过 ActiveMQ 作为 JMS 提供者来实现基本的消息传递功能。在实际应用中，可以根据需求选择不同的消息队列提供者。