Переписать удаление служебной шины Azure
У меня есть класс ServiceBusBackgroundJobManager, он отправляет сообщения в служебную шину Azure.
public class ServiceBusBackgroundJobManager : BackgroundWorkerBase, IBackgroundJobManager
{
private readonly IAppConfigurationAccessor _configurationAccessor;
private readonly ServiceBusClient _client;
private ServiceBusSender _sender;
private readonly string _serviceBusQueueName;
public ServiceBusBackgroundJobManager(IAppConfigurationAccessor configurationAccessor)
{
_configurationAccessor = configurationAccessor;
var connectionString = _configurationAccessor.Configuration["Abp:ServiceBusConnectionString"];
_serviceBusQueueName = _configurationAccessor.Configuration["Abp:ServiceBusQueueName"];
_client = new ServiceBusClient(connectionString);
}
public async Task<string> EnqueueAsync<TJob, TArgs>(TArgs args, BackgroundJobPriority priority = BackgroundJobPriority.Normal,
TimeSpan? delay = null) where TJob : IBackgroundJobBase<TArgs>
{
var messageBody = JsonSerializer.Serialize(args);
var message = new ServiceBusMessage(Encoding.UTF8.GetBytes(messageBody))
{
MessageId = Guid.NewGuid().ToString(),
ContentType = "application/json"
};
if (delay != null)
{
message.ScheduledEnqueueTime = DateTimeOffset.UtcNow.Add(delay.Value);
}
_sender = _client.CreateSender(_serviceBusQueueName);
using var messageBatch = await _sender.CreateMessageBatchAsync();
if (!messageBatch.TryAddMessage(message))
{
throw new Exception($"Exception");
}
try
{
await _sender.SendMessagesAsync(messageBatch);
}
finally
{
await _sender.DisposeAsync();
await _client.DisposeAsync();
}
return string.Empty;
}
}
}
Проблема в том, что в блоке finally у меня есть dispose, но он не удаляется в 2-х вариантах
- Таким образом, если два или более заданий будут поставлены в очередь, у второго не будет клиента, который можно было бы использовать.
- Если в очереди нет заданий, клиент не удаляется.
Как мне нужно написать код, чтобы он работал в этих двух вариантах?
Ответы 3
Вы можете рассмотреть возможность использования своих ресурсов вместе с блоками, как вы это делали для messageBatch.
Дополнительную информацию см. по этой ссылке: https://learn.microsoft.com/en-us/dotnet/csharp/language-reference/statements/using
ОП задал конкретный вопрос. Можете ли вы дать конкретный ответ на этот вопрос?
Я считаю, что ответ не может быть более конкретным, чем этот. Если вы уверены, что оно недостаточно конкретное, вы можете попытаться уточнить его. Спасибо @Enigmativity
ОП спросил: «Итак, если два или более заданий будут поставлены в очередь, у второго не будет клиента для использования». и «Если в очереди нет заданий, клиент не удаляется». - Ваш ответ тоже не касается.
Приятель, судя по твоему последнему комментарию, ты знаешь ответ, мне просто интересно, почему бы тебе просто не ответить на вопрос, а не критиковать? @Энигмативность
Вам нужно каждый раз создавать отправителя? Безопасно кэшировать отправителя или использовать синглтон на протяжении всего времени существования приложения. https://learn.microsoft.com/en-us/dotnet/api/azure.messaging.servicebus.servicebussender?view=azure-dotnet
ОП задал конкретный вопрос. Можете ли вы дать конкретный ответ на этот вопрос?
Вы можете добиться этого более аккуратным способом, используя внедрение зависимостей (DI).
Существуют методы расширения DI, которые безопасно регистрируют классы служебной шины и гарантируют их удаление в нужное время, и вам не придется об этом беспокоиться. Вот как можно изменить код, чтобы сделать это.
1. Настройте DI
При запуске приложения (например, Program.cs) добавьте конфигурацию DI. Этот пример предназначен для функции Azure, но он будет аналогичен и в других платформах.
var host = new HostBuilder()
.ConfigureFunctionsWebApplication() // (Depending on your framework)
.ConfigureServices(services =>
{
// Use the DI extension method for Azure clients.
services.AddAzureClients(configureClients =>
{
// Add the ServiceBusClient.
configureClients.AddServiceBusClient("YourConnectionString");
// Add the Sender for your queue.
configureClients.AddClient<ServiceBusSender, ServiceBusClientOptions>((_, _, provider) =>
provider
.GetRequiredService<ServiceBusClient>()
.CreateSender("YourQueueName"));
});
// And then add your service classes, including your Manager class.
services.AddScoped<IBackgroundJobManager, ServiceBusBackgroundJobManager>();
// You should also add your other Service classes as DI.
})
.Build();
host.Run();
2. Упростите класс менеджера
Ваш класс Manager теперь может просто использовать экземпляры служебной шины в качестве зависимости конструктора, которую DI создаст соответствующим образом. Менеджер больше не несет ответственности за срок существования экземпляров, поэтому ему не нужно рассматривать возможность удаления.
public class ServiceBusBackgroundJobManager : BackgroundWorkerBase, IBackgroundJobManager
{
private readonly ServiceBusSender _sender;
public ServiceBusBackgroundJobManager(ServiceBusSender sender)
{
_sender = sender;
}
public async Task<string> EnqueueAsync<TJob, TArgs>(
TArgs args,
BackgroundJobPriority priority = BackgroundJobPriority.Normal,
TimeSpan? delay = null) where TJob : IBackgroundJobBase<TArgs>
{
var messageBody = JsonSerializer.Serialize(args);
var message = new ServiceBusMessage(Encoding.UTF8.GetBytes(messageBody))
{
MessageId = Guid.NewGuid().ToString(),
ContentType = "application/json"
};
if (delay != null)
{
message.ScheduledEnqueueTime = DateTimeOffset.UtcNow.Add(delay.Value);
}
using var messageBatch = await _sender.CreateMessageBatchAsync();
if (!messageBatch.TryAddMessage(message))
{
throw new Exception($"Exception");
}
await _sender.SendMessagesAsync(messageBatch);
return string.Empty;
}
}
Вы создаете клиент в конструкторе, а это означает, что вы хотите удалить клиент только один раз, например, в методе Dispose работника. Если вы хотите каждый раз его удалять, вам придется каждый раз создавать клиент, то есть в самом методе EnqueueAsync.