Небольшая заметка о брокере MQTT с простой авторизацией (имя\пароль) на Raspberri Pi 2 и Windows IoT. Примера для этого нет ни на официальном сайте GnatMQ, ни в репозитории github, потому приведу, чтобы было. Может кому понадобится… ;)
Итак. Вы создали свой проект приложения, которое будет выполнятся в фоне (background app), далее разберем, как создать брокер для MQTT буквально в несколько шагов. Вначале заходим в NuGet Package Manager для нашего решения (solution):
Далее ищем в онлайн вкладке необходимую библиотеку — GnatMQ:
Справа выбираем, для какого конкретно проекта в решении нужно поставить эту библиотеку и выбираем последнюю стабильную версию библиотеки — v1.1.0:
Жмакаем Install. Внизу в Outputs будет лог установки, должно пройти всё без проблем, в противном случае читаем, что пошло не так, и исправляем…
Проверяем проект, в References должна появится ссылка библиотеку GnatMQ:
Вот и всё с подготовлениями! Теперь осталось написать немного кода…
Во-первых, для того чтобы наше приложение работало в фоне постоянно после инициализации брокера и не завершалось, необходимо создать экземпляр BackgroundTaskDeferral. Тогда после выполнения инициализирующей функции Run приложение не завершится и все асинхронные таски будут выполнятся. Более подробно это описано в мануале Developing Background Applications. В программе это будет выглядеть так:
using System;
using Windows.ApplicationModel.Background;
namespace MQTTBroker
{
public sealed class StartupTask : IBackgroundTask
{
private BackgroundTaskDeferral deferral;
public void Run(IBackgroundTaskInstance taskInstance)
{
deferral = taskInstance.GetDeferral();
}
}
}
После запуска такого приложения оно ничего делать не будет (ведь в функции Run мы ничего и не написали то… :) ), но и не завершится после выполнения (запуска).
Во-вторых, нужно создать метод для делегата, отвечающего за задание параметров авторизации Имя\Пароль.
MqttUserAuthenticationDelegate userauth = new MqttUserAuthenticationDelegate(CheckAuthParams);
static bool CheckAuthParams(string user, string pass)
{
return !(String.IsNullOrEmpty(user) & String.IsNullOrEmpty(pass));
}
В итоге Имя\Пароль для подключения к брокеру назначаются следующим образом:
const string mqtt_brokerUser = "user";
const string mqtt_brokerPass = "pass";
public void Run(IBackgroundTaskInstance taskInstance)
{
userauth(mqtt_brokerUser, mqtt_brokerPass);
broker.UserAuth = userauth;
}
Вот и всё! Собираем эти две части вместе и получаем простой брокер на C#, UWP с авторизацией Имя\Пароль. У вас должно получиться нечто подобное (весь код приложения):
using System;
using Windows.ApplicationModel.Background;
using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Managers;
namespace MQTTBroker
{
public sealed class StartupTask : IBackgroundTask
{
const string mqtt_brokerUser = "user";
const string mqtt_brokerPass = "pass";
private BackgroundTaskDeferral deferral;
MqttBroker broker = new MqttBroker();
MqttUserAuthenticationDelegate userauth = new MqttUserAuthenticationDelegate(CheckAuthParams);
static bool CheckAuthParams(string user, string pass)
{
return !(String.IsNullOrEmpty(user) & String.IsNullOrEmpty(pass));
}
public void Run(IBackgroundTaskInstance taskInstance)
{
deferral = taskInstance.GetDeferral();
userauth(mqtt_brokerUser, mqtt_brokerPass);
broker.UserAuth = userauth;
broker.Start();
}
}
}
Удачного кодинга! ;)
