DM-Tech.Library.MDM 1.1.3

Library MDM

Descrição

Pacote para integração com o sistema MDM através do protocolo MQTT.

Dependências

• MQTTnet

Deploy

Requisitos

• Variável de ambiente API_KEY_GITHUB_NUGET com a chave de acesso do Github

Publicar pacote no Nuget

# Substituir x.x.x pela versão desejada
bash publish.sh x.x.x

Se a versão for diferente do LibraryMDM.csproj, ele irá atualizar o arquivo e commitar automaticamente.

Como usar?

Instalação

dotnet add package DM-Tech.Library.MDM --version x.x.x

Configuração

using LibraryMDM.Client;

MdmConfiguration.Server = "localhost";
MdmConfiguration.Port = 1883;
MdmConfiguration.Username = "lucas";
MdmConfiguration.Password = "secret";
MdmConfiguration.ClientId = "lucas";

Exemplo de uso

// Publisher
Console.WriteLine("Starting console sender...");
Console.WriteLine("Press ESC to exit.");

while (true)
{
    var client = new Mdm();
    
    await client.OnConnectedAsync();

    await client.PublishAsync("samples/guid", "Guid: " + Guid.NewGuid());
    Console.WriteLine("MQTT application message is published.");
    Console.WriteLine("Press any key to publish again");
    var key = Console.ReadKey();

    if (key.Key == ConsoleKey.Escape){
        await client.OnDisconnectedAsync();
        break;
    }
}

// Publisher + Events
Console.WriteLine("Starting console sender...");
Console.WriteLine("Press ESC to exit.");

while (true)
{
    var client = new Mdm(new Events());
    
    await client.OnConnectedAsync();

    await client.PublishAsync("samples/guid", "Guid: " + Guid.NewGuid());
    Console.WriteLine("MQTT application message is published.");
    Console.WriteLine("Press any key to publish again");
    var key = Console.ReadKey();

    if (key.Key == ConsoleKey.Escape){
        await client.OnDisconnectedAsync();
        break;
    }
}

internal class Events : IMdmEvents
{
    public Task OnDisconnectedCallbackAsync(bool disconnectionRequested)
    {
        Console.WriteLine("Disconnected: {0}", disconnectionRequested ? "Requested" : "Unexpected");
        return Task.CompletedTask;
    }

    public Task OnConnectedCallbackAsync()
    {
        Console.WriteLine("Connected");
        return Task.CompletedTask;
    }
}

// Subscriber
using LibraryMDM.Client;

Console.WriteLine("Starting console receiver...");

var client = new Mdm();

await client.OnConnectedAsync();

await client.SubscribeAsync("samples/guid", (string payload) =>
{
    Console.WriteLine($"samples/guid: {payload}");
    return Task.CompletedTask;
});

Console.WriteLine("Press any key to exit.");
Console.ReadKey();

await client.OnDisconnectedAsync();

// Subscriber + Events

using LibraryMDM.Client;

Console.WriteLine("Starting console receiver...");

var client = new Mdm(new Events());

await client.OnConnectedAsync();

await client.SubscribeAsync("samples/guid", (string payload) =>
{
    Console.WriteLine($"samples/guid: {payload}");
    return Task.CompletedTask;
});

Console.WriteLine("Press any key to exit.");
Console.ReadKey();

await client.OnDisconnectedAsync();


internal class Events : IMdmEvents
{
    public Task OnDisconnectedCallbackAsync(bool disconnectionRequested)
    {
        Console.WriteLine("Disconnected: {0}", disconnectionRequested ? "Requested" : "Unexpected");
        return Task.CompletedTask;
    }

    public Task OnConnectedCallbackAsync()
    {
        Console.WriteLine("Connected");
        return Task.CompletedTask;
    }
}