Bot Framework中如何避免用户偏好存储的并发问题（双语场景）

这个问题我太熟悉了——你踩了Bot Framework状态管理里最常见的坑之一：用全局共享存储来保存用户专属的偏好！你的Globals类或者全局Bot State对象是所有用户共享的，所以只要有一个用户修改语言，所有用户的设置都会被覆盖。下面是具体的解决思路和代码实现：

核心问题根源 #

你当前用的是全局状态（比如静态类、全局Bot State实例），这类存储是所有会话、所有用户共享的。而用户的语言偏好是用户专属数据，必须和单个用户绑定，不能共享。

正确解决方案：使用UserState存储用户专属偏好 #

Bot Framework提供了UserState组件，专门用来存储与单个用户绑定的持久化数据——每个用户的UserState都是独立的，不会和其他用户的数据互相干扰。

步骤1：定义用户偏好状态类 #

首先创建一个强类型的类来存储用户的语言偏好：

public class UserPreferences
{
    // 存储用户选择的语言，比如"en"或"de"
    public string SelectedLanguage { get; set; }
}

步骤2：在Bot服务中注册UserState #

在你的Startup（或者Program.cs，.NET 6+）中注册UserState服务：

// .NET 6+ 示例
builder.Services.AddSingleton<UserState>();
builder.Services.AddSingleton<BotFrameworkAdapter>();
// 注册你的根对话框和Bot类，确保注入UserState
builder.Services.AddSingleton<RootDialog>();
builder.Services.AddTransient<IBot, YourBotClass>();

步骤3：在根对话框中注入并使用UserState #

修改你的根对话框，通过构造函数注入UserState，然后创建专属的用户属性容器：

public class RootDialog : ComponentDialog
{
    private readonly UserState _userState;
    private readonly IStatePropertyAccessor<UserPreferences> _userPreferencesAccessor;

    public RootDialog(UserState userState) : base(nameof(RootDialog))
    {
        _userState = userState;
        // 创建用户偏好的属性访问器，每个用户会有独立的实例
        _userPreferencesAccessor = _userState.CreateProperty<UserPreferences>("UserPreferences");

        // 添加你的对话瀑布逻辑
        var waterfallSteps = new WaterfallStep[]
        {
            CheckLanguagePreferenceStepAsync,
            SaveLanguagePreferenceStepAsync,
            // 其他对话步骤...
        };
        AddDialog(new WaterfallDialog(nameof(WaterfallDialog), waterfallSteps));
        AddDialog(new TextPrompt(nameof(TextPrompt)));
        InitialDialogId = nameof(WaterfallDialog);
    }

    private async Task<DialogTurnResult> CheckLanguagePreferenceStepAsync(WaterfallStepContext stepContext, CancellationToken cancellationToken)
    {
        // 获取当前用户的偏好设置（每个用户独立）
        var userPreferences = await _userPreferencesAccessor.GetAsync(stepContext.Context, () => new UserPreferences(), cancellationToken);

        if (string.IsNullOrEmpty(userPreferences.SelectedLanguage))
        {
            // 用户首次对话，询问语言偏好
            await stepContext.Context.SendActivityAsync("Please select your language: English (en) or German (de)?", cancellationToken: cancellationToken);
            return await stepContext.PromptAsync(nameof(TextPrompt), new PromptOptions(), cancellationToken);
        }
        else
        {
            // 使用用户已保存的语言回复
            var greeting = userPreferences.SelectedLanguage == "en" ? "Welcome back!" : "Willkommen zurück!";
            await stepContext.Context.SendActivityAsync(greeting, cancellationToken: cancellationToken);
            return await stepContext.NextAsync(null, cancellationToken);
        }
    }

    // 处理用户选择的语言并保存
    private async Task<DialogTurnResult> SaveLanguagePreferenceStepAsync(WaterfallStepContext stepContext, CancellationToken cancellationToken)
    {
        var selectedLang = stepContext.Result.ToString().ToLower();
        if (selectedLang is "en" or "de")
        {
            var userPreferences = await _userPreferencesAccessor.GetAsync(stepContext.Context, () => new UserPreferences(), cancellationToken);
            userPreferences.SelectedLanguage = selectedLang;
            // 保存用户状态到持久化存储
            await _userState.SaveChangesAsync(stepContext.Context, false, cancellationToken);

            var confirmation = selectedLang == "en" ? "Language set to English!" : "Sprache auf Deutsch eingestellt!";
            await stepContext.Context.SendActivityAsync(confirmation, cancellationToken: cancellationToken);
        }
        else
        {
            await stepContext.Context.SendActivityAsync("Invalid language selection. Please choose English (en) or German (de).", cancellationToken: cancellationToken);
            return await stepContext.ReplaceDialogAsync(InitialDialogId, null, cancellationToken);
        }
        return await stepContext.NextAsync(null, cancellationToken);
    }
}

步骤4：移除全局共享的存储 #

删掉原来的Globals类或者全局状态变量——现在所有用户的语言偏好都存储在各自的UserState里，完全隔离，不会出现并发覆盖的问题。

关键原理说明 #

• UserState是基于用户ID（Activity.From.Id）来区分存储的，每个用户的数据都保存在独立的容器中。
• 调用SaveChangesAsync会将用户的状态持久化到Bot Framework的后端存储（默认是内存，生产环境建议用Azure Cosmos DB或SQL）。
• 即使多个用户同时修改自己的语言偏好，也只会修改自己的专属状态，不会影响其他用户。

内容的提问来源于stack exchange，提问作者Ehsan Ul Haq