.net mvc中SignalR的使用配置

安裝Microsoft.AspNet.SignalR（使用的版本2.4.1）

新建Hubs文件夾:Hub的接口和實現

namespace SingralRedis.Hubs
{
    interface IChatHub
    {
        //服務器下發消息到各個客戶端
        void SendChat(string id, string name, string message);

        //用戶上線通知
        void SendLogin(string id, string name);

        //用戶下線通知
        void SendLogoff(string id, string name);

        //接收客戶端發送的心跳包並處理
        void TriggerHeartbeat(string id, string name);
    }
}

IChatHub

 

提供五個事件：OnConnected, OnReconnected, OnReceived, OnError 和 OnDisconnect.

這裏只 override OnConnected,看須要重載

using Microsoft.AspNet.SignalR;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Timers;


namespace SingralRedis.Hubs
{
    public class ChatHub : Hub,IChatHub
    {

        public override System.Threading.Tasks.Task OnConnected()
        {

            string userName = Context.QueryString["userName"]; //獲取客戶端發送過來的用戶名
            string userId = Context.QueryString["userId"]; //獲取客戶端發送過來的用戶名
            string connectionId = Context.ConnectionId;
            if (!string.IsNullOrEmpty(userId))
            {
                SendLogin(userId, userName, connectionId);
            }
            //HttpContext.Current.Application.Add(userName, connectionId); //存儲關係
            return base.OnConnected();
        }
        public class UserChat
        {
            public UserChat()
            {
                Count = 0;
                if (Timer == null) Timer = new Timer();
                Timer.Interval = 1000;  //1s觸發一次
                Timer.Start();
                Timer.Elapsed += (sender, args) =>
                {
                    Count++;
                    if (Count >= 20)
                    {
                        action();  //該用戶掉線了，拋出事件通知
                        Timer.Stop();
                    }
                };
            }

            private readonly Timer Timer;
            public event Action action;
            //public event Action action1;

            public string UserId { get; set; }
            public string ID { get; set; }
            public string Name { get; set; }

            //內部計數器（每次遞增1），若是服務端每5s能收到客戶端的心跳包，那麼count被重置爲0；
            //若是服務端20s後仍未收到客戶端心跳包，那麼視爲掉線
            public int Count { get; set; }
        }

        public static class ChatUserCache
        {
            public static IList<UserChat> userList = new List<UserChat>();
        }

        private IList<UserChat> userList = ChatUserCache.userList;       
       
        /// <summary>
        /// 推送個單個用戶
        /// </summary>
        /// <param name="name">用戶名</param>
        public void SendToUser(string name)
        {
            //根據username獲取對應的ConnectionId
            var user = userList.FirstOrDefault(v => v.Name == name);
            if (user != null)
            {
                Clients.Client(user.UserId).addNewMessageToPage("新的信息");
            }
        }

        /// <summary>
        /// 自發自收
        /// </summary>
        public void ReturnId()
        {
            Clients.Caller.CheckId(Context.ConnectionId);
        }    

        /// <summary>
        /// 獲取所有用戶
        /// </summary>
        public void GetAllUserList()
        {
            Clients.All.loginUser(userList);
        }



        public void SendChat(string id, string name, string message)
        {
            Clients.Client(id).GetChatMsg("<====用戶 " + name +" 發送消息 "+ message+" ======>");
            
        }

        public void SendLogin(string id, string name, string connectionId)
        {
            connectionId = string.IsNullOrEmpty(connectionId) ? connectionId = Context.ConnectionId : connectionId;

            if (!userList.Any(v => v.ID == id))
            {
                var userInfo = new UserChat() { UserId = connectionId, ID = id, Name = name };
                userInfo.action += () =>
                {
                    //用戶20s無意跳包應答，則視爲掉線，會拋出事件，這裏會接住，而後處理用戶掉線動做。
                    SendLogoff(id, name);
                };
                userList.Add(userInfo);
            }
            else
            {
                var user = userList.FirstOrDefault(v => v.ID == id);
                user.UserId = connectionId;
                user.Count = 0;
            }
            Clients.All.loginUser(userList);
            
        }

        public void SendLogoff(string id, string name)
        {
            var userInfo = userList.Where(x => x.ID.Equals(id) && x.Name.Equals(name)).FirstOrDefault();
            if (userInfo != null)
            {
                var name1 = userInfo.Name;

                if (userList.Remove(userInfo))
                {
                    Clients.All.logoffUser(userList);


                    SendChat(id, name, "<====用戶 " + name + " 退出了討論組====>");
                }
            }
        }

        public void TriggerHeartbeat(string id, string name)
        {
            var userInfo = userList.Where(x => x.ID.Equals(id) && x.Name.Equals(name)).FirstOrDefault();
            if (userInfo != null)
            {
                userInfo.Count = 0;  //收到心跳，重置計數器
            }
        }
    }
}

ChatHub

 

新建Startup.cs文件

using Owin;

namespace SingralRedis
{
    public class Startup
    {
        public void Configuration(IAppBuilder app)
        {
            // Any connection or hub wire up and configuration should go here
            //會默認指定一個路徑  "/signalr" 

            app.MapSignalR();
        }
    }
}