diff --git a/Assets/Temp/Scripts/Judgmentstate.cs b/Assets/Temp/Scripts/Judgmentstate.cs index ca37b0da..d3602a64 100644 --- a/Assets/Temp/Scripts/Judgmentstate.cs +++ b/Assets/Temp/Scripts/Judgmentstate.cs @@ -112,6 +112,7 @@ public class Judgmentstate : MonoBehaviour public void OnLeaveRoom() { string _msg = "leaveroom "; + MyNetMQClient.instance._netMqListener.UnSubtopic(GlobalFlag.roomID); _ = AdamSync.SyncCreateRoom.SendMessageAsync(_msg); } } diff --git a/Assets/Temp/Scripts/Taskpanel.cs b/Assets/Temp/Scripts/Taskpanel.cs index a8bbcf83..73e9791a 100644 --- a/Assets/Temp/Scripts/Taskpanel.cs +++ b/Assets/Temp/Scripts/Taskpanel.cs @@ -153,6 +153,7 @@ public class Taskpanel : MonoBehaviour public void OnLeaveRoom() { string _msg = "leaveroom "; + MyNetMQClient.instance._netMqListener.UnSubtopic(GlobalFlag.roomID); _ = AdamSync.SyncCreateRoom.SendMessageAsync(_msg); } diff --git a/Assets/Temp/Scripts/View_Panel2.cs b/Assets/Temp/Scripts/View_Panel2.cs index d6c99af0..1ce53491 100644 --- a/Assets/Temp/Scripts/View_Panel2.cs +++ b/Assets/Temp/Scripts/View_Panel2.cs @@ -259,7 +259,10 @@ public class View_Panel2 : XUIPanel public void OnJoinRoom(string msg) { + //Debug.Log("OnJoinRoom ViewPanel===" + msg); + //Debug.Log("订阅"+GlobalFlag.roomID); + MyNetMQClient.instance._netMqListener.SubTopic(GlobalFlag.roomID); SceneManager.LoadScene("AdamTraining_pilot_terminal_panl 1"); } public async void GetAllRoomData() diff --git a/Assets/Zion/Scripts/cxx/LoadManage.cs b/Assets/Zion/Scripts/cxx/LoadManage.cs index 38fc6e8a..56a10fab 100644 --- a/Assets/Zion/Scripts/cxx/LoadManage.cs +++ b/Assets/Zion/Scripts/cxx/LoadManage.cs @@ -1,4 +1,4 @@ -using System; +using System; using System.Collections.Generic; using System.Text; using UnityEngine; @@ -48,7 +48,7 @@ public class LoadManage : MonoBehaviour } }); CreateRoomServerClient(string.Format("tcp://{0}:8889", ip), string.Format("tcp://{0}:8888", ip)); - MyNetMQClient.instance._netMqListener.SubTopic("Room"); + //MyNetMQClient.instance._netMqListener.SubTopic("Room"); SceneManager.LoadScene("SampleScene"); } diff --git a/Assets/Zion/Scripts/cxx/NetMqListener.cs b/Assets/Zion/Scripts/cxx/NetMqListener.cs index 01551f3d..0c0008eb 100644 --- a/Assets/Zion/Scripts/cxx/NetMqListener.cs +++ b/Assets/Zion/Scripts/cxx/NetMqListener.cs @@ -1,4 +1,4 @@ -using NetMQ; +using NetMQ; using NetMQ.Sockets; using System; using System.Collections; @@ -110,10 +110,12 @@ public class NetMqListener public void SubTopic(string topic) { + Debug.Log("订阅" + topic); subSocket.Subscribe(topic); } public void UnSubtopic(string topic) { + Debug.Log("退出订阅" + topic); subSocket.Unsubscribe(topic); } public void AddToMono(st_Motions st)