将 REST Web API 应用程序与 SignalR 集成？

Question

目标：通过在数据库中存储新消息（发布到 Web API）并将其推送到单个监听客户端 (SignalR)，促进 2 个用户之间的聊天。

以下是我的担忧：

• 除了命令和查询职责分离（CQRS）模式和事件溯源模式之外，我找不到任何可以解决此问题的设计模式。这两者似乎都专注于复杂的实时应用程序。我的应用程序具有许多传统的 REST 功能，但目前唯一的实时组件是聊天，因此似乎没有必要使用这些模式之一。
• 是否有更简单的方法将基于 REST 的网站 (Web API) 与实时组件 (SignalR) 集成？
• 我现在所做的感觉就像是在混合两种完全不同的东西。

我想过尝试一下：

• 使用事件将我的 POST 处理程序耦合到我的推送处理程序- 尽管我不确定这对我有帮助，因为我不希望我的应用程序的“发送消息”部分从“接收”部分发展出一部分。
• 将我所有的推送逻辑移至由消息代理处理的作业中 - 这似乎也没有必要，但会产生更好的分离。根据这个答案，我的理解是 SignalR 使用内存中消息代理，这样广播就不会等待接收消息，因此不需要外部消息代理，除非我确实需要横向扩展。

也许我的应用程序太简单，不需要更好的设计？

这是我到目前为止所拥有的：

public class chatPush
{
    public chatPush(){}

    public push(string msg)
    {
        try{
            string jsonMsg = JsonConvert.SerializeObject(msg);
            await Clients.User(userId).send(jsonMsg);
        }
        catch
        {
            string errorMsg = //error with msg
            await Clients.User(userId).send(errorMsg);
        }
    }
}

async Task<IHttpActionResult> PostMessage(Message msg)

    db.Messages.Add(msg);

    try
    {
        await db.SaveChangesAsync();
    }
    catch
    {
        //return error in JSON
    }

    //if update succeeded push it out
    _chatPush.push(jsonMsg);

    return //Success or Error code

Answer 1

我认为您不需要使用任何复杂的设计模式，而您的需求就这么简单。SignalR 仅在 POST/等中工作得很好。API 和 MVC 的处理程序。

如果您需要扩展到多个前端服务器，更复杂的设计会对您有所帮助，因为每个用户只会连接到您的一台 SignalR 主机，因此您需要担心通过背板或数据库的持久用户连接映射。但当你需要时，SignalR 有很好的文档。

就基本设计而言，我有一些建议：

1）如果服务器端有MessageHub，创建一个MessageHubHelper可以轻松地将数据推送给正确的用户。

[Authorize]
public class MessageHub : Hub
{
}

public static class MessageHubHelper
{
    private static readonly IHubContext _hubContext =
        GlobalHost.ConnectionManager.GetHubContext<MessageHub>();

    public static IHubContext Context
    {
        get { return _hubContext; }
    }

    public static void Send(User user, Message message)
    {
        _hubContext.Clients.User(GetUserId(user)).Send(message);
    }

    public static void DoSomethingElse(User user, Message message)
    {
        _hubContext.Clients.User(GetUserId(user)).DoSomethingElse(message);
    }

    private static string GetUserId(User user)
    {
        return user.IdentityUser.UserName;
    }
}

2) 确保仅在数据库提交成功时才推送数据（例如，在 try {} 中的 SaveChangesAsync 之后，除非 catch 会提前抛出/返回）。

3）您不需要手动处理JSON。只需向下推对象，C# SignalR 库就会为您处理编码和解码。

4）根据我的经验，SignalR 的重新连接可能有点不稳定，尤其是 IUserIdProvider（我见过客户端和服务器都认为它们已重新连接但实际上没有推送的情况）。因此，我推荐类似https://github.com/DamianEdwards/NDCLondon2013/tree/master/UserPresence的内容，为您提供更可靠（或至少更可调试）的用户状态管理。