JMS&ActiveMQ实战- 消息头

2019-03-27 23:58|来源: 网络

一个消息对象分为三部分:消息头(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&ActiveMQ实战- 消息头,领悟书生学习笔记,转自:http://calvinliu.iteye.com/blog/788611

相关问答

更多

ActiveMQ与Spring实现JMS的问题?

Thread.sleep(5000); 延时加载

ActiveMQ与Spring实现JMS的问题?

Thread.sleep(5000);延时加载

activemq和jms是种什么关系

JMS是一个用于提供消息服务的技术规范,它制定了在整个消息服务提供过程中的所有数据结构和交互流程。而activemq则是消息队列服务,是面向消息中间件(MOM)的最终实现,是真正的服务提供者。 jms 的一个标准或者说是一个协议. 通常用于企业级应用的消息传递. 主要有topic 消息(1 对多), queue 消息(1对1)。activemq 是一个jms 的实现, apache 出的. 另外还其它的实现 jboss 。 MQ简介: MQ全称为Message Queue, 消息队列(MQ)是一种 ...

我们可以使用SOAPUI测试JMS消息到ActiveMQ吗?(Can we test JMS messages to ActiveMQ using SOAPUI?)

这很容易。 使用WSDL文件1创建一个SOAP项目。 然后右键单击WSDL端点绑定。 并添加JMS端点。 给你的配置和其他选项,如会话,发送,接收。 我附上了一个示例图像以帮助您做到这一点。 希望这可以帮助。 快乐的编码。 1 http://www.webservicex.com/CurrencyConvertor.asmx?wsdl It's easy. Create a SOAP project using the WSDL file 1. Then right click on WSDL e ...

Mule - JMS(ActiveMQ)重新连接(Mule - JMS (ActiveMQ) Reconnection)

通过<reconnect-forever/> ,Mule将继续重新尝试连接到ActiveMQ <jms:activemq-connector name="Active_MQ" username="admin" password="admin" brokerURL="tcp://192.168.198.131:61616" validateConnections="true" doc:name="Active MQ" persistentDelivery="true"> <reconnect ...

使用Grizzly和JMS / ActiveMQ(Using Grizzly with JMS/ActiveMQ)

您可以使用TCP适配器/网关(可以选择使用NIO)以及自定义(反)序列化程序。 如果必须使用Grizzly,则可以编写服务器连接工厂实现。 对于出站适配器(或入站网关),端点注册为“TcpListener”(使用connectionId),SI消息包含用于确定哪个连接获得回复的IpHeaders.CONNECTION_ID标头。 连接关闭时,它将取消注册(从地图中删除)。 You could use the TCP adapters/gateways (which have an option t ...

将ActiveMQ重用于Camel JMS端点(Reusing ActiveMQ for Camel JMS Endpoints)

您可以使用单个ActiveMQ实例。 只需确保没有目标名称冲突[除非他们将共享]并且您的实例使用tcp://或其他网络协议之一创建网络侦听器,即您不希望使用vm:// 。 You can use a single ActiveMQ instance. Just make sure you have no destination name collisions [unless they will share] and that your instance creates networked list ...

使用ActiveMQ进行JMS配置(JMS Configuration with ActiveMQ)

使用正确的后端uri创建一个地址端点,如下所示。 <endpoint xmlns="http://ws.apache.org/ns/synapse" name="Service1EP"> <address uri="http://localhost:8080/services/service1""> <suspendOnFailure> <progressionFactor>1.0</progressionFactor> </suspendOnFai ...

通过activemq JMS运行pentaho作业(Running pentaho jobs through activemq JMS)

我将PDI集成到JAX-RS Web应用程序中没有问题。 从JMS调用作业应该很容易。 在这里您可以找到如何将PDI与java集成: http : //wiki.pentaho.com/display/EAI/Pentaho+Data+Integration+-+Java+API+Examples 对于webapps,你可以在网上找到大量的材料。 There is a JMS consumer comes handy and the corresponding settings (Similar ...

Web Socket与JMS或Activemq [已关闭](Web Socket vs JMS or Activemq [closed])

Web套接字是一种在Web浏览器和Web服务器之间提供双向套接字样式接口的方式,服务器能够推送信息,而不是仅响应浏览器HTTP“拉”请求。 这听起来来自你的问题和澄清,这不是你所需要的。 然而,简单套接字是在应用程序之间提供同步通信的好方法。 如果接收到消息的应用程序可以同步处理它们 - 只要它们被发送 - 常规套接字可能是一个很好的解决方案。 消息队列用于异步通信 - 消息在发送后可能需要存储一段时间,然后接收者才能收到消息并对消息进行操作。 由于需要存储,消息队列需要单独的服务器来存储消息,或 ...