signalr中Group 分组群发消息的简单使用

namespace signalrGroupDemo.Models{    public class DbContext    {        public DbContext()        {            Users = new List<User>();            Connections = new List<Connection>();            Rooms = new List<Room>();        }        //用户集合        public List<User> Users { get; set; }        //连接集合        public List<Connection> Connections { get; set; }        //房间集合        public List<Room> Rooms { get; set; }    }    //用户类    public class User    {       [Key]        public string UserName { get; set; }       //用户连接       public List<Connection> Connections { get; set; }        //用户房间集合        public virtual List<Room> Rooms { get; set; }        public User()        {            Connections = new List<Connection>();            Rooms = new List<Room>();        }    }    public class Connection    {        //连接ID        public string ConnectionID { get; set; }        //用户代理        public string userAgent { get; set; }        //是否连接        public bool Connected { get; set; }    }    //房间类    public class Room    {        [Key]        public string RommName { get; set; }       //用户集合       public virtual List<User> Users { get; set; }        public Room() {            Users = new List<User>();        }    }}

using System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using System.Web;using Microsoft.AspNet.SignalR;using signalrGroupDemo.Models;using Newtonsoft.Json;using Microsoft.AspNet.SignalR.Hubs;namespace signalrGroupDemo{    [HubName("groupHub")]    public class GroupHUb : Hub    {        public void Hello()        {            Clients.All.hello();        }        public static DbContext db = new DbContext();        /// <summary>        /// 重写Hub连接事件        /// </summary>        /// <returns></returns>        public override Task OnConnected()        {            //查询用户            var user = db.Users.Where(w => w.UserName == Context.ConnectionId).FirstOrDefault();            //判断用户是否存在            if (user == null)            {                user = new User()                {                    UserName = Context.ConnectionId                };                db.Users.Add(user);            }            //发送房间列表            var rooms = db.Rooms.Select(p => p.RoomName).ToList();            //注册getRooms 获取房间的方法            Clients.Client(Context.ConnectionId).getRoomList(JsonConvert.SerializeObject(rooms));            return base.OnConnected();        }        //更新所有用户的房间列表        private void GetRooms()        {            var rooms =JsonConvert.SerializeObject(db.Rooms.Select(p => p.RoomName).ToList());            Clients.All.getRoomList(rooms);        }        //重写Hub链接断开事件        public override Task OnDisconnected(bool s)        {            var user = db.Users.Where(u=>u.UserName==Context.ConnectionId).FirstOrDefault();            //判断用户是否存在，存在则删除            if (user != null)            {                //删除用户                db.Users.Remove(user);            }            return base.OnDisconnected(s);        }        //加入聊天室        public void AddRoom(string  roomName)        {            //查询聊天室            var room = db.Rooms.Find(a=>a.RoomName==roomName);            //存在则加入            if (room != null)            {                //查找房间中是否存在此用户                var isUser = room.Users.Where(w => w.UserName == Context.ConnectionId).FirstOrDefault();                //不存在则加入                if (isUser == null)                {                    var user = db.Users.Find(a => a.UserName == Context.ConnectionId);                    user.Rooms.Add(room);                    room.Users.Add(user);                    Groups.Add(Context.ConnectionId, roomName);                    //注册加入聊天室的addRoom方法                    Clients.Client(Context.ConnectionId).addRoom(roomName);                }                else                {                    Clients.Client(Context.ConnectionId).showMessage("请勿重复加入房间");                }            }        }        //创建聊天室        public void CreateRoom(string  roomName)        {            var room = db.Rooms.Find(a=>a.RoomName==roomName);            if (room == null)            {                Room r = new Room() { RoomName = roomName };                //将房间加入列表                db.Rooms.Add(r);                AddRoom(roomName);                Clients.Client(Context.ConnectionId).showMessage("房间创建完成");                GetRooms();            }            else            {                Clients.Client(Context.ConnectionId).showMessage("房间名重复");            }        }        //退出聊天室        public void ExitRoom(string  roomName)        {            //查找房间是否存在            var room = db.Rooms.Find(a=>a.RoomName==roomName);            //存在则删除            if (room != null)            {                //查找要删除的用户                var user = room.Users.Where(p => p.UserName == Context.ConnectionId).FirstOrDefault();                //移除此用户                room.Users.Remove(user);                //如果房间人数为0，怎删除房间                if (room.Users.Count == 0)                {                    db.Rooms.Remove(room);                }                //Groups Remove移除分组方法                Groups.Remove(Context.ConnectionId,roomName);                //提示客户端                Clients.Client(Context.ConnectionId).removeRoom("退出成功");            }        }        //给分组内所有用户发送消息        public void SendMsg(string  Room,string  Message)        {            Clients.Group(Room, new string[0]).sendMessage(Room,Message+" "+DateTime.Now.ToString());        }    }}

第三步：前端调用注册的Server方法和注册Client方法

@{    Layout = null;}<!DOCTYPE html><html><head>    <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />    <meta charset="utf-8" />    <meta name="viewport" content="width=device-width, initial-scale=1.0">    <title>signalr group 分组方法的使用</title>    <script src="~/Scripts/jquery-1.10.2.min.js"></script>    <script src="~/Scripts/jquery.signalR-2.2.1.min.js"></script>     @*这里是虚拟目录，也就是你再OWIN Startup中注册的地址*@    <script src="~/signalr/hubs"></script></head><body>    <div><div>名称：<p id="userName"></p></div>        房间名：<input  type="text" value="ceshi" id="roomName"/>        <button id="createRoom">创建聊天室</button></div>      <div style="float:left;border:double">        <div>房间列表</div><ul id="roomList"></ul>    </div>    <div id="rooms"></div>    <script>    var  chat;    var roomCount =0;    $(function(){        chat = $.connection.groupHub;        //调用hub中注册的showMessage方法        chat.client.showMessage= function (message)        {            alert(message);        }        //调用hub中注册的sendMessage 方法        chat.client.sendMessage= function (roomname, message)        {            debugger            $("#" + roomname).find("ul").each(function () {                $(this).append('<li>'+message+'</li>');            })        }        //调用hub中removeRoom 退出房间方法        chat.client.removeRoom = function (data)        {            alert(data);        }        //注册查询房间列表的方法        chat.client.getRoomList = function (data) {                        if (data) {                debugger                var jsonData = $.parseJSON(data);                $("#roomList").html(" ");                for (var i = 0; i < jsonData.length; i++) {                    var html = '<li>房间名:' + jsonData[i] + '<button roomName="' + jsonData[i] + '" onclick="addRoom(this)">加入</button> </li>'                    $("#roomList").append(html);                }            }        }        //调用hub中addRoom 加入房间的方法        chat.client.addRoom = function (roomName)        {            var html = '<div style="float:left; margin-left:30px; border:double" id="' + roomName + '" roomname="' + roomName + '" ><button onclick="removeRoom(this)">退出房间</button>                           ' + roomName + '房间聊天记录如下:<ul></ul> <input type="text"/> <button onclick="send(this)">发送</button><div>'            $("#rooms").append(html);        }        //获取用户名称        $("#userName").html(prompt('请输入您的名称:', ''));        $.connection.hub.start().done(function () {            $("#createRoom").click(function ()            {                if (roomCount < 2) {                    chat.server.createRoom($("#roomName").val());                }                else                {                    alert("聊天窗口只允许有2个");                }            })        })    })          //发送消息的方法        function send(btn)        {                        var message = $(btn).prev().val();            var room = $(btn).parent();            var userName = $("#userName").html();            message = userName + ":" + message;            var roomName = $(room).attr("roomName");            chat.server.sendMsg(roomName,message);        }        //退出房间        function removeRoom(btn)        {            var room = $(btn).parent();            var roomName = $(room).attr("roomName");            chat.server.exitRoom(roomName);        }        //加入房间        function addRoom(roomName)        {            var data = $(roomName).attr("roomName");            chat.server.addRoom(data);        }        </script></body></html>