asp.net core 2.0 webapi集成signalr(實例講解)

來源：懂視網(wǎng) 責(zé)編：小采時間：2020-11-27 22:35:12

asp.net core 2.0 webapi集成signalr(實例講解)

asp.net core 2.0 webapi集成signalr(實例講解):在博客園也很多年了，一直未曾分享過什么東西，也沒有寫過博客，但自己也是汲取著博客園的知識成長的；這兩天想著不能這么無私，最近.NET CORE貌似挺流行的，閑來無事也自己搞了個asp.net core signalr 博客園里面也有人在.net core 2.0下面集成

推薦度：

點擊下載本文 文檔為doc格式

導(dǎo)讀asp.net core 2.0 webapi集成signalr(實例講解):在博客園也很多年了，一直未曾分享過什么東西，也沒有寫過博客，但自己也是汲取著博客園的知識成長的；這兩天想著不能這么無私，最近.NET CORE貌似挺流行的，閑來無事也自己搞了個asp.net core signalr 博客園里面也有人在.net core 2.0下面集成

在博客園也很多年了，一直未曾分享過什么東西，也沒有寫過博客，但自己也是汲取著博客園的知識成長的；

這兩天想著不能這么無私，最近.NET CORE貌似挺流行的，閑來無事也自己搞了個asp.net core signalr

博客園里面也有人在.net core 2.0下面集成了signalr，但是是集成在同一個項目里面的，但是大家都知道我們很多的項目都是分離的；

而且signalr涉及到連接數(shù)和內(nèi)存資源的占用問題，如果都集成在一個項目里面當(dāng)訪問量多大的時候容易造成網(wǎng)站訪問緩慢，具體原因就不多說了

所以我這里做了一個在.net core webapi里面集成signalr，我們就可以通過調(diào)用webapi來實現(xiàn)服務(wù)器向客戶端推送消息

第一步引用nuget：Mrcrosoft.AspNetCore.SignalR

第二步添加配置代碼：

首先ConfigureServices里面添加如下代碼：

public void ConfigureServices(IServiceCollection services)
 {
 services.AddSignalR();
 services.AddCors(options =>
 {
 options.AddPolicy("SignalrCore",
 policy => policy.AllowAnyOrigin()
 .AllowAnyHeader()
 .AllowAnyMethod());
 });
 services.AddSingleton<IServiceProvider, ServiceProvider>();
 }

然后Configure里面添加

public void Configure(IApplicationBuilder app, IHostingEnvironment env)
 {
 if (env.IsDevelopment())
 {
 app.UseDeveloperExceptionPage();
 }
 //跨域支持
 app.UseCors("SignalrCore");
 app.UseSignalR(routes =>
 {
 routes.MapHub<SignalrHubs>("signalrHubs");
 });
 app.UseWebSockets();

 app.UseMvc();
 }

然后我們添加一個hubs

public class SignalrHubs:Hub
 {
 /// <summary>
 /// 創(chuàng)建signalr鏈接
 /// </summary>
 /// <param name="parentId">pid(作為用戶組)</param>
 /// <param name="shopId">sid</param>
 public Task InitUser(string parentId, string shopId)
 {
 Groups.AddAsync(Context.ConnectionId, parentId);
 SignalrGroups.UserGroups.Add(new SignalrGroups()
 {
 ConnectionId = Context.ConnectionId,
 GroupName = parentId,
 ShopId = shopId
 });
 return Clients.All.InvokeAsync("NoticeOnline", "用戶組數(shù)據(jù)更新完成,新增id為：" + Context.ConnectionId + " pid:" + parentId + " sid:" + shopId + "");
 }

 public override Task OnDisconnectedAsync(Exception exception)
 {
 //掉線移除用戶
 var user = SignalrGroups.UserGroups.FirstOrDefault(c => c.ConnectionId == Context.ConnectionId);
 if (user != null)
 {
 SignalrGroups.UserGroups.Remove(user);
 Groups.RemoveAsync(Context.ConnectionId, user.GroupName);
 }
 return base.OnDisconnectedAsync(exception);
 }
 }

