一个侦听器用于多个 Azure 队列

Question

我想创建一个 Web 作业（侦听器）来侦听存储中的所有队列。如果有任何新消息，则会触发处理程序。

Azure WebJobs SDK提供了一个只侦听一个队列的解决方案：

public class Functions
{
    // This function will get triggered/executed when a new message is written 
    // on an Azure Queue called queue.
    public static async Task ProcessQueueMessage(
        [QueueTrigger("%test%")] CloudQueueMessage message,
        IBinder binder)
    {
        //do some stuff
    }
}

这种方法很好，但我需要：1）监听不同的队列2）向这个类注入一个我认为我不能的类

所以我正在考虑创建自己的听众。我想创建多个威胁，每个威胁侦听一个队列。然后，当我运行 Web 作业时，它会启动所有威胁。

我想知道是否有人可以提出更好的解决方案。代码示例会非常好。

谢谢

Answer 1

除非你真的愿意，否则你不需要创建自己的侦听器。Azure Webjobs SDK 已经为你完成了繁重的工作。

下面是一个示例函数.cs它可以处理来自不同队列的数据。您可以将服务注入函数.cs以便根据需要由不同的服务处理不同的队列。

    private readonly IMyService _myService;
    //You can use Dependency Injection if you want to. 
    public Functions(IMyService myService)
    {
        _myService = myService;
    }
    public void ProcessQueue1([QueueTrigger("queue1")] string item)
    {
        //You can get the message as a string or it can be strongly typed
        _myService.ProcessQueueItem1(item);
    }
    public void ProcessQueue2([QueueTrigger("queue2")] MyObject item)
    {
        //You can get the message as a string or it can be strongly typed
        _myService.ProcessQueueItem2(item);
    }

希望这有帮助

Answer 2

正如@lopezbertoni所建议的，我在函数中创建了两个方法，并使用IJobActivator将类注入函数。请参阅以下示例：

public class Program
{
    static void Main()
    {
        var builder = new ContainerBuilder();
        builder.RegisterType<MyMessageHandler>().As<IMessageHandler>();
        builder.RegisterType<Functions>()
            .InstancePerDependency();

        var host = new JobHost(new JobHostConfiguration
        {
            JobActivator = new AutofacJobActivator(builder.Build())
        });
        host.RunAndBlock();
    }
}
public class AutofacJobActivator : IJobActivator
{
    private readonly IContainer _container;
    public AutofacJobActivator(IContainer container)
    {
        _container = container;
    }
    public T CreateInstance<T>()
    {
        return _container.Resolve<T>();
    }
}
public class Functions
{
    private IMessageHandler _myService;
    //You can use Dependency Injection if you want to. 
    public Functions(IMessageHandler myService)
    {
        _myService = myService;
    }
    // This function will get triggered/executed when a new message is written 
    // on an Azure Queue called queue.
    public async Task ProcessQueueMessage1(
        [QueueTrigger("test1")] CloudQueueMessage message,
        IBinder binder)
    {
        _myService.HandleMessage(message.AsString);
        Console.WriteLine("ProcessQueueMessage1 was run");
        await Task.CompletedTask;
    }
    public async Task ProcessQueueMessage2(
        [QueueTrigger("test2")] CloudQueueMessage message,
        IBinder binder)
    {
        _myService.HandleMessage(message.AsString);
        Console.WriteLine("ProcessQueueMessage2 was run");
        await Task.CompletedTask;
    }
}