1、介绍 (文章来源 IBM中国)
现在让我们来查看 Pub/sub 接口。在我们浏览这些接口的时候,应该注意到它们与 PTP 接口非常相像,只有名称和其他少数几处不同的地方。
记住:在JMS 版本 1.1 中添加点对点和 Pub/sub 接口只是为获得向后兼容。如果进行新的开发,应该使用 JMS 1.1 中的新内容:公用接口 和 用公用接口进行客户机编程 各小节中讨论的公用接口。
2、TopicConnectionFactory
TopicConnectionFactory是从 JNDI 中检索的受管理对象,它创建了到提供者的链接。它包含 createTopicConnection() 方法,该方法返回了一个 TopicConnection 对象。
3、TopicConnection
TopicConnection 封装了到提供者的一个活动连接。它的一些方法包括:
createTopicSession(boolean, int)
:返回 TopicSession
对象。boolean
参数指出 TopicSession
是否被处理,int
指出确认模式(请参阅确认)。
start()
(从 Connection
继承):激活提供者发送的消息。
stop()
(从 Connection
继承):临时停止发送消息,可以用 start()
重新开始发送。
close()
(从 Connection
继承):关闭到提供者的连接,并释放它所占有的所有资源。
4、TopicSession
TopicSession是发送和接收 pub/sub 消息的单线程上下文。它的一些方法包括:
createPublisher(Topic)
:返回 TopicPublisher
对象来向指定的 Topic
发送消息。
createSubscriber(Topic)
:返回 TopicSubscriber
对象来接收指定 Topic
中的消息。这个订阅者是 非持久的,也就是说,订阅只持续到对象的生存周期,只在它对象处于活动状态时才接收消息。
createDurableSubscriber(Topic, String)
:返回 TopicSubscriber
对象来接收指定 Topic
中的消息,String
给出订阅者的名字。如果对象没有处于活动状态,则通过 JMS 保留 持久的 订阅者的消息,并将它发送给以后用相同名称创建的订阅者对象。
unsubscribe(String)
:结束名为 String
的订阅者的订阅。
commit()
(从 Session
继承):提交当前事务的所有已使用或者已产生的消息。
rollback()
(从 Session
继承):回滚当前事务的所有已使用或者已产生的消息。
create<MessageType>Message(...)
(从 Session
继承):各种返回 <MessageType>Message
的方法,如 MapMessage
、TextMessage
等。
5、Topic
Topic 封装了一个 pub/sub 目的地。它是从 JNDI 中检索的受管理对象。
6、TopicPublisher
TopicPublisher 被用来发送 pub/sub 消息。它的一些方法包括:
publish(Message)
:发布指示的 Message
。
setDeliveryMode(int)
(从 MessageProducer
继承):设置后续消息发送的发送模式,有效值为 DeliveryMode.PERSISTENT
和 DeliveryMode.NON_PERSISTENT
。
setPriority(int)
(从 MessageProducer
继承):设置后续消息发送的优先级,有效值为 0 到 9。
setTimeToLive(long)
(从 MessageProducer
继承):设置后续发送消息失效前的持续时间,以毫秒为单位。
7、TopicSubscriber
TopicSubscriber 被用来接收点对点消息。它的一些方法包括:
receive()
(从 MessageConsumer
继承):返回到达的下一个消息,这个方法会阻塞,直到一个消息可用为止。
receive(long)
(从 MessageConsumer
继承):接收在 long
毫秒内到达的下一个消息,如果在时间期限内没有消息到达,则返回 null
。
receiveNoWait
(从 MessageConsumer
继承):返回立即可用的下一个消息,如果没有消息可用,则返回 null
。
setMessageListener(MessageListener)
(inherited from MessageConsumer
):设置 MessageListener
,MessageListener
在消息到达时接收消息,即异步接收消息。
分享到:
相关推荐
Java Message Service(JMS)是Java平台中用于创建、发送、接收和读取消息的应用程序接口。它提供了一种标准的方式来解耦应用程序之间的通信,使得它们可以异步地交换信息,提高了系统的可扩展性和可靠性。在JMS中,...
【Java Message Service (JMS) 简介】 Java Message Service (JMS) 是Java平台上的一个标准API,专门设计用于在企业级消息系统中进行消息交换。它为Java应用程序提供了一种统一的方式,以便与各种不同的消息中间件...
### Java Message Service (JMS) 概述与详解 #### JMS 定义与作用 Java消息服务(JMS)是一套定义了Java程序如何访问消息中间件的标准接口集。虽然JMS仅提供了接口规范而没有具体的实现细节,但它允许Java开发人员...
Java消息服务(Java Message Service, JMS)是Java平台中的消息中间件接口标准,它为应用程序之间的通信提供了一种高效、可靠的机制。通过定义一系列的接口规范,JMS允许开发者在不同的消息传递系统之间进行互操作,...
Java Message Service(简称JMS)是一种消息中间件的标准接口,它为应用程序提供了与消息中间件进行交互的方式。JMS规范定义了一组接口和方法,允许Java应用程序发送、接收消息,并管理消息传递过程中的各种细节。 ...
### 深入掌握 JMS(Java Message Service) #### JMS 基础概念 - **JMS**(Java Message Service)是一种Java平台中的消息中间件技术标准,它定义了一套标准API,用于应用程序之间的消息传递。JMS的出现极大地简化...
JAVA消息服务JMS,全称Java Message Service,是Java平台中的一种标准API,设计用于在分布式系统中实现应用程序之间的异步通信。通过JMS,开发者能够创建、发送、接收和读取消息,降低了不同组件之间的耦合度,提高...
Java Message Service (JMS) API 是一种消息传递服务的标准接口,用于在应用程序之间进行消息通信。它提供了一种简单、灵活且可靠的方式,使得软件组件或应用程序能够发送和接收消息。 **消息传递**是一种重要的...
Topic 是一种 Pub/Sub 模式的消息队列, publisher 将消息发送到 Topic,然后订阅者可以从 Topic 中接收消息。 什么是 AMQP 协议 AMQP(Advanced Message Queuing Protocol)是一种基于标准的消息队列协议,用于在...
ActiveMQ是Apache软件基金会开发的一款开源消息中间件,它遵循开放消息传递协议(Open Message Broker Protocol,即AMQP)和Java消息服务(Java Message Service,JMS)规范,为企业级应用提供可靠的消息传递服务。...
OpenJMS是一个开源的Java Message Service API 1.0.2 规范的实现,它包含有以下特性: *. 它既支持点到点(point-to-point)(PTP)模型和发布/订阅(Pub/Sub)模型。 *. 支持同步与异步消息发送 *. JDBC持久性...
4. Java后端集成:BlazeDS允许Java开发者使用Spring框架进行服务层和业务逻辑的开发,同时通过Java Message Service (JMS) 支持发布/订阅模型的消息传递,增强了系统的可扩展性和并发性。 5. 数据服务:BlazeDS提供...
在Java企业级应用中,MDBs被用来接收和响应JMS(Java Message Service)消息,从而解耦应用程序的不同部分,提高系统的可扩展性和可靠性。以下是对"Message-Driven Bean EJB实例源代码"的详细解析: 1. **什么是...
FMS支持发布/订阅(Pub/Sub)模型和点到点(Point-to-Point)模型,允许应用之间进行异步通信。 消息由头信息(header)和主体(body)两部分组成。头信息包括消息的标识和路径信息,而消息主体则包含应用数据。在...
Java消息服务(JMS,Java Message Service)是Java平台中用于进行异步消息传输的标准接口。JMS提供了两种消息模型:点对点(Point-to-Point, P2P)和发布/订阅(Publish/Subscribe, Pub/Sub)。 点对点模型(P2P)...
2. **JMS接口**:Java消息服务(Java Message Service,JMS)是Java平台上的标准接口,用于与消息代理(如EMS)进行交互。通过JMS,开发者可以创建、发送、接收和阅读消息,支持点对点(P2P)和发布/订阅(Pub/Sub)...
JMS,全称为Java Messaging Service,是Java平台上的标准接口,用于在分布式环境中交换异步消息。它提供了一种可靠的、高效的消息传递机制,使得应用程序可以发送和接收消息,而无需两者同时在线。JMS支持两种主要的...