ABP.io中Library App向Admin SignalR Hub发送通知失败问题

核心问题分析 #

你遇到的服务器端错误，大概率是ABP SignalR Hub的身份验证缺失或跨域配置未覆盖服务端调用场景导致的——AbpHub默认集成了ABP的权限系统，无有效身份凭证的请求会被拦截。

具体修复步骤 #

1. 为后台任务的SignalR请求添加身份凭证 #

ABP的SignalR Hub需要有效的身份信息才能调用受保护方法，后台任务作为服务端请求，可通过以下方式添加凭证：

方式一：模拟目标用户身份（推荐）

在Library App的后台任务中，先模拟目标用户身份获取JWT令牌，再注入到SignalR连接：

// 新增注入依赖
private readonly IAbpSession _abpSession;
private readonly ITokenManager _tokenManager;

// 构造函数补充注入
public ExtractBooksCoversJob(IGdPictureAppService gdPictureAppService, IConfiguration configuration, IAbpSession abpSession, ITokenManager tokenManager)
{
    _gdPictureAppService = gdPictureAppService;
    _configuration = configuration;
    _abpSession = abpSession;
    _tokenManager = tokenManager;
}

public override async Task ExecuteAsync(ExtractBooksCoversArgs args)
{
    // ... 封面提取逻辑 ...

    // 模拟目标用户身份生成令牌
    using (_abpSession.Use(args.UserId, null))
    {
        var token = await _tokenManager.CreateAccessTokenAsync();
        
        // 创建带令牌的SignalR连接
        _connection = new HubConnectionBuilder()
            .WithUrl(_configuration["SaasUrl"] + "/signalr-hubs/notification", options =>
            {
                options.AccessTokenProvider = () => Task.FromResult(token);
            })
            .Build();

        await _connection.StartAsync();

        // 发送通知
        await _connection.InvokeAsync(
            "SendNotification", 
            $"Covers extracted successfully: {args.BooksIds.Count}", 
            "/", 
            args.UserId.ToString()
        );
    }
}

方式二：使用系统管理员凭证（无特定用户场景）

如果不需要关联特定用户，可预先生成系统管理员的JWT令牌，配置在Library App的appsettings.json中，直接添加到请求头：

_connection = new HubConnectionBuilder()
    .WithUrl(_configuration["SaasUrl"] + "/signalr-hubs/notification", options =>
    {
        options.Headers.Add("Authorization", $"Bearer {_configuration["AdminSignalRToken"]}");
    })
    .Build();

2. 更新Admin App的跨域配置 #

ABP默认跨域配置可能仅允许前端请求，需在Admin App的Module类中修改CORS规则，允许Library App的后端域名：

public override void ConfigureServices(ServiceConfigurationContext context)
{
    // ... 其他配置 ...

    context.Services.AddCors(options =>
    {
        options.AddPolicy("AllowLibraryApp",
            builder =>
            {
                builder.WithOrigins(_configuration["LibraryAppBackendUrl"]) // Library App后端域名
                       .AllowAnyHeader()
                       .AllowAnyMethod()
                       .AllowCredentials(); // 必须启用，SignalR需要凭证支持
            });
    });
}

public override void OnApplicationInitialization(ApplicationInitializationContext context)
{
    var app = context.GetApplicationBuilder();
    // ... 其他中间件 ...

    app.UseCors("AllowLibraryApp");
    app.UseSignalR(routes =>
    {
        routes.MapHub<NotificationHub>("/signalr-hubs/notification");
    });
}

3. 增加服务器端错误日志排查 #

在Admin App的NotificationHub中添加异常捕获，输出详细错误信息，定位具体问题：

public async Task SendNotification(string notificationMessage, string url, string userId)
{
    try
    {
        userId = userId ?? CurrentUser.Id?.ToString();
        if (string.IsNullOrEmpty(userId))
        {
            Logger.LogError("UserId is null or empty when sending notification");
            return;
        }

        await Clients.Users(userId!).SendAsync("ReceiveNotification", notificationMessage, url);
    }
    catch (Exception ex)
    {
        Logger.LogError(ex, "Failed to send notification to user {UserId}", userId);
        throw; // 重新抛出，让客户端获取完整错误详情
    }
}

4. 优化SignalR连接的资源管理 #

后台任务中要确保连接正确释放，避免资源泄漏，同时添加连接失败的重试逻辑：

public override async Task ExecuteAsync(ExtractBooksCoversArgs args)
{
    // ... 封面提取逻辑 ...

    _connection = new HubConnectionBuilder()
        .WithUrl(/* 你的连接配置 */)
        .Build();

    // 连接断开时自动重试
    _connection.Closed += async (error) =>
    {
        Logger.LogError(error, "SignalR connection closed unexpectedly");
        await Task.Delay(TimeSpan.FromSeconds(5));
        await _connection.StartAsync();
    };

    try
    {
        await _connection.StartAsync();
        await _connection.InvokeAsync("SendNotification", /* 参数 */);
    }
    catch (Exception ex)
    {
        Logger.LogError(ex, "Failed to send notification via SignalR");
    }
    finally
    {
        await _connection.DisposeAsync(); // 任务结束后释放连接
    }
}

额外验证点 #

• 确认Admin App的NotificationHub已正确注册：检查Module类中是否存在MapHub配置。
• 验证JWT令牌有效性：调用Admin App的/api/abp/application-configuration接口，确认令牌包含SignalR相关权限。
• 检查用户在线状态：如果目标用户未在线，Clients.Users(userId)不会抛出错误，但通知无法送达，可在Admin端添加日志确认用户连接状态。

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