文章来源 (IBM 中国)
介绍
这一节将分析点对点编程的重要 JMS 接口和它们的一些方法。
在下一节(点对点编程)中,我们将分析一些进行点对点消息处理的示例代码。
记住:将点对点和 pub/sub 接口添加到 JMS 版本 1.1 中只是为了获得向后兼容。如果是进行新的开发,应该使用前两节中讨论的公用接口(JMS 1.1 中的新内容:公用接口 和 用公用接口进行客户机编程)。
QueueConnectionFactory
QueueConnectionFactory
是从 JNDI 中检索的受管理对象,它创建了到提供者的连接。它包含 createQueueConnection()
方法,该方法返回一个 QueueConnection
对象。
QueueConnection
QueueConnection
封装了链接到提供者的活动连接。它的一些方法包括:
createQueueSession(boolean, int)
:返回一个 QueueSession
对象。boolean
参数指出 QueueSession
是否被处理,int
指出确认模式(请参阅 确认)。
start()
(从 Connection
继承):激活提供者发送消息。
stop()
(从 Connection
继承):临时停止发送消息,可以用 start()
重新开始发送。
close()
(从 Connection
继承):关闭到提供者的链接,并释放它占有的所有资源
QueueSession
QueueSession
是发送和接收 PTP 消息的单线程上下文。它的一些方法包括:
createSender(Queue)
:返回 QueueSender
来向指定的 Queue
发送消息。
createReceiver(Queue)
:返回 QueueReceiver
对象来接收来自指定的 Queue
的消息。
createBrowser(Queue)
(从 Session
继承):返回一个 QueueBrowser
对象来浏览指定 Queue
上的消息。
commit()
(从 Session
继承):提交当前事务中所有已经使用或者产生的消息。
rollback()
(从 Session
继承):回滚当前事务中所有已使用或者已产生的消息。
create<MessageType>Message(...)
(从 Session
继承):返回 <MessageType>Message
的各种方法——例如 MapMessage
、TextMessage
等。
Queue
Queue
封装了点对点目的地。它是一个从 JNDI 中检索的受管理对象。
QueueSender
QueueSender
被用来发送点对点消息。它的一些方法包括:
send(Message)
:发送指示的 Message
。
setDeliveryMode(int)
(从 MessageProducer
继承):设置后续消息发送的发送模式,有效值为 DeliveryMode.PERSISTENT
和 DeliveryMode.NON_PERSISTENT
。
setPriority(int)
(从 MessageProducer
继承):设置后续消息发送的优先级,有效值为 0 到 9。
setTimeToLive(long)
(从 MessageProducer
继承):设置后面发送的消息失效前的持续时间,以毫秒为单位。
QueueReceiver
QueueReceiver
被用来接收点对点消息。它的一些方法包括:
receive()
(从 MessageConsumer
继承):返回到达的下一个消息,这个方法会阻塞,直到下一个消息可用为止。
receive(long)
(从 MessageConsumer
继承):接收在 long
毫秒内到达的下一个消息,如果在时间期限内没有消息到达,则返回 null
。
receiveNoWait
(从 MessageConsumer
继承):如果当前有一条消息,则接收下一条消息,如果没有消息,则返回 null
。
setMessageListener(MessageListener)
(从 MessageConsumer
继承):设置 MessageListener
,MessageListener
对象在消息到达时接收它们,即异步方式接收消息(请参阅 MessageListener )。
QueueBrowser
用 QueueReceiver
接收消息时,在接收消息后从队列中删除她们。用 QueueBrowser
可以查看队列中的消息而不删除它们。完成这项操作的方法是 getEnumeration()
,它返回一个可以用来扫描队列中消息的java.util.Enumeration
,队列的变化(消息到达或失败)可能是可见的,也可能是不可见的。
分享到:
相关推荐
Java Message Service(JMS)是Java平台中用于创建和管理消息传递系统的一种API。它提供了一种标准的方式来发送和接收消息,使得不同的应用程序之间能够进行异步通信。JMS允许开发者在分布式环境中创建可靠的、基于...
Java消息服务(JMS,Java Message Service)是Java平台中用于在分布式系统中进行可靠的消息传递的标准API。它提供了一种解耦应用程序的方式,使得不同的组件可以异步通信,即使它们可能在不同的时间运行,或者在不同...
2. **消息队列(Message Queue)**:在点对点模式下,消息队列是一个存放消息的临时存储区。每个消息只能被一个消费者消费一次,消费后即从队列中移除。 3. **主题(Topic)**:在发布/订阅模式下,主题是一个广播...
Java Message Service(JMS)是Java平台上的一个标准接口,用于在分布式环境中交换消息。JSR-000343则是对这个标准的第2.0版本的规范定义,它详细描述了如何在Java应用程序之间可靠地发送和接收消息。Javadoc是一种...
Java消息服务(Java Message Service, JMS)是Java平台中的消息中间件接口标准,它为应用程序之间的通信提供了一种高效、可靠的机制。通过定义一系列的接口规范,JMS允许开发者在不同的消息传递系统之间进行互操作,...
2. **API接口**:JMS提供了一组标准接口,如`MessageProducer`用于发送消息,`MessageConsumer`用于接收消息,以及`Queue`和`Topic`接口,分别对应点对点(Point-to-Point, PTP)和发布/订阅(Publish/Subscribe, ...
企业消息产品(或者有时称为面向消息的中间件产品)正逐渐成为公司内操作集成的关 ...由于消息是点对点的,所以JMS 的所有用户都称为客户端(clients)。JMS 应用由定义 消息的应用和一系列与他们交互的客户端组成。
Java Message Service(简称JMS)是一种消息中间件的标准接口,它为应用程序提供了与消息中间件进行交互的方式。JMS规范定义了一组接口和方法,允许Java应用程序发送、接收消息,并管理消息传递过程中的各种细节。 ...
### 点对点接口与编程 点对点通信模型是JMS支持的两种主要通信模式之一。在这种模式下,消息被发送到一个队列中,然后由消费者从队列中读取消息。每个消息只能被一个消费者接收一次,确保了消息处理的唯一性与可靠...
Java Message Service (JMS) API 是一种消息传递服务的标准接口,用于在应用程序之间进行消息通信。它提供了一种简单、灵活且可靠的方式,使得软件组件或应用程序能够发送和接收消息。 **消息传递**是一种重要的...
Java Message Service(JMS)是Java平台上的一个标准接口,用于在分布式系统中进行消息传递。JMS 1.1是这个规范的一个重要版本,它为应用程序提供了可靠的异步通信能力,是企业级应用集成中的关键组件。在这个压缩包...
点对点短消息发送协议(SMPP)是一种用于在通信网络中传递SMS(Short Message Service,短信服务)的标准协议,广泛应用于移动运营商、短信服务提供商和企业内部的短信系统。这个Java实现的SMPP开发包提供了全面的...