如何在StackExchange.Redis订阅回调中使用依赖注入的作用域服务？

当然可以在StackExchange.Redis的订阅回调里使用自定义服务，但咱得注意作用域服务的生命周期问题——订阅回调是在Redis客户端的后台线程中执行的，不在ASP.NET Core默认的请求作用域里，直接从根服务容器获取作用域服务会导致服务无法正确释放，甚至引发线程安全问题。

解决方案：创建独立作用域获取服务 #

核心思路是在回调内部创建一个新的依赖注入作用域，从这个作用域中解析你的IProfileService，用完后及时释放作用域。下面是修改后的完整示例：

1. 封装订阅逻辑到服务类（注入IServiceProvider）

public class RedisProfileSubscriptionService
{
    private readonly IServiceProvider _serviceProvider;

    // 通过构造函数注入根服务提供者
    public RedisProfileSubscriptionService(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }

    public void StartListening()
    {
        var redis = ConnectionMultiplexer.Connect("redis");
        var subscriber = redis.GetSubscriber();
        
        // 订阅消息并处理
        subscriber.Subscribe("profile:created").OnMessage(async channelMsg =>
        {
            var profile = JsonConvert.DeserializeObject<Profile>(channelMsg.Message);
            
            // 创建独立作用域，确保服务生命周期正确
            using (var scope = _serviceProvider.CreateScope())
            {
                // 从作用域中解析作用域服务
                var profileService = scope.ServiceProvider.GetRequiredService<IProfileService>();
                // 执行业务逻辑（建议用异步方法避免阻塞线程）
                await profileService.InsertProfile(profile);
            }
        });
    }
}

2. 在Startup中注册服务并启动订阅

public void ConfigureServices(IServiceCollection services)
{
    // 注册你的作用域服务
    services.AddScoped<IProfileService, ProfileService>();
    // 注册订阅服务为单例（因为订阅是长期运行的）
    services.AddSingleton<RedisProfileSubscriptionService>();
}

public void Configure(IApplicationBuilder app, RedisProfileSubscriptionService subscriptionService)
{
    // 其他中间件配置...
    
    // 启动Redis订阅
    subscriptionService.StartListening();
}

关键注意事项 #

• 必须用using包裹作用域：确保作用域和其中的服务在使用后被正确释放，避免内存泄漏和资源占用。
• 优先使用异步方法：如果InsertProfile是异步的，一定要把回调改成async，避免阻塞Redis的后台线程，影响其他订阅消息的处理。
• 禁止直接从根容器获取作用域服务：根容器的服务生命周期是全局的，直接获取会导致作用域服务无法被正确回收，违反ASP.NET Core依赖注入的设计原则。

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