SignalR实时通信，多客户端与服务端交互

1.SignalR介绍

SignalR是一个开源的库，跨平台；让Web应用与其他应用通讯变得很简单，Web服务端可以实时的将内容推送给对应的客户端，客户端发送的信息也可以实时到其他客户端。
SignalR提供了一种远程过程调用(RPC)的方式，使得客户端可以调用服务器的方法，同样在服务器端的方法中也能调用客户端的方法。
1.1 SignalR的通信方式

SignalR支持如下的方式实现实时通信：

• WebSockets：是一种在单个TCP连接上进行全双工通信的协议，使得服务器和浏览器的通信更加简单，服务端可以主动发送信息。
  
• Server-Sent Events：SSE 与 WebSocket 作用相似，都是建立浏览器与服务器之间的通信渠道，然后服务器向浏览器推送信息。WebSocket是双向的，而SSE是单向的。
  
• **Long Polling(长轮询) **：和传统的轮询原理一样，只是服务端不会每次都返回响应信息，只有有数据或超时了才会返回，从而减少了请求次数。
  

SignalR会自动选择服务器和客户端能力范围内的最佳通信方式(是不是很优秀) ，当然也可以手动指定。
1.2 SignalR的应用场景

其实对于Web模式下的实时通信，SignalR用上试试，感觉还是很给力的。

• 服务端主动推送信息；比如发送公告场景；
  
• 监控或看板数据实时显示；比如监控系统实时展示分布到各个客户端上的数据；
  
• 服务端和客户端交互；比如客服系统的聊天场景。
  

2.案例展示

2.1 SignalR服务端展示

• 创建一个net8的webapi项目，引入nuget包：Microsoft.AspNetCore.SignalR
  
• 编写自己的SignalR Hub
  

hub类

1.         public class ChatHub : Hub
2.         {
3.                 private static readonly ConcurrentDictionary<string, User> ChatClientDict = new(); //用户字典
4.                 /// <summary>
5.                 /// 给所有人发消息
6.                 /// </summary>
7.                 /// <param name="userId"></param>
8.                 /// <param name="msg"></param>
9.                 /// <returns></returns>
10.                 public async Task SendMsg(long userId, string msg)
11.                 {
12.                         string sendMsg = $"用户名{Context.ConnectionId}：{msg}";
14.                         //服务端推送给 除自已以外 的所有客户端
15.                         //await Clients.Others.SendAsync("ReceiveMsg", sendMsg);
17.                         //服务端推送给所有客户端
18.                         await Clients.All.SendAsync("ReceiveMsg", sendMsg);
20.                 }
22.                 /// <summary>
23.                 /// 给指定人员发消息
24.                 /// </summary>
25.                 /// <param name="userId"></param>
26.                 /// <param name="message"></param>
27.                 /// <returns></returns>
28.                 /// <exception cref="ArgumentException"></exception>
29.                 public async Task SendMessageToUser(string userId, string message)
30.                 {
31.                         // 确保用户ID是有效的
32.                         if (string.IsNullOrEmpty(userId))
33.                         {
34.                                 throw new ArgumentException("Invalid user ID", nameof(userId));
35.                         }
36.                         await Clients.Client(userId).SendAsync("ReceiveToUserMsg", message);
37.                 }
39.                 //客户端成功连接时，会触发此方法
40.                 public override Task OnConnectedAsync()
41.                 {
42.                         var cid = Context.ConnectionId;
43.                         //根据id获取指定客户端
44.                         var client = Clients.Client(cid);
45.                         return Task.CompletedTask;
46.                 }
48.                 //客户端断开连接时，会触发此方法
49.                 public override Task OnDisconnectedAsync(Exception? exception)
50.                 {
51.                         return Task.CompletedTask;
52.                 }
54.                 //客户端调用服务端更新数据时，会触发此方法
55.                 public async Task UpdateMessage(MsgInfo ReceiveMessage)
56.                 {
57.                         await Clients.All.SendAsync("UpdateData", ReceiveMessage);
58.                 }
61.         }

复制代码

• 业务API编写，推送消息
  1.   IHubContext<ChatHub> _hubContext 定义一个hub上下文，通过这个可以获取所有客户端，并进行方法调用PushMessage，推送消息

  复制代码

注册相关服务及管道

2.2 winform客户端

客户端的核心代码：
客户端调用服务端的chathub类中的UpdateMessage方法，将客户端数据更新到服务端

服务端与客户端的交互逻辑

数据展示

案例源码地址：https://gitee.com/chenshibao/csb.-signal-r

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！