Conectividad cliente MQTT con .Net

var options = nuevo MqtClientOptionsBuilder()
.ConClientId("testClientDotNet4")
.ConTcpServer("localhost", 1883)
.Build();
// Crear cliente MQTT
var factory = nuevo MqttFactory();
var mqttClient = factory.CreateMqtClient();
mqttClient.UseConnectedHandler(async e =
{}
Consola.WriteLine("Connected successfully with MQTT broker.");
});
// Conectarse con el corredor MQTT
await mqttClient.ConnectAsync(options);

var options = nuevo MqtClientOptionsBuilder()
.ConClientId("testclient")
.ConTcpServer("localhost", 1883)
.ConCredentials("nombre de usuario", "password") // Agregar nombre de usuario y contraseña
.Build();

var options = nuevo MqtClientOptionsBuilder()
.ConClientId("testcient")
. ConTcpServer(GetHostDesdeAddress(ADDRESS), GetPortDesdeAddress(ADDRESS)
.Contls(nuevo) MqttClientOptionsBuilderTlsParameters
{}
UseTls = verdadero,
Certificados = nueva lista(), // Opcionalmente añadir certificados de cliente aquí
Valor de certificado Handler = context =
{}
// Lógica de validación del certificado de servidor personalizado
contexto de retorno. SslPolicy Errores == System.Net.Security.SslPolicyErrors. Ninguna;
}
AllowUntrustedCertificates = false, // No permita certificados no confiables
IgnoreCertificate ChainErrors = falso, // No ignore los errores de cadena de certificados
IgnoreCertificate Revocación Errores = falsos // No ignore errores de revocación de certificados
})
.Build();

var options = nuevo MqtClientOptionsBuilder()
.ConClientId("testclient")
. ConWebSocketServer("ws://localhost:10443/mqtt") // Use WebSocket server URI
.Build();

var mensaje = nuevo MqtApplicationMessageBuilder()
.ConTema(tema)
.ConPayload($"Hola, MQTT! Número de mensaje {i}")
.ConQualityOfServiceLevel(MqtQualityOfServiceLevel.AtLeastOnce)
.ConRetainFlag()
.Build();
await mqttClient.PublishAsync(message);
await Task.Delay(1000); // Espera 1 segundo

await mqttClient.DisconnectAsync();

usando System.Security.Authentication;
Uso del sistema. Texto;
utilizar MQTTnet;
utilizar MQTTnet.Client;
MQTTnet.Protocol;
Programa de clases
{}
static async Task Main(string[] args)
{}
corredor de cadena = "localhost";
int port = 1883;
cliente de cuerda Id = Guid.NewGuid().ToString();
Tema de cuerda = "sensor/data";
// Crear una fábrica de clientes MQTT
var factory = nuevo MqttFactory();
// Crear una instancia cliente MQTT
var mqttClient = factory.CreateMqtClient();
// Crear opciones de cliente MQTT
var options = nuevo MqtClientOptionsBuilder()
.ConTcpServer(broker, port) // Dirección de corretaje MQTT y puerto
.ConClientId(cliente Id)
.ConCleanSession()
.ConCredentials("nombre de usuario", "password")
// .ConProtocolVersion(MQTTnet.Formatter.MqtProtocolVersion.V500) //si utiliza la versión de mqtt 5
.Build();
// Conectarse con el corredor MQTT
var connectResult = espera mqttClient.ConnectAsync(opciones);
si (conectar Resultado. ResultadoCode == MqtClientConnectResultCode.Success)
{}
Consola.WriteLine("Connected to MQTT broker successfully.");
// Suscribirse a un tema
espera mqttClient. SubscribeAsync(topic);
// Función de devolución cuando se recibe un mensaje
mqttClient.ApplicationMessageRecibidoAsync += e =
{}
Consola.WriteLine($"Recibido mensaje: {Encoding.UTF8.GetString(e.ApplicationMessage.PayloadSegment)}");
Tareas de retorno. Tareas;
};
var mensaje = nuevo MqtApplicationMessageBuilder()
.ConTema(tema)
.ConPayload($"Hola, MQTT!")
.ConQualityOfServiceLevel(MqtQualityOfServiceLevel.AtLeastOnce)
.ConRetainFlag()
.Build();
Consola.WriteLine($"Publishing message: {Encoding.UTF8.GetString(message.PayloadSegment)}");
espera mqttClient. PublishAsync(message);
await Task.Delay(1000); // Espera 1 segundo
// Describir y desconectar
espera mqttClient. UnsubscribeAsync(topic);
await mqttClient.DisconnectAsync();
}
más
{}
Consola.WriteLine($"Failed to connect to MQTT broker: {connectResult.ResultCode}");
}
}
}

dotnet run