A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

  • import javax.jms.Connection;
  • 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 DeliveryModeReceiveTest {
  •     public staticvoid main(String[] args)throws Exception {
  •         ActiveMQConnectionFactory factory = newActiveMQConnectionFactory("vm://localhost");
  •    
  •         Connection connection = factory.createConnection();
  •         connection.start();
  •         
  •         Queue queue = new ActiveMQQueue("testQueue");
  •         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  •         
  •         MessageConsumer comsumer = session.createConsumer(queue);
  •         comsumer.setMessageListener(new MessageListener(){
  •             public void onMessage(Message m) {
  •                 try {
  •                     System.out.println("Consumer get " + ((TextMessage)m).getText());
  •                 } catch (JMSException e) {
  •                     e.printStackTrace();
  •                 }
  •             }
  •         });
  •     }
  • }

[java] view plain copy


  • import javax.jms.Connection;  
  • 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 DeliveryModeReceiveTest {  
  •     public static void main(String[] args) throws Exception {  
  •         ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");  
  •      
  •         Connection connection = factory.createConnection();  
  •         connection.start();  
  •          
  •         Queue queue = new ActiveMQQueue("testQueue");  
  •         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  
  •          
  •         MessageConsumer comsumer = session.createConsumer(queue);  
  •         comsumer.setMessageListener(new MessageListener(){  
  •             public void onMessage(Message m) {  
  •                 try {  
  •                     System.out.println("Consumer get " + ((TextMessage)m).getText());  
  •                 } catch (JMSException e) {  
  •                     e.printStackTrace();  
  •                 }  
  •             }  
  •         });  
  •     }  
  • }  

运行上面的程序,可以得到下面的输出结果:

Consumer get A persistent Message

可以看出消息消费者只接收到一个消息,它是一个Persistent的消息。而刚才发送的non persistent消息已经丢失了。

另外, 如果发送一个non persistent消息, 而刚好这个时候没有消费者在监听, 这个消息也会丢失.




深入掌握JMS(八):JMSReplyTo

    在下面的例子中,首先创建两个Queue,发送者给一个Queue发送,接收者接收到消息之后给另一个Queue回复一个Message,然后再创建一个消费者来接受所回复的消息。
[java] view plaincopy


  • import javax.jms.Connection;
  • import javax.jms.JMSException;
  • import javax.jms.Message;
  • import javax.jms.MessageConsumer;
  • import javax.jms.MessageListener;
  • import javax.jms.MessageProducer;
  • 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 MessageSendReceiveAndReply {
  •     public staticvoid main(String[] args)throws Exception {
  •         ActiveMQConnectionFactory factory = newActiveMQConnectionFactory("vm://localhost");
  •    
  •         Connection connection = factory.createConnection();
  •         connection.start();
  •         
  •         //消息发送到这个Queue
  •         Queue queue = new ActiveMQQueue("testQueue");
  •         //消息回复到这个Queue
  •         Queue replyQueue = new ActiveMQQueue("replyQueue");
  •         
  •         final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  •         //创建一个消息,并设置它的JMSReplyTo为replyQueue。
  •         Message message = session.createTextMessage("Andy");
  •         message.setJMSReplyTo(replyQueue);
  •         
  •         MessageProducer producer = session.createProducer(queue);
  •         producer.send(message);
  •             
  •         //消息的接收者
  •         MessageConsumer comsumer = session.createConsumer(queue);
  •         comsumer.setMessageListener(new MessageListener(){
  •             public void onMessage(Message m) {
  •                 try {
  •                     //创建一个新的MessageProducer来发送一个回复消息。
  •                     MessageProducer producer = session.createProducer(m.getJMSReplyTo());
  •                     producer.send(session.createTextMessage("Hello " + ((TextMessage) m).getText()));
  •                 } catch (JMSException e1) {
  •                     e1.printStackTrace();
  •                 }
  •             }
  •             
  •         });
  •         
  •         //这个接收者用来接收回复的消息
  •         MessageConsumer comsumer2 = session.createConsumer(replyQueue);
  •         comsumer2.setMessageListener(new MessageListener(){
  •             public void onMessage(Message m) {
  •                 try {
  •                     System.out.println(((TextMessage) m).getText());
  •                 } catch (JMSException e) {
  •                     e.printStackTrace();
  •                 }
  •             }
  •         });
  •     }
  • }


1 个回复

倒序浏览
我来占层楼啊  
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马