Conectividad cliente MQTT con .Net

mqttClient.UseDisconnectedHandler(async e =
{}
Consola.WriteLine("Disconnected from MQTT broker.");
// Opcionalmente, maneje la lógica de reconexión aquí
});
await mqttClient.DisconnectAsync();

mediante el Sistema;
usando System. Colecciones. Genérico;
utilizando System.Security.Cryptography.X509Certificates;
usando System. Texto;
usando System. Continúo. Tareas;
utilizar MQTTnet;
usando MQTTnet.Client
Programa de clases
{}
static async Task Main(string[] args)
{}
// Cargar el certificado raíz
//var rootCert = nuevo X509Certificate2("path_of_the_root_file");
// Configurar las opciones del cliente MQTT
var options = nuevo MqtClientOptionsBuilder()
. ConClientId(GenerateClientId("crystalmq_",10))
. ConTcpServer("public-mqt-broker.bevywise.com", 1883) // Activar TLS cambiar puerto 8883
//.ConWebSocketServer("ws://public-mqtt-broker.bevywise.com:10443/mqtt") // Utilice WebSocket servidor URI y Habilitar TLS cambiar puerto 11443
// .ConCredentials("nombre de usuario", "password") // Agregar nombre de usuario y contraseña
//
// .ConTls(nuevo MqttClientOptionsBuilderTlsParameters
/ {
// UseTls = verdadero,
// Certificados = nueva lista{ rootCert},
// Permiso no confiadoCertificates = verdadero, // Cadena de certificados deshabilitables validación
// IgnoreCertificate ChainErrors = verdadero, // Ignorar la cadena de certificados Errores
// IgnoreCertificate Errores de revocación = verdadero // Certificado de diagnóstico errores de revocación
}
.Build();
// Crear cliente MQTT
var factory = nuevo MqttFactory();
var mqttClient = factory.CreateMqtClient();
// Eventos del cliente
mqttClient.ConnectedAsync += async e =
{}
Consola.WriteLine("Connected successfully with MQTT Broker.");
// Suscribirse a un tema
await mqttClient.SubscribeAsync(new MqttClientSubscribeOptionsBuilder(). ConTopicFilter(f = confianza f.WithTopic("cmq/topic")).Build());
Consola.WriteLine("Suscrito al tema.");
// Publicar un mensaje
var mensaje = nuevo MqtApplicationMessageBuilder()
.ConTema("cmq/topic")
.ConPayload("Hola CrystalMQ")
.Build();
await mqttClient.PublishAsync(message);
Consola.WriteLine("Message published.");
};
mqttClient.DisconnectedAsync += async e =
{}
Consola.WriteLine("Disconnected from MQTT Broker.");
await Task.Delay(TimeSpan.fromSeconds(5));
Pruebe
{}
await mqttClient.ConnectAsync(options);
}
captura
{}
Consola.WriteLine("Reconnecting failed.");
}
};
mqttClient.ApplicationMessageRecibidoAsync += e =
{} Consola.WriteLine($"Recibido mensaje: {System.Text.Encoding.UTF8.GetString(e.ApplicationMesage.Payload)}");
Tareas de retorno. Tareas;
};
// Conectarse con el corredor MQTT
await mqttClient.ConnectAsync(options);
// Mantenga la aplicación en funcionamiento
Consola.WriteLine("Press key to exit");
Consola.ReadLine();
cadena estática privada GenerateClient Id (prefijo de cuerda, longitud de entrada)
{}
const string chars = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
var random = nuevo Random();
Var al azar Chars = new char[length];
para (int i = 0; i)
{}
randomChars[i] = chars[random.Next(chars.Length)];
}
volver prefijo + nueva cadena (cámaras de la sabiduría);
}
}

mediante el Sistema;
usando System. Colecciones. Genérico;
utilizando System.Security.Cryptography.X509Certificates;
usando System. Texto;
usando System. Continúo. Tareas;
utilizar MQTTnet;
usando MQTTnet.Client;
Programa de clases
{}
static async Task Main(string[] args)
{}
var options = nuevo MqtClientOptionsBuilder()
. ConClientId(GenerateClientId("crystalmq_",10))
. ConTcpServer("public-mqt-broker.bevywise.com", 1883)
//.ConWebSocketServer("ws://public-mqtt-broker.bevywise.com:10443/mqtt")
// .ConCredentials("nombre de usuario", "password") // Agregar nombre de usuario y contraseña
. ConProtocolVersion(MQTTnet.Formatter.MqtProtocolVersion.V500) //si usted use la versión mqtt 5. nota: TLS no admite la versión 5
.Build();
// Crear cliente MQTT
var factory = nuevo MqttFactory();
var mqttClient = factory.CreateMqtClient();
// Eventos del cliente
mqttClient.ConnectedAsync += async e =
{}
Consola.WriteLine("Connected successfully with MQTT Broker.");
// Suscribirse a un tema
await mqttClient.SubscribeAsync(new MqttClientSubscribeOptionsBuilder(). ConTopicFilter(f = confianza f.WithTopic("cmq/topic")).Build());
Consola.WriteLine("Suscrito al tema.");
// Publicar un mensaje
var mensaje = nuevo MqtApplicationMessageBuilder()
.ConTema("cmq/topic")
.ConPayload("Hola CMQ")
. ConQualityOfServiceLevel(MQTTnet.Protocol.MqtQualityOfServiceLevel.ExactlyOnce)
.ConRetainFlag(verdad)
.Build();
await mqttClient.PublishAsync(message);
Consola.WriteLine("Message published.");
};
mqttClient.DisconnectedAsync += async e =
{} Consola.WriteLine("Disconnected from MQTT Broker.");
await Task.Delay(TimeSpan.fromSeconds(5));
Pruebe
{}
await mqttClient.ConnectAsync(options);
}
captura
{}
Consola.WriteLine("Reconnecting failed.");
}
};
mqttClient.ApplicationMessageRecibidoAsync += e =
{}
Consola.WriteLine($"Recibido mensaje: {System.Text.Encoding.UTF8.GetString(e.ApplicationMesage.Payload)}");
Tareas de retorno. Tareas;
};
// Conectarse con el corredor MQTT
await mqttClient.ConnectAsync(options);
// Mantenga la aplicación en funcionamiento
Consola.WriteLine("Press key to exit");
Consola.ReadLine();
cadena estática privada GenerateClientId (prefijo de cuerda, longitud de entrada)
{}
const string chars = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
var random = nuevo Random();
Var random Chars = new char[length];
para (int i = 0; i)
{}
randomChars[i] = chars[random.Next(chars.Length)];
}
volver prefijo + nueva cadena (cámaras de la sabiduría);
}
}

dotnet run

dotnet build