Как ИСПОЛЬЗОВАТЬ ПРОСТРАНСТВО ИМЕН СЕТКИ СОБЫТИЙ MQTT HOSTNAME НА ESP32 ИЛИ ESP32 ОНЛАЙН, КАК WOKWI, для отправки таких данных, как температура или влажность, с помощью датчика DHT22

Ниже приведен рабочий пример клиента MQTT ESP32-S3 для публикации нажатой кнопки в теме брокера MQTT Azure Event Grid. Издатель написан с использованием .NET nanoFramework.

using Iot.Device.Button;
using nanoFramework.M2Mqtt;
using nanoFramework.M2Mqtt.Messages;
using nanoFramework.Networking;
using nanoFramework.Runtime.Native;
using System;
using System.Diagnostics;
using System.Security.Cryptography.X509Certificates;
using System.Text;
using System.Threading;

namespace NFAppM5StampS3_MQTT_Broker
{
    public class Program
    {
        static string ssid = "xxxxxx";
        static string password = "xxxxxx";
        //
        static string deviceId = "device2";
        static string username = "device2";
        static string brokerHostName = "xxxxxx.westeurope-1.ts.eventgrid.azure.net";
        static string pub_topic = "abc/test/button";
        //
        static MqttClient device = null;
        static int pinButton = 0;
        

        public static void Main()
        {
            int counter = 0;
            Debug.WriteLine("Hello from nanoFramework!");
            GpioButton buttonM5 = new GpioButton(buttonPin: pinButton);

            try
            {
                #region Connect to WiFi
                CancellationTokenSource cs = new(60000);
                if (WifiNetworkHelper.ScanAndConnectDhcp(ssid, password, requiresDateTime: true, token: cs.Token))
                    Debug.WriteLine($"Wifi ready - {ssid}");
                else
                    throw new Exception($"Wifi is not connected.");
                #endregion

                #region MQTT Connection
                var clientCert = new X509Certificate2(client_cert, client_key, "");
                device = new MqttClient(brokerHostName, 8883, true, null, clientCert, MqttSslProtocols.TLSv1_2);
                device.ProtocolVersion = MqttProtocolVersion.Version_5;
                device.Settings.ValidateServerCertificate = false;  //no CA signed server! 
                var ret = device.Connect(deviceId, username, "");
                if (ret != MqttReasonCode.Success)
                {
                    Debug.WriteLine($"MQTT ERROR connecting: {ret}");
                    device.Disconnect();
                    throw new Exception("Device failed to connect it");
                }
                Debug.WriteLine(">>> Device is connected");
                #endregion
            }
            catch (Exception ex)
            {
                Debug.WriteLine(ex.InnerException?.Message ?? ex.Message);
                Thread.Sleep(5000);
                Power.RebootDevice();
            }

            #region ButtonPress          
            buttonM5.Press += (sender, e) =>
            {
                Debug.WriteLine("The Button has been pressed");
                string payload = $"{{\"counter\":{counter++}}}";
                device.Publish(pub_topic, Encoding.UTF8.GetBytes(payload), "application/json; charset=utf-8", null);
            };
            #endregion

            Thread.Sleep(Timeout.Infinite);            
        }

        #region Certificates
        private const string client_cert = @"-----BEGIN CERTIFICATE-----
.....
-----END CERTIFICATE-----";

        private const string client_key = @"-----BEGIN EC PRIVATE KEY-----
....
-----END EC PRIVATE KEY-----";
        #endregion
    }
}

В следующем фрагменте экрана показан клиентский инструмент MQTTx подписчика с получением по теме, где кнопка опубликовала сообщение:

а следующий фрагмент экрана показывает сообщения сетки событий, полученные по этой теме и перенаправленные подписчикам AEG.

Отметим, что получение телеметрических данных с датчиков — это несложная работа. Его можно публиковать в AEG MQTT Broker по таймеру каждую минуту.

Обновлять:

Ниже приведен файл packages.config, используемый в приведенном выше коде:

<?xml version = "1.0" encoding = "utf-8"?>
<packages>
  <package id = "nanoFramework.CoreLibrary" version = "1.15.5" targetFramework = "netnano1.0" />
  <package id = "nanoFramework.Iot.Device.Button" version = "1.2.536" targetFramework = "netnano1.0" />
  <package id = "nanoFramework.M2Mqtt" version = "5.1.123" targetFramework = "netnano1.0" />
  <package id = "nanoFramework.Runtime.Events" version = "1.11.15" targetFramework = "netnano1.0" />
  <package id = "nanoFramework.Runtime.Native" version = "1.6.12" targetFramework = "netnano1.0" />
  <package id = "nanoFramework.System.Collections" version = "1.5.31" targetFramework = "netnano1.0" />
  <package id = "nanoFramework.System.Device.Gpio" version = "1.1.38" targetFramework = "netnano1.0" />
  <package id = "nanoFramework.System.Device.Wifi" version = "1.5.81" targetFramework = "netnano1.0" />
  <package id = "nanoFramework.System.IO.Streams" version = "1.1.59" targetFramework = "netnano1.0" />
  <package id = "nanoFramework.System.Net" version = "1.10.77" targetFramework = "netnano1.0" />
  <package id = "nanoFramework.System.Text" version = "1.2.54" targetFramework = "netnano1.0" />
  <package id = "nanoFramework.System.Threading" version = "1.1.32" targetFramework = "netnano1.0" />
</packages>