用signalR只给一个用户发送消息。

Question

我正在编写一个聊天应用程序。我使用 Angular 6 和 .Net Core 3.1.

我看了很多文件，但还是不明白哪里有错误。

My Hub Class

public class ChatHub : Hub
{ 
    private static List<ConnectedUser> _connectedUsers = new List<ConnectedUser>();

    public override Task OnConnectedAsync()
    {
        var username = Context.GetHttpContext().Request.Query["username"];

        var status = _connectedUsers.FirstOrDefault(x => x.Username == username);

        if (status == null)
        {
            _connectedUsers.Add(new ConnectedUser
            {
                ConnId = Context.ConnectionId,
                Username = username
            });

        }

        return base.OnConnectedAsync();
    } 
    ...

我有一个列表，保持了 connection id 连接到我的用户信息 Hub Class. 当用户连接时，我就会添加到这个列表中。

我在我的 Private Chat Function 下面。

public void PrivateChat(string toUser,string fromUser,string message)
{
    _connectedUsers.ForEach(val =>
    {
        if(val.Username == toUser)
           Clients.User(val.ConnId).SendAsync("receiveMessage", message,fromUser);
    });
}

但是，我无法回到我想要的用户。

你用它在 Angular 这样

this._hubConnection.on('receiveMessage', (message,fromUser) => {
     console.log(message , "+" , fromUser);
  }
);

Answer 1

你应该使用

 Clients.Clients(val.ConnId).SendAsync("receiveMessage", message,fromUser);