wenyongda/ZrAdminNetCore
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat：新增在线用户聊天消息通知

Browse Source
This commit is contained in:
不做码农 2022-06-19 11:36:32 +08:00
parent ff6e6304b2
commit 0f8bcb9434
1 changed files with 23 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
ZR.Admin.WebApi/Hubs/MessageHub.cs
View File

@ -17,7 +17,7 @@ namespace ZR.Admin.WebApi.Hubs
private static readonly List<OnlineUsers> clientUsers = new(); private static readonly List<OnlineUsers> clientUsers = new();
private readonly NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger(); private readonly NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();
private readonly ISysNoticeService SysNoticeService; private readonly ISysNoticeService SysNoticeService;
public MessageHub(ISysNoticeService noticeService) public MessageHub(ISysNoticeService noticeService)
{ {
SysNoticeService = noticeService; SysNoticeService = noticeService;
@ -41,7 +41,7 @@ namespace ZR.Admin.WebApi.Hubs
var name = Context.User.Identity.Name; var name = Context.User.Identity.Name;
var ip = HttpContextExtension.GetClientUserIp(App.HttpContext); var ip = HttpContextExtension.GetClientUserIp(App.HttpContext);
var ip_info = IpTool.Search(ip); var ip_info = IpTool.Search(ip);
LoginUser loginUser = JwtUtil.GetLoginUser(App.HttpContext); LoginUser loginUser = JwtUtil.GetLoginUser(App.HttpContext);
var user = clientUsers.Any(u => u.ConnnectionId == Context.ConnectionId); var user = clientUsers.Any(u => u.ConnnectionId == Context.ConnectionId);
//判断用户是否存在，否则添加集合 //判断用户是否存在，否则添加集合
@ -56,7 +56,7 @@ namespace ZR.Admin.WebApi.Hubs
//Clients.All.SendAsync("welcome", $"欢迎您：{name},当前时间：{DateTime.Now}"); //Clients.All.SendAsync("welcome", $"欢迎您：{name},当前时间：{DateTime.Now}");
Clients.All.SendAsync(HubsConstant.MoreNotice, SendNotice()); Clients.All.SendAsync(HubsConstant.MoreNotice, SendNotice());
} }
Clients.All.SendAsync(HubsConstant.OnlineNum, clientUsers.Count); Clients.All.SendAsync(HubsConstant.OnlineNum, clientUsers.Count);
Clients.All.SendAsync(HubsConstant.OnlineUser, clientUsers); Clients.All.SendAsync(HubsConstant.OnlineUser, clientUsers);
return base.OnConnectedAsync(); return base.OnConnectedAsync();
@ -81,5 +81,25 @@ namespace ZR.Admin.WebApi.Hubs
} }
#endregion #endregion
/// <summary>
/// 注册信息
/// </summary>
/// <param name="connectId"></param>
/// <param name="userName"></param>
/// <param name="message"></param>
/// <returns></returns>
[HubMethodName("SendMessage")]
public async Task SendMessage(string connectId, string userName, string message)
{
Console.WriteLine($"{connectId},message={message}");
bool isDemoMode = AppSettings.GetAppConfig("DemoMode", true);
if (isDemoMode)
{
await Clients.Caller.SendAsync("receiveChat", new { userName, message = "当前环境为演示环境，消息不会发送给对方" });
return;
}
await Clients.Client(connectId).SendAsync("receiveChat", new { userName, message });
}
} }
} }