55 lines
1.4 KiB
C#
55 lines
1.4 KiB
C#
using UnityEngine;
|
|
using UVC.Data;
|
|
using UVC.Data.Mqtt;
|
|
using UVC.Network;
|
|
|
|
public class WebGLSample : MonoBehaviour
|
|
{
|
|
private string domain = "localhost";//"simulator.flexing.ai";
|
|
private int port = 1883;
|
|
private bool useWebSocket = false;
|
|
private bool useTLS = false;
|
|
|
|
void Start()
|
|
{
|
|
|
|
//#if UNITY_WEBGL && !UNITY_EDITOR
|
|
port = 8083;
|
|
useWebSocket = true;
|
|
//#endif
|
|
|
|
//TestMqttReceiver();
|
|
TestMQTTService();
|
|
|
|
}
|
|
|
|
private void TestMqttReceiver()
|
|
{
|
|
var mqttConfig = new MqttSubscriptionConfig("#");
|
|
mqttConfig.SetHandler((dataObject) =>
|
|
{
|
|
if (dataObject != null)
|
|
{
|
|
Debug.Log($"WebGLSample MqttReceiver: {dataObject.ToString()}");
|
|
}
|
|
});
|
|
|
|
DataRepository.Instance.MqttReceiver.SetDomainPort(domain, port);
|
|
DataRepository.Instance.MqttReceiver.SetUseWebSocket(useWebSocket);
|
|
DataRepository.Instance.MqttReceiver.SetUseTLS(useTLS);
|
|
DataRepository.Instance.MqttReceiver.Add(mqttConfig);
|
|
DataRepository.Instance.MqttReceiver.Start();
|
|
}
|
|
|
|
private void TestMQTTService()
|
|
{
|
|
var mqttService = new MQTTService(domain, port, useWebSocket, useTLS);
|
|
mqttService.AddTopicHandler("#", (topic, message) =>
|
|
{
|
|
Debug.Log($"WebGLSample MQTTService. Topic:{topic}, Message:{message}");
|
|
});
|
|
mqttService.Connect();
|
|
}
|
|
|
|
}
|