Welogic中的JMS(原创)

WebLogic JMS 概述

企业消息传递系统使得应用程序能够通过消息的交换与其他系统之间进行通信。消息是包含协调不同应用程序之间通信所需信息的请求、报告和/或事 件。消息提供了提取级别，使您能够从应用程序代码中分离出有关目标系统的详细信息。Java 消息服务 (JMS) 是用于访问企业消息传递系统的标准 API。尤其是 JMS：

使得共享消息传递系统的 Java 应用程序能够交换消息

通过提供用于创建、发送和接收消息的标准接口简化了应用程序开发

如图中所说明，WebLogic JMS 接受来自生成器应用程序的消息，然后将其传递给使用者应用程序。

WebLogic JMS 是企业级消息传递系统，紧密集成于 WebLogic Server 平台之中。它完全支持 JMS Specification，还提供了很多超出标准JMS API的WebLogic JMS扩展。

WebLogic JMS体系架构

主要组件:

JMS 服务器，承载定义的模块组和 WebLogic Server 实例上驻留的任何关联的持久性存储。

JMS 模块，由符合 weblogic-jmsmd.xsd Schema 的 XML 文档定义，其中包含配置资源（例如队列、主题和连接工厂）。

客户端 JMS 应用程序，它们生成消息以传递给目标，或使用来自目标的消息。

JNDI（Java 命名和目录接口），提供资源查找工具。

WebLogic 持久性存储（文件存储或可通过 JDBC 访问），用于存储持久性消息数据。

消息传递模型

JMS 支持两种消息传递模型：点对点（point-to-point，简称 PTP）和发布/订阅（publish/subscribe，简称pub/sub）。这两种消息传递模型非常相似，只有以下区别：

PTP 消息传递模型支持一条消息仅传递给一个接收方。

Pub/sub 消息传递模型支持一条消息传递给多个接收方。

每种模型都通过扩展公用基类的类来实现。例如，PTP 类 javax.jms.Queue 和 pub/sub 类 javax.jms.Topic 都扩展 javax.jms.Destination 类。

点对点消息传递

通过点对点 (PTP) 的消息传递模型，一个应用程序可以向另一个应用程序发送消息。PTP消息传递应用程序使用命名队列接发消息。队列发送方（生成器）向特定队列发送消息。队列接收方（使用者）从特定队列接收消息。

下图说明 PTP 消息传递。

一个队列可以关联多个队列发送方和接收方，但一条消息仅传递给一个队列接收方。
如果多个队列接收方正在监听队列上的消息，WebLogic JMS 将根据“先来者优先”的原则确定由哪个队列接收方接收下一条消息。如果没有队列接收方在监听队列，消息将保留在队列中，直至队列接收方连接队列为止。
发布/订阅消息传递
通过发布/订阅 (pub/sub) 消息传递模型，应用程序能够将一条消息发送到多个应用程序。Pub/sub 消息传递应用程序可通过订阅主题来发送和接收消息。主题发布者（生成器）可向特定主题发送消息。主题订阅者（使用者）从特定主题获取消息。
下图说明 pub/sub 消息传递。

与PTP消息传递模型不同，pub/sub消息传递模型允许多个主题订阅者接收同一条消息。JMS 一直保留消息，直至所有主题订阅者都收到消息为止。
Pub/Sub消息传递支持持久订阅者，您可以为主题订阅者分配名称，然后将该名称与某个用户或应用程序关联起来。
消息持久性
根据 JMS 规范的“Message Delivery Mode”部分，消息可以指定为持久性消息或非持久性消息：
可以保证持久性消息传递“一次且仅一次”。消息不会因 JMS 提供程序失败而丢失，也不会传递两次。除非消息已经安全写入文件或数据库，否则视为消息未传送。WebLogic JMS 向 WebLogic 持久性存储（基于磁盘的文件或可通过JDBC访问的数据库）写入持久性消息，可选择在配置过程中由每个JMS服务器确定存储位置。
不存储非持久性消息。除非JMS提供程序失败（这可能引起消息丢失），否则仅保证它们传递“最多一次”，不会传递两次。如果连接关闭或恢复，则将重新传递所有未经确认的非持久性消息。非持久性消息一旦经过确认，则不会重新传递。
JMS API
要创建 JMS 应用程序，请使用 javax.jms API。通过该 API，您可以创建连接JMS、发送和接收消息所需要的类对象。所创建的 JMS 类接口将用作子类，以便提供队列特定或主题特定的版本的公用父类。
下表列出常见的JMS 类。

