ASP.NET Core 2 SignalR Hub 接收复杂对象而不是字符串答案

【问题标题】：ASP.NET Core 2 SignalR Hub to receive complex object instead of stringASP.NET Core 2 SignalR Hub 接收复杂对象而不是字符串
【发布时间】：2024-01-12 02:06:01
【问题描述】：

我目前正在使用 SignalR Core 开发 ASP.NET Core 2 应用程序。我想知道是否可以在 Hub 类中接收一个复杂的对象，而不是一个简单的字符串或简单的数据结构。

工作 - 这个例子工作正常：string message

public class MyHub : Hub
{
    public Task SendMessage(string message)
    {
        // ... some logic
    }
}

有效 - 此示例也可以正常工作：List<Dictionary<string, object>> message

public class MyHub : Hub
{
    public Task SendMessage(List<Dictionary<string, object>> message)
    {
        // ... some logic
    }
}

无法正常工作 - 我似乎无法通过 SignalR 传输复杂对象，例如如果我创建一个自定义消息类：

public class Message 
{
   public int MessageId { get; set; }

   public List<Dictionary<string, object>> Items { get; set; }

   public List<string> TextMessages { get; set; }
}

public class MyHub : Hub
{
    public Task SendMessage(Message message)
    {
        // ... some logic
    }
}

您知道如何通过 SignalR RPC 传输复杂对象吗？

谢谢！

【问题讨论】：

您能否为SendMessage 接受Message 参数的集线器添加客户端代码？只要您发送正确的 JSON，它就应该通过。
谢谢，我只在 .NET 中工作，但没有 JavaScript……也许我只是缺少 [Serializable] 属性……
与我们分享您的 signalR 客户端代码。

标签： c# asp.net-core signalr

【解决方案1】：

您可以使用 Newtonsoft.Json Nuget。

你有一个可以序列化你的对象的 JsonConverter。

所以在你的例子中：

    public class MyHub : Hub
    {
          public Task SendMessage(Message message)
          {
             var messageJsonString = JsonConvert.SerializeObject<Message>(message);
             // some logic
           }
    }

在您的客户端上，您可以将其转换回对象。它有一个原生 API，所以你只需调用

connection.on("ReceiveMessage",  (message) => { 
    let messageObject = JSON.parse(message);
    // Other code here
});

现在消息再次是您从服务器发送的对象。

当然，您可以使用JsonConvert.DeserializeObject<T>() 将您从客户端收到的json 字符串转换为对象。

【讨论】：

优秀的答案 - 经历 MS 如何决定处理序列化/反序列化操作的烦恼正在加剧。一个很好的简单 - 自己动手的解决方案有助于缓解头痛！

【解决方案2】：

按照以下步骤进行工作演示，该演示在 signalR 客户端和服务器之间传递 Message。

服务器

public class TimeHub: Hub
{
    public async Task UpdateTime(string message)
    {
        if (Clients != null)
        {
            await Clients?.All.SendAsync("ReceiveMessage", message);
        }
    }
    public Task SendMessage(Message message)
    {
        // ... some logic
        return Task.CompletedTask;
    }
}

客户

private static async void Connect()
{
    var hubConnectionBuilder = new HubConnectionBuilder();
    #region Worked
    var hubConnection = hubConnectionBuilder.WithUrl("https://localhost:44381/timeHub", options =>
    {

    }).Build();
    #endregion

    await hubConnection.StartAsync();
    await hubConnection.SendAsync("UpdateTime", $"From Client");
    var item1 = new Dictionary<string, object> {
        { "T1", new { Name = "TT1" } },
        { "T2", new { Name = "TT2" } },
        { "T3", new { Name = "TT3" } },
    };
    var item2 = new Dictionary<string, object> {
        { "T11", new { Name = "TT11" } },
        { "T12", new { Name = "TT12" } },
        { "T13", new { Name = "TT13" } },
    };

    await hubConnection.SendAsync("SendMessage", new Message {
        MessageId = 1,
        Items = new List<Dictionary<string, object>> {
            item1,
            item2
        },
        TextMessages = new List<string> {
            "H1",
            "H2"
        }
    });
    var on = hubConnection.On("ReceiveMessage", OnReceivedAction);
    Console.WriteLine($"Client is Start");
    Console.ReadLine();
    on.Dispose();
    await hubConnection.StopAsync();
}

【讨论】：

【解决方案3】：

如果您考虑使用 JSON 解析只是为了将多个对象/参数传递到客户端，则有另一种选择。

服务器端 (C#)。您可以将任意数量的参数传递给匿名对象数组。

SendCoreAsync("MethodName", new object[] {someObject, someNumber, someString });

客户端（打字稿）

private alertHandler = (someObject: any, someNumber: number, someString: string) => {
    console.log(someObject, someNumber, someString);
};

我有一个稍微详细一点的答案here

【讨论】：