黑马程序员技术交流社区

标题: JavaEE的13种核心技术规范-JMS(3) [打印本页]
作者: li745547    时间: 2018-3-25 14:21
标题: JavaEE的13种核心技术规范-JMS(3)

运行后得到下面的输出结果：

[java] view plaincopy


  • Consumer1 get Message:0
  • Consumer2 get Message:0
  • Consumer1 get Message:1
  • Consumer2 get Message:1
  • Consumer1 get Message:2
  • Consumer2 get Message:2
  • Consumer1 get Message:3
  • Consumer2 get Message:3
  • Consumer1 get Message:4
  • Consumer2 get Message:4
  • Consumer1 get Message:5
  • Consumer2 get Message:5
  • Consumer1 get Message:6
  • Consumer2 get Message:6
  • Consumer1 get Message:7
  • Consumer2 get Message:7
  • Consumer1 get Message:8
  • Consumer2 get Message:8
  • Consumer1 get Message:9
  • Consumer2 get Message:9

[java] view plain copy


  • Consumer1 get Message:0  
  • Consumer2 get Message:0  
  • Consumer1 get Message:1  
  • Consumer2 get Message:1  
  • Consumer1 get Message:2  
  • Consumer2 get Message:2  
  • Consumer1 get Message:3  
  • Consumer2 get Message:3  
  • Consumer1 get Message:4  
  • Consumer2 get Message:4  
  • Consumer1 get Message:5  
  • Consumer2 get Message:5  
  • Consumer1 get Message:6  
  • Consumer2 get Message:6  
  • Consumer1 get Message:7  
  • Consumer2 get Message:7  
  • Consumer1 get Message:8  
  • Consumer2 get Message:8  
  • Consumer1 get Message:9  
  • Consumer2 get Message:9  


说明每一个消息都会被所有的消费者消费



一个消息对象分为三部分：消息头(Headers)，属性（Properties）和消息体（Payload）。对于StreamMessage和MapMessage，消息本身就有特定的结构，而对于TextMessage，ObjectMessage和BytesMessage是无结构的。一个消息可以包含一些重要的数据或者仅仅是一个事件的通知。

    消息的Headers部分通常包含一些消息的描述信息，它们都是标准的描述信息。包含下面一些值：

　　JMSDestination
       消息的目的地，Topic或者是Queue。

　　JMSDeliveryMode
        消息的发送模式：persistent或nonpersistent。前者表示消息在被消费之前，如果JMS提供者DOWN了，重新启动后消息仍然存在。后者在这种情况下表示消息会被丢失。可以通过下面的方式设置：
       Producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

      JMSTimestamp
       当调用send()方法的时候，JMSTimestamp会被自动设置为当前事件。可以通过下面方式得到这个值：
       long timestamp = message.getJMSTimestamp();

　　JMSExpiration
       表示一个消息的有效期。只有在这个有效期内，消息消费者才可以消费这个消息。默认值为0，表示消息永不过期。可以通过下面的方式设置：
       producer.setTimeToLive(3600000); //有效期1小时 （1000毫秒 * 60秒 * 60分）

　　JMSPriority
       消息的优先级。0-4为正常的优先级，5-9为高优先级。可以通过下面方式设置：
       producer.setPriority(9);

　　JMSMessageID
       一个字符串用来唯一标示一个消息。

　　JMSReplyTo
       有时消息生产者希望消费者回复一个消息，JMSReplyTo为一个Destination，表示需要回复的目的地。当然消费者可以不理会它。

　　JMSCorrelationID
       通常用来关联多个Message。例如需要回复一个消息，可以把JMSCorrelationID设置为所收到的消息的JMSMessageID。

　　JMSType
       表示消息体的结构，和JMS提供者有关。

　　JMSRedelivered
       如果这个值为true，表示消息是被重新发送了。因为有时消费者没有确认他已经收到消息或者JMS提供者不确定消费者是否已经收到。

    除了Header，消息发送者可以添加一些属性(Properties)。这些属性可以是应用自定义的属性，JMS定义的属性和JMS提供者定义的属性。我们通常只适用自定义的属性。

    后面会讲到这些Header和属性的用法。

深入掌握JMS（七）：DeliveryMode例子


在下面的例子中，分别发送一个Persistent和nonpersistent的消息，然后关闭退出JMS。

[java] view plaincopy


  • import javax.jms.Connection;
  • import javax.jms.DeliveryMode;
  • 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 DeliveryModeSendTest {
  •     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);
  •                
  •         MessageProducer producer = session.createProducer(queue);
  •         producer.setDeliveryMode(DeliveryMode.PERSISTENT);
  •         producer.send(session.createTextMessage("A persistent Message"));
  •         
  •         producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  •         producer.send(session.createTextMessage("A non persistent Message"));
  •         
  •         System.out.println("Send messages sucessfully!");
  •     }
  • }

[java] view plain copy


  • import javax.jms.Connection;  
  • import javax.jms.DeliveryMode;  
  • 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 DeliveryModeSendTest {  
  •     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);  
  •                  
  •         MessageProducer producer = session.createProducer(queue);  
  •         producer.setDeliveryMode(DeliveryMode.PERSISTENT);  
  •         producer.send(session.createTextMessage("A persistent Message"));  
  •          
  •         producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);  
  •         producer.send(session.createTextMessage("A non persistent Message"));  
  •          
  •         System.out.println("Send messages sucessfully!");  
  •     }  
  • }  

   运行上面的程序，当输出“Send messages sucessfully!”时，说明两个消息都已经发送成功，然后我们结束它，来停止JMS Provider。

    接下来我们重新启动JMS Provicer，然后添加一个消费者：






欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2