从.net core SignalR和react接收两条消息

Question

我正在尝试使用。net SignalR和React应用程序作为客户端来设置WebSocket连接，以便能够发送私人消息。

下面是我在客户端的代码:

const setUpSignalRConnection = async () => {
const connection = new HubConnectionBuilder()
.withUrl("http://localhost:5000/messaginghub")
.build();
setConnection(connection);
connection.on("ReceiveMessage", (message: string) => {
console.log("Recieved Message", message);
setChatMessages((oldArray) => [...oldArray, message]);
});
try {
await connection.start();
} catch (err) {
console.log("Errors", err);
}
return connection;
};

const SendMessage = async () => {
if (connection) {
try {
console.log("sending message");
await connection.send("SendPrivateMessage", user.user.email, message);
} catch (e) {
console.log("Errors sending message", e);
}
} else {
alert("No connection to server yet.");
}
};

和服务器端代码

public async Task SendPrivateMessage(string userEmail, string message)
{
var RecivingMessageUser = _unitOfWork.UserRepository.GetByEmail(userEmail);
var currUserEmail = Context.User.FindFirstValue(ClaimTypes.NameIdentifier);
var sender = _unitOfWork.UserRepository.GetByEmail(currUserEmail);
var newMessage = new MessagesDto
{
FromId = sender.UserId,
ToId = RecivingMessageUser.UserId,
MessageBody = message,
SentAt = DateTime.UtcNow,
};
await Clients.Group(userEmail).SendAsync("ReceiveMessage", message);
_unitOfWork.MessagingRepository.Insert(_mapper.Map<MessagesDto, Messages>(newMessage));
_unitOfWork.SaveChanges();
}
public override Task OnConnectedAsync()
{
var groupName = Context.User.FindFirstValue(ClaimTypes.NameIdentifier);
Groups.AddToGroupAsync(Context.ConnectionId, groupName);
return base.OnConnectedAsync();
}
public override Task OnDisconnectedAsync(Exception ex)
{
Groups.RemoveFromGroupAsync(Context.ConnectionId, Context.User.FindFirstValue(ClaimTypes.NameIdentifier));
return base.OnDisconnectedAsync(ex);
}

与控制台。我看到我发送了一条消息，消息存储在DB中一次，但不知何故，在另一端，我收到了两条消息。

我正在我的本地机器上用两个不同的浏览器进行测试。

我做错了什么?

Answer 1

哪个后端方法调用了两次?你告诉你的消息保存到数据库一次，所以它不应该是SendPrivateMessage方法调用语音。

Answer 2

这是客户端应用程序的SignalR响应的正常问题，因为我们的响应没有等待服务器，所以尝试添加setTimeout(() =>setChatMessages ((oldArray) =比;[…olarray, message])， 1);我希望你能得到你想要的。