这是闹剧。
我正在使用 websocket-sharp 构建一个网络应用程序,我遇到了一个问题,即服务器向客户端发送数百条(不一致数量相同)的重复消息,这是故障。
1.)客户端连接(此握手工作正常)。
2.) 在客户端连接时,服务器向所述客户端发送为该连接创建的会话 ID。(这有效)
3.) 客户端接收并存储会话 ID。(这有效,这里没有重复发送)
4.) 客户端向服务器上的大厅系统发送请求以创建匹配。(这有效并且被正确接收)
5.)服务器接收到匹配创建请求,创建匹配并将匹配数据发送回客户端(实际上发送了一条消息,但客户端接收到数百条相同的消息(所有消息大小相同,包含相同的信息) ))。
我已经查看了我的大厅系统逻辑,没有可以多次发送匹配创建回复的循环,而且我知道服务器上的“发送”方法只被调用一次。
我查看了 websocket-sharp 文档,我想也许不知何故,有数百个会话是通过一个连接进行的,或者沿着这些线路进行一些无意义的,但我正在连接一个客户端并且只有一个会话退出:/
如果您有任何想法,请告诉我这是如何发生的。提前致谢。
请参阅下面的代码。
服务器:
发送方法:
public void Send (string path, string targetID, string script, string method, params object[] data) {
print ("SERVER: Sending Message");
WebSocketServiceHost host = null;
GetSocketServer ().WebSocketServices.TryGetServiceHost (path, out host);
if (host != null) {
Network.Packet packet = new Network.Packet ("Server", targetID, script, method, data);
if (targetID != "Broadcast") {
GetSocketServer ().WebSocketServices.Broadcast (Formatter.singleton.Serialize (packet));
} else if (targetID == "Service") {
host.Sessions.Broadcast (Formatter.singleton.Serialize (packet));
} else {
host.Sessions.SendToAsync (Formatter.singleton.Serialize (packet), targetID);
}
}
}
客户:
接收方法:
GetPersistent ().OnMessage += MessageHandler;
void MessageHandler (object sender, MessageEventArgs e) {
Debug.Log ("CLIENT: Message Recieved");
Network.singleton.Recieve (e.RawData);
}
网络:(由服务器和客户端使用)
接收方法:
public void Recieve (byte[] data) {
object obj = Formatter.singleton.Deserialize (data);
messages.Add (messages.Count, obj);
}
IEnumerator ProcessorCoro () {
WaitForSeconds delay = new WaitForSeconds (Time.deltaTime);
while (true) {
if (messages.Count >= 1) {
Process (messages [(messages.Count - 1)]);
messages.Remove ((messages.Count - 1));
}
yield return delay;
}
}
public void Process (object data) {
Network.Packet packet = (Network.Packet)data;
switch (packet.script) {
case "Home":
Home.singleton.SendMessage (packet.method, data, SendMessageOptions.DontRequireReceiver);
break;
case "Arena":
Arena.singleton.SendMessage (packet.method, data, SendMessageOptions.DontRequireReceiver);
break;
case "Client":
Client.singleton.SendMessage (packet.method, data, SendMessageOptions.DontRequireReceiver);
break;
case "Database":
Database.singleton.SendMessage (packet.method, data, SendMessageOptions.DontRequireReceiver);
break;
}
}