NServiceBus 过滤发送给订阅者的消息

Question

我刚刚开始使用 NService 总线，我想知道如何在发送消息时过滤消息，以便它们只发送给特定的订阅者。

例如，假设我有一个包含已分类产品的数据库。我的发布者将每 N 秒检查一次数据库，并在将新产品添加到数据库时发送消息。

但每个订阅者只对特定类别感兴趣，并假设 我可以获得订阅者发送他们感兴趣的类别，然后我只想向对其感兴趣的订阅者发布有关特定类别中的产品的消息。

类别是动态的，因此我无法为不同的类别创建不同的消息。因此，出于这个原因，我假设所有订阅者都必须订阅相同的已发布的 IMessage。

编辑：为了消除一些混乱，这里有另一个更接近真实情况的示例。

我的发布者的工作是根据标签通知订阅者有关 stackoverflow 上的新帖子的信息。但我不希望发布者在 stackoverflow 上查询没人感兴趣的标签……更不用说做类似事情的开销了。

因此，当订阅者订阅时，他们会注册自己的兴趣以及一些元数据，告诉发布者他们对哪些帖子感兴趣 - 例如标记为 NServiceBus 的帖子。

现在，发布者知道他们必须监视 stackoverflow 中是否有标记为 NServiceBus 的新帖子，并且可以开始这样做。

因此，当有一个带有 NServiceBus 标签的新帖子并且我的发布者去通知它的订阅者时，我希望它只通知对该标签感兴趣的订阅者......而不是对以下内容感兴趣的订阅者：不同的标签。

更有意义吗？

我刚刚开始这个项目，所以如果我走错了路，我会很感激您的提醒和建议，以使用不同的工具集。

Answer 1

假设您使分类订阅正常工作，那么广播类别和关联产品就足够了，并且让每个端点忽略它不关心的产品。否则，您必须为每个产品创建一条消息并包含类别，以便端点可以忽略配置的类别。

Answer 2

NServiceBus 附带的“PubSub”示例演示了这种情况。

消息由以下内容组成：

using NServiceBus;
using System;

namespace MyMessages
{
    [Serializable]
    public class EventMessage : IEvent
    {
        public Guid EventId { get; set; }
        public DateTime? Time { get; set; }
        public TimeSpan Duration { get; set; }
    }

    public interface IEvent : IMessage
    {
        Guid EventId { get; set; }
        DateTime? Time { get; set; }
        TimeSpan Duration { get; set; }
    }
}

然后发布者（在示例中）交替创建 EventMessage 或 IEvent，然后发布它。

var eventMessage = publishIEvent ? Bus.CreateInstance<IEvent>() : new EventMessage();

eventMessage.EventId = Guid.NewGuid();
eventMessage.Time = DateTime.Now.Second > 30 ? (DateTime?)DateTime.Now : null;
eventMessage.Duration = TimeSpan.FromSeconds(99999D);

Bus.Publish(eventMessage);

订阅者 1 处理以下类型的消息：

namespace Subscriber1
{
    public class EventMessageHandler : IHandleMessages<EventMessage>

而订阅者 2 处理通用 IEvent（这将导致处理所有消息、EventMessage 和 IEvent），

namespace Subscriber2
{
    public class EventMessageHandler : IHandleMessages<IEvent>

这应该可以帮助您找到正确的方向，通过不同的方式处理不同的产品类别。订户。