はじめに
IoTの普及に伴い、.NETフレームワークはIoTアプリケーションの構築においてますます人気が高まっています。Microsoftの.NET Coreと.NET Frameworkは、開発者にRaspberry Pi、HummingBoard、BeagleBoard、Pine A64などで動作するIoTアプリケーションを構築するためのツールとライブラリを提供します。
MQTTnetは、MQTTプロトコルを実装した高性能な.NETライブラリです。GitHubでオープンソース化されており、MQTT 5.0プロトコルやTLS/SSLのサポートなど豊富な機能を備えています。
この記事では、MQTTnetライブラリを使用してサーバーレスのMQTTブローカーに接続する方法を説明します。プロジェクト全体のコードはMQTT Client Examplesからダウンロードできます。
MQTTブローカーの準備
EMQX Serverlessは、すべてのサーバーレスの利点を備えたパブリッククラウド上のMQTTブローカーサービスです。数回のクリックで数秒以内にサーバーレスデプロイメントを開始できます。さらに、ユーザーは毎月100万の無料セッション分を獲得でき、23台のデバイスが1か月間オンラインになるのに十分であり、小規模なIoTテストシナリオに最適です。
このブログのガイドに従って、無料でサーバーレスデプロイメントを作成できます。オンラインガイドの登録プロセスを完了すると、デプロイメントの「概要」に次のようなインスタンス情報が表示されます。後ほど接続情報とCA証明書を使用します。
MQTT C#デモ
1. .NETとVisual Studioのインストール
まだコンピュータに.NET環境をインストールしていない場合は、Microsoftの公式ドキュメントを参照して詳細なインストール手順を確認してください。
Visual Studioは、.NET開発者向けの総合的なIDEで、.NETアプリケーションの開発、デバッグ、デプロイのための豊富な機能を提供します。お使いのコンピュータのシステムとバージョンに応じてこちらからダウンロードしてインストールできます。
2. MQTTnetパッケージのインストール
MQTTnetはNuGetパッケージマネージャー経由で提供されます。インストールするには、コンソールアプリケーションを作成し、NuGetを使用してMQTTnetパッケージをインストールします。Visual StudioでNuGetを使用する方法の詳細については、公式ドキュメントを参照してください。Visual Studio for Macを使用している場合は、Visual Studio for MacでのNuGetパッケージのインストールと管理を参照してください。
3. MQTT接続の設定
EMQX Serverlessブローカーに接続するには、MqttClientOptionsBuilderクラスのインスタンスを作成し、ブローカーのアドレス、ポート、ユーザー名、パスワードなど必要なオプションを設定する必要があります。以下のコードスニペットは、MqttClientOptionsBuilderのインスタンスを作成する方法を示しています。
string broker = "******.emqxsl.com";
int port = 8883;
string clientId = Guid.NewGuid().ToString();
string topic = "Csharp/mqtt";
string username = "emqxtest";
string password = "******";
// MQTTクライアントファクトリの作成
var factory = new MqttFactory();
// MQTTクライアントインスタンスの作成
var mqttClient = factory.CreateMqttClient();
// MQTTクライアントオプションの作成
var options = new MqttClientOptionsBuilder()
.WithTcpServer(broker, port) // MQTTブローカーのアドレスとポート
.WithCredentials(username, password) // ユーザー名とパスワードの設定
.WithClientId(clientId)
.WithCleanSession()
.Build();
接続パラメータは、ご自身のEMQX接続情報とログイン資格情報に置き換えてください。
- ブローカーとポート：サーバーデプロイメントの概要ページから接続アドレスとポート情報を取得します。
- トピック：トピックは異なるメッセージを識別・区別するために使用され、MQTTメッセージルーティングの基礎となります。
-
クライアントID：各MQTTクライアントは一意のクライアントIDを持つ必要があります。.NETの
Guid.NewGuid()を使用して新しい一意の識別子を生成できます。 - ユーザー名とパスワード：クライアント接続を確立するために、正しいユーザー名とパスワードを提供してください。以下の画像は、サーバー側の「認証とACL」の下でこれらの資格情報を設定する方法を示しています。
4. TLS/SSLの使用
EMQX Serverlessに接続する際、これはマルチテナントアーキテクチャに依存しており、複数のユーザーが単一のEMQXクラスターを共有できることに注意が必要です。このマルチテナント環境でのデータ転送のセキュリティと信頼性を確保するために、TLSが必要です。サーバーが自己署名証明書を使用している場合、デプロイメントの概要パネルから対応するCAファイルをダウンロードし、接続設定プロセス中に提供する必要があります。
TLSを追加し、証明書ファイルをMqttClientOptionsBuilderインスタンスに設定するには、WithTls()を使用します。以下のコードスニペットは、TLSを使用したMqttClientOptionsBuilderのインスタンスを作成する方法を示しています。
string broker = "******.emqxsl.com";
int port = 8883;
string clientId = Guid.NewGuid().ToString();
string topic = "Csharp/mqtt";
string username = "emqxtest";
string password = "******";
// MQTTクライアントファクトリの作成
var factory = new MqttFactory();
// MQTTクライアントインスタンスの作成
var mqttClient = factory.CreateMqttClient();
// MQTTクライアントオプションの作成
var options = new MqttClientOptionsBuilder()
.WithTcpServer(broker, port) // MQTTブローカーのアドレスとポート
.WithCredentials(username, password) // ユーザー名とパスワードの設定
.WithClientId(clientId)
.WithCleanSession()
.WithTls(
o =>
{
// 使用されるパブリックブローカーは時々無効な証明書を持つことがあります。このサンプルではすべての証明書を受け入れます。実稼働環境ではこの方法は使用しないでください。
o.CertificateValidationHandler = _ => true;
// デフォルト値はOSによって決定されます。バージョンを強制するために手動で設定します。
o.SslProtocol = SslProtocols.Tls12;
// 証明書ファイルのパスを提供してください。現在のディレクトリは/binです。
var certificate = new X509Certificate("/opt/emqxsl-ca.crt", "");
o.Certificates = new List<X509Certificate> { certificate };
}
)
.Build();
5. MQTTブローカーへの接続
これでMQTTクライアントを作成し、接続オプションを設定したので、ブローカーに接続する準備ができました。MQTTクライアントのConnectAsyncメソッドを使用して接続を確立し、メッセージの送受信を開始します。
var connectResult = await mqttClient.ConnectAsync(options);
ここでは非同期プログラミングを使用しています。これにより、ブロッキングを防ぎつつメッセージのパブリッシュとサブスクライブが可能です。
6. トピックの購読
ブローカーに接続したら、ResultCodeの値を確認して接続の成功を確認できます。接続が成功した場合、MQTTトピックを購読してメッセージを受信できます。
if (connectResult.ResultCode == MqttClientConnectResultCode.Success)
{
Console.WriteLine("MQTTブローカーへの接続に成功しました。");
// トピックを購読
await mqttClient.SubscribeAsync(topic);
// メッセージを受信したときのコールバック関数
mqttClient.ApplicationMessageReceivedAsync += e =>
{
Console.WriteLine($"受信したメッセージ：{Encoding.UTF8.GetString(e.ApplicationMessage.PayloadSegment)}");
return Task.CompletedTask;
};
この関数内で、受信した対応するメッセージを表示することもできます。これにより、必要に応じて受信データを表示および処理できます。
7. メッセージのパブリッシュ
ブローカーにメッセージを送信するには、MQTTクライアントのPublishAsyncメソッドを使用します。以下は、ループ内でブローカーにメッセージを送信する例で、1秒ごとにメッセージを1つ送信します。
for (int i = 0; i < 10; i++)
{
var message = new MqttApplicationMessageBuilder()
.WithTopic(topic)
.WithPayload($"Hello, MQTT! メッセージ番号 {i}")
.WithQualityOfServiceLevel(MqttQualityOfServiceLevel.AtLeastOnce)
.WithRetainFlag()
.Build();
await mqttClient.PublishAsync(message);
await Task.Delay(1000); // 1秒待機
}
8. 購読の解除
購読を解除するには、以下を呼び出します。
await mqttClient.UnsubscribeAsync(topic);
9. 接続の切断
接続を切断するには、以下を呼び出します。
await mqttClient.DisconnectAsync();
完全なコード
以下のコードは、サーバーへの接続、トピックの購読、メッセージのパブリッシュと受信方法を示しています。すべての機能の完全なデモについては、プロジェクトのGitHubリポジトリを参照してください。
using System.Security.Authentication;
using System.Security.Cryptography.X509Certificates;
using System.Text;
using MQTTnet;
using MQTTnet.Client;
using MQTTnet.Protocol;
class Program
{
static async Task Main(string[] args)
{
string broker = "******.emqxsl.com";
int port = 8883;
string clientId = Guid.NewGuid().ToString();
string topic = "Csharp/mqtt";
string username = "emqxtest";
string password = "**********";
// MQTTクライアントファクトリの作成
var factory = new MqttFactory();
// MQTTクライアントインスタンスの作成
var mqttClient = factory.CreateMqttClient();
// MQTTクライアントオプションの作成
var options = new MqttClientOptionsBuilder()
.WithTcpServer(broker, port) // MQTTブローカーのアドレスとポート
.WithCredentials(username, password) // ユーザー名とパスワードの設定
.WithClientId(clientId)
.WithCleanSession()
.WithTls(
o =>
{
// 使用されるパブリックブローカーは時々無効な証明書を持つことがあります。このサンプルではすべての証明書を受け入れます。実稼働環境ではこの方法は使用しないでください。
o.CertificateValidationHandler = _ => true;
// デフォルト値はOSによって決定されます。バージョンを強制するために手動で設定します。
o.SslProtocol = SslProtocols.Tls12;
// 証明書ファイルのパスを提供してください。現在のディレクトリは/binです。
var certificate = new X509Certificate("/opt/emqxsl-ca.crt", "");
o.Certificates = new List<X509Certificate> { certificate };
}
)
.Build();
// MQTTブローカーへの接続
var connectResult = await mqttClient.ConnectAsync(options);
if (connectResult.ResultCode == MqttClientConnectResultCode.Success)
{
Console.WriteLine("MQTTブローカーへの接続に成功しました。");
// トピックを購読
await mqttClient.SubscribeAsync(topic);
// メッセージを受信したときのコールバック関数
mqttClient.ApplicationMessageReceivedAsync += e =>
{
Console.WriteLine($"受信したメッセージ：{Encoding.UTF8.GetString(e.ApplicationMessage.PayloadSegment)}");
return Task.CompletedTask;
};
// メッセージを10回パブリッシュ
for (int i = 0; i < 10; i++)
{
var message = new MqttApplicationMessageBuilder()
.WithTopic(topic)
.WithPayload($"Hello, MQTT! メッセージ番号 {i}")
.WithQualityOfServiceLevel(MqttQualityOfServiceLevel.AtLeastOnce)
.WithRetainFlag()
.Build();
await mqttClient.PublishAsync(message);
await Task.Delay(1000); // 1秒待機
}
// 購読解除と接続切断
await mqttClient.UnsubscribeAsync(topic);
await mqttClient.DisconnectAsync();
}
else
{
Console.WriteLine($"MQTTブローカーへの接続に失敗しました：{connectResult.ResultCode}");
}
}
}
テスト
Visual Studioでプロジェクトを実行すると、以下のようにターミナルウィンドウに出力情報が表示されます。クライアントはMQTTブローカーへの接続に成功し、毎秒メッセージを受信しています。
また、別のクライアントとしてMQTTクライアントツール - MQTTXを使用してメッセージの送受信テストを行うこともできます。MQTTXで「Csharp/mqtt」トピックを購読すると、毎秒メッセージを受信します。
このトピックにメッセージをパブリッシュすると、サーバーがメッセージを受信し、MQTTXとコンソールの両方で確認できます。
MQTTXで受信したメッセージを表示
ターミナルで受信したメッセージを表示
まとめ
この記事では、MQTTnetライブラリを使用してサーバーレスMQTTデプロイメントに接続するためのステップバイステップガイドを提供しました。これらの手順に従うことで、サバーレスのMQTTサービスを使用してパブリッシュおよびサブスクライブできる.NETアプリケーションを作成することに成功しました。