原文地址：http://blog.csdn.net/zhangxs_3/article/details/4034811
与Queue不同的是，Topic实现的是发布/订阅模型，发布者发布的消息，可以被多个订阅者消费。现在我们建立两个订阅者，一个发布者，循环给这个topic发送消息。
public class TestTopic {
private static String brokerURL = "tcp://192.168.2.240:61616";
private static ConnectionFactory connectionFactory;
private static Connection connection;
private static Session session;
private static Destination topic;
static{
connectionFactory = new ActiveMQConnectionFactory(brokerURL);
try {
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
topic = session.createTopic("testtopic");
} catch (JMSException e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws Exception {
MessageProducer producer = session.createProducer(topic);
MessageConsumer consumer1 = session.createConsumer(topic);
MessageConsumer consumer2 = session.createConsumer(topic);
consumer1.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
try {
String content = message.getStringProperty("content");
System.out.println("consumer1:"+content);
} catch (JMSException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});
consumer2.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
try {
String content = message.getStringProperty("content");
System.out.println("consumer2:"+content);
} catch (JMSException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});
for(int i=0;i<10;i++){
Message message = session.createMessage();
message.setStringProperty("content", i+"");
producer.send(message);
}
}
}
运行结果：
consumer1:0
consumer2:0
consumer1:1
consumer2:1
consumer1:2
consumer2:2
consumer1:3
consumer2:3
consumer1:4
consumer2:4
consumer1:5
consumer2:5
consumer1:6
consumer2:6
consumer1:7
consumer2:7
consumer1:8
consumer2:8
consumer1:9
consumer2:9
从结果中我们看出，发布者发送的消息会被多个订阅者使用。这说明每个订阅者都会消费其订阅者发送的消息。