JMS类	描述
ConnectionFactory	封装连接配置信息。将使用连接工厂创建连接。使用 JNDI 查找连接工厂。
Connection	代表通往消息传递系统的开放式通信通道。将使用连接创建会话。
Session	定义生成的消息和使用的消息的顺序。
Destination	标识队列或主题，并封装特定提供程序的地址。队列和主题目标分别管理通过 PTP 和 pub/sub 消息传递模型传递的消息。
MessageProducer 和 MessageConsumer	提供发送和接收消息的接口。消息生成器向队列或主题发送消息。消息使用者从队列或主题接收消息。
Message	封装要发送或要接收的信息。
ServerSessionPoolFactory 1	封装服务器管理的消息使用者缓冲池的配置信息。将使用服务器会话缓冲池工厂创建服务器会话缓冲池。
ServerSessionPool 2	提供服务器会话缓冲池，可以用于并发地处理连接使用者的消息。
ServerSession 3	将线程与 JMS 会话关联。
ConnectionConsumer 4	指定检索服务器会话以并发地处理消息的使用者。

1支持用于并发地处理多个消息的可选 JMS 接口。

2支持用于并发地处理多个消息的可选 JMS 接口。

3支持用于并发地处理多个消息的可选 JMS 接口。

4支持用于并发地处理多个消息的可选 JMS 接口。

ConnectionFactory

ConnectionFactory封装 配置信息，支持JMS应用程序创建Connection。连接工厂支持并发使用，可以使多个线程同时访问该对象。可以使用WebLogic JMS提供的预配置默认连接工厂，或配置一个和多个连接工厂，从而使用适合您应用程序的预定义特性创建连接。

WebLogic JMS 定义了两个默认连接工厂，可以使用以下 JNDI 名查找这些连接工厂：

weblogic.jms.ConnectionFactory

weblogic.jms.XAConnectionFactory

两者之间的主要差别在于：用于支持 JTA 事务的“已启用 XA 连接工厂”特性的默认值不同，如下表所示。

默认连接工厂. . .	“已启用 XA 连接工厂”设置是. . .
weblogic.jms.ConnectionFactory	False
weblogic.jms.XAConnectionFactory	True

对于使用JTA用户事务的JMS应用程序，XA 工厂是必需的，但是对于事务处理会话，则不是必需的。

如果默认工厂设置不适合您的应用程序，您只需要配置一个用户定义的连接工厂。 使用默认连接工厂时的另外一点区别是，您无法控制可能部署连接工厂的WebLogic Server实例的目标。但可以基于每台服务器禁用默认连接工厂。

要在特定独立服务器上、群集中的特定服务器上或者在整个群集上部署连接工厂，必须配置新的连接工厂并指定适当的目标，如配置和部署连接工厂中所说明。

注意：为了实现向后兼容，WebLogic JMS 仍支持两种不赞成使用的默认连接工厂。这两种连接工厂的 JNDI 名是：javax.jms.QueueConnectionFactory 和 javax.jms.TopicConnectionFactory。

系统管理员可以定义和配置一个或多个连接工厂以创建具有预定义特性的连接，WebLogic Server 会在启动时将它们添加到 JNDI 空间中。然后应用程序使用 WebLogic JNDI 检索连接工厂。任何用户定义的连接工厂都必须具有唯一的名称。

系统管理员可以以群集为目标或以群集中的一个或多个服务器实例为目标，在群集范围内建立从群集中任意服务器乃至 JMS 目标的透明访问。这样，每一个连接工厂都可以部署到多个 WebLogic Server 实例。

ConnectionFactory 类不定义任何方法；但其子类会定义适用于各个消息传递模型的方法。连接工厂支持并发使用，可以使多个线程同时访问该对象。

下表描述 ConnectionFactory 子类。

子类. . .	消息传递模型. . .	用于创建. . .
QueueConnectionFactory	PTP	JMS PTP 提供程序的 QueueConnection
TopicConnectionFactory	Pub/Sub	JMS Pub/Sub 提供程序的 TopicConnection

Connection

Connection 代表应用程序和消息传递系统之间的开放式通信通道，用于创建生成消息或使用消息的Session。连接创建用于管理应用程序和JMS之间的消息传递活动的服务器端和客户端对象。连接还可以提供用户身份验证。

