.net - 在 ASP.Net 中使用 Azure.Storage.Queues - 配置 DI

Question

我正在寻找用于在 ASP.Net Web 应用程序(使用 .Net Core 5)中配置 Azure.Storage.Queues 的代码示例，以便通过 DI 将 QueueClient 注入(inject)到我的服务类中。 谁能帮我指出正确的方向吗？

Answer 1

在启动中配置服务:

services.AddAzureClients(builder =>
{
  // Use the environment credential by default
  builder.UseCredential(new DefaultAzureCredential()); 
  builder.AddQueueServiceClient(Configuration.GetSection("StorageConnectionString"))
    .ConfigureOptions(c => c.MessageEncoding = Azure.Storage.Queues.QueueMessageEncoding.Base64);
});

类中的实现是:

    public class AzureQueueService : IQueueService
    {
        private readonly QueueServiceClient _queueServiceClient;

        public AzureQueueService(QueueServiceClient queueServiceClient)
        {
            this._queueServiceClient = queueServiceClient;
        }

        public void SendMessageToQueue(MyMessage message)
        {
            this._queueServiceClient.GetQueueClient("my-queue-name")
                .SendMessage(JsonSerializer.Serialize(message, new JsonSerializerOptions { PropertyNamingPolicy = JsonNamingPolicy.CamelCase }));
        }
    }