90 lines
2.7 KiB
C#
90 lines
2.7 KiB
C#
using System.Threading.Tasks;
|
||
using New_College.Common.LogHelper;
|
||
using Microsoft.AspNetCore.SignalR;
|
||
|
||
namespace New_College.Hubs
|
||
{
|
||
public class ChatHub : Hub<IChatClient>
|
||
{
|
||
/// <summary>
|
||
/// 向指定群组发送信息
|
||
/// </summary>
|
||
/// <param name="groupName">组名</param>
|
||
/// <param name="message">信息内容</param>
|
||
/// <returns></returns>
|
||
public async Task SendMessageToGroupAsync(string groupName, string message)
|
||
{
|
||
await Clients.Group(groupName).ReceiveMessage(message);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 加入指定组
|
||
/// </summary>
|
||
/// <param name="groupName">组名</param>
|
||
/// <returns></returns>
|
||
public async Task AddToGroup(string groupName)
|
||
{
|
||
await Groups.AddToGroupAsync(Context.ConnectionId, groupName);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 退出指定组
|
||
/// </summary>
|
||
/// <param name="groupName">组名</param>
|
||
/// <returns></returns>
|
||
public async Task RemoveFromGroup(string groupName)
|
||
{
|
||
await Groups.RemoveFromGroupAsync(Context.ConnectionId, groupName);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 向指定成员发送信息
|
||
/// </summary>
|
||
/// <param name="user">成员名</param>
|
||
/// <param name="message">信息内容</param>
|
||
/// <returns></returns>
|
||
public async Task SendPrivateMessage(string user, string message)
|
||
{
|
||
await Clients.User(user).ReceiveMessage(message);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 当连接建立时运行
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public override Task OnConnectedAsync()
|
||
{
|
||
//TODO..
|
||
return base.OnConnectedAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 当链接断开时运行
|
||
/// </summary>
|
||
/// <param name="ex"></param>
|
||
/// <returns></returns>
|
||
public override Task OnDisconnectedAsync(System.Exception ex)
|
||
{
|
||
//TODO..
|
||
return base.OnDisconnectedAsync(ex);
|
||
}
|
||
|
||
|
||
public async Task SendMessage(string user, string message)
|
||
{
|
||
await Clients.All.ReceiveMessage( user, message);
|
||
}
|
||
|
||
//定于一个通讯管道，用来管理我们和客户端的连接
|
||
//1、客户端调用 GetLatestCount，就像订阅
|
||
public async Task GetLatestCount(string random)
|
||
{
|
||
//2、服务端主动向客户端发送数据，名字千万不能错
|
||
await Clients.All.ReceiveUpdate(LogLock.GetLogData());
|
||
|
||
//3、客户端再通过 ReceiveUpdate ，来接收
|
||
|
||
}
|
||
}
|
||
}
|