`
This commit is contained in:
parent
d148681135
commit
d753b9206d
@ -81,15 +81,15 @@ namespace XNet.Business
|
||||
}
|
||||
|
||||
// 序列化该实例的所有同步消息
|
||||
byte[] jsonData = MessagePackSerializer.Serialize(group.ToList());
|
||||
byte[] bytesData = MessagePackSerializer.Serialize(group.ToList());
|
||||
var wsMsg = new WsMessage
|
||||
{
|
||||
Type = WsMsgType.AgentPositionSync,
|
||||
Data = jsonData
|
||||
Data = bytesData
|
||||
};
|
||||
byte[] sendBytes = MessagePackSerializer.Serialize(wsMsg);
|
||||
|
||||
// 异步发送给所有订阅者(逐个发送,失败则清理连接)
|
||||
// 异步发送给所有房间订阅者(逐个发送,失败则清理连接)
|
||||
List<string> deadConnIds = new();
|
||||
lock (subscriberConnIds)
|
||||
{
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user