`

Java Message Service 点对点接口

    博客分类:
  • JMS
阅读更多

文章来源 (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 的各种方法——例如 MapMessageTextMessage 等。

Queue

Queue 封装了点对点目的地。它是一个从 JNDI 中检索的受管理对象。

QueueSender

QueueSender 被用来发送点对点消息。它的一些方法包括:

  • send(Message):发送指示的 Message
  • setDeliveryMode(int) (从 MessageProducer 继承):设置后续消息发送的发送模式,有效值为 DeliveryMode.PERSISTENTDeliveryMode.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 继承):设置 MessageListenerMessageListener 对象在消息到达时接收它们,即异步方式接收消息(请参阅 MessageListener )。

QueueBrowser

QueueReceiver 接收消息时,在接收消息后从队列中删除她们。用 QueueBrowser 可以查看队列中的消息而不删除它们。完成这项操作的方法是 getEnumeration(),它返回一个可以用来扫描队列中消息的java.util.Enumeration,队列的变化(消息到达或失败)可能是可见的,也可能是不可见的。

分享到:
评论

相关推荐

    Java Message Service 基础教程

    Java Message Service(JMS)是Java平台中用于创建和管理消息传递系统的一种API。它提供了一种标准的方式来发送和接收消息,使得不同的应用程序之间能够进行异步通信。JMS允许开发者在分布式环境中创建可靠的、基于...

    JMS教程 java message service

    Java消息服务(JMS,Java Message Service)是Java平台中用于在分布式系统中进行可靠的消息传递的标准API。它提供了一种解耦应用程序的方式,使得不同的组件可以异步通信,即使它们可能在不同的时间运行,或者在不同...

    Java Message Service

    2. **消息队列(Message Queue)**:在点对点模式下,消息队列是一个存放消息的临时存储区。每个消息只能被一个消费者消费一次,消费后即从队列中移除。 3. **主题(Topic)**:在发布/订阅模式下,主题是一个广播...

    JSR-000343 Java Message Service 2.0 javadocs for Evaluation

    Java Message Service(JMS)是Java平台上的一个标准接口,用于在分布式环境中交换消息。JSR-000343则是对这个标准的第2.0版本的规范定义,它详细描述了如何在Java应用程序之间可靠地发送和接收消息。Javadoc是一种...

    java message service 第二版

    Java消息服务(Java Message Service, JMS)是Java平台中的消息中间件接口标准,它为应用程序之间的通信提供了一种高效、可靠的机制。通过定义一系列的接口规范,JMS允许开发者在不同的消息传递系统之间进行互操作,...

    JMS简介 Java Message Service

    2. **API接口**:JMS提供了一组标准接口,如`MessageProducer`用于发送消息,`MessageConsumer`用于接收消息,以及`Queue`和`Topic`接口,分别对应点对点(Point-to-Point, PTP)和发布/订阅(Publish/Subscribe, ...

    中文java message service

    企业消息产品(或者有时称为面向消息的中间件产品)正逐渐成为公司内操作集成的关 ...由于消息是点对点的,所以JMS 的所有用户都称为客户端(clients)。JMS 应用由定义 消息的应用和一系列与他们交互的客户端组成。

    Java Message Service中文完整版

    Java Message Service(简称JMS)是一种消息中间件的标准接口,它为应用程序提供了与消息中间件进行交互的方式。JMS规范定义了一组接口和方法,允许Java应用程序发送、接收消息,并管理消息传递过程中的各种细节。 ...

    Introducing the Java Message Service

    ### 点对点接口与编程 点对点通信模型是JMS支持的两种主要通信模式之一。在这种模式下,消息被发送到一个队列中,然后由消费者从队列中读取消息。每个消息只能被一个消费者接收一次,确保了消息处理的唯一性与可靠...

    Java™ Message Service API

    Java Message Service (JMS) API 是一种消息传递服务的标准接口,用于在应用程序之间进行消息通信。它提供了一种简单、灵活且可靠的方式,使得软件组件或应用程序能够发送和接收消息。 **消息传递**是一种重要的...

    JMS 1.1 规范中英文版本 Java Message Service.zip

    Java Message Service(JMS)是Java平台上的一个标准接口,用于在分布式系统中进行消息传递。JMS 1.1是这个规范的一个重要版本,它为应用程序提供了可靠的异步通信能力,是企业级应用集成中的关键组件。在这个压缩包...

    Java实现的点对点短消息发送协议(smpp)开发包

    点对点短消息发送协议(SMPP)是一种用于在通信网络中传递SMS(Short Message Service,短信服务)的标准协议,广泛应用于移动运营商、短信服务提供商和企业内部的短信系统。这个Java实现的SMPP开发包提供了全面的...

Global site tag (gtag.js) - Google Analytics