1.介绍

　　我们知道传统的http采用的是“拉模型”，也就是每次请求，每次断开这种短请求模式，这种场景下，client是老大，server就像一个小乌龟任人摆布，

很显然，只有一方主动，这事情就没那么完美了，所以为了能够让server也能主动点,html5就应运而生了，或许大家都知道html5中有两种server的主动

模型，第一种叫做websockect，也就是基于tcp模式的双工通讯，还有一种叫做SSE，也就是客户端来订阅服务器的一种事件模型，当然了，在html5出

来之前，如果要做到服务器主动，我们只能采用变相的longpool和foreverframe勉强实现，而signalR这吊毛就是一个对他们进行了高层封装，也就是说

signalR会在这四种技术中根据浏览器和服务器设置采取最优的一种模式，废话不多说，我们快速建立一个例子。

2.快速搭建

1.引入dll

2.创建hub类（消息处理）

using Microsoft.AspNet.SignalR;using Microsoft.AspNet.SignalR.Hubs;using ServiceStack.Redis;using System;using System.Collections.Generic;using System.Diagnostics;using System.Linq;using System.Threading.Tasks;using System.Web;namespace SignalRMvcDemo{    [HubName("MessageHub")]    public class MessageHub : Hub    {        //当前用户        public static List
      
        OnlineUsers = new List
       
        (); // 在线用户列表        RedisClient client = new RedisClient("192.168.10.134", 6379, "111111", 3);        /// 
                /// 登录连线        /// 
        /// 
        用户Id        /// 
        用户名        public void Register(string userName)        {            OnlineUsers = client.Get
        
         
          >("list") ?? new List
          
           ();            var connnectId = Context.ConnectionId;            if (!OnlineUsers.Any(x => x.ConnectionId == connnectId))            {                //添加在线人员                OnlineUsers.Add(new UserInfo                {                    ConnectionId = connnectId,                    UserName = userName,                    LastLoginTime = DateTime.Now                });            }            // 所有客户端同步在线用户            Clients.All.onConnected(connnectId, userName, OnlineUsers);            client.Set
           
            
             >("list", OnlineUsers); } /// 
              /// 发送私聊 /// 
 /// 
             接收方用户ID /// 
             内容 public void SendPrivateMessage(string toConnectionId, string message) { OnlineUsers = client.Get
             
              
               >("list") ?? new List
               
                (); var fromConnectionId = Context.ConnectionId; var toUser = OnlineUsers.FirstOrDefault(x => x.ConnectionId == toConnectionId); var fromUser = OnlineUsers.FirstOrDefault(x => x.ConnectionId == fromConnectionId); if (toUser != null) { Clients.Client(toUser.ConnectionId).receivePrivateMessage(fromUser.ConnectionId, fromUser.UserName, message); } else { //表示对方不在线 Clients.Caller.absentSubscriber(); } } /// 
                 /// 全部发送 /// 
 /// 
                 public void AllSend(string name, string message) { Clients.All.AllSend(name, message); } /// 
                 /// 连线时调用 /// 
 /// 
                 public override Task OnConnected() { //Console.WriteLine("客户端连接，连接ID是:{0},当前在线人数为{1}", Context.ConnectionId, OnlineUsers.Count + 1); return base.OnConnected(); } /// 
                 /// 断线时调用 /// 
 /// 
                 /// 
                 public override Task OnDisconnected(bool stopCalled) { OnlineUsers = client.Get
                
                 
                  >("list")??new List
                  
                   (); var user = OnlineUsers.FirstOrDefault(u => u.ConnectionId == Context.ConnectionId); // 判断用户是否存在,存在则删除 if (user == null) { return base.OnDisconnected(stopCalled); } // 删除用户 OnlineUsers.Remove(user); Clients.All.onUserDisconnected(OnlineUsers); //调用客户端用户离线通知 client.Set
                   
                    
                     >("list", OnlineUsers); return base.OnDisconnected(stopCalled); } /// 
                      /// 重新连接时调用 /// 
 /// 
                      public override Task OnReconnected() { return base.OnReconnected(); } } public class UserInfo { public string ConnectionId { get; set; } public string UserName { get; set; } public DateTime LastLoginTime { get; set; } }}

View Code

3.Startup类（1.配置跨域 2.配置多实例）

using System;using System.Threading.Tasks;using Microsoft.Owin;using Owin;using Microsoft.AspNet.SignalR;using Microsoft.Owin.Cors;[assembly: OwinStartup(typeof(SignalRMvcDemo.StartupSignalR))]namespace SignalRMvcDemo{    public class StartupSignalR    {        public void Configuration(IAppBuilder app)        {            //允许CORS跨域            app.UseCors(CorsOptions.AllowAll);            #region Redis配置            //添加redis            RedisScaleoutConfiguration redisScaleoutConfiguration = new RedisScaleoutConfiguration("192.168.10.134", 6379, "111111", "redis_signalr");            //连接DB，默认为0            redisScaleoutConfiguration.Database = 3;            //SignalR用Redis            GlobalHost.DependencyResolver.UseRedis(redisScaleoutConfiguration);            #endregion            // 有关如何配置应用程序的详细信息，请访问 http://go.microsoft.com/fwlink/?LinkID=316888            app.MapSignalR();//启动SignalR        }    }}

View Code

4.前端调用（引用hub生产的js文件，前端方法名称要与后端一致）

    
              
          
          
          
              
                   
        分布式-消息推送测试
        
       
    
      
    ConnectionId：        当前用户名称：        
      
    在线用户数量：        
      
    
      
                                                            ConnectionId                          UserName                     
               
               
          
    接收用户:

View Code

5.效果（支持跨域，需要有redis）

3.项目下载路径 https://github.com/lgxlsm/SignalRMvcDemo

转载于:https://www.cnblogs.com/lgxlsm/p/7490139.html

你可能感兴趣的文章