消息服务与消息驱动bean

《消息服务与消息驱动bean》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

1、第8章消息服务与消息驱动BeanJavaEE5教程吉林大学软件学院主要内容什么是消息服务JMS基础消息服务的分类JMS相关的APIJMS的使用消息驱动Bean消息驱动Bean事务8.1什么是消息服务是一种在分布式应用之间提供消息传递服务的系统。实现过程：封装发送者和接收者之间传递的消息，并在与分布式客户端程序交互的位置上添加了一个软件处理层。消息服务为客户端程序提供了一个标准接口。它隔离了底层的消息服务，使得各种不同的客户端程序能够通过一个统一的编程接口与消息服务系统交互。8.1什么是消息服务消息服务与方法调用相同点从发送方

2、把消息发送到接收方，消息的接收方对消息进行处理。不同点消息的发送者不需要等待接收者的响应，而方法调用必须等待接收者的响应。8.1什么是消息服务消息服务的好处异步可靠松耦合8.2JMS基础Java消息服务(JavaMessageService，简称JMS)是一个JavaAPI,是Sun推出的用于统一不同消息服务和消息调用接口的标准。定义客户端如何与底层的消息服务提供者之间进行交互.通过队列服务器形式提供。8.2JMS基础8.2.1JMS基本模型（1）早期的消息系统模型早期MQ系统调用结构示意图JMSAPI示意图（2）JMS消息

3、系统模型8.2JMS基础8.2.2消息类型（1）PTP（点到点）消息队列这个消息队列可以同时有多个发送者，每个发送者可以自由的向当前队列发送消息。被发送的消息按照先发先进的原则依次排列在队列中。只能有一个接收者PTP类型队列示意图8.2JMS基础8.2.2消息类型（2）Pub/Sub（发布/订阅）消息队列所有发送者可以自由地向消息队列中发送消息，首先发送的消息先进入队列，后发送的消息排在队列后面。一个消息可以被多个使用者接受并使用。默认情况下，如果当前队列没有使用者，则队列中的消息会自动被丢失。Pub/Sub队列示意图8.2

4、JMS基础8.2.3JMS消息组成消息头：标识消息和路由信息JMSDestination、JMSDeliveryMode、JMSExpiration、JMSPriority、JMSMessageID、JMSTimestamp、JMSCorrelationID、JMSReplyTo、JMSType、JMSRedelivered属性：可选，增加额外的消息头。可以实现消息过滤消息体：消息的具体内容消息类型StreamMessage、MapMessage、TextMessage、ObjectMessage、BytesMessage、

5、XMLMessage8.2JMS基础8.2.4JMS传递模式两种模式持久存储暂存如何选择要求可靠性？要求性能？8.2JMS基础8.2.5消息服务器微软的MSMQJBossMQIBM的MQSeriesOracle的WeblogicJMSServiceSUN的SunOneMessageQueue金蝶8.3JMS消息队列操作模型名称注释队列服务器对应于WeblogicJMSService服务，所有的消息队列都被该服务器维护队列对象对应特定的队列，这些队列需要被部署到特定WeblogicJMSService服务器上队列对象JNDI注

6、册队列对象为了使用方便，通常以JNDI名称形式注册到名称服务器上，客户通过JNDI注册名，可以获得对应的队列对象JMSAPISun公司提供的队列对象进行操作的类库接口JMSProviderJMSAPI和消息队列服务器进行通信的驱动程序，不同消息队列服务器需要不同驱动JMS队列操作模型概念对照表8.3JMS消息队列操作模型JMS操作消息队列的基本架构8.3.1JMS消息操作框架8.3JMS消息队列操作模型8.3.2JMS消息操作对象体系JMS消息操作对象体系8.3JMS消息队列操作模型在上图中，存在4个主要JMS对象Conne

7、ction对象：Session对象：消息生产者对象消息消费者对象8.3JMS消息队列操作模型8.3.3JMS消息操作对象体系的创建队列获取过程示意图8.4JMS相关API8.4.1JMSAPIJMSAPI有两个版1.0.2和1.1。JMSAPI1.0.2将PTP和Pub/Sub当成两种完全不同队列，提供了两套不同API操作接口。JMSAPI1.1把他们看成相同类型队列，提供统一编程接口。名称类名连接工厂类TopicConnectionFactoryJMS连接TopicConnectionJMS会话TopicSessionJM

8、S队列对象TopicJMS消息生产者TopicSenderJMS消息消费者TopicReceiverJMSAPI1.0.2Pub/Sub队列操作接口名称类名连接工厂类QueueConnectionFactoryJMS连接QueueConnectionJMS会话QueueSessionJMS