一、引言
在前一篇文章已經詳細介紹了SignalR了,並且簡單介紹它在Asp.net MVC 和WPF中的應用。在上篇部落格文章介紹的都是群發訊息的實現,然而,對於SignalR是為了即時聊天而生的,自然少了不像QQ一樣的端對端的聊天了。本篇部落格文章將介紹如何使用SignalR來實現類似QQ聊天的功能。
二、使用SignalR實作端對端聊天的想法
在介紹具體實作之前,我先來介紹了使用SignalR實作端對端聊天的想法。相信大家在前篇文章已經看過Clients.All.sendMessage(name, message);這樣的程式碼,其表示呼叫所有客戶端的SendMessage。 SignalR的集線器使得客戶端和服務端可以即時通訊。那要實現端對端的聊天,自然就不能像所有客戶端發送訊息了,而只能向特定的客戶端發送訊息才可以,不然不就亂套了,沒有任何隱私權了。那怎麼才可以向特定的客戶端發送訊息呢?這個問題也就是我們實現端對端聊天功能的關鍵。
我們發送Clients物件除了All屬性外,還有其他屬性,你可以在VS中按F12來查看Clients物件的所有屬性或方法,具體的定義如下:
public interface IHubConnectionContext<T> { T All { get; } // 代表所有客户端 T AllExcept(params string[] excludeConnectionIds); // 除了参数中的所有客户端 T Client(string connectionId); // 特定的客户端,这个方法也就是我们实现端对端聊天的关键 T Clients(IList<string> connectionIds); // 参数中的客户端端 T Group(string groupName, params string[] excludeConnectionIds); // 指定客户端组,这个也是实现群聊的关键所在 T Groups(IList<string> groupNames, params string[] excludeConnectionIds); T User(string userId); // 特定的用户 T Users(IList<string> userIds); // 参数中的用户 }
一個客戶端為標記其唯一性,SignalR都會指派它一個ConnnectionId,這樣我們就可以透過ConnnectionId來找到特定的客戶端了。這樣,我們在傳送訊息給某個客戶的時候,除了要將訊息傳入,也需要將傳送給對方的ConnectionId輸入,這樣服務端就能根據傳入的ConnectionId來轉送對應的訊息給對應的客戶端了。這樣也就完成了端對端聊天的功能。另外,如果用戶如果不在線上的話,服務端可以把訊息保存到資料庫中,等對應的客戶端上線的時候,再從資料庫中查看該客戶端是否有訊息需要推送,有的話,從資料庫中取出數據,將該資料推送給該客戶端。 (不過這點,服務端快取資料的功能本篇博文沒有實現,在這裡介紹就是讓大家明白QQ一個實現原理)。
下面我們來梳理下端對端聊天功能的實現思路:
客戶端登錄的時候記錄下客戶端的ConnnectionId,並將用戶加入到一個靜態數組中,該數據為了記錄所有在線用戶。
用戶可以點擊線上用戶中的用戶聊天,在發送訊息的時候,需要將ConnectionId一併傳入到服務端。服務端根據傳入的訊息內容和ConnectionId呼叫Clients.Client(connnection).sendMessage方法來進行轉送至對應的客戶端。
三、實現酷炫聊天功能核心代碼
有了實現思路,實現功能也就得心應手了,接下來,讓我們先看下集線器ChatHub中的代碼:
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 Connect(string userId, string userName) { var connnectId = Context.ConnectionId; if (OnlineUsers.Count(x => x.ConnectionId == connnectId) == 0) { if (OnlineUsers.Any(x => x.UserId == userId)) { var items = OnlineUsers.Where(x => x.UserId == userId).ToList(); foreach (var item in items) { Clients.AllExcept(connnectId).onUserDisconnected(item.ConnectionId, item.UserName); } OnlineUsers.RemoveAll(x => x.UserId == userId); } //添加在线人员 OnlineUsers.Add(new UserInfo { ConnectionId = connnectId, UserId = userId, 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 toUserId, string message) { var fromUserId = Context.ConnectionId; var toUser = OnlineUsers.FirstOrDefault(x => x.ConnectionId == toUserId); var fromUser = OnlineUsers.FirstOrDefault(x => x.ConnectionId == fromUserId); if (toUser != null && fromUser != null) { // send to Clients.Client(toUserId).receivePrivateMessage(fromUserId, fromUser.UserName, message); // send to caller user // Clients.Caller.sendPrivateMessage(toUserId, fromUser.UserName, message); } else { //表示对方不在线 Clients.Caller.absentSubscriber(); } } /// <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); return base.OnDisconnected(stopCalled); } }上面只是列出了一些核心程式碼實作。另外,為了實現的酷炫的效果,這裡採用了一個Jquery插件:layer,官方網址為:http://layer.layui.com/。這個外掛主要為了實現彈出框和彈出層的效果,要實現酷炫的聊天特效,就需要自己寫JS代碼了,由於本人並不是很熟悉前端,所以這個JS特效代碼也是參考網絡上的實現。大家如果想執行查看效果,建議到文章最後下載原始碼運行。 四、最終效果
介紹完了實現思路和實現代碼之後,既然就到了我們激動人心的一刻了,那就是看看我們實現功能是否可以滿足需求,另外,除了滿足基本的聊天功能外,還需要看看介面是不是夠酷炫。