JMS是什么 JMSJava Message Service,java消息服务,是java EE的一中技术。 JMS定义了java中访问消息中间件的接口,并没有给予实现,实现JMS 接口的消息中间件称为JMS Provider,例如activeMQ。 基本概念JMSMessage:JMS的消息,JMS消息由一下三部分组成: 消息头,每个消息头字段都有相应getter和setter方法 消息属性,如果需要除消息头字段以外的值,那么可以使用消息属性 消息体,封装具体的消息数据 JMSProducer消息生产者,创建和发送JMS消息的客户端应用 JMS Consumer消息消费者,接收和处理JMS消息的客户端应用 消息的消费可以采用以下两种方式之一: 1:同步消费:通过调用消费者的receive方法从目的地显示的提取消息,receive方法可以一直阻塞到消息到达。 2:异步消费:客户可以为消费者注册一个消息监听器,以定义在消息到达时所采取的动作。 Connectionfactory 连接工厂,用来创建连接对象,以连接到JMS的Provider JMSConnection封装了客户端与JMS Provider之间的一个虚拟连接 JMSSession是生产和消费消息的一个单线程上下文 session会话用于创建生产者、消费者和消息(message)等。会话提供了一个事务性的上下文,在这个上下文中,一组发送和接收被组合到了一个原子操作中。 Destination消息发送到的目的地 Acknowledge签收 Transaction事务 JMSClient用来收发消息的java应用 Non-JMSClient 使用JMS Provider本地API写的应用,用来替换JMS API实现收发消息的功能,通常会提供其他的一些特性,比如CORBA、RMI等。
Administeredobjects预定义的JMS对象,通常会在Provider规范中有定义,提供给JMS客户端来访问,比如:ConnectionFactory、Destination。 JMS消息结构JMS消息由以下几部分组成:消息头,属性和消息体。 消息头包含消息的识别信息和路由信息,消息头包含一些标准的属性如下: JMSDestination由send方法设置 消息发送的目的地,主要指Queue和Topic JMSDeliveryMode由send方法设置 传送模式,有两种:持久模式和非持久模式。一条持久性的消息应该被传送“一次仅仅一次”,这就意味着JMS提供者出现故障,该消息并不会丢失,它会在服务器恢复之后再次传递。一条非持久的消息最多会传送一次,这意味着服务器出现故障,该消息将永远丢失。 JMSExpiration由send方法设置 消息过期时间,producer的send方法中的timeToLive值加上发送时刻的GMT时间值。如果timeTolive值等于0,则JMSExpiration值被设为0,表示消息永不过期。如果消息发送之后,在过期时间之后,还没有被发送到目的地,则该消息被清除。 JMSPriority由send方法设置 消息优先级,从0-9十个级别,0-4是普通消息,5-9是加急消息。JMS不要求JMS Provider严格按照这十个优先级发送消息,但必须保证加急消息要先于普通消息到达。默认是4级。默认是永不过期。 JMSMessageId由send方法设置 唯一识别每个消息的标识 JMSTimestamp由客户端设置message属性 一个JMS Provider在调用send方法时自动设置的。它是消息被发送和消费者实际接收的时间差。 JMSCorrelationID由客户端设置message属性 同来连接到另外一个消息,典型的应用的在回复消息中连接到原消息。在大多数情况下,JMSCorrelationID用于将一条消息标记为对JMSMessageID标识的上一条消息的应答,不过JMSCorrelationID可以是任何值,不仅仅是JMSMessageID。 JMSReplyTo由客户端设置message属性 提供本消息回复消息的目的地址 JMSType由客户端设置message属性 消息类型的识别符 JMSRedelivered由客户端设置message属性 如果一个客户端收到一个设置JMSRedelivered属性的消息,则表示可能客户端曾经在早些时候收到过该消息,但并没有签收(acknowledged)。如果该消息被重复发送,JMSRedelivered=true,反之,JMSRedelivered=false。
如下代码示例: for(int i=0;i<30;i++){ TextMessage textMessage = session.createTextMessage("messageaa"+i); //设置消息属性 //textMessage.setJMSRedelivered(redelivered); producer.send(textMessage); //通过send方法设置不同属性值 //producer.send(destination,message, deliveryMode, priority, timeToLive); } 消息体 JMSAPI定义了5种消息体格式,也叫消息类型,可以使用不同形式发送接收数据,并可以兼容现有的消息格式。包括:TextMessage、MapMessage、ByteMessage、StreamMessage和ObjectMessage 要求 发送的是什么类型的消息,接收的时候也必须是什么类型 消息属性 应用程序设置和添加的属性: Message.serStringProperty(“username”,username); JMS 定义的属性 使用“JMSX”作为属性名的前缀,connection.getMetaData().getJMSXPropertyNames(),方法返回所有连接支持的JMSX属性的名字。 JMS定义的属性 JMSXUserID发送消息的用户标识 JMSXAppID发送消息的应用标识 JMSXDeliveryCount转发消息重试次数,第一次是1,第二次是2,。。。 JMSXGroupID消息所在消息组标识 JMSXGroupSeq组内消息的序号,第一个消息是1,第二个消息是2,。。。 JMSXProducerTXID产生消息的事务的事务标识 JMSXConsumerTXID消费消息的事务的事务标识 JMSXRCVTimestampJMS转发消息到消费者的时间
JMSXState假定存在一个消息仓库,他存储了每个消息的单独拷贝,且这些消息从原始消息被发送时开始。每个拷贝的状态有:1(等待),2(准备),3(到期)或4(保留)。由于状态与生产者和消费者无关,所以它不是由它们来提供,它只和在仓库中查找消息相关,因此JMS没有提供这种API。
消息传递域JMS规范中定义了两种消息传递域: 点对点消息传递域点对点消息传递域,point-to-point,简写成PTP,消息目的地被称为队列(queue)。 点对点消息传递域特点如下: 每个(条)消息只能有一个消费者,但是一个消息队列可以有多个消费者,消息被消费之后,消息就会被移出队列,其他的消费者就不能在去消费这条消息了。 消息的生产者和消费者之间没有时间上的相关性,无论消费者在生产者发送消息的时候是否处于运行状态,它都可以提取消息。
点对点方式,生产者和消费者之间是一个队列。既然是一个队列,那么消息的就遵循先进先出的原则,消费者接收到的消息,是按照生产者发送的顺序接收的。 如果在session关闭时,有一些消息已被收到,但还没有签收(acknowledge),那么。当消费者下次连接到相同的队列时,这些消息还会被再次接收 如果用户在receive方法中设定了消息选择条件,那么不符合条件的消息会留在队列中,不会被接收到 队列可以长久保存消息直到消费者接收消息。消费者不需要因为担心消息丢失而时刻和队列保持激活的连接状态,充分体现了异步传输模式的优势 发布/订阅消息传递域发布/订阅消息传递域,publish/subscribe,简写成pub/sub,消息目的地被称为主题(topic) 发布/订阅消息传递域特点如下: 每个(条)消息可以有多个消费者 生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自它订阅之后发布的消息(类似与微博)。JMS规范允许客户创建持久订阅,这在一定程度上放松了时间上的相关性要求。持久订阅允许消费者消费它在处于未激活状态时发送的消息。 消息订阅分为非持久订阅和持久订阅 非持久订阅只有当客户端处于激活(在线)状态,也就是和JMS Provider保持连接状态才能收到发送到某个topic的消息,而当客户端处于离线状态,这个时间段发到topic的消息将会丢失,永远不会收到。 持久订阅时,客户端向JMS注册一个识别自己身份ID,当这个客户端处于离线时,JMS Provider会为这个ID保存所有发送到topic的消息,当客户端再次连接到JMS Provider时,会根据自己的ID得到所有当自己处于离线时发送到topic的消息。 如果用户在receive方法中设定了消息选择条件,那么不符合条件的消息不会被接收 非持久订阅状态下,不能恢复或重新发送一个未签收的消息。只有持久订阅才能恢复或重新发送一个未签收的消息。 当所有的消息必须被接收,则用持久订阅。当丢失消息能够被容忍,则使用非持久订阅。 性能上肯定是非持久订阅好,就不用保存以前的消息了
|