如何优雅实现Redis订阅消息的异步等待并返回消息内容？

当然有！在异步C#编程场景里，TaskCompletionSource<T>就是专门解决这类"等待外部事件触发后返回结果"需求的完美工具，它能把回调式的逻辑转换成可等待的Task，完全规避全局变量和手动事件等待的弊端，代码更简洁也更符合异步编程规范。

改造后的代码示例 #

// GET: api/<controller>
[HttpGet]
public async Task<string> GetAsync()
{
    // 创建TaskCompletionSource，用来后续传递Redis消息的结果
    var tcs = new TaskCompletionSource<string>();

    // 订阅Redis消息，收到消息时完成Task并传递内容
    var subscription = _pubsub.Subscribe("x", (channel, message) =>
    {
        // 设置Task的结果，同时立即取消订阅避免重复触发
        tcs.TrySetResult(message);
        subscription.Unsubscribe();
    });

    try
    {
        // 等待Redis消息到来，拿到结果后直接返回
        return await tcs.Task;
    }
    finally
    {
        // 确保无论请求成功还是失败，都取消订阅，防止资源泄漏
        subscription.Unsubscribe();
    }
}

这个方案的优势 #

• 无全局状态：结果直接通过TaskCompletionSource传递，完全避免了全局变量带来的线程安全问题
• 异步友好：直接返回Task<string>，符合ASP.NET Core的异步编程模型，不会像WaitOne()那样阻塞线程池线程，资源利用率更高
• 自动清理资源：finally块里的订阅取消逻辑，确保即使请求中途被取消或出错，也不会留下无效的Redis订阅
• 逻辑更清晰：把"等待消息"的逻辑封装成可等待的Task，代码可读性和维护性都更好

如果需要处理超时或者客户端取消请求的场景，还可以结合CancellationToken来增强健壮性：

public async Task<string> GetAsync(CancellationToken cancellationToken)
{
    var tcs = new TaskCompletionSource<string>();
    // 注册取消回调，当客户端取消请求时标记Task为取消状态
    using var cancellationRegistration = cancellationToken.Register(() => tcs.TrySetCanceled());

    var subscription = _pubsub.Subscribe("x", (channel, message) =>
    {
        tcs.TrySetResult(message);
        subscription.Unsubscribe();
    });

    try
    {
        return await tcs.Task;
    }
    finally
    {
        subscription.Unsubscribe();
    }
}

这样当客户端主动取消请求时，TaskCompletionSource会被立即标记为取消状态，避免不必要的等待和资源浪费。

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