azure - 如何主动处理 Azure 服务总线队列消息

Question

我们目前正在利用 Azure 服务总线来处理来 self 们应用程序的各种消息。

我想知道实时处理这些消息的最佳方式是什么？

有没有办法在消息放入队列时自动执行脚本？

我只是认为必须有一种比让单独的应用程序每分钟/30 秒/等检查队列更好的方法。

谢谢大家

Answer 1

您不需要不断地根据计时器检查总线。

服务总线主题和订阅支持发布/订阅消息通信模型。

当消息发送到主题时，每个订阅都可以独立处理该消息。

以下是有关如何从主题接收消息的 C# 示例:

string connectionString =
    CloudConfigurationManager.GetSetting("Microsoft.ServiceBus.ConnectionString");

SubscriptionClient Client =
    SubscriptionClient.CreateFromConnectionString
            (connectionString, "TestTopic", "HighMessages");

// Configure the callback options.
OnMessageOptions options = new OnMessageOptions();
options.AutoComplete = false;
options.AutoRenewTimeout = TimeSpan.FromMinutes(1);

Client.OnMessage((message) =>
{
    try
    {
        // Process message from subscription.
        Console.WriteLine("\n**High Messages**");
        Console.WriteLine("Body: " + message.GetBody<string>());
        Console.WriteLine("MessageID: " + message.MessageId);
        Console.WriteLine("Message Number: " +
            message.Properties["MessageNumber"]);

        // Remove message from subscription.
        message.Complete();
    }
    catch (Exception)
    {
        // Indicates a problem, unlock message in subscription.
        message.Abandon();
    }
}, options);

以下是有关发布者订阅者模型的更多详细信息:

https://azure.microsoft.com/en-us/documentation/articles/service-bus-dotnet-how-to-use-topics-subscriptions/