JMS--Queue实战

原文地址：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);
　　　　}
　　}
}