MQTT Client Connectivity mit .Net

mqtClient.UseDisconnectedHandler(async e =>
(STÖHNT)
Console.WriteLine("Disconnected from MQTT broker.");
// Optionale Handhabe hier die Reconnection-Logik
})
mqtClient.DisconnectAsync();

mit System;
mit System. Sammlungen. Generisch;
Verwendung System.Security.Cryptography.X509Certificates;
mit System. Text:
mit System. Threading. Aufgaben;
mit MQTTnet;
mit MQTTnet.Client
Klasse Programm
{\cHFFFF}
statischer Async Task Main(string[] args)
{\cHFFFF}
// Root-Zertifikat laden
//var rootCert = new X509Certificate2("path_of_the_root_file");
// MQTT Client Optionen konfigurieren
var Optionen = neue MqtClientOptionenBuilder()
. MitClientId(GenerateClientId("kristallmq_",10))
. MitTcpServer("public-mqtt-broker.bevywise.com", 1883) // TLS-Änderung aktivieren Hafen 8883
//.WithWebSocketServer("ws://public-mqtt-broker.bevywise.com:10443/mqtt") // Verwenden Sie WebSocket Server URI und aktivieren Sie TLS Änderung Port 11443
// .WithCredentials("username", "password") // Benutzername und Passwort hinzufügen
//
// .WithTls(neue MqtClientOptionenBuilderTlsParameter
~
// UseTls = true,
// Zertifikate = neue ListeWurzeln Cer
// LassenUntrusted Zertifikate = true, // Deaktivierte Zertifikatskette ANHANG
// IgnorierenCertificate ChainErrors = true, // Ignorieren der Zertifikatskette Fehler
// IgnorierenZertifikat Revokation Fehler = true // Ignorieren von Zertifikat Ich bin nicht da.
//
.Build();
// MQTT-Client erstellen
var factory = new MqttFactory();
var mqtClient = factory.CreateMqttClient();
// Client-Events ausschalten
mqtClient.ConnectedAsync += async e=>
(STÖHNT)
Console.WriteLine('Connected erfolgreich mit MQTT Broker.");
Ein Das ist ein Thema
Warten Sie mqtClient. SubscribeAsync(neu MqttClientSubscribeOptionenBuilder(). MitTopicFilter(f) f.WithTopic("cmq/topic")).Build());
Console.WriteLine("Beschrieben zum Thema".
// Mitteilungen veröffentlichen
var message = new MqttApplicationMessageBuilder()
.WithTopic("cmq/topic")
.WithPayload("Hello CrystalMQ")
.Build();
warten mqtClient.PublishAsync(message);
Console.WriteLine("Message veröffentlicht.");
};
mqtClient.DisconnectedAsync += async e =>
(STÖHNT)
Console.WriteLine("Disconnected from MQTT Broker.");
erwartete Aufgabe.Delay(TimeSpan.FromSeconds(5));
Das ist doch alles.
(STÖHNT)
mqtClient.ConnectAsync(Optionen);
}
Fangmenge
(STÖHNT)
Console.WriteLine("Reconnecting fail.");
}
};
mqtClient.ApplicationMessageReceivedAsync += e =>
(STÖHNT) Console.WriteLine($"Received message: {System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}");
zurück zur Übersicht In den Warenkorb
};
// Anschluss an den MQTT-Broker
mqtClient.ConnectAsync(Optionen);
Englisch Sie haben die Möglichkeit
Console.WriteLine("Druckgeschmack zum Aussteigen");
Konsole.ReadLine();
In den Warenkorb Id(String Prefix, Int Länge)
(STÖHNT)
const string chars = „ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789“;
var random = new Random();
var random Chars = neue Char[Länge];
für (in i = 0; i < Länge; i++)
(STÖHNT)
randomChars[i] = chars[random.Next(chars.Length)];
}
zurück Präfix + neue Zeichenkette(randomChars);
}
}

mit System;
mit System. Sammlungen. Generisch;
Verwendung System.Security.Cryptography.X509Certificates;
mit System. Text:
mit System. Threading. Aufgaben;
mit MQTTnet;
mit MQTTnet.Client;
Klasse Programm
{\cHFFFF}
statischer Async Task Main(string[] args)
{\cHFFFF}
var Optionen = neue MqtClientOptionenBuilder()
. MitClientId(GenerateClientId("kristallmq_",10))
. MitTcpServer("public-mqtt-broker.bevywise.com", 1883)
//.WithWebSocketServer("ws://public-mqtt-broker.bevywise.com:10443/mqtt")
// .WithCredentials("username", "password") // Benutzername und Passwort hinzufügen
. MitProtocolVersion(MQTTnet.Formatter.MqttProtocolVersion.V500) //wenn Sie mqtt-Version verwenden 5. Anmerkung: TLS aktivieren ist nicht Unterstützung Version 5
.Build();
// MQTT-Client erstellen
var factory = new MqttFactory();
var mqtClient = factory.CreateMqttClient();
// Client-Events ausschalten
mqtClient.ConnectedAsync += async e =>
{\cHFFFF}
Console.WriteLine('Connected erfolgreich mit MQTT Broker.");
// Ein Thema eintragen
warten mqtClient.SubscribeAsync(neu MqttClientSubscribeOptionenBuilder(). MitTopicFilter(f => f.WithTopic("cmq/topic")).Build());
Console.WriteLine("Beschrieben zum Thema.");
// Mitteilung veröffentlichen
var message = new MqttApplicationMessageBuilder()
.WithTopic("cmq/topic")
.WithPayload("Hello CMQ")
. MitQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce)
.WithRetainFlag(true)
.Build();
warten mqtClient.PublishAsync(message);
Console.WriteLine("Message veröffentlicht.");
};
mqtClient.DisconnectedAsync += async e =>
{\cHFFFF} Console.WriteLine("Disconnected from MQTT Broker.");
erwarten Task.Delay(TimeSpan.FromSeconds(5));
Versuch
{\cHFFFF}
warten mqtClient.ConnectAsync(Optionen);
}
Fangmenge
{\cHFFFF}
Console.WriteLine("Reconnecting fail.");
}
};
mqtClient.ApplicationMessageReceivedAsync += e =>
{\cHFFFF}
Console.WriteLine($"Received message: {System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}");
zurück Task.Komplett Aufgabe
};
// Anschluss an den MQTT-Broker
warten mqtClient.ConnectAsync(Optionen);
// Halten Sie die Anwendung laufen
Console.WriteLine("Drucktaste zum Aussteigen");
Konsole.ReadLine();
Private statische String GenerateClientId(String Prefix, Int Länge)
{\cHFFFF}
const string chars = „ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789“;
var random = new Random();
var random Chars = neue Char[Länge];
für (in i = 0; i < Länge; i++)
{\cHFFFF}
randomChars[i] = chars[random.Next(chars.Length)];
}
zurück Präfix + neue Zeichenkette(randomChars);
}
}

Das ist nicht möglich.

wohnzimmer