BPASmartClient/BPASmartClient.Business/LocalMqtt.cs

using BPA.Message;
using BPASmartClient.MQTT;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace BPASmartClient.Business
{
    public class LocalMqtt 
    {
        private volatile static LocalMqtt _Instance;
        public static LocalMqtt GetInstance => _Instance ?? (_Instance = new LocalMqtt());
        private LocalMqtt() { }

        /// <summary>
        /// 
        /// </summary>
        SendScreenDataModel MqttPushs = new SendScreenDataModel();

        MQTTProxy mQTTProxy = new MQTTProxy();

        ScreenDeviceType LocDeviceType;

        string MQTT_IP;
        string MQTT_PORT;
        string MQTT_USERNAME;
        string MQTT_PASSWORD;

        public void Init(ScreenDeviceType DeviceType)
        {
            MqttPushs.Name = DeviceType;
            LocDeviceType = DeviceType;
            mQTTProxy.Connected = new Action(() =>
            {
                mQTTProxy.Subscrib(ScreenTOPIC.GetInstance.GetTopic(DeviceType)) ;
               
            });
            MQTT_IP = System.Configuration.ConfigurationManager.AppSettings["MQTT_DevieScreem_IP"].ToString();
            MQTT_PORT = System.Configuration.ConfigurationManager.AppSettings["MQTT_DevieScreem_Port"].ToString();
            MQTT_USERNAME = System.Configuration.ConfigurationManager.AppSettings["MQTT_DevieScreem_User"].ToString();
            MQTT_PASSWORD = System.Configuration.ConfigurationManager.AppSettings["MQTT_DevieScreem_Password"].ToString();

            mQTTProxy.Connect(MQTT_USERNAME, MQTT_PASSWORD, MQTT_IP, int.Parse(MQTT_PORT), $"{DeviceType}_设备监听数据{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");//"10.2.1.254""admin", "public"
        }

        public void Start()
        {
            
        }

        

        /// <summary>
        /// MQTT消息推送
        /// </summary>
        /// <param name="topic">主题</param>
        /// <param name="message">消息体</param>
        public void Publish(object message)
        {
            MqttPushs.Value = message;
            mQTTProxy.Publish(ScreenTOPIC.GetInstance.GetTopic(LocDeviceType), JsonConvert.SerializeObject(MqttPushs));
        }
    }
}