我尝试使用 StackExchange.Redis nuget 将同步 Redis 存储转换为 .NET Core 2.2 Web API 的异步实现。

同步版本有效。

Basic Usage Guide状态:

Additionally, if you plan to make use of the asynchronous API and you require the Task.AsyncState to have a value, this can also be specified:

int databaseNumber = ...
object asyncState = ...
IDatabase db = redis.GetDatabase(databaseNumber, asyncState);

我不确定该声明是否意味着如果我想使用异步 API，我必须设置它，或者我可以设置它并从中获得一些好处. 如果是后者，那会有什么好处？

以下是我当前的(简化的)代码，我不知道是否/何时将什么设置为 _asyncState 对象以及从哪里获取它？

• ConnectionMultiplexerAsync() 和 DatabaseAsync() 做一些延迟初始化
• 存储旨在作为单例添加到依赖注入(inject)
• 然后在服务/ Controller 中用于存储比简单字符串更复杂的数据。

using Microsoft.Extensions.Options;
using StackExchange.Redis;
using System;
using System.Threading.Tasks;

namespace Test
{

    public class Settings
    {
        public string Config { get; set; }
    }

    public class MyAsyncRedisStorageService
    {

        private readonly Settings _settings;

        private IConnectionMultiplexer _connectionMultiplexer;
        private IDatabase _database;

        private object _asyncState;

        public MyAsyncRedisStorageService(IOptions<Settings> settings)
        {
            _settings = settings?.Value ?? throw new ArgumentNullException(nameof(settings));
            _asyncState = "what to use as asyncState object and when to get it from where?";
        }

        protected async Task<IConnectionMultiplexer> ConnectionMultiplexerAsync()
        {
            if (_connectionMultiplexer == null) _connectionMultiplexer = await ConnectionMultiplexer.ConnectAsync(_settings.Config);
            return _connectionMultiplexer;
        }

        protected async Task<IDatabase> DatabaseAsync()
        {

            if (_database == null)
            {
                IConnectionMultiplexer cm = await ConnectionMultiplexerAsync();
                _database = cm.GetDatabase();
            }
            return _database;

        }

        protected async Task<IDatabase> DatabaseAsync(object asyncStateObject)
        {

            if (_database == null)
            {
                IConnectionMultiplexer cm = await ConnectionMultiplexerAsync();
                _database = cm.GetDatabase(asyncState: asyncStateObject);
            }
            return _database;

        }

        public async Task<bool> StoreValueAsync(string key, string val)
        {
            //IDatabase db = await DatabaseAsync(_asyncState);
            IDatabase db = await DatabaseAsync();
            bool success = await db.StringSetAsync(key, val);
            return success;
        }

        public async Task<string> ReadValueAsync(string key)
        {
            //IDatabase db = await DatabaseAsync(_asyncState);
            IDatabase db = await DatabaseAsync();
            string value = await db.StringGetAsync(key);
            return value;
        }


    }

}

最佳答案

I am not sure if the statement means I have to set it if I want to use the asnychronous API or I can set it and get some benefit of doing so.

这意味着您可以根据需要进行设置。

If the later what would that benefits be?

Asynchronous Programming Model (APM) 使用“异步状态” .只有当您的应用程序大量使用 APM 并且您现在需要保持这种状态时，您才需要提供异步状态。 Task-based Asynchronous Pattern (TAP)能够使用更简单和更易于维护的代码来完成 APM 可以做的所有事情。因此，如果您拥有大型代码库并且还没有时间转换它，那么您只会使用 APM。这是将“异步状态”传递给此 API 的唯一原因。

I don't know if/when to set what as the _asyncState object and where to get it from?

“异步状态”是您的程序想要的任何状态。这个想法是，您向 Begin* 方法提供一个对象，然后当异步操作完成时，您将在回调中获得相同的对象。很多年前，在出现 lambda 和变量捕获之前，这非常有用。

关于c# - 在 C# 的 StackExchange.Redis 中将什么用作 asyncState 对象(或从哪里获取它)，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/54825493/