欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

SignalR中丰富多彩的消息推送方式的实现代码

程序员文章站 2023-12-12 20:28:58
在上一篇 signalr 文章中,演示了如何通过 signalr 实现了简单的聊天室功能;本着简洁就是美的原则,这一篇我们也来聊聊在 signalr 中的用户和组的概念,理...

在上一篇 signalr 文章中,演示了如何通过 signalr 实现了简单的聊天室功能;本着简洁就是美的原则,这一篇我们也来聊聊在 signalr 中的用户和组的概念,理解这些基础知识有助于更好的开发基于 signalr 的应用,通过对用户和分组的理解,进一步扩展出对用户和分组的管理,以及消息推送的各种方式,为全面接入 signalr 做准备。

1. 用户

在 signalr 中,用户表示连接,一个用户代表一个连接,一个“系统用户”可以创建多个连接身份,通过函数集线器,可以给一个用户的所有连接发送消息;比如一个“系统用户”拥有多个连接,这些连接分别是 web连接、android手机客户端连接,ios手机客户端连接、或者其它客户端连接,“系统用户”分别登录了这些客户端,同时创建了多个连接;默认情况下这些连接都通过 claimtypes.nameidentifier 在 claimsprincipal 于用户标识进行关联。

** 注意:用户标识符是区分大小写的,为了实现一个客户多个连接,本例还简单实现了一个基于 claimsidentity 登录接口,算是意外惊喜。

1.1 用户连接管理

为了直观的观察到用户是可以拥有多连接的,需要建立一个本地静态对象,用于存储用户连接

public class wechathub : hub
 {
  public dictionary<string, list<string>> userlist { get; set; } = new dictionary<string, list<string>>();

  public void send(chatmessage body)
  {
   clients.all.sendasync("recv", body);
  }

  public override task onconnectedasync()
  {
   var username = this.context.user.identity.name;
   var connectionid = this.context.connectionid;
   if (!userlist.containskey(username))
   {
    userlist[username] = new list<string>();
    userlist[username].add(connectionid);
   }
   else if (!userlist[username].contains(connectionid))
   {
    userlist[username].add(connectionid);
   }
   console.writeline("哇,有人进来了:{0},{1},{2}", this.context.useridentifier, this.context.user.identity.name, this.context.connectionid);
   return base.onconnectedasync();
  }

  public override task ondisconnectedasync(exception exception)
  {
   var username = this.context.user.identity.name;
   var connectionid = this.context.connectionid;
   if (userlist.containskey(username))
   {
    if (userlist[username].contains(connectionid))
    {
     userlist[username].remove(connectionid);
    }
   }

   console.writeline("靠,有人跑路了:{0}", this.context.connectionid);
   return base.ondisconnectedasync(exception);
  }
 }

上面的代码包含了一个内部成员 userlist,用于存储用户的每个连接,在用户进行 signalr 连接时,将当前连接存储到 userlist 中,当连接断开的时候,将当前连接从 userlist 中删除。这样就实现了一个简单的用户连接管理。

在上面的代码中,当前用户昵称是根据 var username = this.context.user.identity.name; 这行代码获取的,为了取得这个用户昵称,我们实现了一个简单的 useridentity 登录,然后将 user 信息写入到 cookie 中,最后才可以通过 var username = this.context.user.identity.name; 获得当前登录用户昵称(熟悉 id 登录流程的同学应该不会感到陌生,实际上我也很少使用 id 验证)

1.2 给单个用户发送消息

  [authorize(roles = "user")]
  [httppost("sendtouser")]
  public async task<iactionresult> sendtouser([frombody] userinfoviewmodel model)
  {
   chatmessage message = new chatmessage()
   {
    type = 1,
    content = model.content,
    username = model.username
   };

   if (this.chathub.userlist.containskey(model.username))
   {
    var connections = this.chathub.userlist[model.username].first();
    await this.chathub.clients.client(connections).sendasync("recv", new object[] { message });
   }

   return json(new { code = 0 });
  }

在 usercontroller 中,定义了上面的接口 sendtouser ,客户端传入用户昵称和消息,然后服务端就会去根据 chathub.userlist 成员查找目标用户的连接信息,最后,通过 sendasync 将消息推送到目标客户端连接中。

2. 分组

分组的概念类似于聊天室,每个房间就是一个独立的分组,用户可以选择加入 a 房间,也可以选择加入 b 房间,如果业务允许,一个用户还可以加入多个分组(房间),通过使用分组对用户进行管理,可以实现一个或者多个聊天房间,用户可以加入分组,也可以将用户从分组中删除(类似离开房间),这里的用户并发真正意义上的“系统用户”,而是指系统用户创建的那些 signalr连接。

** 注意:当连接断开后重新发起连接的时候,signalr 不会保留组成员身份,必须重新加入分组。

下面的代码演示了如何对分组进行操作,要对分组进行操作,主要包含三个方面:

2.1 加入分组

 public async task addtogroupasync(string groupname)
  {
   await groups.addtogroupasync(this.context.connectionid, groupname);
  }

2.2 离开分组

 public async task removefromgroupasync(string groupname)
  {
   await groups.removefromgroupasync(this.context.connectionid, groupname);
  }

2.3 发送消息到指定分组

 public async task sendtogroupasync(string groupname, chatmessage message)
  {
   await clients.group(groupname).sendasync(groupname, new object[] { message });
  }

对分组的操作非常的简单,几乎都是一行代码的事情,不得不说,微软的封装实在是太好了。

3. signalr的推送消息的其它方式

通过上面对用户和分组的学习,再去扩展学习其它推送消息的方式,就非常的好理解和上手,在 signalr 内部还有多种推送消息的方式,他们分别是

3.1 all(全站推送)

3.2 others(全站推送排除自己)

3.3 othersingroup(指定分组推送,排除自己)

3.4 allexcept(除指定列表外的所有人)

3.5 演示代码

 list<string> blacklist = new list<string>();
  public async task othersendasync(chatmessage body)
  {
   // 给当前连接到 hub 上的所有连接发送消息,相当于广播
   await clients.all.sendasync("recv", body);

   // 给当前连接对象发送消息
   await clients.caller.sendasync("recv", body);

   // 给其它所有连接的客户端发送消息,除了当前正在连接的客户端
   await clients.others.sendasync("recv", body);

   // 查找当前所有连接的客户端(排除自己),如果是已加入此分组,则给他们推送消息
   await clients.othersingroup("groupname").sendasync("recv", body);

   // 给除了 blacklist(黑名单)之外的所有人发送消息
   await clients.allexcept(blacklist).sendasync("recv", body);
  }

4. 一个简单的示例

本示例代码包含两个简单的界面

4.1 登录

SignalR中丰富多彩的消息推送方式的实现代码

4.2 各种方式发送消息

SignalR中丰富多彩的消息推送方式的实现代码

结束语

最近在做一个开源项目,还处于试用阶段,准备写个使用的 wiki 出来,看看大家是否感兴趣,此 singalr 系列只能不定期更新了,抱歉。

演示代码下载

已托管到 github 仓库

https://github.com/lianggx/examples/tree/master/signalr/ron.signalrlesson2

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

上一篇:

下一篇: