在azure service bus主题中使用MASTRANSIT向特定用户组发送消息

Question

我是azure服务巴士和Masstransit的新手。我在寻找一个解决特定情况的方法。

class Program
    {
        static void Main(string[] args)
        {

            string connectionString = "Endpoint connection string";

            // the names of topics and subscriptions we'll be working with
            const string topicName = "MyTestTopic";
            const string allMessagesSubName = "AllMessages";
            const string filteredSubName1 = "Filtered1";
            const string filteredSubName2 = "Filtered2";

            // let's create the topic if it doesn't already exist...
            var namespaceManager = NamespaceManager.CreateFromConnectionString(connectionString);
            if (!namespaceManager.TopicExists(topicName))
            {
                var td = new TopicDescription(topicName);
                namespaceManager.CreateTopic(td.Path);
            }
            if (!namespaceManager.SubscriptionExists(topicName, allMessagesSubName))
            {
                namespaceManager.CreateSubscription(topicName, allMessagesSubName);
            }

            if (!namespaceManager.SubscriptionExists(topicName, filteredSubName1))
            {
                namespaceManager.CreateSubscription(
                    new SubscriptionDescription(topicName, filteredSubName1),
                    new Microsoft.ServiceBus.Messaging.SqlFilter("From LIKE '%Smith'"));
            }

            if (!namespaceManager.SubscriptionExists(topicName, filteredSubName2))
            {
                namespaceManager.CreateSubscription(
                    new SubscriptionDescription(topicName, filteredSubName2),
                    new Microsoft.ServiceBus.Messaging.SqlFilter("sys.Label='important'"));
            }

            var message1 = new BrokeredMessage("Hello World");

            var message2 = new BrokeredMessage("Second message");
            message2.Label = "important";

            var message3 = new BrokeredMessage("Third message");
            message3.Properties["From"] = "Kelly Smith";
            message3.Label = "information";

            var client = TopicClient.CreateFromConnectionString(connectionString, topicName);
            client.Send(message1);
            client.Send(message2);
            client.Send(message3);
            client.Close();
        }
    }

注：我已经读过这个问题的答案了，但是这里的anwer告诉我们要过滤用户端的消息。我想要的是这种过滤将在到达订阅者之前发生。

Answer 1

当使用Azure Service Bus和MassTransit时，您可以在常规endpoint之外添加订阅endpoint。配置订阅终结点时，应该能够将规则和/或筛选器指定为订阅的一部分。这正是你在上面所做的，所以这是可以处理的。

另一部分，向消息添加属性，可以通过向sendcontext添加文本头来完成。这些标头被复制到message Properties集合中，我相信该集合可用于使用“SQL”筛选器（在订阅endpoint上配置，或在接收endpoint上配置主题订阅）筛选消息。