能否在单个 Spring XD 流上定义多个点击

Can multiple taps be defined on a single Spring XD stream

对于 Spring XD 1.3.1,使用 Rabbit MQ 传输,分布式。

正在寻求有关 Spring XD taps 如何用于指标的说明。 我需要知道是否可以多次点击一个流,以便通过主流的每条消息都将发送到每个活动定义的点击。

该场景是一个带有 rabbit 源的流,在传送到接收器之前进行处理,例如 mongo。此流被分流到备用接收器。我们还想在此流上创建多个指标,包括一个聚合计数器和几个字段值计数器,它们将按类型保留消息总数和消息的指标,查看源消息中的不同字段(os JSON).

关于每次点击是否获得消息副本的文档不清楚。

在测试中,第一次点击是获取所有消息,但 none 的字段值或聚合计数器似乎正在获取数据。

是的,一个流可以有多个点击。这是流中每个潜在分接点的 example. Internally, XD uses the message bus to bind to a pub-sub resource (transport dependent). For example, using Rabbit MQ transport, a Fanout exchange is created。将队列绑定到该交换器是延迟执行的,即,当创建点击流时。您应该在 Rabbit 管理控制台中看到每次点击的相应交换和队列绑定。

我不确定为什么您没有在所有点击中看到消息。请记住,应该始终部署 tap(在创建目标流之后但在部署目标流之前),在部署 tap 之前流中的任何数据都不会被 tap 消耗。