深入掌握JMS（三）：MessageListener

        消息的消费者接收消息可以采用两种方式：

        1.consumer.receive() 或 consumer.receive(int timeout)； 

        2.注册一个MessageListener。 

        采用第一种方式，消息的接收者会一直等待下去，直到有消息到达，或者超时。后一种方式会注册一个监听器，当有消息到达的时候，会回调它的onMessage()方法。下面举例说明：

MessageReceive.java

package com.bijian.study;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;

public class MessageReceive {

	public static void main(String[] args) throws Exception {
		
		ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
		Connection connection = factory.createConnection();
		connection.start();
		Queue queue = new ActiveMQQueue("testQueue");
		final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		MessageConsumer comsumer = session.createConsumer(queue); 
		comsumer.setMessageListener(new MessageListener(){ 
		            @Override 
		            public void onMessage(Message m) { 
		                TextMessage textMsg = (TextMessage) m; 
		                try { 
		                    System.out.println(textMsg.getText()); 
		                } catch (JMSException e) { 
		                    e.printStackTrace(); 
		                } 
		            } 
		});
	}
}

MessageSend.java

package com.bijian.study;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;

public class MessageSend {

	public static void main(String[] args) throws Exception {
		
		ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
		Connection connection = factory.createConnection();
		connection.start();
		Queue queue = new ActiveMQQueue("testQueue");
		final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		Message message = session.createTextMessage("Hello JMS!");
		MessageProducer producer = session.createProducer(queue);
		producer.send(message);
		System.out.println("Send Message Completed!");
	}
}

        先运行MessageReceive.java，再运行MessageSend.java，将会看到MessageSend.java将消息一发送成功，MessageReceive.java即获取到了。

 

文章来源：http://www.cnblogs.com/guthing/archive/2010/06/12/1757149.html