Overview

A MQTT demonstration application that connects & subscribes to MQTT topics. All MQTT connection handling , subscription & message processing is implemented as Background service with simple abstraction for application to register message processing logic

• Console application connects & process MQTT messages from the MQTT Server.
• ASP.NET Core API application connects & process MQTT messages from the MQTT Server

Highlevel context overview

Project structure

ProjectName	Description
AspNetCoreWebApiWithMqttSubscription	ASP.NET Core API application with Backgound service subscribed to MQTT topics
MqttWorkerServiceSubscriber	.NET Console application with Backgound service subscribed to MQTT topics,
MqttPublisherApi	ASP.NET Core API application that publishes message to all connected MQTT Clients
MqttSupport	Class Library thats provides application ability to subscribe to MQTT messages
DynamicLogging	Class Library to support changing log level without application restart

How to run

• Run AspNetCoreWebApiWithMqttSubscription application in a terminal

  cd AspNetCoreWebApiWithMqttSubscription
  dotnet run
  

• Run MqttWorkerServiceSubscriber application in a terminal

  cd MqttWorkerServiceSubscriber
  dotnet run
  

• Run MqttPublisherApi application in a terminal

  cd MqttPublisherApi
  dotnet run
  

• Publish message to all connected broker via MqttPublisherApi API application & observe the console messages of AspNetCoreWebApiWithMqttSubscription & MqttWorkerServiceSubscriber

  curl -v --json "{\"message\": \"Hello to all\"}" http://localhost:5050/MqttPublish/notify

Kubernetes deployment of opensource MQTT Broker

A cloud deployed mosquitto MQTT broker is used for demonstration wss://test.mosquitto.org:8081 . Refer mosquitto test mqtt broker information page
A Kubernetes deployment yaml also available to host open source mosquitto MQTT broker in Docker desktop with Kubernetes support

cd deployment
kubectl apply -f mosquitto-deployment.yaml