先生と生徒の会話形式で理解しよう

生徒

「C#を使ってIoT機器を動かしたいのですが、MQTT通信というのが難しそうで困っています。どうすればいいですか？」

先生

「MQTT通信は、IoTの世界では標準的な通信ルールです。C#ではMQTTnetという便利な道具を使うと驚くほど簡単に実装できますよ。」

生徒

「MQTTnetを使うと、どんなことができるようになるのですか？」

先生

「離れた場所にあるセンサーのデータを集めたり、スマホから照明を点けたりといった制御が自在にできるようになります。一緒に手順を見ていきましょう！」

1. IoTとMQTT通信の基礎知識

まず、言葉の整理から始めましょう。IoTとは「モノのインターネット」のことで、普段使っている家電やセンサーをインターネットにつなぐ技術です。そして、そのモノ同士が会話をするためのルールがMQTTです。

MQTTは、郵便局のような仕組みで動きます。サーバー（MQTTブローカー）が郵便局の役割をし、誰かがメッセージを送り（パブリッシュ）、それを必要としている人が受け取る（サブスクライブ）という流れです。この仕組みを使うと、少ない通信量で効率よく情報をやり取りできるため、省電力で動くIoT機器に最適なのです。

2. 開発環境の準備とMQTTnetのインストール

C#でIoT開発を始めるには、まず「Visual Studio」というプログラムを書くためのソフトを用意します。次に、MQTTnetというライブラリをインストールします。ライブラリとは、他の誰かが作ってくれた「便利な部品セット」のことです。これを使うことで、ゼロから難しい通信ルールをプログラミングする必要がなくなります。

インストールは、Visual Studioの「NuGetパッケージマネージャー」から「MQTTnet」と検索してクリックするだけです。これだけで、高度な通信機能があなたのパソコンで使えるようになります。

3. MQTTブローカーに接続する基本コード

では、実際にMQTTブローカーと接続してみましょう。ブローカーとは、先ほどの例でいう郵便局のことです。接続には、クライアントと呼ばれる接続用プログラムを作成します。


var factory = new MqttFactory();
var mqttClient = factory.CreateMqttClient();
var options = new MqttClientOptionsBuilder()
    .WithTcpServer("broker.hivemq.com", 1883)
    .Build();

await mqttClient.ConnectAsync(options);
Console.WriteLine("接続が完了しました");

このコードは、インターネット上にある公開ブローカーに接続するものです。ポート番号の1883は、MQTT通信専用の「通り道」のような数字だと考えてください。プログラムが動くと、無事にサーバーと手をつなぐことができます。

4. データの送信（パブリッシュ）に挑戦

接続ができたら、次はメッセージを送ってみましょう。これをパブリッシュと呼びます。センサーが温度を計測して、それをサーバーに送るようなイメージです。


var message = new MqttApplicationMessageBuilder()
    .WithTopic("my/iot/sensor")
    .WithPayload("25.5")
    .Build();

await mqttClient.PublishAsync(message);

トピックという「荷札」のようなものを指定して、そこに温度などのデータを書き込みます。この荷札（トピック）が、後でデータを受け取る人との目印になります。例えば、家のリビングの温度なら「home/living/temp」のように階層を作ると整理しやすくなります。

5. データの受信（サブスクライブ）を実装する

次に、誰かが送ったデータを受け取るサブスクライブという機能を作ります。これは、自分が興味のあるトピックを監視し続ける仕組みです。データが届いた瞬間に、何か別の処理を動かすことも可能です。


mqttClient.ApplicationMessageReceivedAsync += e =>
{
    var payload = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
    Console.WriteLine($"新しいデータを受信しました: {payload}");
    return Task.CompletedTask;
};

await mqttClient.SubscribeAsync("my/iot/sensor");

このコードでは、指定したトピックにデータが届くと自動的に反応するように設定しています。これができれば、離れた場所から送られてくる情報をリアルタイムで表示したり、家電を遠隔操作したりするシステムが作れます。

6. ハードウェア制御へつなげる応用編

最後に、実際のハードウェアを動かすための考え方を解説します。例えば、受信したデータが「ON」ならLEDライトを点灯させ、「OFF」なら消灯させるという処理を追加します。C#にはGPIOというハードウェアの信号を制御する機能もありますので、MQTTで受け取ったコマンドをGPIOに変換して送るだけで、物理的なスイッチを動かせます。


if (payload == "ON")
{
    // ここにLEDを点灯させるハードウェア制御のコードを書く
    Console.WriteLine("ライトを点灯します");
}

このように、MQTTnetはプログラミングの入口と出口をつなぐ重要な役割を果たします。パソコンの中のプログラムと、現実世界の機械がMQTTを通じて会話を始める瞬間は、まさにIoT開発の醍醐味といえるでしょう。

C#のIoT開発入門！MQTTnetライブラリでMQTT通信を実装する方法