首页 > 其他 > 详细

ActiveMQ笔记(二)---JMS消息头、消息体、消息属性

时间:2020-02-11 10:15:38      阅读:331      评论:0      收藏:0      [点我收藏+]

参考:https://www.bilibili.com/video/av55976700?p=21

1、JMS组成的四大元素

JMS provider :实现JMS接口和规范的消息中间件,也就是我们的MQ服务器

JMS producer:消息生产者,创建和发送JMS消息的客户端应用

JMS consumer:消息消费者,接收和处理JMS消息的客户端应用

JMS Message:  消息头、消息属性、消息体

2、JMS的消息头

JMSDestination : 消息发送的目的地,主要是指Topic或Queue        

JMSDeliveryMode 
       
消息的发送模式:持久模式和非持久模式

       Producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);            

技术分享图片

 

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

技术分享图片

 

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

技术分享图片

 

 

  JMSMessageID 
       唯一识别每一条消息,消息调用的幂等性

   

3、JMS的消息体

技术分享图片

 

 4、JMS的消息属性

技术分享图片

 

 

  
void setBooleanProperty(String name, boolean value) throws JMSException;

void setByteProperty(String name, byte value) throws JMSException;

void setShortProperty(String name, short value) throws JMSException;

void setIntProperty(String name, int value) throws JMSException;

void setLongProperty(String name, long value) throws JMSException;

void setFloatProperty(String name, float value) throws JMSException;

void setDoubleProperty(String name, double value) throws JMSException;

void setStringProperty(String name, String value) throws JMSException;

void setObjectProperty(String name, Object value) throws JMSException;

                                 

 

ActiveMQ笔记(二)---JMS消息头、消息体、消息属性

原文:https://www.cnblogs.com/ts-sd/p/12293822.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!