javascript - 私人消息未在 SignalR 中发送
问题描述
我正在做一个非常简单的项目,用户使用 SignalR 库通过服务器向另一个人发送私人消息。我将此代码用作基础https://www.codeproject.com/Articles/562023/Asp-Net-SignalR-Chat-Room
我从一个简单的功能测试开始,但我的收件人没有收到消息并且它不能正常工作,你能帮我理解为什么吗?
在我的程序中,用户名是在会话中动态生成的,下面代码中的用户名不是真实数据,我只是将它们用于示例
客户端
</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
}
当我执行程序时,它会在控制台上显示日志“已连接”,并且在按下按钮时触发事件,但由于某种原因,消息未发送或未收到
解决方案
您在代码中缺少的是开始收听您的服务器,该方法发送给您的内容喜欢
.on("YourMethodName")
建立连接后。还建议使用 connectionId 解析用户,您可以调用特定用户,例如:
Clients.Client(Context.ConnectionId).sendPrivateMessage(fromUserId, fromUser.UserName, message);
推荐阅读
- python - 使用 List 参数调用 marshmallow 验证的 GET 端点
- node.js - 如何使用 node.js 查找文件扩展名更改?
- angular - 在 ionic 2 中试图从一页移动(导航)到另一页,但它不起作用?
- java - 试图用java计算向量
- python - 获取 IndexError:尝试将技术指标应用于股票信息的 pandas DataFrame 时,单个位置索引器超出范围
- go - 通过 GRPC 服务器为 graphql 服务器提供服务
- c# - 从 API 控制器从服务器数据库检索数据时缺少实体
- html - HTML5 日期时间-本地选择器自定义占位符
- javascript - 怎么做