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

Question

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

这是我的担忧:

• 除了 Command and Query Responsibility Segregation (CQRS) Pattern 之外，我找不到任何解决此问题的设计模式和 Event Sourcing Pattern .这两个似乎都专注于复杂的实时应用程序。我的应用程序有很多传统的 REST 功能，但目前唯一的实时组件是聊天，因此似乎没有必要使用这些模式之一。
• 是否有更简单的方法将基于 REST 的网站 (Web API) 与实时组件 (SignalR) 集成？
• 我现在所做的感觉就像是在混合两种完全不同的东西。

我想试试:

• 使用 events 将我的 POST 处理程序耦合到我的推送处理程序- 虽然我不确定这是否对我有帮助，因为我不希望我的应用程序的“发送消息”部分从“接收”部分演变为一部分。
• 将我所有的推送逻辑转移到一个由消息代理处理的作业中——这似乎也没有必要，但会产生更好的分离。我的理解是根据这个answer是 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/etc 中运行良好。 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 的东西为您提供更可靠(或至少更可调试)的用户状态管理。