yulong
/
NewN_UAVPlane
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

1

This commit is contained in:
王志勋 2024-02-27 17:32:15 +08:00
parent fcce007966
commit c004b28565
5 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
Assets/Temp/Scripts/Judgmentstate.cs
View File

@ -112,6 +112,7 @@ public class Judgmentstate : MonoBehaviour
public void OnLeaveRoom() public void OnLeaveRoom()
{ {
string _msg = "leaveroom "; string _msg = "leaveroom ";
MyNetMQClient.instance._netMqListener.UnSubtopic(GlobalFlag.roomID);
_ = AdamSync.SyncCreateRoom.SendMessageAsync(_msg); _ = AdamSync.SyncCreateRoom.SendMessageAsync(_msg);
} }
} }

1
Assets/Temp/Scripts/Taskpanel.cs
View File

@ -153,6 +153,7 @@ public class Taskpanel : MonoBehaviour
public void OnLeaveRoom() public void OnLeaveRoom()
{ {
string _msg = "leaveroom "; string _msg = "leaveroom ";
MyNetMQClient.instance._netMqListener.UnSubtopic(GlobalFlag.roomID);
_ = AdamSync.SyncCreateRoom.SendMessageAsync(_msg); _ = AdamSync.SyncCreateRoom.SendMessageAsync(_msg);
} }

3
Assets/Temp/Scripts/View_Panel2.cs
View File

@ -259,7 +259,10 @@ public class View_Panel2 : XUIPanel
public void OnJoinRoom(string msg) public void OnJoinRoom(string msg)
{ {
//Debug.Log("OnJoinRoom ViewPanel===" + msg); //Debug.Log("OnJoinRoom ViewPanel===" + msg);
//Debug.Log("订阅"+GlobalFlag.roomID);
MyNetMQClient.instance._netMqListener.SubTopic(GlobalFlag.roomID);
SceneManager.LoadScene("AdamTraining_pilot_terminal_panl 1"); SceneManager.LoadScene("AdamTraining_pilot_terminal_panl 1");
} }
public async void GetAllRoomData() public async void GetAllRoomData()

4
Assets/Zion/Scripts/cxx/LoadManage.cs
View File

@ -1,4 +1,4 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Text; using System.Text;
using UnityEngine; using UnityEngine;
@ -48,7 +48,7 @@ public class LoadManage : MonoBehaviour
} }
}); });
CreateRoomServerClient(string.Format("tcp://{0}:8889", ip), string.Format("tcp://{0}:8888", ip)); 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"); SceneManager.LoadScene("SampleScene");
} }

4
Assets/Zion/Scripts/cxx/NetMqListener.cs
View File

@ -1,4 +1,4 @@
using NetMQ; using NetMQ;
using NetMQ.Sockets; using NetMQ.Sockets;
using System; using System;
using System.Collections; using System.Collections;
@ -110,10 +110,12 @@ public class NetMqListener
public void SubTopic(string topic) public void SubTopic(string topic)
{ {
Debug.Log("订阅" + topic);
subSocket.Subscribe(topic); subSocket.Subscribe(topic);
} }
public void UnSubtopic(string topic) public void UnSubtopic(string topic)
{ {
Debug.Log("退出订阅" + topic);
subSocket.Unsubscribe(topic); subSocket.Unsubscribe(topic);
} }
public void AddToMono(st_Motions st) public void AddToMono(st_Motions st)