带有 DI 的 Azure 服务 IMessageSender

大佬教程收集整理的这篇文章主要介绍了带有 DI 的 Azure 服务 IMessageSender，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决带有 DI 的 Azure 服务 ImessageSender？

我正在使用 .net 核心项目。

我像这样实现了 DI：

builder.services.AddSingleton<ImessageSender>(x => new 
    messageSender(Environment.GetEnvironmentvariable("serviceBusConnection"),"queuename"));
var serviceprovIDer = builder.services.buildserviceProvIDer();

serviceBusUtils.Configure(serviceprovIDer.Getservice<ImessageSender>());

另外，我有一个实用程序类：

public static class serviceBusUtils
{
  
    private static ImessageSender _messageSender;

  
    public static voID Configure(ImessageSender messageSender)
    {
        _messageSender = messageSender;
    }

    
    public static async Task<bool> Sendmessage(Executemessage<message> message,String queuename,String ID)
    {
       

        var message = new message(EnCoding.UTF8.GetBytes(JsonConvert.serializeObject(messagE)))
        {
            SessionID = ID,};

        await _messageSender.SendAsync(messagE);

        return true;
    }
}

但我无法使用参数设置 queuename。

我想使用类似的实现

serviceBusUtils.Sendmessage(message,"quename");

解决方法

public void Configureservices(IserviceCollection services)
{
    var queuenames = new String[] { "q1","q2" };
    var queueFactory = new Dictionary<String,ImessageSender>();
            
    foreach (var queuename in queuenames)
    {
        queueFactory.Add(queuename,new messageSender(Environment.GetEnvironmentVariable("serviceBusConnection"),queueName));
    }

    services.AddSingleton(queueFactory);
    services.AddSingleton<IserviceBus,serviceBus>();
}


public interface IserviceBus
{
    public Task Sendmessage(String message,String queuE);
}


public class serviceBus : IserviceBus
{
    private readonly Dictionary<String,ImessageSender> _queueFactory;

    public serviceBus(Dictionary<String,ImessageSender> queueFactory)
    {
        _queueFactory = queueFactory;
    }
    public async Task Sendmessage(String message,String queuE)
    {
        var messageSender = _queueFactorY[queue];
        await messageSender.SendAysnc(messagE);
    }
}

_serviceBus.Sendmessage("message","q1");

大佬总结

以上是大佬教程为你收集整理的带有 DI 的 Azure 服务 IMessageSender全部内容，希望文章能够帮你解决带有 DI 的 Azure 服务 IMessageSender所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。