原文地址：http://blog.csdn.net/zhangxs_3/article/details/4034801

　　我們都知道Queue 即我們經常說的點對點或者生產者/消費者 模型。 生產者將消息發送到隊列， 消費者從隊列中消費消息，一個消息指能被消費一次。下面例子中啟動了兩個消費者一個生產者。

public class TestQueue {
　　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 queue;

　　static{
　　　　connectionFactory = new ActiveMQConnectionFactory(brokerURL);
　　　　try {
　　　　　　connection = connectionFactory.createConnection();
　　　　　　connection.start();
　　　　　　session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
　　　　　　queue = session.createQueue("testqueue");
　　　　} catch (JMSException e) {
　　　　　　e.printStackTrace();
　　　　}
　　}


　　public static void main(String[] args) throws Exception {
　　　　MessageProducer producer = session.createProducer(queue);

　　　 ??MessageConsumer consumer1 = session.createConsumer(queue);
　　　　MessageConsumer consumer2 = session.createConsumer(queue);

　　　　consumer1.setMessageListener(new MessageListener() {

　　　　　　@Override
　　　　　　public void onMessage(Message message) {
　　　　　　　　try {
　　　　　　　　　　String content = message.getStringProperty("content");
　　　　　　　　　　System.out.println("consumer1:"+content);
　　　　　　　　} catch (JMSException e) {
　　　　　　　　　　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) {
　　　　　　　　　　e.printStackTrace();
　　　　　　　　}
　　　　　　}
　　　　});


　　　　for(int i=0;i<10;i++){
　　　　　　Message message = session.createMessage();
　　　　　　message.setStringProperty("content", i+"");
　　　　　　producer.send(message);
　　　　}
　　}
}

運行結果：

consumer1:0
consumer2:1
consumer1:2
consumer2:3
consumer1:4
consumer2:5
consumer1:6
consumer2:7
consumer1:8
consumer2:9

?從結果中我們可以看出，每條消息只能被一個消費者消費，但我們并不能確定到底有哪個消費者消費。

轉載于:https://www.cnblogs.com/gaohuiqian/p/5215949.html

總結

以上是生活随笔為你收集整理的JMS--Queue实战的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。