2019独角兽企业重金招聘Python工程师标准>>>

1. import javax.jms.Connection;
2. import javax.jms.JMSException;
3. import javax.jms.Message;
4. import javax.jms.MessageConsumer;
5. import javax.jms.MessageListener;
6. import javax.jms.MessageProducer;
7. import javax.jms.Session;
8. import javax.jms.TextMessage;
9. import javax.jms.Topic;
10. import org.apache.activemq.ActiveMQConnectionFactory;
11. import org.apache.activemq.command.ActiveMQTopic;
12. public class TopicTest {
13. public static void main(String[] args) throws Exception {
14. ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
15. Connection connection = factory.createConnection();
16. connection.start();
17. //创建一个Topic
18. Topic topic= new ActiveMQTopic("testTopic");
19. Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
20. //注册消费者1
21. MessageConsumer comsumer1 = session.createConsumer(topic);
22. comsumer1.setMessageListener(new MessageListener(){
23. public void onMessage(Message m) {
24. try {
25. System.out.println("Consumer1 get " + ((TextMessage)m).getText());
26. } catch (JMSException e) {
27. e.printStackTrace();
28. }
29. }
30. });
31. //注册消费者2
32. MessageConsumer comsumer2 = session.createConsumer(topic);
33. comsumer2.setMessageListener(new MessageListener(){
34. public void onMessage(Message m) {
35. try {
36. System.out.println("Consumer2 get " + ((TextMessage)m).getText());
37. } catch (JMSException e) {
38. e.printStackTrace();
39. }
40. }
41. });
42. //创建一个生产者，然后发送多个消息。
43. MessageProducer producer = session.createProducer(topic);
44. for(int i=0; i<10; i++){
45. producer.send(session.createTextMessage("Message:" + i));
46. }
47. }
48. }

1. Consumer1 get Message:0
2. Consumer2 get Message:0
3. Consumer1 get Message:1
4. Consumer2 get Message:1
5. Consumer1 get Message:2
6. Consumer2 get Message:2
7. Consumer1 get Message:3
8. Consumer2 get Message:3
9. Consumer1 get Message:4
10. Consumer2 get Message:4
11. Consumer1 get Message:5
12. Consumer2 get Message:5
13. Consumer1 get Message:6
14. Consumer2 get Message:6
15. Consumer1 get Message:7
16. Consumer2 get Message:7
17. Consumer1 get Message:8
18. Consumer2 get Message:8
19. Consumer1 get Message:9
20. Consumer2 get Message:9