Java 消息服务 (JMS) 2.0 实体

连接到 Azure 服务总线高级版并使用 Azure 服务总线 JMS 库的客户端应用程序可以使用以下实体。

队列

JMS 中的队列在语义上与传统的服务总线队列类似。

若要创建队列，请使用 JMSContext 类中的以下方法 -

Queue createQueue(String queueName)

主题

JMS 中的主题在语义上与传统的服务总线主题类似。

若要创建主题，请使用 JMSContext 类中的以下方法 -

Topic createTopic(String topicName)

临时队列

如果客户端应用程序需要在应用程序的生存期内存在的临时实体，它可以使用临时队列。 这些实体以请求-回复模式使用。

若要创建临时队列，请使用 JMSContext 类中的以下方法 -

TemporaryQueue createTemporaryQueue()

临时主题

就像临时队列一样，可以使用临时主题通过在应用程序生存期内存在的临时实体来启用发布/订阅。

若要创建临时主题，请使用 JMSContext 类中的以下方法 -

TemporaryTopic createTemporaryTopic()

Java 消息服务 (JMS) 订阅

尽管它们在语义上类似于订阅（即存在于主题上并启用发布/订阅语义），但 Java 消息服务规范引入了给定订阅的共享、非共享、**持久和非持久特性概念 。

共享持久订阅

当某个主题上发布的所有消息都要由某个应用程序接收并处理时，可使用共享持久订阅，无论该应用程序是否任何时候都主动使用该订阅中的消息。

通过身份验证后可以从服务总线接收消息的任何应用程序都可以从共享持久订阅中接收消息。

若要创建共享持久订阅，请使用 JMSContext 类中的以下方法：

JMSConsumer createSharedDurableConsumer(Topic topic, String name)

JMSConsumer createSharedDurableConsumer(Topic topic, String name, String messageSelector)

除非使用 JMSContext 类上的 unsubscribe 方法删除了共享持久订阅，否则该订阅将一直存在。

void unsubscribe(String name)

非共享持久订阅

与共享持久订阅一样，当某个主题上发布的所有消息都要由某个应用程序接收并处理时，可使用非共享持久订阅，无论该应用程序是否主动使用该订阅中的消息。

不过，由于这是一个非共享的订阅，因此只有创建该订阅的应用程序才能从其中接收消息。

若要创建非共享持久订阅，请使用 JMSContext 类中的以下方法：

JMSConsumer createDurableConsumer(Topic topic, String name)

JMSConsumer createDurableConsumer(Topic topic, String name, String messageSelector, boolean noLocal)

除非使用 JMSContext 类上的 unsubscribe 方法删除了非共享持久订阅，否则该订阅将一直存在。

void unsubscribe(String name)

共享非持久订阅

当多个客户端应用程序需要接收和处理来自单个订阅的消息时，会使用共享非持久订阅，直到它们主动使用/接收其中的消息为止。

由于订阅不是持久的，因此不会持久保存。 在没有主动使用者的情况下，此订阅不会接收消息。

若要创建共享非持久订阅，请创建一个 JmsConsumer，如 JMSContext 类中的以下方法中所示：

JMSConsumer createSharedConsumer(Topic topic, String sharedSubscriptionName)

JMSConsumer createSharedConsumer(Topic topic, String sharedSubscriptionName, String messageSelector)

只要有主动使用者从中接收消息，共享非持久订阅就会一直存在。

非共享非持久订阅

当客户端应用程序需要接收和处理来自订阅的消息时，会使用非共享非持久订阅，直到它主动使用其中的消息为止。 此订阅上只能有一个使用者，即创建了该订阅的客户端。

由于订阅不是持久的，因此不会持久保存。 在没有主动使用者的情况下，此订阅不会接收消息。

若要创建非共享非持久订阅，请创建一个 JMSConsumer，如 JMSContext 类中的以下方法中所示：

JMSConsumer createConsumer(Destination destination)

JMSConsumer createConsumer(Destination destination, String messageSelector)

JMSConsumer createConsumer(Destination destination, String messageSelector, boolean noLocal)

只要有主动使用者从中接收消息，非共享非持久订阅就会一直存在。

消息选择器

正如常规服务总线订阅存在筛选器和操作一样，JMS 订阅存在消息选择器。

消息选择器可在每个 JMS 订阅上设置，并作为消息标头属性的筛选条件存在。 只会传递其标头属性与消息选择器表达式匹配的消息。 如果值为 null 或空字符串，则表示不存在与 JMS 订阅/使用者对应的消息选择器。

Java 消息服务 JMS (2.0) 订阅的其他概念

客户端范围

根据 Java 消息服务 (JMS) 2.0 API 中指定的订阅，其范围可能限定为或不限定为特定客户端应用程序（由 clientId 进行标识）。

订阅限定范围后，只能从具有相同客户端 ID 的客户端应用程序对其进行访问。

尝试访问范围为特定客户端 ID（例如 clientId1）的订阅时，从具有另一个客户端 ID（例如 clientId2）的应用程序进行的任何尝试都会导致创建范围为另一个客户端 ID (clientId2) 的另一个订阅。

可共享性

共享订阅允许多个客户端/使用者（即 JMSConsumer 对象）接收来自它们的消息。

非共享订阅仅允许一个客户端/使用者（即 JMSConsumer 对象）接收来自它们的消息。 如果在非共享订阅上创建了一个 JMSConsumer，同时它已有一个活跃的 JMSConsumer 在侦听其消息，则会抛出 JMSException。

持续性

持久订阅具有持久性，并持续从主题中收集消息，而不考虑应用程序 (JMSConsumer) 是否在使用来自该主题的消息。

非持久订阅不具有持久性，只有应用程序 (JMSConsumer) 在使用来自主题的消息时才会从该主题收集消息。

客户端范围内订阅的表示形式

鉴于客户端范围内 (JMS) 订阅必须与现有订阅共存，客户端范围内 (JMS) 订阅的表示方式会遵循以下格式。

• <SUBSCRIPTION-NAME>$<CLIENT-ID>$D（适用于持久订阅）
• <SUBSCRIPTION-NAME>$<CLIENT-ID>$ND（适用于非持久订阅）

此处，$ 为分隔符。

后续步骤

有关使用服务总线消息传送的详细信息和示例，请参阅以下高级主题：

• 服务总线消息传送概述
• 将 Java 消息服务 2.0 API 与 Azure 服务总线高级版配合使用