Connection 由通过 JNDI 查找获得的 ConnectionFactory 创建。

由于与用户身份验证和建立通信关联的资源 开销比较大，因此多数应用程序为所有消息传递建立一个连接。在 WebLogic Server 中，JMS 流量通过客户端与服务器的连接上的其他 WebLogic 服务进行多路传输。无需再为 JMS 创建其他 TCP/IP 连接。Servlet 和其他服务器端对象可能还包含 JMS 连接。

连接支持并发使用，可以使多个线程同时访问该对象。

注意：对于本版本，可以使用 JMS v1.1 规范的连接对象，或选择使用子类。

子类. . .	消息传递模型. . .	用于创建. . .
QueueConnection	PTP	QueueSessions ，包括由 QueueConnectionFactory  创建的、与 JMS PTP 提供程序之间的连接。
TopicConnection	Pub/sub	TopicSessions ，包括由 TopicConnectionFactory 创建的、与 JMS pub/sub 提供程序之间的连接。

Session

Session 对象定义生成及使用消息的顺序，并可创建多个消息生成器和消息使用者。同样的线程可以用于生成和使用消息。如果应用程序希望使用单独的线程生成和使用消息，应用程序应针对每个功能创建独立的会话。 Session 由 Connection 创建。

非事务处理会话

在非事务处理会话中，创建会话的应用程序会在下表中定义的五个确认模式中任选其一。

确认模式

描述

AUTO_ACKNOWLEDGE

一旦消息处理中返回了应用程序接收方法，Session  对象即确认消息接收。

CLIENT_ACKNOWLEDGE

Session 对象依赖于应用程序对已收到的消息调用确认方法。一旦调用该方法，会话将确认所有自上次确认后收到的消息。

该方法允许应用程序通过一次调用接收、处理和确认一批消息。

注意：	在管理控制台中，如果连接工厂的“确认策略”特性设置为Previous ，但您希望确认给定会话的所有已接收消息，则请使用最后一条消息调用确认方法。

DUPS_OK_ACKNOWLEDGE

一旦消息处理中返回了应用程序接收方法，Session 对象即确认消息接收，允许重复确认。

就资源利用情况而言，此模式最高效。

注意：	如果您的应用程序无法处理重复消息，则应避免使用此模式。如果第一次尝试传递消息失败，则可能会发送重复消息。

NO_ACKNOWLEDGE

不需要确认。发送至 NO_ACKNOWLEDGE  会话的消息将立即从服务器中删除。此模式下接收的消息不可恢复，因此，消息可能会丢失，也可能在第一次传递消息失败后传递重复消息。

支持将此模式用于不需要由会话确认确保服务质量且不希望引发关联开销的应用程序。

注意：	如果您的应用程序无法处理丢失或重复消息，则应避免使用此模式。如果第一次尝试传递消息失败，则可能会发送重复消息。

MULTICAST_NO_ACKNOWLEDGE

多播模式且不需要确认。

发送到 MULTICAST_NO_ACKNOWLEDGE  会话的消息与 NO_ACKNOWLEDGE  模式具有相同特征，如前所述。

支持此模式用于希望支持多播但不需要由会话确认来确保服务质量的应用程序。

注意：	仅用于主题。如果您的应用程序无法处理丢失或重复消息，则应避免使用此模式。如果第一次尝试传递消息失败，则可能会发送重复消息。

事务处理会话

在事务处理会话中，在任意给定时刻，只有一个事务处于活动状态。事务期间发送或接收的任意数量的消息将视为原子单元。

创建事务处理会话时，将忽略确认模式。应用程序提交事务时，应用程序在事务期间接收的所有消息将由消息传递系统进行确认，应用程序发送的消息也将被接收以进行传递。如果应用程序发生事务回滚，则应用程序在该事务期间接收的消息不会经过确认，其发送的消息也将被放弃。

JMS 可以通过其他 Java 服务参与分布式事务，例如 EJB 会使用 Java 事务 API (JTA)。事务处理会话不支持此功能，因为事务仅限于访问与该会话关联的消息。

Destination

Destination 对象可以是队列或主题，它封装特定提供程序的地址语法。JMS 规范中没有定义标准地址语法，因为各个提供程序之间的语法有所不同。与连接工厂类似，管理员定义和配置目标，然后WebLogic Server会在启动期间将目标添加到 JNDI 空间中。应用程序还可以创建临时目标，临时目标的生存期仅限于其创建时所位于的 JMS 连接的持续时间。

