SignalR Self Host+MVC等多端消息推送服务（一）

一、概述

由于项目需要，最近公司项目里有个模块功能，需要使用到即时获得审批通知；原本的设计方案是使用ajax对服务器进行定时轮询查询，刚刚开始数据量和使用量不大的时候还好，后来使用量的增加和系统中各种业务的复杂度增加，服务器的压力也越来越大，于是我想使用消息推送的方式替换掉ajax轮询查询，当有审批提交时，调用推送方法，将消息推送到下一审批人那，这样就减低了服务器的压力。

signal 是微软支持的一个运行在.net平台上的 html websocket 框架。它出现的主要目的是实现服务器主动推送消息到客户端页面，这样客户端就不必重新发送请求或使用轮询技术来获取消息。而且signalr的兼容性也是很强大的，这里不在多言。既然选择了signalr，那么就开始干吧！

我的想法是将signalr做成一个自托管的服务，和我们的b/s项目分离出来，这样的好处是，1、推送服务不依赖于iis，就算iis挂了，我们的推送服务还可以正常运行；2、我们可以多平台调用这个推送服务，多个项目都可以同时使用；

二、创建服务端

废话不多说了，我也是第一次写博客，介绍完业务场景和构思，我们就开始撸码吧。

1、用vs创建一个名为 "signalrproject" 的解决方案;

2、在 signalrproject解决方案下新建一个名为server的控制台

3、在程序包管理器控制台,输入如下命令

install-package microsoft.aspnet.signalr.selfhost 

4、输入如下命令:

install-package microsoft.owin.cors

5、在server控制台中添加userinfo类，代码如下

using system; 
 
namespace server 
{ 
 public class userinfo 
 { 
  public string connectionid { get; set; } 
  public string username { get; set; } 
  public datetime lastlogintime { get; set; } 
 } 
}

6、在server控制台中添加chathub类，代码如下

using microsoft.aspnet.signalr;
using microsoft.aspnet.signalr.hubs;
using system;
using system.collections.generic;
using system.linq;
using system.threading.tasks;

namespace server
{
 [hubname("imhub")]
 public class chathub : hub
 {
  // 静态属性
  public static list<userinfo> onlineusers = new list<userinfo>(); // 在线用户列表

  /// <summary>
  /// 登录连线
  /// </summary>
  /// <param name="userid">用户id</param>
  /// <param name="username">用户名</param>
  public void register(string username)
  {
   var connnectid = context.connectionid;

   if (onlineusers.count(x => x.connectionid == connnectid) == 0)
   {
    if (onlineusers.any(x => x.username == username))
    {
     var items = onlineusers.where(x => x.username == username).tolist();
     foreach (var item in items)
     {
      clients.allexcept(connnectid).onuserdisconnected(item.connectionid, item.username);
     }
     onlineusers.removeall(x => x.username == username);
    }

    //添加在线人员
    onlineusers.add(new userinfo
    {
     connectionid = connnectid,
     username = username,
     lastlogintime = datetime.now
    });
   }

   // 所有客户端同步在线用户
   clients.all.onconnected(connnectid, username, onlineusers);
  }

  /// <summary>
  /// 发送私聊
  /// </summary>
  /// <param name="touserid">接收方用户连接id</param>
  /// <param name="message">内容</param>
  public void sendprivatemessage(string tousername, string message)
  {
   var fromconnectionid = context.connectionid;

   var touser = onlineusers.firstordefault(x => x.username == tousername);
   var fromuser = onlineusers.firstordefault(x => x.connectionid == fromconnectionid);

   if (touser != null )
   {
    clients.client(touser.connectionid).receiveprivatemessage(fromuser.username, message);
    clients.client(touser.connectionid).receiveprivatemessage(message);
   }
   else
   {
    //表示对方不在线
    clients.caller.absentsubscriber();
   }
  }

  public void send(string name, string message)
  {
   //clients.all { get; } // 代表所有客户端
   //clients.allexcept(params string[] excludeconnectionids); // 除了参数中的所有客户端
   //clients.client(string connectionid); // 特定的客户端，这个方法也就是我们实现端对端聊天的关键
   //clients.clients(ilist<string> connectionids); // 参数中的客户端
   //clients.group(string groupname, params string[] excludeconnectionids); // 指定客户端组，这个也是实现群聊的关键所在
   //clients.groups(ilist<string> groupnames, params string[] excludeconnectionids);参数中的客户端组
   //clients.user(string userid); // 特定的用户
   //clients.users(ilist<string> userids); // 参数中的用户

   console.writeline("connectionid:{0}, invokemethod:{1}", context.connectionid, "send");
   clients.all.addmessage(name, message);
  }

  /// <summary>
  /// 连线时调用
  /// </summary>
  /// <returns></returns>
  public override task onconnected()
  {
   console.writeline("客户端连接，连接id是:{0},当前在线人数为{1}", context.connectionid, onlineusers.count+1);
   return base.onconnected();
  }


  /// <summary>
  /// 断线时调用
  /// </summary>
  /// <param name="stopcalled"></param>
  /// <returns></returns>
  public override task ondisconnected(bool stopcalled)
  {
   var user = onlineusers.firstordefault(u => u.connectionid == context.connectionid);

   // 判断用户是否存在,存在则删除
   if (user == null)
   {
    return base.ondisconnected(stopcalled);
   }

   clients.all.onuserdisconnected(user.connectionid, user.username); //调用客户端用户离线通知
   // 删除用户
   onlineusers.remove(user);
   console.writeline("客户端断线，连接id是:{0},当前在线人数为{1}", context.connectionid, onlineusers.count);
   return base.ondisconnected(stopcalled);
  }

  public override task onreconnected()
  {
   return base.onreconnected();
  }
 }
}

7、在server控制台中添加startup类，代码如下

using microsoft.owin.cors;
using owin;

namespace server
{
 public class startup
 {
  public void configuration(iappbuilder app)
  {
   //允许cors跨域
   app.usecors(corsoptions.allowall);
   app.mapsignalr();
  }
 }
}

8、修改server控制台中添加program类，代码如下

using microsoft.owin.hosting;
using system;

namespace server
{
 class program
 {
  static void main(string[] args)
  {
   string url = "http://localhost:10086";//设定 signalr hub server 对外的接口
   using (webapp.start(url))//启动 signalr hub server
   {
    console.writeline("server running on {0}", url);
    console.readline();
   }
  }
 }
}

9、f5运行起来

然后浏览器中访问http://localhost:10086/signalr/hubs

结果如下：

见上图内容就基本完成了，今天先讲到着，时间不早了，先休息了，后续有时间再将后面的文章补上

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