asp.net core 2.0 webapi集成signalr(实例讲解)

更新时间：2017年11月26日 09:05:08 作者：Mr.落叶

下面小编就为大家分享一篇asp.net core 2.0 webapi集成signalr的实例讲解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

在博客园也很多年了，一直未曾分享过什么东西，也没有写过博客，但自己也是汲取着博客园的知识成长的；

这两天想着不能这么无私，最近.NET CORE貌似挺流行的，闲来无事也自己搞了个asp.net core signalr

博客园里面也有人在.net core 2.0下面集成了signalr，但是是集成在同一个项目里面的，但是大家都知道我们很多的项目都是分离的；

而且signalr涉及到连接数和内存资源的占用问题，如果都集成在一个项目里面当访问量多大的时候容易造成网站访问缓慢，具体原因就不多说了

所以我这里做了一个在.net core webapi里面集成signalr，我们就可以通过调用webapi来实现服务器向客户端推送消息

第一步引用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>
  /// 创建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", "用户组数据更新完成,新增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:我这里是根据本人业务需要来做的，大家可以修改成其他的(用户量大的时候内存占用肯定高，这里只做一个简单的例子)

以上基本的环境搭建就已经完成了

接下来控制器里面的代码

[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>
  /// 多参数接收方式
  /// </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();
  }
 }

服务器端的代码到这里全部完成，接下来咱们看客户端的代码

我的客户端代码是在另外一个项目里面，和服务器端是分离的

<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;\">多参数接收：" + message + " : " + data + "</li>");
   });
   hubConnection.start();

  });
 </script>
}

页面上引用连个js

到这里基本就已经完成了，下面看一下运行效果

第一次写博客，有点紧张，代码写得比较仓促，很多细节都没有优化，有很多不足之处，望各位多多指正

以上这篇asp.net core 2.0 webapi集成signalr(实例讲解)就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

ASP.NET MVC视图寻址
这篇文章介绍了ASP.NET MVC视图寻址的方法，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-03-03
VB.NET验证邮件地址的合法性实现代码
现在，对于用户在Web页面上或电话中给出的Email地址，我们越来越不敢肯定它是否真的有效。在今天这个垃圾邮件泛滥成灾的年代，人们完全有理由舍不得轻易透露Email地址。
2011-04-04
ASP.NET对路径"xxxxx"的访问被拒绝的解决方法小结
异常详细信息: System.UnauthorizedAccessException: 对路径“D:/temp1/MyTest.txt”的访问被拒绝
2012-09-09
在Apache环境下成功的运行ASP.NET的注意事项
在Apache环境下成功的运行ASP.NET的注意事项...
2007-08-08
ASP.NET实现Hadoop增删改查的示例代码
本篇文章主要介绍了ASP.NET实现Hadoop增删改查的示例代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-10-10
详解ASP.NET MVC下的异步Action的定义和执行原理
这篇文章主要介绍了详解ASP.NET MVC下的异步Action的定义和执行原理，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2016-12-12
.NET中的HashSet及原理解析
HashSet定义在System.Collections.Generic中，是一个不重复、无序的泛型集合，本文学习下HashSet的工作原理，对.NET中的HashSet相关知识感兴趣的朋友一起看看吧
2022-03-03
Discuz!nt 源文件变成乱码的解决方法
其实原因就是因为没有默认编码类型。按照下面的方法加载即可。
2009-06-06
Asp.net 5种页面转向方法
页面转向也是有技巧的，下面的是asp.net下的几种转向方法。
2009-02-02
ASP.NET编程简单实现生成静态页面的方法【附demo源码下载】
这篇文章主要介绍了ASP.NET编程简单实现生成静态页面的方法,较为详细的分析了asp.net生成静态页面的步骤与相关操作技巧,并附带相关实例源码供读者下载参考,需要的朋友可以参考下
2017-07-07

asp.net core 2.0 webapi集成signalr(实例讲解)

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具