简单聊天室
使用持久链接类我们就可以做一些即时通讯的应用了，我使用Group做了一个简单的聊天室，先上图技术细节下面再讲
可以加入聊天室、创建聊天室、发送消息，下面就说说我是如何通过Group做出来的
持久链接类有一个Groups的对象，通过这个对象，我们可以进行分组添加人员、发送消息、删除人员等操作
在连接事件中，给当前游客指定随机名称，并且返回当前已有的聊天室信息
protected override Task OnConnected(IRequest request, string connectionId)
{
var outPut = new OutPut
{
ResultType = "RoomList",
Data = RoomList,
UserName = $"游客{Rdom.Next(1, 999)}"
};
//返回房间信息
return Connection.Send(connectionId, JsonConvert.SerializeObject(outPut));
}
下面的代码做了剩下所有的处理，先从创建聊天室开始讲起，如果客户端的请求Action是createRoom那么当前操作就是创建聊天室，聊天室id是一个随机生成的Guid，并且把当前的游客添加到当前聊天室中
加入聊天室也是非常简单的，使用 Groups.Add方法可以轻松的做到，然后再进行广播给当前聊天室中的所有人推送有新的游客加入
发送消息则是最简单的了，可以看到最后的发送消息最后一个参数 connectionid，因为是当前人去发送消息 所以把当前人排除掉，给聊天室里的其他所有人发送
protected override Task OnReceived(IRequest request, string connectionId, string data)
{
var dto = JsonConvert.DeserializeObject<GroupDto>(data); var outPut = new OutPut
{
ResultType = "msgResult",
Data = $"{dto.UserName} : {dto.Data}",
CurrentRoomId = dto.RoomId
}; if (dto.Action.Equals("jionUs"))
{
//加入聊天室
Groups.Add(connectionId, dto.RoomId);
outPut.Data = $"欢迎{dto.UserName}加入{dto.RoomName}聊天室";
outPut.CurrentRoomId = dto.RoomId;
Connection.Send(connectionId, JsonConvert.SerializeObject(outPut));
return Groups.Send(dto.RoomId, JsonConvert.SerializeObject(outPut));
} if (dto.Action.Equals("createRoom"))
{
//创建聊天室
var room = new Group() { RoomId = Guid.NewGuid().ToString(), RoomName = dto.RoomName };
Groups.Add(connectionId, room.RoomId);
dto.RoomId = room.RoomId;
RoomList.Add(room);
//返回聊天室列表
outPut.ResultType = "RoomList";
outPut.Data = RoomList;
outPut.CurrentRoomId = dto.RoomId; //发送消息
return Connection.Send(connectionId, JsonConvert.SerializeObject(outPut)); }
//发送消息
return Groups.Send(dto.RoomId, JsonConvert.SerializeObject(outPut), connectionId);
}