【SignalR全套系列】之在.Net Core 中实现SignalR实时通信

​

编辑

1// 注入SignalR所需服务 2builder.Services.AddSignalR(); 

1// 开启静态文件  将客户端代码写入wwwroot中  防止跨域 2app.UseStaticFiles(); 

1// 开启路由节点 用来映射Signalr请求路径   2// /custom 为自定义路径   3// CustomHub 为Hub 类型 4app.MapHub<CustomHub>("/custom"); 5// 同时支持分组请求，下篇讲解，，，， 

1// CustomHub:Hub 继承 Hub 2public class CustomHub:Hub<ClientData>{} 

 1        /// <summary>  2        /// 重写链接钩子  3        /// </summary>  4        /// <returns></returns>  5        public override Task OnConnectedAsync()  6        {  7            return base.OnConnectedAsync();  8        }  9 10        public override Task OnDisconnectedAsync(Exception? exception) 11        { 12            return base.OnDisconnectedAsync(exception); 13        } 

1// 引入日志 方便控制台输出 2private readonly ILogger<CustomHub> _logger; 3 4public CustomHub(ILogger<CustomHub> logger) 5{ 6   this._logger = logger; 7} 

 1        /// <summary>  2        /// 建立通信  3        /// </summary>  4        /// <param name="data"></param>  5        public void BeginSendData(TransData data)  6        {  7            _logger.LogInformation("接受数据{0},{1}",data.id,data.message);  8        }  9 10        /// <summary> 11        /// 单一客户端调用 通信 12        /// 仅仅通知 调用的那个客户端 其余建立链接的客户端不生成通信 13        /// </summary> 14        /// <returns></returns> 15        public Task SingleClientCaller() 16        { 17            _logger.LogInformation("单独客户端调用"); 18            return Clients.Caller.ClientHook(new (111,"111 客户端调用")); 19        } 20 21        /// <summary> 22        /// 所有客户端建立通信 23        /// 可通知所有的客户端 24        /// </summary> 25        /// <returns></returns> 26        public Task AllClientResponse() 27        { 28            _logger.LogInformation("通知所有的客户端"); 29 30            return Clients.All.ClientHook(new(Guid.NewGuid(),"通知所有的客户端")); 31        } 32 33        /// <summary> 34        /// 指定调用   35        /// </summary> 36        /// <returns></returns> 37        [HubMethodName("invoke")] 38        public TransData IvoData() 39        { 40            return new TransData(666,"返回invoke data"); 41        } 

​

编辑

1// 初始化 路由：/custom 被路由节点捕获 2let connection = new signalR.HubConnectionBuilder() 3        .withUrl("/custom") 4        .build(); 

1// 开始连接 调用后台 BeginSendData 方法 成功后双方交互数据 2        connection.start().then(() => { 3        console.log("开始链接") 4        let id = parseInt(Math.random()*100); 5        connection.send('BeginSendData', {id: id, message: "链接成功了"}) 6    }); 

 1    // 调用 SingleClientCaller 这个方法  2    const selfCall = () => connection.send('SingleClientCaller')  3  4    // 调用AllClientResponse这个方法  5    const all = () => connection.send('AllClientResponse')  6  7    // 触发后台控制器  8    const triggerFetch = () => fetch('/SendData')  9 10    // call signalR hub function from client 11    const withReturn = () => connection.invoke('invoke') 12        .then(data => console.log('ivo data', data)) 

1 // 后台默认触发 2    connection.on("ClientHook", data => console.log('客户端触发成功', data)); 3 4    // 后台指定方法触发之后 5    connection.on("client_recive", data => console.log('后台触发成功', data)); 

​