ActiveMQ之Destination

Posted 2023-03-04

参考技术A

Wildcard用来支持名字分层体系，它不是JMS规范的一部分，是ActiveMQ的扩展。

ActiveMQ支持以下三种wildcard：

示例，假设有两个Destination：PRICE.STOCK.NASDAQ.IBM 和 PRICE.STOCK.NYSE.SUNW。那么如下配置通配符：

路径符号替换，将“/"替换"."，添加如下插件：

组合队列Composite Destinations 允许用一个虚拟的destination代表多个destinations,这样就可以通过composite destinations在一个操作中同时向多个queue/topic发送消息。 有两种实现方式：

在创建客户端连接的Destination时，多个destination之间采用","分隔。如下：

如果希望不同的Destination的话，需要加前缀“queue://”或者“topic://”。如下

客户端发送示例：

当客户端向“comQueue”发送消息时，消息就会同时发送到"queue.FOO"和“topic.FOO”中。

通过配置selecter来过滤掉不需要的消息，如下：

在启动ActiveMQ的时候如果需要创建Destination的话，可以在activemq.xml中配置:

在ActiveMQ的queue在不使用之后，可以通过web控制台或者JMX方式来删除掉，当然，也可以通过配置，使得broker可以自动探测到无用的队列并删除掉，回收相应资源。

参数说明：

schedulePeriodForDestinationPurge ：设置多长时间检查一次，单位是毫秒。
inactiveTimoutBeforeGC ： 设置当Destination为空后，多长时间被删除，单位是毫秒。
gcInactiveDestinations ：设置删除掉不活动的队列，默认为false。

Destination Options是一种无需扩展JMS API即可向JMS消费者提供扩展配置选项的方法。这些选项使用URL查询语法在创建消费者的目标名称中进行编码。

消费者选项如下：

虚拟destination用来创建逻辑destination,客户端可以通过它来生产和消费消息，它会把消息映射到物理destination。

ActiveMQ支持2种方式：

ActiveMQ中，topic只有在持久订阅下才会持久化消息。JMS持久化订阅者 MessageConsumer 在创建时会生成一个 唯一的 JMS clientID 和一个持久化订阅者的name。 为了符合JMS，对于一个JMSclientID，同一时间，只能有一个活跃的JMS连接，并且，对于一个clientID和订阅者name而言，只有一个消费者可以是活跃的。也就是说，对于给定的topic订阅者来说，只能由一个活跃的进程进行消费。这意味着我们不能实现：

如今，JMS中的队列语义提供了通过多个消费者来实现可靠的负载均衡——允许多线程，进程和机器来处理消息。然后我们就有了成熟而复杂的负载均衡技术，就像Messge Groups一样在维护订单时进行负载均衡和并行化处理。如下图所示，全量的消息先发送到队列，然后再分发给消费者，通过队列来解决负载均衡和故障转移问题。

virtual topic背后的思想是生产者用正常的JMS方式把消息发送到一个topic。消费者可以继续使用JMS标准中的Topic语义。然而，如果 topic 是虚拟的， 订阅一个逻辑topic的消费者可以从一个真实队列中消费，允许多个消费者分布在多个机器上且多线程的进行负载均衡。 例如，假定我们现在有一个叫做 VirtualTopic.Orders 的topic。（前缀 VirtualTopic. 表明这是一个 virtual topic）。

我们希望将orders 发送到系统A 和 系统B。于是，用通常的 durable topics ，我们需要为 clientID_A 和 "A" 创建一个JMS消费者，同时为 clientID_B 和 "B"创建一个JMS消费者。 有了virtual topics 我们可以直接从队列 Consumer.A.VirtualTopic.Orders 中为系统A 消费，或者从队列 Consumer.B.VirtualTopic.Orders 中为系统B 消费。

默认前缀是： VirtualTopic.>

自定义消费虚拟地址默认格式： Consumer. .VirtualTopic.>*

下面的示例演示如何使所有主题成为虚拟主题。下面的示例使用名称“>“”表示“匹配所有主题”，“VirtualTopicConsumers”为消费队列的前缀。

其他的配置参数：

通常情况下，使用网络连接消费者队列。在这种情况下，不要在虚拟主题上桥接任何普通主题消费者，因为任何转发的消息都会再次分散到网络代理上的消费者队列，从而导致消息重复。下面示例展示了如何排除虚拟队列：

ActiveMQ中每个queue中的消息只能被一个consumer消费。然而，有时候你可能希望能够监视生产者和消费者之间的消息流。你可以通过使用Virtual Destinations 来建立一个virtual queue 来把消息转发到多个queues中。但是 为系统中每个queue都进行如此的配置可能会很麻烦。 使用ActiveMQ支持Mirrored Queues。Broker会把发送到某个queue的所有消息转发到一个名称类似的topic，因此监控程序只需要订阅这个mirrored queue topic。为了启用Mirrored Queues，首先要将BrokerService的“useMirroredQueues“属性设置成true，然后可以通过destinationInterceptors设置其它属性，如mirror topic的前缀，缺省是“VirtualTopic.Mirror.”。如下订阅“*.qmirror”的主题就开启了mirrored queue。

http://activemq.apache.org/features