GHZMRNavigatorProXR/Assets/Scripts/Blue/Test/MQTTTest.cs

using System.Collections.Generic;
using Blue;
using UnityEngine;
using uPLibrary.Networking.M2Mqtt.Messages;

public class MQTTTest : AbstractController
{
    private List<string> topics = new List<string>()
    {
        "client/manage",
        "client/mqttx_d4c106a3",
        "client/mqttx_b4c02ddc",
        "client/mqttx_ab869d21"
    };
    private string[] topicSub = new string[4]
    {
        "client/manage",
        "client/mqttx_d4c106a3",
        "client/mqttx_b4c02ddc",
        "client/mqttx_ab869d21"
    };
    private IMQTTService mQTTService;
/*
1883	MQTT 协议端口
8883	MQTT/SSL 端口
8083    MQTT/WebSocket 端口
8080    HTTP API 端口
18083   Dashboard 管理控制台端口
*/
    private void Start()
    {
        mQTTService = this.GetService<IMQTTService>();
        mQTTService.brokerAddress = "api-fat1.ghz-tech.com";
        mQTTService.brokerPort = 1883;
        mQTTService.mqttUserName = "u@unity3";
    }
    void Update()
    {
        mQTTService.Update();

        if(Input.GetKeyDown(KeyCode.A))
        {
            mQTTService.SubscribeTopics(topicSub, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE , MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE , MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
        }
        else if(Input.GetKeyDown(KeyCode.S))
        {
            mQTTService.UnsubscribeTopics(topicSub);
        }

        if(Input.GetKeyDown(KeyCode.D))
        {
            mQTTService.Connect();
        }

        if(Input.GetKeyDown(KeyCode.Q))
        {
            this.SendCommand(new MQTTCommand(topics[0],"KeyCode.Q"));
        }
        else if(Input.GetKeyDown(KeyCode.W))
        {
            this.SendCommand(new MQTTCommand(topics[1],"KeyCode.W"));
        }
        else if(Input.GetKeyDown(KeyCode.E))
        {
            this.SendCommand(new MQTTCommand(topics[2],"KeyCode.E"));
        }
        else if(Input.GetKeyDown(KeyCode.R))
        {
            this.SendCommand(new MQTTCommand(topics[3],"KeyCode.R"));
        }
    }
    private void OnApplicationQuit()
    {
        mQTTService.OnApplicationQuit();
    }
}