在MEF实例化类中是否需用静态TopicClient属性确保Web应用单实例？

嘿，这个问题我熟！Azure官方反复强调TopicClient这类Service Bus客户端必须用单例，不然频繁创建连接不仅浪费资源，还可能引发各种奇怪的问题。结合你用MEF和ASP.NET Web API的场景，咱们一步步来搞定：

1. 把TopicClient封装成线程安全的单例 #

首先得确保TopicClient本身是全局唯一的实例，别在AzureServiceBusService里每次都新建。咱们用Lazy<T>来实现线程安全的延迟初始化，完美适配单例需求：

public class TopicClientSingleton
{
    // Lazy<T>保证只有第一次调用时才初始化，且线程安全
    private static readonly Lazy<TopicClient> _lazyInstance = new Lazy<TopicClient>(() =>
    {
        // 替换成你的Service Bus连接字符串和主题名称
        var serviceBusConnection = "你的Service Bus连接字符串";
        var targetTopicName = "你的目标主题名称";
        return new TopicClient(serviceBusConnection, targetTopicName);
    });

    // 对外暴露唯一实例
    public static TopicClient Instance => _lazyInstance.Value;
}

2. 调整AzureServiceBusService依赖单例TopicClient #

接下来修改你的AzureServiceBusService，让它依赖这个单例TopicClient，而不是自己创建实例。同时用MEF的特性标记，确保能被正确注入：

// 标记为MEF导出，并且设置为单例创建策略
[Export(typeof(IAzureServiceBusService)), PartCreationPolicy(CreationPolicy.Shared)]
public class AzureServiceBusService : IAzureServiceBusService, IDisposable
{
    private readonly TopicClient _topicClient;

    // MEF导入构造函数，初始化时获取单例TopicClient
    [ImportingConstructor]
    public AzureServiceBusService()
    {
        _topicClient = TopicClientSingleton.Instance;
    }

    // 发送消息的业务方法
    public async Task SendMessageAsync(string messageContent)
    {
        var message = new Message(Encoding.UTF8.GetBytes(messageContent));
        await _topicClient.SendAsync(message);
    }

    // 实现IDisposable，在服务销毁时关闭TopicClient释放资源
    public void Dispose()
    {
        _topicClient?.CloseAsync().Wait();
    }
}

这里用PartCreationPolicy(CreationPolicy.Shared)让MEF只创建一个AzureServiceBusService实例，配合单例TopicClient，双重保障连接唯一。

3. 在Web API控制器中注入服务 #

最后在你的Web API控制器里，通过MEF注入IAzureServiceBusService的实例：

public class MessagesController : ApiController
{
    // MEF注入属性
    [Import]
    public IAzureServiceBusService BusService { get; set; }

    public MessagesController()
    {
        // 这里需要确保MEF容器已经初始化，并且完成部件组合
        // 比如调用你的MEF容器实例：MefContainer.ComposeParts(this);
    }

    [HttpPost]
    public async Task<IHttpActionResult> SendMessage([FromBody] string message)
    {
        if (string.IsNullOrWhiteSpace(message))
            return BadRequest("消息内容不能为空");

        await BusService.SendMessageAsync(message);
        return Ok("消息已成功发送到Azure Service Bus");
    }
}

关键注意事项 #

• 资源释放：一定要在应用生命周期结束时触发AzureServiceBusService的Dispose方法，比如在Global.asax的Application_End事件里手动调用，避免连接泄漏。
• MEF容器单例：确保你的MEF容器本身是全局单例的，不然容器多次创建可能导致服务实例重复（不过咱们已经设置了CreationPolicy.Shared，就算容器多实例也能保证服务单例，但容器单例更稳妥）。

内容的提问来源于stack exchange，提问作者Adrian