Asp.net SignalR应用并实现群聊功能_实用技巧_

 public class Startup { public void Configuration(IAppBuilder app) { app.MapSignalR(); } }

 [HubName("simpleHub")] public class SimpleHub : Hub { public void SendMsg(string msg) { } } 

 [HubName("simpleHub")] public class SimpleHub : Hub { public void SendMsg(string msg) { // 获取链接id var connectionId = Context.ConnectionId; // 获取cookie var cookie = Context.RequestCookies; } } 

 [HubName("simpleHub")] public class SimpleHub : Hub { public void SendMsg(string msg) { Clients.All.msg("发送给客户端的消息"); } } 

 // 所有人 Clients.All.msg("发送给客户端的消息"); // 特定 cooectionId Clients.Client("connectionId").msg("发送给客户端的消息"); // 特定 group Clients.Group("groupName").msg("发送给客户端的消息"); 

 /// 
 /// SignalR Hub 群聊类 /// 
 [HubName("groupChatHub")] // 标记名称供js调用 public class GroupChatHub : Hub { /// 
 /// 用户名 /// 
 private string UserName { get { var userName = Context.RequestCookies["USERNAME"]; return userName == null ? "" : HttpUtility.UrlDecode(userName.Value); } } /// 
 /// 在线用户 /// 
 private static Dictionary _onlineUser = new Dictionary(); /// 
 /// 开始连接 /// 
 ///  public override Task OnConnected() { Connected(); return base.OnConnected(); } /// 
 /// 重新链接 /// 
 ///  public override Task OnReconnected() { Connected(); return base.OnReconnected(); } private void Connected() { // 处理在线人员 if (!_onlineUser.ContainsKey(UserName)) // 如果名称不存在，则是新用户 { // 加入在线人员 _onlineUser.Add(UserName, 1); // 向客户端发送在线人员 Clients.All.publshUser(_onlineUser.Select(i => i.Key)); // 向客户端发送加入聊天消息 Clients.All.publshMsg(FormatMsg("系统消息", UserName + "加入聊天")); } else { // 如果是已经存在的用户，则把在线链接的个数+1 _onlineUser[UserName] = _onlineUser[UserName] + 1; } // 加入Hub Group，为了发送单独消息 Groups.Add(Context.ConnectionId, "GROUP-" + UserName); } /// 
 /// 结束连接 /// 
 ///  ///  public override Task OnDisconnected(bool stopCalled) { // 人员链接数-1 _onlineUser[UserName] = _onlineUser[UserName] - 1; // 判断是否断开了所有的链接 if (_onlineUser[UserName] == 0) { // 移除在线人员 _onlineUser.Remove(UserName); // 向客户端发送在线人员 Clients.All.publshUser(_onlineUser.Select(i => i.Key)); // 向客户端发送退出聊天消息 Clients.All.publshMsg(FormatMsg("系统消息", UserName + "退出聊天")); } // 移除Hub Group Groups.Remove(Context.ConnectionId, "GROUP-" + UserName); return base.OnDisconnected(stopCalled); } /// 
 /// 发送消息，供客户端调用 /// 
 /// 用户名，如果为0，则是发送给所有人 /// 消息 public void SendMsg(string user, string msg) { if (user == "0") { // 发送给所有用户消息 Clients.All.publshMsg(FormatMsg(UserName, msg)); } else { //// 发送给自己消息 //Clients.Group("GROUP-" + UserName).publshMsg(FormatMsg(UserName, msg)); //// 发送给选择的人员 //Clients.Group("GROUP-" + user).publshMsg(FormatMsg(UserName, msg)); // 发送给自己消息 Clients.Groups(new List { "GROUP-" + UserName, "GROUP-" + user }).publshMsg(FormatMsg(UserName, msg)); } } /// 
 /// 格式化发送的消息 /// 
 ///  ///  ///  private dynamic FormatMsg(string name, string msg) { return new { Name = name, Msg = HttpUtility.HtmlEncode(msg), Time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") }; } } 

 群聊系统（1人在线）：@ViewBag.UserName 
所有人
发送

 /// 
 /// 主动发送给用户消息，单例模式 /// 
 public class GroupChat { /// 
 /// Clients，用来主动发送消息 /// 
 private IHubConnectionContext Clients { get; set; } private readonly static GroupChat _instance = new GroupChat(GlobalHost.ConnectionManager.GetHubContext().Clients); private GroupChat(IHubConnectionContext clients) { Clients = clients; } public static GroupChat Instance { get { return _instance; } } /// 
 /// 主动给所有人发送消息，系统直接调用 /// 
 ///  public void SendSystemMsg(string msg) { Clients.All.publshMsg(new { Name = "系统消息", Msg = msg, Time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") }); } } 

提示： 本文由神整理自网络，如有侵权请联系本站删除！
本站声明：
1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持；
2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！