Asp.Net Core 2.0使用SignalR技术-入门

曾经终败给现在 2022-01-22 01:17 250阅读 0赞

**一、定义Hub集线器**

在Asp.Net Core Web项目中已经内置了SignalR的类库可以直接使用。

public class CountService
    {
        private int _count = 0;
        public int getLastestCount()
        {
            return _count++;
        }
    }
    public class CountHub : Hub
    {
        private readonly CountService _countService;
        public CountHub(CountService countService)
        {
            _countService = countService;
        }
        public async Task GetLatestCount()
        {
            int count;
            do
            {
                count = _countService.getLastestCount();
                Thread.Sleep(1000);
                await Clients.All.SendAsync("ReceiveUpdate", count);
            } while (count < 10);
            await Clients.All.SendAsync("Finished");
        }
    }

**二、配置启用SignalR**

1.注册SignalR

public void ConfigureServices(IServiceCollection services)
    {
        services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
    
        //添加SignalR
        services.AddSingleton<CountService>();
        services.AddSignalR();
    }

2.使用配置SignalR的集线器

public void Configure(IApplicationBuilder app, IHostingEnvironment env)
    {
        if (env.IsDevelopment())
        {
            app.UseDeveloperExceptionPage();
        }
    
        app.UseStaticFiles();
        app.UseMvc();
    
        //配置SignalR
        app.UseSignalR(routes => routes.MapHub<CountHub>("/count"));
    }

3.定义操作控制器，响应处理

[Route("api/[controller]")]
        [ApiController]
        public class CountController : ControllerBase
        {
            //接受集线器，用于通知客户端
            private readonly IHubContext<CountHub> _countHub;
            public CountController(IHubContext<CountHub> countHub)
            {
                _countHub = countHub;
            }
            [HttpPost]
            public async Task<IActionResult> Post()
            {
                await _countHub.Clients.All.SendAsync("someFunc", new { random = "abcd" });
                return Accepted(1);
            }
        }

**三、添加客户端使用库**

1.在vs中右键添加signarl客户端库，输入@aspnet/signalr@1

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTExMjcwMTk_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTExMjcwMTk_size_16_color_FFFFFF_t_70 1][]

2.引用类库文件到html中，编写js链接代码，处理操作逻辑

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTExMjcwMTk_size_16_color_FFFFFF_t_70 2][]

3.执行操作定义代码：

官方入门教程：[https://docs.microsoft.com/en-us/aspnet/core/tutorials/signalr?view=aspnetcore-2.2&tabs=visual-studio][https_docs.microsoft.com_en-us_aspnet_core_tutorials_signalr_view_aspnetcore-2.2_tabs_visual-studio]

[ Asp.Net Core WebSocket绑定][Asp.Net Core WebSocket]

[SingalR自托管（self-host）实例2-实现Wpf客户端和Web客户端矩形同步][SingalR_self-host_2-_Wpf_Web]

[SingalR自托管（self-host）实例][SingalR_self-host]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTExMjcwMTk_size_16_color_FFFFFF_t_70]: /images/20220122/84656a08aff148bfac4ccc0c2f00be7c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTExMjcwMTk_size_16_color_FFFFFF_t_70 1]: /images/20220122/91bf6167416543efb0b61f2f21400a44.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTExMjcwMTk_size_16_color_FFFFFF_t_70 2]: /images/20220122/f0eb2e5007c44bac8eae471e041518a6.png
[https_docs.microsoft.com_en-us_aspnet_core_tutorials_signalr_view_aspnetcore-2.2_tabs_visual-studio]: https://docs.microsoft.com/en-us/aspnet/core/tutorials/signalr?view=aspnetcore-2.2&tabs=visual-studio
[Asp.Net Core WebSocket]: https://blog.csdn.net/u011127019/article/details/77408072
[SingalR_self-host_2-_Wpf_Web]: https://blog.csdn.net/u011127019/article/details/52692217
[SingalR_self-host]: https://blog.csdn.net/u011127019/article/details/52689814