JavaEE开发技术与实践教程教学课件作者聂艳明ch02-Services课件.pptVIP

尚辅网 / JMS消息服务的类型 - 两种类型： 点对点(Point-To-Point, PTP)消息处理：通过一个消息队列(Queue)实现，消息发送者向消息队列写入消息，消息接收者从消息队列中读取消息。该模型中的每个消息只有一个消息接收者，消息发送者和消息接收者之间不存在时间上的依赖关系； 发布-订阅(Publish-Subscribe, Pub/Sub)消息处理：把消息发送给一个主题(Topic)，消息发布者将消息发送给消息主题，消息服务器将消息发布给订阅该消息主题的每一个消息订阅者。该模型中每个消息可以有多个订阅者，而且某个消息主题的订阅者只能收到订阅之后发布的消息。为了接收消息，订阅者必须保持活动状态。因而，消息发布者和消息订阅者之间存在时间上的依赖关系。 第六节 JMS 尚辅网 / 2、JMS API JMS包括三个部分： ConnectionFactory：为客户端程序创建一个消息连接的管理对象，由消息服务器管理员创建并绑定到JNDI树上； Connection：客户端到JMS服务器之间的一个活动连接； Destination：位于消息服务器上的消息源和消息存储位置； Session：客户端和消息间的会话状态，定义了消息的顺序； MessageProducer：由会话创建的消息发送者对象； MessageConsumer：由会话创建的消息接收者对象； Selector：JMS消息选择器。可根据消息属性进行消息过滤。 第六节 JMS 尚辅网 / 第五节 JMS JMS API中主要接口对象关系： 尚辅网 / 第五节 JMS PTP和Pub/Sub各自JMS API的比较： 尚辅网 / JMS消息服务器配置： 在使用消息服务之前，需要对消息服务器进行配置。不同消息服务器的配置也不尽相同。 JBoss内置的Hornetq是一个支持集群和多种协议、可嵌入、高性能的异步消息系统，完全支持JMS(不但支持JMS1.1 API同时也定义属于自己的消息API)，在不久的将来将支持更多的协议。 JBoss中JMS消息服务器的配置： 通过Jboss控制台配置Hornetq； 直接通过修改配置文件hornetq-jms.xml来配置Hornetq。 第六节 JMS 尚辅网 / 3、JMS应用开发： 发送消息（以Queue消息为例，Topic消息同理）： 获取一个JBoss上下文的引用：Context； 使用上下文和JNDI获得对连接工厂的引用：QueueConnectionFactory； 使用连接工厂创建一个消息连接：QueueConnection； 使用消息连接创建一个会话：QueueSession； 基于上下文和JNDI创建一个消息目的地：Queue； 创建一个指定类型的待发送消息并装入消息：如TextMessage； 使用会话创建消息发送者并发送消息：QueueSender。 第六节 JMS 尚辅网 / 接收消息： 接收消息分为同步接收和异步接收： 同步接收使用receive()接收下一个消息，如消息可用则返回该消息，否则接收者就处于阻塞状态来等待消息的到来，因而接收的消息是有序的。 异步消息必须实现javax.jms.MessageListener接口的onMessage()方法。并通过调用setMessageListener()注册到JMS。异步接收无需一直处于阻塞状态来等待消息的到来，当JMS接收到一个消息时才将消息传给接收者。 接收接收消息的初始化和发送消息是一样的 。 第六节 JMS 尚辅网 / 同步接收消息： 首先使用会话创建一个消息接收者实例：QueueSession和QueueReceiver； 然后，使用QueueReceiver的receive()方法询问JMS是否有新消息，并通过对应消息类型（如TextMessage）的方法（如getText()）读取消息使用连接工厂创建一个消息连接：QueueReceiver和TextMessage等。 第六节 JMS 尚辅网 / 异步接收消息： 首先使用会话创建一个消息接收者实例：QueueSession和QueueReceiver； 异步消息接收时需注册异步消息监听器，实现消息监听器接口： javax.jms.MessageListener； 创建异步消息接收者并启动消息连接：QueueReceiver和QueueConnectio