ActiveMQ主题订阅
ActiveMQ主题订阅是一种消息传递机制，它允许多个订阅者（消费者）订阅同一主题并接收相同的消息。以下是使用Java编写这种机制的代码示例：
- 创建ActiveMQ的ConnectionFactory：
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
- 创建一个Connection对象并启动：
Connection connection = connectionFactory.createConnection(); connection.start();
- 创建Session对象：
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
- 创建一个Topic并命名：
Topic topic = session.createTopic("myTopic");
- 创建一个MessageConsumer对象并设置它的MessageListener：
MessageConsumer consumer = session.createConsumer(topic); consumer.setMessageListener(new MessageListener() { public void onMessage(Message message) { try { System.out.println("Received message: " + ((TextMessage) message).getText()); } catch (JMSException e) { e.printStackTrace(); } } });
- 发布消息到主题：
MessageProducer producer = session.createProducer(topic); TextMessage message = session.createTextMessage("Hello World!"); producer.send(message);
- 关闭连接：
connection.close();
通过上述代码示例，我们可以实现ActiveMQ主题订阅的功能。