关于.net core 中的signalR组件的使用

来源：cnblogs　　作者：村长lv　　时间：2019/10/8 9:35:20　　对本文有异议

SignalR是为了提供更方便的web交互响应式到推送式的解决方案。有了它之后可以实现客户端直接调用服务端的方法并且获得返回值 (客户端可以是各种平台，目前SignalR支持的语言版本有C#、java、javaScript、nodejs等)，服务端也是可以调用客户端的方法，通过这样的方式实现了由原来的单通变成双通的目的。

在SignalR中有个非常重要的概念就是Hub，这个Hub如果拿到以前的MVC架构中所对应的就是控制器，他们的区别就是我们需要自己去注册这个Hub的路由，而控制器是可以基于约定的。

首先创建一个Hub

 public class NewsPushHub:Hub
    {
 
    }

　　这是一个新闻推送的Hub，它必须要继承至Hub这个基类，Hub这个基类还可以接收一个泛型的实现,这个泛型可以用来规范客户端的方法

  public class NewsPushHub : Hub<IClientFuncs>
    {
        /// <summary>
        /// 可以被客户端调用的方法
        /// </summary>
        /// <param name="msg"></param>
        /// <returns></returns>
        public async Task DepartmentNotice(string msg)
        {
            //这里发送只能是接口中约束的方法
            await Clients.All.SendMsg( msg);
        }
    }
    /// <summary>
    /// 定义客户端所监听的方法名称
    /// </summary>
    public interface IClientFuncs
    {
        Task SendMsg(string msg);
    }

这里面写的两个方法是可以被客户端直接调用的，但是在被调用之前首先要注册，在Core3.0之前 我们是用app.UseSignalR(hub=>hub.MapHub<NewsPushHub>("/SignalRNews"))来注册SignalR的访问路由，现在改成全部统一在app.UseEndpoints()这个扩展方法中去注册，现在在Startup类的代码就像这样了

    public class Startup
    {
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddControllersWithViews();
            services.AddSignalR();
        }
        public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
        {
            if (env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }
 
            app.UseRouting();
            app.UseEndpoints(endpoints =>
            {
                endpoints.MapHub<NewsPushHub>("/SignalRNews");
                endpoints.MapControllerRoute("default", "{controller=Home}/{action=Index}/{id?}");
            }); 
          
        }

　　在这个里面我配置了包含MVC的中间件和依赖注入，在3.0中MVC的中间件和依赖注入都变了变得更加具体，路由设置也变得统一在UseEndpoints()这个方法里面，它里面的委托是一个IEndpointRouteBuilder的参数，我们通过这个参数可以映射各种路由配置，有非常多的map，在这里配置MVC的目的是为了和SignalR交互的。下面是客户端的js代码首先需要安装aspnet-signalr

//创建一个匹配 http:localhost:5000/SignalRNews路由的连接
const connection = new signalR.HubConnectionBuilder()
    .withUrl("/SignalRNews")
    .configureLogging(signalR.LogLevel.Information)
    .build();
// 开始连接，这个时候会发送一个101状态为pending的连接
connection.start().then(function () {
    console.log("connected");
});
// 监听服务端调用的客户端方法
connection.on("sendMsg", (msg) => {
    $(".dispaly-message").append(`<p>${msg}</p>`);
});
 
$("#submit").click(e => {
    const msg = $("#msg").val();
    // 调用服务端的DepartmentNotice方法
    connection.invoke("DepartmentNotice", msg).then(() => {
        console.log("消息发送完成");
    });
})

上面是最终的结果可以看出实现了不同客户端之间的消息互通

其实Signalr还可以有依赖注入的用法例如在控制器里面注入然后直接在MVC中随意推送消息

  public class HomeController:Controller
    {
        private readonly IHubContext<NewsPushHub> _hub;
 
        public HomeController(IHubContext<NewsPushHub> hub)
        {
            this._hub = hub;
        }
        public IActionResult Index()
        {
            _hub.Clients.All.SendAsync("Temp", "test");
            return View();
        }
       
       
    }