求助：ASP.NET Core Razor Pages实时响应Pub/Sub模式实现方案

历史背景 #

此前在.NET Framework中使用SignalR实现实时功能，现正将整个应用重构为.NET Core，以摆脱单一依赖。

目标 #

计划采用Redis与默认InMemoryCacheServices作为临时数据库，混合使用Redis Pub/Sub、Kafka、RabbitMQ实现实时告警。

已完成工作 #

已在本地Docker中运行Redis，并可通过控制台应用发送实时消息，核心代码如下：

// PROGRAM.CS (.NET 7.0)
var redis = ConnectionMultiplexer.Connect(configurationOptions);
ISubscriber subScriber = redis.GetSubscriber();
builder.Services.AddScoped(s => redis.GetDatabase());

// IndexModel 构造函数
private readonly ILogger<IndexModel> _logger;
private readonly IDatabase _database;

public IndexModel(ILogger<IndexModel> logger, IDatabase database)
{
    _database = database;
    _logger = logger;
} 

// OnGet 方法
public void OnGet()
{
    var configurationOptions = new ConfigurationOptions
    {
        EndPoints = { { "localhost", 32768 } },
        AbortOnConnectFail = false,
        ConnectTimeout = 10000
    };

    var redis = ConnectionMultiplexer.Connect(configurationOptions);
    ISubscriber subScriber = redis.GetSubscriber();
 
    var pubSub = redis.GetSubscriber();

    ViewData["message"] = pubSub.SubscribeAsync("MyKey", (channel, message) => MessageAction(message));
    ViewData["message2"] = _database.StringGetAsync("MyKey").ToString();
}

private void MessageAction(RedisValue message)
{
    ViewData["message3"] = message;
}

问题与解决方案 #

1. 如何实现前端实时响应？ #

Razor Pages默认是请求响应模式，无法直接实现实时UI更新，需要结合SignalR作为实时通信层，搭配Redis Pub/Sub做后端消息中转，步骤如下：

• 安装Microsoft.AspNetCore.SignalR NuGet包
• 创建SignalR Hub类，用于推送消息给前端：

  public class AlertHub : Hub
  {
      public async Task SendAlert(string message)
      {
          await Clients.All.SendAsync("ReceiveAlert", message);
      }
  }
  

• 在Program.cs中注册SignalR并配置Redis连接复用器（单例，避免重复创建连接）：

  var redisConfig = new ConfigurationOptions
  {
      EndPoints = { { "localhost", 32768 } },
      AbortOnConnectFail = false,
      ConnectTimeout = 10000
  };
  var redis = ConnectionMultiplexer.Connect(redisConfig);
  builder.Services.AddSingleton<IConnectionMultiplexer>(redis);
  builder.Services.AddScoped(s => redis.GetDatabase());
  builder.Services.AddScoped(s => redis.GetSubscriber());
  // 注册SignalR
  builder.Services.AddSignalR();
  app.MapHub<AlertHub>("/alertHub");
  

• 前端页面引入SignalR JS脚本，连接Hub并监听消息更新UI：

  <script src="~/lib/signalr/dist/browser/signalr.js"></script>
  <script>
      const connection = new signalR.HubConnectionBuilder()
          .withUrl("/alertHub")
          .build();
  
      connection.on("ReceiveAlert", function (message) {
          // 更新UI，比如追加告警内容到页面
          document.getElementById("alertContainer").innerHTML += `<div>${message}</div>`;
      });
  
      connection.start().catch(err => console.error(err.toString()));
  </script>
  

2. OnGet()方法在控制台应用中返回值，但在Razor页面中返回布尔值，该如何解决？ #

你的代码存在三个核心问题：

• ConnectionMultiplexer在OnGet中重复创建，会导致连接泄漏，应该注册为单例复用
• 调用异步方法（SubscribeAsync、StringGetAsync）未使用await，直接ToString()得到的是Task对象的字符串，而非实际值
• SubscribeAsync返回的是Task<bool>，直接赋值给ViewData会显示任务状态而非订阅结果

修正后的IndexModel代码：

private readonly ILogger<IndexModel> _logger;
private readonly IDatabase _database;
private readonly ISubscriber _subscriber;
private readonly IHubContext<AlertHub> _hubContext;

public IndexModel(ILogger<IndexModel> logger, IDatabase database, ISubscriber subscriber, IHubContext<AlertHub> hubContext)
{
    _database = database;
    _logger = logger;
    _subscriber = subscriber;
    _hubContext = hubContext;
}

// 改为异步方法
public async Task OnGet()
{
    // 订阅逻辑建议放到后台服务，避免每次请求重复订阅
    await _subscriber.SubscribeAsync("MyKey", async (channel, message) =>
    {
        // 通过SignalR推送消息给前端
        await _hubContext.Clients.All.SendAsync("ReceiveAlert", message.ToString());
    });

    // 正确获取Redis缓存值
    var cachedValue = await _database.StringGetAsync("MyKey");
    ViewData["message2"] = cachedValue.HasValue ? cachedValue.ToString() : "无缓存数据";
}

3. 若当前方向有误，合适的实现模式与技术指引 #

当前直接在Razor Pages的OnGet中订阅Redis Pub/Sub的方向是错误的，会导致重复订阅、资源浪费，且无法实现真正的实时UI。正确的架构模式：

• 实时通信层：用.NET Core SignalR作为前端与后端的实时桥梁，替代直接在页面请求中处理订阅
• 消息订阅层：用**后台服务（IHostedService）**统一订阅Redis Pub/Sub、Kafka、RabbitMQ的消息，避免每个请求重复订阅
• 数据存储层：Redis作为告警历史数据的缓存，供页面初始加载时获取；InMemoryCache作为本地临时缓存
• 消息转发层：如果需要混合多种消息队列，可通过自定义消息处理服务统一接收不同队列的消息，再转发给SignalR推送给前端

尝试与期望 #

已尝试上述代码，期望实现.NET Core Razor Pages的响应式UI。

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