MQ例子文档

ActiveMQ 是一款由 Apache 开发的开源消息中间件，它遵循 JMS（Java Message Service）1.1 规范和 J2EE 1.4 规范，是实现消息传递服务的强大工具。ActiveMQ 允许应用程序通过消息队列进行异步通信，提高系统的可扩展性和可靠性。在本文档中，我们将深入理解 ActiveMQ 的基本使用，并通过一个简单的 Java 示例来展示如何建立连接、发送和接收消息。 我们来看一下连接 ActiveMQ 服务器所需的配置文件 `connection.properties`。在这个文件中，我们需要定义服务器的连接地址（如 `tcp://192.168.1.101:61616`），消息队列的名称（例如 `MYQUEUE`），以及用于身份验证的用户名和密码。 接着，我们创建一个 `ConnectionManager` 类来管理与 ActiveMQ 服务器的连接。这个类包含了初始化连接参数的方法，它从 `connection.properties` 文件中读取配置信息。`init()` 方法负责加载配置文件中的 `url`、`queue`、`username` 和 `password`，并存储在类的成员变量中。`Properties` 类用于处理配置文件，`InputStream` 用于读取文件内容。如果文件读取成功，`init()` 方法返回 `true`，表示初始化成功。 在实际使用时，`ConnectionManager` 类将帮助我们创建 `Connection` 对象，这是与 ActiveMQ 服务器的会话。通过 `ActiveMQConnectionFactory`，我们可以创建一个连接工厂，然后利用工厂创建 `Connection`。此外，`Session` 对象用于管理事务和同步，`MessageConsumer` 用于接收消息，而 `MessageProducer` 则用于发送消息。 以下是一个简化的示例，展示了如何使用 `ConnectionManager` 创建连接并发送消息： ```java import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; public class MessageSender { private ConnectionManager connectionManager = new ConnectionManager(); public void sendMessage(String message) { // 初始化连接 if (connectionManager.init()) { try { ConnectionFactory factory = new ActiveMQConnectionFactory(connectionManager.getUrl()); Connection connection = factory.createConnection(connectionManager.getUsername(), connectionManager.getPassword()); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer producer = session.createProducer(connectionManager.getQueue()); TextMessage textMessage = session.createTextMessage(message); producer.send(textMessage); System.out.println("Sent message: " + message); } catch (JMSException e) { e.printStackTrace(); } finally { // 关闭资源 try { if (connection != null) { connection.close(); } } catch (JMSException e) { e.printStackTrace(); } } } else { System.err.println("Failed to initialize connection"); } } } ``` 这个 `MessageSender` 类首先调用 `ConnectionManager` 的 `init()` 方法初始化连接参数，然后创建 `ConnectionFactory`，通过工厂创建 `Connection` 并启动。接下来，创建 `Session` 和 `MessageProducer`，然后构造一个 `TextMessage` 对象，设置要发送的消息内容，并通过 `MessageProducer` 发送出去。确保在操作完成后关闭连接资源。 同样，接收消息的示例可以通过创建 `MessageConsumer` 并监听指定队列来实现。当有新消息到达时，`MessageConsumer` 将触发回调函数，处理收到的消息。 总结来说，ActiveMQ 是一个强大的消息中间件，适用于构建分布式系统中的异步通信。通过 `ConnectionManager` 类，我们可以方便地管理与 ActiveMQ 服务器的连接，实现消息的发送和接收。这个简单的 Java 示例为初级学者提供了一个良好的起点，帮助他们理解和应用 ActiveMQ 的基本功能。随着对 ActiveMQ 更深入的理解，开发者可以利用其丰富的特性，如主题、持久化、事务支持等，来构建更加复杂和健壮的系统。