注意：管理员还可以配置分布式目标，即一组目标（队列或主题），但可以视作单个逻辑目标供客户端访问。

在客户端，Queue和Topic对象是服务器上的对象的句柄。它们的方法仅返回它们的名称。要访问它们以进行消息传递，需要创建与其连接的消息生成器和使用者。

目标支持并发使用，可以使多个线程同时访问该对象。JMS Queues和Topics扩展 javax.jms.Destination。

注意：对于本版本，可以使用 JMS v1.1 规范的目标对象，或选择使用子类。

下表描述 Destination 子类。

子类	消息传递模型	管理下列消息
Queue	PTP	JMS 点对点提供程序。
TemporaryQueue	PTP	JMS 点对点提供程序，其生存期为消息创建时所位于的 JMS 连接的持续时间。临时队列仅由创建该队列的队列连接使用。
Topic	Pub/sub	JMS pub/sub 提供程序。
TemporaryTopic	Pub/sub	JMS pub/sub 提供程序，其生存期为消息创建时所位于的 JMS 连接的持续时间。临时主题仅由创建该主题的主题连接使用

注意：应用程序可以选择在队列会话中创建 QueueBrowser 对象以浏览该队列。在创建队列浏览器时，此对象将为队列中的消息生成快照。应用程序可以查看队列中的消息，但并不等于消息是可读的，也不能从队列中删除消息。

分布式目标

分布式目标资源是可作为单个逻辑目标供客户端进行访问的一组目标（队列或主题），例如，分布 式主题有其各自的 JNDI 名称。通常，集合成员分布在群集中的多个服务器内，而且每个成员都分属于不同的JMS服务器。使用分布式目标的应用程序比使用独立目标的应用程序具有更高 的可用性，因为WebLogic JMS为群集中分布式目标的成员提供了负载平衡和故障转移。

MessageProducer和MessageConsumer

MessageProducer 向队列或主题发送消息。MessageConsumer从队列或主题接收消息。消息生成器和使用者相互独立运行。无论是否已经创建消息使用者或使用者是否在等待消息，消息生成器都会生成和发送消息，反之亦然。

Session创建MessageProducers和MessageConsumers，它们将连接到队列和主题上。将创建消息发送方和接收方对象，并用作MessageProducer 和 MessageConsumer 类的子类。

下表描述 MessageProducer 和 MessageConsumer 子类。

子类	消息传递模型	管理下列消息
QueueSender	PTP	JMS 点对点提供程序。
QueueReceiver	PTP	JMS 点对点提供程序。
TopicPublisher	Pub/sub	JMS pub/sub 提供程序发送消息。
TopicSubscriber	Pub/sub	JMS pub/sub 提供程序发送消息。

如图点对点 (PTP) 消息传递所示，PTP 模型允许多个会话接收来自同一个队列的消息。但是，消息只能传递给一个队列接收方。存在多个队列接收方时，WebLogic JMS 将根据“先来者优先”的原则定义下一个接收消息的队列接收方。

如图发布/订阅 (Pub/Sub) 消息传递所示，pub/sub 模型允许向多个主题订阅者传递消息。主题订阅者可以为持久订阅者或非持久订阅者，如设置持久订阅中所述。

应用程序可以使用同一个 JMS 连接发布并订阅单个主题。因为主题消息将传递至所有订阅者，所以应用程序会接收到其自身发布的消息。为防止客户端接收它们自己发布的消息，JMS 应用程序可以在主题订阅者上设置 noLocal 特性

Message

Message 封装应用程序之间交换的信息。这些信息包括三个组件：消息头字段、消息属性字段、消息正文

消息头字段

每个JMS消息包含一个默认包含的标准头字段集，可供消息使用者使用。某些字段可由消息生成器设置。

下表描述消息头中的各个字段，显示每个字段应该定义的值。

