`

Java Message Service Pub/sub 接口

    博客分类:
  • JMS
阅读更多

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 的方法,如 MapMessageTextMessage 等。
  • 5、Topic

    Topic 封装了一个 pub/sub 目的地。它是从 JNDI 中检索的受管理对象。

    6、TopicPublisher

    TopicPublisher 被用来发送 pub/sub 消息。它的一些方法包括:

  • publish(Message):发布指示的 Message

  • setDeliveryMode(int) (从 MessageProducer 继承):设置后续消息发送的发送模式,有效值为 DeliveryMode.PERSISTENTDeliveryMode.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):设置 MessageListenerMessageListener 在消息到达时接收消息,即异步接收消息。

  • 分享到:
    评论

    相关推荐

      JMS消息服务代码(java message service)

      Java Message Service(JMS)是Java平台中用于创建、发送、接收和读取消息的应用程序接口。它提供了一种标准的方式来解耦应用程序之间的通信,使得它们可以异步地交换信息,提高了系统的可扩展性和可靠性。在JMS中,...

      JMS简介 Java Message Service

      【Java Message Service (JMS) 简介】 Java Message Service (JMS) 是Java平台上的一个标准API,专门设计用于在企业级消息系统中进行消息交换。它为Java应用程序提供了一种统一的方式,以便与各种不同的消息中间件...

      Java Message Service

      ### Java Message Service (JMS) 概述与详解 #### JMS 定义与作用 Java消息服务(JMS)是一套定义了Java程序如何访问消息中间件的标准接口集。虽然JMS仅提供了接口规范而没有具体的实现细节,但它允许Java开发人员...

      java message service 第二版

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

      Java Message Service中文完整版

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

      深入掌握 JMS(java message service)

      ### 深入掌握 JMS(Java Message Service) #### JMS 基础概念 - **JMS**(Java Message Service)是一种Java平台中的消息中间件技术标准,它定义了一套标准API,用于应用程序之间的消息传递。JMS的出现极大地简化...

      JAVA消息服务JMS规范及原理详解.docx

      JAVA消息服务JMS,全称Java Message Service,是Java平台中的一种标准API,设计用于在分布式系统中实现应用程序之间的异步通信。通过JMS,开发者能够创建、发送、接收和读取消息,降低了不同组件之间的耦合度,提高...

      Java™ Message Service API

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

      Java 如何使用AMQP协议订阅启用Partition 的Azure ServiceBus Topic1

      Topic 是一种 Pub/Sub 模式的消息队列, publisher 将消息发送到 Topic,然后订阅者可以从 Topic 中接收消息。 什么是 AMQP 协议 AMQP(Advanced Message Queuing Protocol)是一种基于标准的消息队列协议,用于在...

      ActiveMQ通信方式点对点和订阅发布

      ActiveMQ是Apache软件基金会开发的一款开源消息中间件,它遵循开放消息传递协议(Open Message Broker Protocol,即AMQP)和Java消息服务(Java Message Service,JMS)规范,为企业级应用提供可靠的消息传递服务。...

      开源的JMS服务器和源码

      OpenJMS是一个开源的Java Message Service API 1.0.2 规范的实现,它包含有以下特性: *. 它既支持点到点(point-to-point)(PTP)模型和发布/订阅(Pub/Sub)模型。 *. 支持同步与异步消息发送 *. JDBC持久性...

      flex与java交互的中间介质Blazeds

      4. Java后端集成:BlazeDS允许Java开发者使用Spring框架进行服务层和业务逻辑的开发,同时通过Java Message Service (JMS) 支持发布/订阅模型的消息传递,增强了系统的可扩展性和并发性。 5. 数据服务:BlazeDS提供...

      Message-Driven Bean EJB实例源代码

      在Java企业级应用中,MDBs被用来接收和响应JMS(Java Message Service)消息,从而解耦应用程序的不同部分,提高系统的可扩展性和可靠性。以下是对"Message-Driven Bean EJB实例源代码"的详细解析: 1. **什么是...

      Flex Message Service 消息服务

      FMS支持发布/订阅(Pub/Sub)模型和点到点(Point-to-Point)模型,允许应用之间进行异步通信。 消息由头信息(header)和主体(body)两部分组成。头信息包括消息的标识和路径信息,而消息主体则包含应用数据。在...

      ActiveMQ在Java编程中的应用.docx

      Java消息服务(JMS,Java Message Service)是Java平台中用于进行异步消息传输的标准接口。JMS提供了两种消息模型:点对点(Point-to-Point, P2P)和发布/订阅(Publish/Subscribe, Pub/Sub)。 点对点模型(P2P)...

      关于EMS的一些接口

      2. **JMS接口**:Java消息服务(Java Message Service,JMS)是Java平台上的标准接口,用于与消息代理(如EMS)进行交互。通过JMS,开发者可以创建、发送、接收和阅读消息,支持点对点(P2P)和发布/订阅(Pub/Sub)...

      基于JMS(Java Messaging Service)开发JAVAMAIL详解

      JMS,全称为Java Messaging Service,是Java平台上的标准接口,用于在分布式环境中交换异步消息。它提供了一种可靠的、高效的消息传递机制,使得应用程序可以发送和接收消息,而无需两者同时在线。JMS支持两种主要的...

    Global site tag (gtag.js) - Google Analytics