PS:我這里是根據(jù)本人業(yè)務(wù)需要來做的，大家可以修改成其他的(用戶量大的時候內(nèi)存占用肯定高，這里只做一個簡單的例子)

以上基本的環(huán)境搭建就已經(jīng)完成了

接下來控制器里面的代碼

[Produces("application/json")]
 [Route("api/MRSoftPush")]
 public class MRSoftPushController : Controller
 {
 private IHubContext<SignalrHubs> hubContext;
 public MRSoftPushController(IServiceProvider service)
 {
 hubContext = service.GetService<IHubContext<SignalrHubs>>();
 }

 [HttpGet]
 public string Get()
 {
 return DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:ffff");
 }

 /// <summary>
 /// 單個connectionid推送
 /// </summary>
 /// <param name="groups"></param>
 /// <returns></returns>
 [HttpPost,Route("AnyOne")]
 public IActionResult AnyOne([FromBody]IEnumerable<SignalrGroups> groups)
 {
 if (groups != null && groups.Any())
 {
 var ids = groups.Select(c=>c.ShopId);
 var list = SignalrGroups.UserGroups.Where(c=>ids.Contains(c.ShopId));
 foreach (var item in list)
 hubContext.Clients.Client(item.ConnectionId).InvokeAsync("AnyOne", $"{item.ConnectionId}: {item.Content}");
 }
 return Ok();
 }

 /// <summary>
 /// 全部推送
 /// </summary>
 /// <param name="message"></param>
 /// <returns></returns>
 [HttpGet,Route("EveryOne")]
 public IActionResult EveryOne(string message)
 {
 hubContext.Clients.All.InvokeAsync("EveryOne", $"{message}");
 return Ok();
 }

 /// <summary>
 /// 組推送
 /// </summary>
 /// <param name="group"></param>
 /// <returns></returns>
 [HttpPost,Route("AnyGroups")]
 public IActionResult AnyGroups([FromBody]SignalrGroups group)
 {
 if (group != null)
 {
 hubContext.Clients.Group(group.GroupName).InvokeAsync("AnyGroups", $"{group.Content}");
 }
 return Ok();
 }

 /// <summary>
 /// 多參數(shù)接收方式
 /// </summary>
 /// <param name="message"></param>
 /// <returns></returns>
 [HttpGet,Route("MoreParamsRequest")]
 public IActionResult MoreParamsRequest(string message)
 {
 hubContext.Clients.All.InvokeAsync("MoreParamsRequest", message, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:ffff"));
 return Ok();
 }
 }

服務(wù)器端的代碼到這里全部完成，接下來咱們看客戶端的代碼

我的客戶端代碼是在另外一個項目里面，和服務(wù)器端是分離的

<input type="text" id="ParentId" placeholder="ParentId" />
<br />
<input type="text" id="ShopId" placeholder="ShopId" />
<br />
<button id="fuckyou">用戶上線</button>
<br />
<br />
<br />

<ul id="message" ></ul>

@section scripts {
 <script>
 $(function () {

 let hubUrl = 'http://192.168.0.149:8009/signalrHubs';
 let httpConnection = new signalR.HttpConnection(hubUrl);
 let hubConnection = new signalR.HubConnection(httpConnection);
 $("#fuckyou").click(function () {
 hubConnection.invoke('InitUser', $("#ParentId").val(), $("#ShopId").val());
 });
 hubConnection.on('NoticeOnline', data => {
 $("#message").append("<li>" + data + "</li>");
 });
 hubConnection.on('EveryOne', data => {
 $("#message").append("<li style=\"color:red;\">全部推送：" + data + "</li>");
 });
 hubConnection.on('AnyGroups', data => {
 $("#message").append("<li style=\"color:black;\">單個用戶組推送：" + data + "</li>");
 });
 hubConnection.on('AnyOne', data => {
 $("#message").append("<li style=\"color:blue;\">單個ID推送：" + data + "</li>");
 });
 hubConnection.on('MoreParamsRequest', (message, date) => {
 $("#message").append("<li style=\"color:green;\">多參數(shù)接收：" + message + " : " + data + "</li>");
 });
 hubConnection.start();

 });
 </script>
}

頁面上引用連個js

到這里基本就已經(jīng)完成了，下面看一下運(yùn)行效果