字段	描述	定义者
JMSCorrelationID	指定以下某项：WebLogic JMSMessageID （此表稍后描述）、应用程序特定的字符串或一个 byte[]  数组。JMSCorrelationID  用于关联消息，在 send()  之前，应用程序将直接在消息上设置此字段。 此字段有两种常见应用。 第一种应用是通过建立请求/响应方案链接消息，如下： 应用程序发送消息时，此字段存储系统为其分配的 JMSMessageID  值。 应用程序接收消息时，会向发送应用程序返回响应消息，此字段会将 JMSMessageID  复制到该响应消息的 JMSCorrelationID  字段中。 第二种应用是使用 JMSCorrelationID  字段存储您选择的任意字符串，将一系列消息通过应用程序确定的某些值链接起来。	应用程序
JMSDeliveryMode	指定 PERSISTENT  或 NON_PERSISTENT  消息传递。此字段设置在生成器上，或设置为应用程序在 send()  之前发送的参数。 发送持久性消息时，它存储于 WebLogic 持久性存储 中。直到消息传递确保完成时，才认为 send()  操作已成功。对于持久性消息，可以保证传递至少一次。 WebLogic JMS 不在持久性存储中存储非持久性消息。该模式的操作的开销最低。除非系统发生故障，否则非持久性消息仅保证传递至少一次，一旦发生故障，消息可能会丢失。如 果连接关闭或恢复，则将重新传递所有未经确认的非持久性消息。非持久性消息一旦经过确认，则不会重新传递。 此值将由 producer.send() 调用所覆盖，直接在消息上设置此值没有任何作用。通过向 producer.send()  传递的消息，或当使用者接收到消息时，可以查询生成器设置的值。	send() 方法
JMSDeliveryTime	定义可将消息传递给使用者的最早绝对时间。应用程序在 send()  之前将设置此字段，它依赖于生成器上设置的 timeToDeliver 。 可以使用此字段对目标中的消息进行排序以及选择消息。JMSDeliveryTime 是长整数，这方便执行数据类型转换。	send() 方法
JMSDestination	指定消息将传递至的目标（队列或主题）。此字段将在创建生成器时设置，或设置为应用程序在 send()  之前发送的参数。 此值将由 producer.send() 调用覆盖，直接在消息上设置此值没有任何作用。通过向 producer.send()  传递的消息，或当使用者接收到消息时，可以查询生成器设置的值。收到消息时，它的目标值必须等于发送它时为它分配的值。	send() 方法
JMSExpiration	指定消息的过期值或生存时间值。应用程序在 send()  之前将设置此字段。此字段依赖于生成器上设置的 timeToLive ，或用作应用程序向 send()  发送的参数。 WebLogic JMS 将以应用程序的生存时间与当前格林威治标准时间的和作为 JMSExpiration  的计算值。如果应用程序指定生存时间为 0，则将 JMSExpiration  设置为 0，这表明消息永不过期。 WebLogic JMS 会从系统中删除过期消息，以防传递过期消息。	send() 方法
JMSMessageID	包含唯一标识 JMS 提供程序所发送的各条消息的字符串值。此字段由 send()  在内部设置。 所有 JMSMessageID  均以“ID: ”前缀开始。 此值将由 producer.send() 调用覆盖，直接在消息上设置此值没有任何作用。通过向 producer.send()  传递的消息，或当使用者接收到消息时，可以查询生成器设置的值。收到消息时，消息中包含提供程序分配的值。	send() 方法
JMSPriority	指定优先级级别。此字段设置在生成器上，或设置为应用程序在 send()  之前发送的参数。 JMS 定义十个优先级级别，从 0 到 9，0 是最低优先级。级别 0-4 表示普通优先级，级别 5-9 表示高优先级。 收到消息时，消息中包含发送消息的方法所指定的值。	send() 方法
JMSRedelivered	由于未收到任何确认而重新传递消息时，请设置一个标志。该标志对接收应用程序很有意义。 如果设置了标志，则表明，JMS 以前可能由于下列某情况已传递过该消息： 应用程序已经收到消息，但没有确认该消息。 调用了会话的 recover()  方法以重新启动会话，从最后一条确认消息后开始传递。	WebLogic JMS
JMSReplyTo	指定应向其发送答复消息的队列或主题。应用程序在 send()  之前直接在消息上设置此字段。 此功能可用于 JMSCorrelationID  头字段，以协调请求/响应消息。 仅设置 JMSReplyTo  字段并不能保证响应；它只是使接收应用程序能够响应而已。	应用程序
JMSTimestamp	包含消息发送时间。WebLogic JMS 接收消息以准备传递时，会在消息中写入时间戳，而应用程序发送消息时，则不写入时间戳。 接收消息时，它包含时间戳。 字段中存储的值是 Java millis 时间值。	WebLogic JMS
JMSType	指定消息类型标识符（字符串），由应用程序在 send()  之前直接在消息上设置。 JMS 规范允许此字段具有一定灵活性，以便适应各种不同的 JMS 提供程序。某些消息传递系统允许使用应用程序特定的消息类型。对于此类系统，可以使用 JMSType  字段保存消息类型 ID，该 ID 可以提供对存储的类型定义的访问。 WebLogic JMS 不限制此字段的使用。	应用程序

