저장
This commit is contained in:
@@ -19,6 +19,8 @@ namespace Studio
|
|||||||
public class StudioRepoistory
|
public class StudioRepoistory
|
||||||
{
|
{
|
||||||
private MQTTClient client;
|
private MQTTClient client;
|
||||||
|
|
||||||
|
public bool isMQTTConnected;
|
||||||
public bool isConnected
|
public bool isConnected
|
||||||
{
|
{
|
||||||
get
|
get
|
||||||
@@ -33,7 +35,10 @@ namespace Studio
|
|||||||
public StudioRepoistory()
|
public StudioRepoistory()
|
||||||
{
|
{
|
||||||
Debug.Log($"11MQTT Domain{Constants.MQTTDomain} , MQTTPORT{Constants.MQTTPort}");
|
Debug.Log($"11MQTT Domain{Constants.MQTTDomain} , MQTTPORT{Constants.MQTTPort}");
|
||||||
MQTTCreateConnect();
|
if (isMQTTConnected)
|
||||||
|
{
|
||||||
|
MQTTCreateConnect();
|
||||||
|
}
|
||||||
Application.quitting += OnDestroy;
|
Application.quitting += OnDestroy;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -6,6 +6,7 @@ using System.Threading.Tasks;
|
|||||||
using UnityEngine;
|
using UnityEngine;
|
||||||
using Studio;
|
using Studio;
|
||||||
using Studio.Core;
|
using Studio.Core;
|
||||||
|
using Studio.Conifg;
|
||||||
|
|
||||||
namespace Studio
|
namespace Studio
|
||||||
{
|
{
|
||||||
@@ -23,11 +24,6 @@ namespace Studio
|
|||||||
|
|
||||||
public class StudioService : UnitySingleton<StudioService>
|
public class StudioService : UnitySingleton<StudioService>
|
||||||
{
|
{
|
||||||
#region Singleton
|
|
||||||
|
|
||||||
|
|
||||||
#endregion
|
|
||||||
|
|
||||||
private Dictionary<string, Dictionary<string, EventHandler<StudioServiceTypeEventArgs>>> listenerIdMap;
|
private Dictionary<string, Dictionary<string, EventHandler<StudioServiceTypeEventArgs>>> listenerIdMap;
|
||||||
private StudioRepoistory repository;
|
private StudioRepoistory repository;
|
||||||
public bool isConnected
|
public bool isConnected
|
||||||
@@ -59,6 +55,20 @@ namespace Studio
|
|||||||
|
|
||||||
bool isMQTTConnected;
|
bool isMQTTConnected;
|
||||||
|
|
||||||
|
private void Awake()
|
||||||
|
{
|
||||||
|
this.repository = new StudioRepoistory();
|
||||||
|
listenerIdMap = new Dictionary<string, Dictionary<string, EventHandler<StudioServiceTypeEventArgs>>>();
|
||||||
|
|
||||||
|
repository.OnTopicList += OnTopicList;
|
||||||
|
|
||||||
|
Constants.MQTTDomain = "220.90.135.190";
|
||||||
|
Constants.APIDomain = "220.90.135.190";
|
||||||
|
Constants.APIPort = 23000;
|
||||||
|
Constants.MQTTPort = 8088;
|
||||||
|
ConnectMQTT();
|
||||||
|
}
|
||||||
|
|
||||||
//private string
|
//private string
|
||||||
private StudioService(StudioRepoistory repository)
|
private StudioService(StudioRepoistory repository)
|
||||||
{
|
{
|
||||||
@@ -73,11 +83,8 @@ namespace Studio
|
|||||||
if (isMQTTConnected)
|
if (isMQTTConnected)
|
||||||
return;
|
return;
|
||||||
|
|
||||||
this.repository = new StudioRepoistory();
|
|
||||||
listenerIdMap = new Dictionary<string, Dictionary<string, EventHandler<StudioServiceTypeEventArgs>>>();
|
|
||||||
|
|
||||||
repository.OnTopicList += OnTopicList;
|
|
||||||
repository.MQTTConnect();
|
repository.MQTTConnect();
|
||||||
|
repository.isMQTTConnected = true;
|
||||||
isMQTTConnected = true;
|
isMQTTConnected = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -51,7 +51,7 @@ namespace Studio
|
|||||||
|
|
||||||
Constants.MQTTDomain = InputField_Domain.text;
|
Constants.MQTTDomain = InputField_Domain.text;
|
||||||
Constants.MQTTPort = int.Parse(InputField_Port.text);
|
Constants.MQTTPort = int.Parse(InputField_Port.text);
|
||||||
StudioService.instance.ConnectMQTT();
|
//StudioService.instance.ConnectMQTT();
|
||||||
|
|
||||||
foreach (UI_InputTopicItem item in inputTopicItems)
|
foreach (UI_InputTopicItem item in inputTopicItems)
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user