после некоторого исследования у меня наконец-то появился рабочий код для отправки MQTT-сообщения на тестовый сервер MQTT от комаров
var mqttClient = factory.CreateMqttClient();
var options = new MqttClientOptionsBuilder()
.WithTcpServer("test.mosquitto.org", 1883)
.WithClientId("client123")
.Build();
await mqttClient.ConnectAsync(options);
Main account = new Account
{
Email = "test@example.com",
Active = true,
CreatedDate = new DateTime(2013, 1, 20, 0, 0, 0, DateTimeKind.Utc),
Roles = new List<string>
{
"User",
"Admin"
}
};
string json = JsonConvert.SerializeObject(account, Formatting.Indented);
var message = new MqttApplicationMessageBuilder()
.WithTopic("MyTopic")
.WithPayload(json)
.WithExactlyOnceQoS()
.WithRetainFlag()
.Build();
await mqttClient.PublishAsync(message);
Console.WriteLine("press return to carry on");
Console.ReadLine();
Мой следующий шаг - подписаться и опубликовать тему в AWS IoT сTLS.
Я знаю, что должен использовать (в MqttClientOptionsBuilder)
.WithTls()
, но я не уверен, как указать, какой сертификат использовать для аутентификации с
Любая помощь будетцениться