From 036ce5eaab6126560cf9ca19b4a2783d42c2e191 Mon Sep 17 00:00:00 2001
From: ningshuxia <ningshuxia0927@outlook.com>
Date: 星期四, 23 二月 2023 17:44:52 +0800
Subject: [PATCH] SQI 常规和振动测点客户端
---
Mqtt/IStation.DataDockingMqtt4SQI/Program.cs | 141 ++---------------------------------------------
1 files changed, 6 insertions(+), 135 deletions(-)
diff --git a/Mqtt/IStation.DataDockingMqtt4SQI/Program.cs b/Mqtt/IStation.DataDockingMqtt4SQI/Program.cs
index 562fcf7..ebbba91 100644
--- a/Mqtt/IStation.DataDockingMqtt4SQI/Program.cs
+++ b/Mqtt/IStation.DataDockingMqtt4SQI/Program.cs
@@ -1,4 +1,5 @@
-锘縰sing MQTTnet;
+锘縰sing IStation.DataDockingMqtt4SQI_DEMO;
+using MQTTnet;
using MQTTnet.Client.Connecting;
using MQTTnet.Client.Options;
using MQTTnet.Client.Receiving;
@@ -17,143 +18,13 @@
static void Main(string[] args)
{
Console.WriteLine("鍚姩 涓婃捣璐ㄦ鎵� MQTT!");
-
- Connect();
-
+ /*Mqtt1.Connect();
+ Mqtt2.Connect();*/
+ Mqtt.Connect();
Console.ReadLine();
}
-
-
- static string TopicName = "MK-S906/up/Data/SHHM22100001";
- static string MqttUserName = "test";
- static string MqttUserPwd = "123456";
- static string MqttHostAdress = "106.14.83.94";
- static int MqttHostPort = 8810;
-
- static async void Connect()
- {
- //string info = "{\"GW_MAC\":\"0080E10A4D34\",\"GW_IMEI\":\"867542055972080\",\"ICCID\":\"898608022221C0013505\",\"csq\":31,\"sensor\":{\"ID\":\"22100005\",\"name\":\"22100005\",\"rssi\":-29,\"battery\":100,\"type\":\"N\",\"data\":{\"value\":[32],\"unit\":[\"dB\"]},\"time\":1677072683,\"alarm\":\"N\"}}";
- //IStation.UserDto.MqttMsg data = JsonHelper.Json2Object<IStation.UserDto.MqttMsg>(info);
-
- //if (data != null && data.sensor != null)
- //{
- // var t = data.sensor.GetTime();
- //}
-
-
-
- // 杩炴帴鍒癕QTT鏈嶅姟鍣�
- IManagedMqttClient _mqttClient = new MqttFactory().CreateManagedMqttClient();
- _mqttClient.ConnectedHandler = new MqttClientConnectedHandlerDelegate(e =>
- {
- Console.WriteLine("閾炬帴 MQTT 鏈嶅姟鍣ㄦ垚鍔�!");
- });
- _mqttClient.ConnectingFailedHandler = new ClientConnectingFaildHandler(e =>
- {
- Console.WriteLine("閾炬帴 MQTT 鏈嶅姟鍣ㄥけ璐�!");
- });
- _mqttClient.UseDisconnectedHandler(ee =>
- {
- Console.WriteLine("閾炬帴 MQTT 鏈嶅姟鍣ㄦ柇寮�杩炴帴!");
- });
- _mqttClient.UseConnectedHandler(ee =>
- {
- Console.WriteLine("閾炬帴 MQTT 杩炴帴鍒版湇鍔�!");
- });
- //client.DisconnectedHandler
- _mqttClient.ApplicationMessageReceivedHandler = new MqttApplicationMessageReceivedHandlerDelegate(Client_ApplicationMessageReceived);
-
-
- IMqttClientOptions clientOptions = new MqttClientOptionsBuilder()
- .WithClientId("EventechDemo01")
- .WithTcpServer(MqttHostAdress, MqttHostPort)
- .WithCredentials(MqttUserName, MqttUserPwd)
- .WithCleanSession(false)//false 鎺ユ敹绂荤嚎娑堟伅 鏈嶅姟绔渶瑕佸惎鐢ㄤ箣涔呬細璇� WithPersistentSessions
- //.WithWillMessage(new MqttApplicationMessage { Topic = "ooo", Payload = Encoding.UTF8.GetBytes("涓嬬嚎閫氱煡"), Retain = true })
- .WithWillDelayInterval(1)
- .Build();
- IManagedMqttClientOptions options = new ManagedMqttClientOptionsBuilder()
- .WithAutoReconnectDelay(TimeSpan.FromSeconds(5))
- .WithClientOptions(clientOptions)
- .Build();
-
- await _mqttClient.StartAsync(options);// 寮傛杩炴帴鍒版湇鍔″櫒
-
-
- // 璁㈤槄涓婚杩囨护鍣�
- MqttTopicFilter topicFilter = new MqttTopicFilterBuilder()
- .WithTopic(TopicName)// 涓婚
- .WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce)
- .Build();
- await _mqttClient.SubscribeAsync(topicFilter);
- //client.UnsubscribeAsync()
-
-
- //await Task.Delay(1000);
- //// 鍙戝竷锛堬級 TCP 鐐瑰鐐�
- //// 閽堝鏌愪釜涓婚鍙戝竷 闇�瑕佹寚瀹氫富棰�
- //// 閽堝杩欎釜涓婚鐨勫唴瀹癸紙璐熻浇锛�
- //string msg = "Hello Eventech";
- //MqttApplicationMessage message = new MqttApplicationMessageBuilder()
- // .WithTopic("test")
- // .WithPayload(Encoding.Default.GetBytes(msg))
- // .WithRetainFlag(false)
- // .Build();
- //await client.PublishAsync(message);
- }
-
- // 鍝嶅簲璁㈤槄涓婚鐨勬秷鎭�
- static void Client_ApplicationMessageReceived(MqttApplicationMessageReceivedEventArgs e)
- {
- if (e.ApplicationMessage == null)
- return;
- Console.WriteLine(">>> 鏀跺埌娑堟伅:" + e.ApplicationMessage.ConvertPayloadToString());// + ",鏉ヨ嚜瀹㈡埛绔�" + e.ClientId + ",涓婚:" + e.ApplicationMessage.Topic);
- //try
- //{
- // {Encoding.UTF8.GetString(ee.ApplicationMessage.Payload)}");
- //}
- //catch { }
-
- var data = JsonHelper.Json2Object<IStation.UserDto.MqttMsg>(e.ApplicationMessage.ConvertPayloadToString());
- if(data != null && data.sensor != null && data.sensor.data != null && data.sensor.data.value != null
- && data.sensor.data.value.Count>0)
- {
- //1620681990539972608 杩涘彛鍘嬪姏
- //1620682095074611200 鍑哄彛鍘嬪姏
- //1620682379477782528 娓╁害
- //1620682549540032512 鍑哄彛鐬椂娴侀噺
- //1620684539431096320 鍣０
- IStation.Model.MonitorDataDockingSrcRecord r = new Model.MonitorDataDockingSrcRecord();
- r.RecordType = Model.eMonitorType.General;
- r.SrcTime = data.sensor.GetTime();
- //DateTime.Now;
- r.SrcValue = data.sensor.data.value[0].ToString();
-
- var id = data.sensor.ID;
- if(id == "22100004")
- {//娴侀噺
- r.SignId = "1620682549540032512";
- HandleDataHelper.Add(r);
- }
- if (id == "22100002")
- {//鍑哄彛鍘嬪姏
- r.SignId = "1620682095074611200";
- HandleDataHelper.Add(r);
- }
- if (id == "22100005")
- {//鍣煶
- r.SignId = "1620684539431096320";
- HandleDataHelper.Add(r);
- }
- if (id == "22100003")
- {//娓╁害
- r.SignId = "1620682379477782528";
- HandleDataHelper.Add(r);
- }
- }
- }
}
-
+
class ClientConnectingFaildHandler : IConnectingFailedHandler
{
Action<ManagedProcessFailedEventArgs> action;
--
Gitblit v1.9.3