javascript - SignalR 中未发送私有(private)消息

Question

我正在开发一个非常简单的项目，其中用户使用 SignalR 库通过服务器向另一个用户发送私有(private)消息。我使用此代码作为基础 https://www.codeproject.com/Articles/562023/Asp-Net-SignalR-Chat-Room

我从一个简单的功能测试开始，但我的收件人没有收到消息，并且它无法正常工作，您能帮助我理解原因吗？

在我的程序中，用户名是在 session 中动态生成的，下面代码中的用户名不是真实数据，我只是将它们用于示例

客户端

    </script>
    <script type="text/javascript" src="/Scripts/jquery-1.6.4.min.js"></script>
    <script type="text/javascript" src="/Scripts/jquery.signalR-1.2.2.js"></script>
    <script type="text/javascript" src="/signalr/hubs"></script>
    <script type="text/javascript">
        $(function () {
            var chatHub = $.connection.chatHub;
            console.log('connected')

            chatHub.client.messageReceived = function (userName, message) {
                alert("You have a new message");
            }

            $.connection.hub.start().done(function () {
                chatHub.server.connect('FromUsername');

                $('#btnSend').click(function () {
                    var userId='ToUsername'
                    var msg = 'Test';
                    chatHub.server.sendPrivateMessage(userId, msg);
                });
            });
        });
    </script>

服务器端

public class ChatHub : Hub
    {
        #region Data Members

        static List<UserDetail> ConnectedUsers = new List<UserDetail>();
        static List<MessageDetail> CurrentMessage = new List<MessageDetail>();

        #endregion

        #region Methods

        public void Connect(string userName)
        {
            var id = Context.ConnectionId;


            if (ConnectedUsers.Count(x => x.ConnectionId == id) == 0)
            {
                ConnectedUsers.Add(new UserDetail { ConnectionId = id, UserName = userName });

                // send to caller
                Clients.Caller.onConnected(id, userName, ConnectedUsers, CurrentMessage);

                // send to all except caller client
                Clients.AllExcept(id).onNewUserConnected(id, userName);

            }

        }

        public void SendMessageToAll(string userName, string message)
        {
            // store last 100 messages in cache
            AddMessageinCache(userName, message);

            // Broad cast message
            Clients.All.messageReceived(userName, message);
        }

        public void SendPrivateMessage(string toUserId, string message)
        {

            string fromUserId = Context.ConnectionId;

            var toUser = ConnectedUsers.FirstOrDefault(x => x.ConnectionId == toUserId) ;
            var fromUser = ConnectedUsers.FirstOrDefault(x => x.ConnectionId == fromUserId);

            if (toUser != null && fromUser!=null)
            {
                // send to 
                Clients.Client(toUserId).sendPrivateMessage(fromUserId, fromUser.UserName, message); 

                // send to caller user
                Clients.Caller.sendPrivateMessage(toUserId, fromUser.UserName, message); 
            }

        }

        public override System.Threading.Tasks.Task OnDisconnected()
        {
            var item = ConnectedUsers.FirstOrDefault(x => x.ConnectionId == Context.ConnectionId);
            if (item != null)
            {
                ConnectedUsers.Remove(item);

                var id = Context.ConnectionId;
                Clients.All.onUserDisconnected(id, item.UserName);

            }

            return base.OnDisconnected();
        }


        #endregion

        #region private Messages

        private void AddMessageinCache(string userName, string message)
        {
            CurrentMessage.Add(new MessageDetail { UserName = userName, Message = message });

            if (CurrentMessage.Count > 100)
                CurrentMessage.RemoveAt(0);
        }

        #endregion
    }

当我执行程序时，它在控制台上显示日志“已连接”，并且按下按钮时会触发事件，但由于某种原因，消息未发送或未接收

Answer 1

你的代码中缺少的是开始监听你的服务器，该方法会发送给你什么

.on("YourMethodName")

连接建立后。还建议使用connectionId解析用户，您可以调用特定用户，例如:

Clients.Client(Context.ConnectionId).sendPrivateMessage(fromUserId, fromUser.UserName, message);