.NET Core 7一对一聊天：无SignalR连接ID时如何通知用户收消息？

1. 离线消息持久化 + 前端主动拉取 #

• 维护一个在线用户映射表（内存字典或分布式缓存均可），存储用户ID与对应SignalR连接ID的集合。
• 发送消息时先校验接收方在线状态：
  • 在线则直接通过SignalR推送消息；
  • 不在线就把消息存入数据库，标记为未读状态。
• 用户打开应用（无需进入聊天界面）时，前端主动调用接口拉取未读消息，或定时轮询更新未读计数，触发页面通知。
• 示例Hub代码：

  public async Task SendPrivateMessage(string targetUserId, string content)
  {
      var onlineConnIds = _onlineUserStore.GetConnections(targetUserId);
      if (onlineConnIds.Any())
      {
          foreach (var connId in onlineConnIds)
          {
              await Clients.Client(connId).SendAsync("GetNewMessage", content);
          }
      }
      else
      {
          _dbContext.UnreadMessages.Add(new UnreadMessage
          {
              ReceiverId = targetUserId,
              Content = content,
              CreatedAt = DateTime.UtcNow
          });
          await _dbContext.SaveChangesAsync();
      }
  }
  

2. 全局初始化SignalR连接 #

• 把SignalR连接逻辑移到网站全局布局脚本中，用户一打开网站就建立Hub连接，而非仅在聊天界面初始化。
• 启用SignalR自动重连机制，处理网络波动导致的连接中断问题。
• 全局监听消息通知事件，收到新消息时通过浏览器提示（右上角小红点、系统通知）引导用户进入聊天界面。
• 示例前端代码：

  const chatConnection = new signalR.HubConnectionBuilder()
      .withUrl("/chatHub")
      .withAutomaticReconnect()
      .build();
  
  chatConnection.start().catch(err => console.error(err));
  
  chatConnection.on("ReceiveNotification", (msg) => {
      showUnreadBadge();
      if (Notification.permission === "granted") {
          new Notification("新消息", { body: msg });
      }
  });
  

3. 结合Web Push API实现离线推送 #

• 用户首次访问时，请求浏览器通知权限，获取推送订阅信息（包含推送端点、密钥等），关联用户ID存入数据库。
• 当接收方不在线时，后端调用Web Push服务向其浏览器发送系统级推送通知，无需用户保持网站打开。
• 用户点击通知可直接跳转至聊天界面查看消息。
• 示例后端推送代码（使用WebPush库）：

  var userSubscription = _dbContext.PushSubscriptions.FirstOrDefault(s => s.UserId == targetUserId);
  if (userSubscription != null)
  {
      var webPushClient = new WebPushClient();
      var vapidConfig = new VapidDetails("mailto:your-support@example.com", "你的公钥", "你的私钥");
      var payload = JsonSerializer.Serialize(new { title = "新消息提醒", content = content });
      await webPushClient.SendNotificationAsync(userSubscription, payload, vapidConfig);
  }
  

4. 基于SignalR分组的消息路由 #

• 为每个用户创建专属的SignalR分组，用户连接Hub时自动加入自己的分组。
• 发送消息时直接向目标用户的分组推送，支持用户多标签页在线的场景。
• 用户上线后，Hub主动查询并推送其未读消息，同时标记为已读。
• 示例Hub连接逻辑：

  public override async Task OnConnectedAsync()
  {
      var currentUserId = Context.User.FindFirst(ClaimTypes.NameIdentifier)?.Value;
      if (!string.IsNullOrEmpty(currentUserId))
      {
          await Groups.AddToGroupAsync(Context.ConnectionId, $"UserGroup_{currentUserId}");
          _onlineUserStore.AddUser(currentUserId, Context.ConnectionId);
  
          var unreadMsgs = await _dbContext.UnreadMessages.Where(m => m.ReceiverId == currentUserId).ToListAsync();
          foreach (var msg in unreadMsgs)
          {
              await Clients.Caller.SendAsync("GetNewMessage", msg.Content);
              _dbContext.UnreadMessages.Remove(msg);
          }
          await _dbContext.SaveChangesAsync();
      }
      await base.OnConnectedAsync();
  }
  

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