消息属性字段

消息的属性字段包含发送应用程序所添加的头字段。这些属性是标准Java 名/值对。属性名称必须符合 javax.jms.Message Javadoc 中定义的消息选择器语法规范。以下值有效：boolean、byte、double、float、int、long、short 和 String。

WebLogic Server 支持使用下列 JMS (JMSX) 定义属性，如 JMS 1.1.规范所定义：

类型	描述
JMSXUserID	系统生成的属性，它标识发送消息的用户。
JMSXDeliveryCount	系统生成的属性，指定消息传递尝试次数，其中第一次尝试是 1。
JMSXGroupID	消息组的标识。
JMSXGroupSeq	消息在组内的顺序号。

尽管消息属性字段可以用于各种应用程序特定的用途，但 JMS 提供这些属性主要是为了在消息选择器中使用。您可以决定如何在您的环境中使用 JMS 属性。您可以选择在某些消息中包含这些属性，而在其他消息中忽略这些属性，这取决于您的处理条件。

消息正文

消息正文包含从生成器传递给使用者的内容。

下表描述 JMS 定义的消息类型。所有消息类型扩展 javax.jms.Message，其中包括消息头和属性，但不包括消息正文。

类型	描述
javax.jms.BytesMessage	未经解释但发送方和接收方都必须理解其含义的字节流。此消息类型的访问方法是基于 java.io.DataInputStream  和 java.io.DataOutputStream  的面向流的读取器和编写器。
javax.jms.MapMessage	名/值对集合，其中名称是字符串，值是 Java 基元类型。可以顺序读取这些对或通过指定名称随机读取这些对。
javax.jms.ObjectMessage	单个可序列化的 Java 对象。
javax.jms.StreamMessage	类似于 BytesMessage，只是对于此类型，从流中读取或向流中写入的数据必须是 Java 基元类型。
javax.jms.TextMessage	单字符串。TextMessage 可以包含 XML 内容。
weblogic.jms.extensions.XMLMessage	XML 内容。使用 XMLMessage 类型可以简化消息筛选，而对于 TextMessage 中提供的 XML 内容，执行筛选则复杂得多。

ServerSessionPoolFactory

注意：会话缓冲池和连接使用者配置对象在此版本 WebLogic Server 中已不赞成使用。它们不是 J2EE 规范的必需部分，不支持 JTA 用户事务，并且已基本被消息驱动 Bean (MDB) 替代，MDB 更简单、易于管理且功能更强大。

服务器会话缓冲池 WebLogic 特定的 JMS 功能，使您能够并发处理消息。可以使用服务器会话缓冲池工厂创建服务器端 ServerSessionPool

WebLogic JMS 定义一个 ServerSessionPoolFactory 对象，默认为：weblogic.jms.extensions.ServerSessionPoolFactory:<name>，其中 <name> 指定会话缓冲池创建至的 JMS 服务器的名称。WebLogic Server 在启动期间向 JNDI 空间中添加默认服务器会话缓冲池工厂，然后应用程序使用 WebLogic JNDI 检索服务器会话缓冲池工厂。

ServerSessionPool

ServerSessionPool 应用程序服务器对象提供服务器会话缓冲池，连接使用者可以在其中进行检索，以便并发地处理消息。

ServerSessionPool 由通过 JNDI 查找获得的 ServerSessionPoolFactory 对象创建。

ServerSession

通过提供创建、发送和接收消息的上下文，ServerSession 应用程序对象，使您能够将线程与 JMS 会话关联起来。

ServerSession 由 ServerSessionPool 对象创建。

ConnectionConsumer

ConnectionConsumer 对象使用服务器会话处理接收的消息。如果消息流量很大，连接使用者可以加载具有多个消息的每个服务器会话，以使线程上下文切换最小化。

ConnectionConsumer 由 Connection 对象创建。

注意：连接使用者监听器与服务器运行在同一台 JVM 上。

参考至:http://edocs.weblogicfans.net/wls/docs92/jms/fund.html
本文原创，转载请注明出处、作者
如有错误，欢迎指正
邮箱:[e-mail]