DEV Community: Daniel Olivares

Secure Your MQTT Client in C# with Basic Authentication

Daniel Olivares — Fri, 11 Jul 2025 16:33:00 +0000

It’s tempting to use quick examples without credentials, but in a real-world scenario you must authenticate your MQTT client. In this post we’ll show how to add basic authentication in C# and discuss brute-force risks and how to mitigate them.

Basic Authentication Setup

Using the MQTTnet library, simply call .WithCredentials() when building the client options:

using MQTTnet;
using MQTTnet.Client;
using MQTTnet.Client.Options;
using System;
using System.Text;
using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        var options = new MqttClientOptionsBuilder()
            .WithTcpServer("broker.hivemq.com", 1883)
            .WithClientId("dotnet-iot-secure-demo")
            .WithCredentials("myUser", "myStrongPassword") // ← basic authentication
            .Build();

        var factory = new MqttFactory();
        var client = factory.CreateMqttClient();

        client.UseConnectedHandler(async _ =>
        {
            Console.WriteLine("Connected with basic authentication");
            await client.SubscribeAsync("iot/door/status");
        });

        client.UseApplicationMessageReceivedHandler(e =>
        {
            var payload = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
            Console.WriteLine($"Message received: {payload}");
        });

        await client.ConnectAsync(options);
        Console.WriteLine("Press ENTER to exit...");
        Console.ReadLine();
    }
}

Note: Even with username/password, it’s critical that your broker and client use TLS (port 8883) so credentials aren’t sent in plaintext.

Best Practices to Harden Security Strong Passwords

Use ≥16 characters and mix uppercase, lowercase, numbers, and symbols.

Attempt Limiting
Lock out after N failed attempts (e.g., 5 failures → 5-minute lock).

IP Filtering
Restrict connections to trusted IP ranges (e.g., your corporate network).

Enforce TLS
Never transmit credentials in plaintext; require TLS on both client and broker. .WithTls

Credential Rotation
Change usernames/passwords regularly (every 3–6 months).

Monitoring & Alerts
Log failed logins and set up alerts when thresholds are exceeded.

Protege tu cliente MQTT en C# con autenticación básica

Daniel Olivares — Fri, 11 Jul 2025 16:30:54 +0000

Siempre es tentador usar ejemplos rápidos sin credenciales, pero en un escenario real debes autenticar tu cliente MQTT. En este post veremos cómo añadir autenticación básica en C# y hablaremos de los riesgos de fuerza bruta y cómo mitigarlos.

Configuración de autenticación básica

Con la librería MQTTnet, basta con llamar a .WithCredentials() al construir las opciones:

using MQTTnet;
using MQTTnet.Client;
using MQTTnet.Client.Options;
using System;
using System.Text;
using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        var options = new MqttClientOptionsBuilder()
            .WithTcpServer("broker.hivemq.com", 1883)
            .WithClientId("dotnet-iot-secure-demo")
            .WithCredentials("miUsuario", "miContrasenaSegura") // ← autenticación básica
            .Build();

        var factory = new MqttFactory();
        var client = factory.CreateMqttClient();

        client.UseConnectedHandler(async _ =>
        {
            Console.WriteLine("Conectado con autenticación básica");
            await client.SubscribeAsync("iot/door/status");
        });

        client.UseApplicationMessageReceivedHandler(e =>
        {
            var payload = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
            Console.WriteLine($"Mensaje: {payload}");
        });

        await client.ConnectAsync(options);
        Console.WriteLine("Presiona ENTER para salir...");
        Console.ReadLine();
    }
}

Nota: Aunque usas usuario/contraseña, es crucial que tu broker esté configurado para TLS (puerto 8883) si quieres proteger las credenciales en tránsito.

Buenas prácticas para reforzar la seguridad Contraseñas robustas

Usa longitudes ≥16 caracteres, mezcla de mayúsculas, minúsculas, números y símbolos.

Limitación de intentos
Implementa bloqueo temporal tras N intentos fallidos (e.g., 5 intentos = bloqueo 5 min).

Filtrado por IP
Permite conexiones solo desde rangos confiables (por ejemplo, tu red corporativa).

TLS obligatorio
Nunca envíes credenciales en texto plano; configura tu cliente y broker para usar TLS.

var options = new MqttClientOptionsBuilder()
    .WithTcpServer("tu-broker-seguro.com", 8883)   // puerto estándar TLS
    .WithClientId("cliente-seguro-csharp")
    .WithCredentials("usuario", "contraseña")
    .WithTls(new MqttClientOptionsBuilderTlsParameters {
        UseTls = true,
        AllowUntrustedCertificates = false,         // rechaza certs no válidos
        IgnoreCertificateChainErrors = false,
        IgnoreCertificateRevocationErrors = false
    })
    .Build();

