在Azure Service Bus的ProcessErrorAsync处理器中获取userName

针对你遇到的ProcessErrorAsync无法获取消息上下文（进而拿不到UserName）的问题，有以下几种常用处理方式：

1. 利用Azure Service Bus消息的UserProperties传递UserName #

在发送Service Bus消息时，把UserName存入消息的自定义属性中，这样即使消息处理出错，ProcessErrorAsync也能通过ExceptionReceivedEventArgs拿到消息属性：

发送消息时的代码： #

// 发送Service Bus消息时，添加UserName到自定义属性
var message = new ServiceBusMessage(Encoding.UTF8.GetBytes(messageBody))
{
    UserProperties = { ["UserName"] = targetUserName }
};
await _serviceBusSender.SendMessageAsync(message);

在IHostedService的错误回调中获取： #

public async Task ProcessErrorAsync(ProcessErrorEventArgs args)
{
    // 从出错的消息属性中提取UserName
    if (args.ExceptionReceivedContext.Message != null 
        && args.ExceptionReceivedContext.Message.UserProperties.TryGetValue("UserName", out var userNameObj)
        && userNameObj is string userName)
    {
        var userGroupName = CreateUserGroupName(userName ?? "Empty");
        await _notificationHub.Clients.Group(userGroupName)
            .SendAsync("OnError", $"消息处理出错：{args.Exception.Message}");
    }
    // 处理无UserName的通用错误场景
    else
    {
        // 可以发送给所有在线客户端，或者记录日志
        await _notificationHub.Clients.All.SendAsync("OnGlobalError", $"服务总线出现未关联用户的错误：{args.Exception.Message}");
    }
}

2. 自定义消息处理器，在错误时保留上下文 #

如果你的消息处理逻辑比较复杂，可以自定义Service Bus消息处理器，在ProcessMessageAsync中捕获异常并手动触发错误通知，同时保留当前消息的UserName上下文：

public async Task ProcessMessageAsync(ProcessMessageEventArgs args)
{
    string userName = null;
    try
    {
        // 从消息体或属性中解析UserName
        userName = ExtractUserNameFromMessage(args.Message);
        // 执行正常的消息处理逻辑
        await HandleBusinessLogic(args.Message, userName);
        // 处理完成后发送成功通知
        var userGroupName = CreateUserGroupName(userName ?? "Empty");
        await _notificationHub.Clients.Group(userGroupName).SendAsync("OnReceived", "处理完成");
        await args.CompleteMessageAsync(args.Message);
    }
    catch (Exception ex)
    {
        // 出错时直接用当前上下文的UserName发送错误通知
        if (!string.IsNullOrEmpty(userName))
        {
            var userGroupName = CreateUserGroupName(userName);
            await _notificationHub.Clients.Group(userGroupName).SendAsync("OnError", $"处理失败：{ex.Message}");
        }
        // 记录错误并放弃/死信消息
        await args.AbandonMessageAsync(args.Message);
    }
}

这种方式相当于把错误处理的逻辑提前到消息处理的上下文里，避免依赖ProcessErrorAsync的有限上下文。

3. 针对无关联用户的错误，发送全局通知 #

如果某些错误确实无法关联到具体用户（比如队列级别的连接错误），可以直接给所有在线客户端发送全局错误通知，或者只记录日志并在后台处理：

public async Task ProcessErrorAsync(ProcessErrorEventArgs args)
{
    // 判断错误类型，如果是无法关联用户的错误，发送全局通知
    if (args.ErrorSource == ServiceBusErrorSource.Receiver)
    {
        await _notificationHub.Clients.All.SendAsync("OnGlobalError", $"服务总线连接异常：{args.Exception.Message}");
    }
    // 其他错误尝试从消息属性获取UserName
    else if (args.ExceptionReceivedContext.Message != null)
    {
        // 同方案1的逻辑
    }
}

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