Rotación de credenciales
Cambia usuario/contraseña periódicamente (cada 3–6 meses).

Monitorización y alertas
Registra intentos fallidos y configura notificaciones si superan un umbral.

¿Sabías que con C# puedes suscribirte a un broker MQTT en menos de 10 líneas?

Daniel Olivares — Fri, 11 Jul 2025 16:28:08 +0000

Siempre vemos ejemplos de Python o Node.js en IoT, pero la verdad es que C# también es sorprendentemente sencillo, robusto y seguro. En este breve tutorial vamos a:

Conectar nuestro cliente .NET a un broker público (HiveMQ).
Suscribirnos a un tópico (iot/puerta/estado).
Mostrar en consola los mensajes que llegan.

¿Qué necesitás?

.NET 8 SDK
La librería MQTTnet
Un broker MQTT público (usaremos broker.hivemq.com:1883)
¡Ganas de automatizar y experimentar!

Código de ejemplo

using MQTTnet;
using MQTTnet.Client;
using MQTTnet.Client.Options;
using System;
using System.Text;
using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        // 1. Configuramos las opciones del cliente
        var options = new MqttClientOptionsBuilder()
            .WithTcpServer("broker.hivemq.com", 1883)
            .WithClientId("dotnet-iot-demo")
            .Build();

        // 2. Creamos el cliente y definimos handlers
        var factory = new MqttFactory();
        var client = factory.CreateMqttClient();

        client.UseConnectedHandler(async _ =>
        {
            Console.WriteLine("Conectado a HiveMQ");
            await client.SubscribeAsync("iot/puerta/estado");
            Console.WriteLine("Suscrito a: iot/puerta/estado");
        });

        client.UseApplicationMessageReceivedHandler(e =>
        {
            var payload = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
            Console.WriteLine($"Mensaje recibido: {payload}");
            // Aquí podrías, por ejemplo:
            // • Registrar un evento en tu base de datos
            // • Activar una alerta por e-mail o SMS
            // • Enviar la info a un dashboard web
        });

        // 3. Conectamos y esperamos mensajes
        await client.ConnectAsync(options);
        Console.WriteLine("Presioná ENTER para salir...");
        Console.ReadLine();
    }
}

¿Por qué C# + MQTTnet?

Simplicidad: La API es intuitiva y con poco código ya tenés un cliente funcional.
Rendimiento: .NET es rápido y ligero, ideal para apps que corran en Raspberry Pi o Windows IoT.
Seguridad: MQTTnet soporta TLS y autenticación, clave para proteger tu proyect IoT.

¡En el siguiente post veremos como agregar autenticación básica a nuestro proyecto!

Did you know you can subscribe to an MQTT broker with C# in under 10 lines?

Daniel Olivares — Fri, 11 Jul 2025 16:18:59 +0000

We always see Python or Node.js examples in IoT, but C# is just as easy, robust, and secure. In this quick tutorial we will:

Connect our .NET client to a public broker, like: HiveMQ.
Subscribe to a topic: iot/door/status.
Display incoming messages in the console.

What you need

.NET 8 SDK
The MQTTnet library
A public MQTT broker (broker.hivemq.com:1883)
And a willingness to automate and experiment!

Example code

using MQTTnet;
using MQTTnet.Client;
using MQTTnet.Client.Options;
using System;
using System.Text;
using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        // 1. Configure client options
        var options = new MqttClientOptionsBuilder()
            .WithTcpServer("broker.hivemq.com", 1883)
            .WithClientId("dotnet-iot-demo")
            .Build();

        // 2. Create the client and define handlers
        var factory = new MqttFactory();
        var client = factory.CreateMqttClient();

        client.UseConnectedHandler(async _ =>
        {
            Console.WriteLine("Connected to HiveMQ");
            await client.SubscribeAsync("iot/door/status");
            Console.WriteLine("Subscribed to: iot/door/status");
        });

        client.UseApplicationMessageReceivedHandler(e =>
        {
            var payload = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
            Console.WriteLine($"Message received: {payload}");
            // Here you could, for example:
            // • Log the event to your database
            // • Trigger an email or SMS alert
            // • Send the data to a web dashboard
        });

        // 3. Connect and wait for messages
        await client.ConnectAsync(options);
        Console.WriteLine("Press ENTER to exit...");
        Console.ReadLine();
    }
}