スキップしてメイン コンテンツに移動

enter image description here

C# (.net) で使える MQTT クライアント

はじめに

C# で使える MQTT クライアントを探していて、
eclipse プロジェクトより 出ている “Paho M2Mqtt” というライブラリが
シンプルで使いやすかった為、そのメモです。

“Paho M2Mqtt” 以下の環境をサポートしている為、
IoT機器でも使用可能になっています。

.NET Framework、.NET Compact Framewoprk、
.NET Microframework 4.2/4.3、Mono、
Windows 8.1, Windows Phone 8.1のWinRT

セットアップ

"Paho M2Mqtt"ライブラリは、NuGet からダウンロードします。
まず最初に Visual Studio で新規の「コンソールプロジェクト」を作成します。

Visual Studioプロジェクト作成

NuGetの管理コンソールを開いて、「M2Mqtt」で検索しインストールを行います。

enter image description here

Subscriber(サブスクライバー)のサンプル コード

Publisher (パブリッシャー) からメッセージが送信されると、
コンソールにそのメッセージを表示するサンプルです。

static void Main(string[] args) {

    // HIVE MQ の brokerを指定して、クライアントを作成
    MqttClient client = new MqttClient("broker.mqttdashboard.com");

    // メッセージを受信した際に発生するイベント
    client.MqttMsgPublishReceived += (sender, e) => {
        Console.WriteLine(Encoding.UTF8.GetString(e.Message));
    };

    string clientId = Guid.NewGuid().ToString();
    client.Connect(clientId);

    // 受信するメッセージのトピック、QoSレベルを指定して、メッセージ受信待ち状態に入る
    client.Subscribe(new string[] { "/my/mqtt/sample/testdata" }, new byte[] { 2 });

    while (true) {
        System.Threading.Thread.Sleep(1000);
    }
}

動作確認

今回は、ブラウザだけで動作するMQTT クライアントの、HIVE MQを使用して
確認を行っていきたいと思います。
※本来はメッセージの中継を行う Broker というサーバを立てる必要がありますが、
今回は、ライブラリの紹介がメインなので、HIVE MQ の Broker サーバを使用します。

1. まず↑で作成した「コンソールプロジェクト」を Visual Studio で起動します

enter image description here

2. 以下のHIVE MQのサイトにアクセスします。
http://www.hivemq.com/demos/websocket-client/

3. サイトが表示されたら「Connect」ボタンをクリックします。

enter image description here

4. Publish の枠に↓のイメージの通り入力して、Publish ボタンをクリックします。

項目 入力値
Topic /my/mqtt/sample/testdata
Qos 1
Message はろー!MQTT

enter image description here

5. コンソールに「はろー!MQTT」が表示されば成功です。
enter image description here

Publisher (パブリッシャー)のサンプル コード

今度は、C#のコードからメッセージを送信するサンプルです。

static void Main(string[] args) {

    // HIVE MQ の brokerを指定して、クライアントを作成
    MqttClient client = new MqttClient("broker.mqttdashboard.com");

    string clientId = Guid.NewGuid().ToString();
    client.Connect(clientId);

	// メッセージを送信
    client.Publish("/my/mqtt/sample/testdata", Encoding.UTF8.GetBytes("メッセージ飛ばしてみた!!"), 0, false);
}

動作確認

C#のコードから送信したメッセージが、
HIVE MQの Subscriber(サブスクライバー)に表示されるか確認します。

1. HIVE MQの [Add New Topic Subscription]をクリックします。

enter image description here

2. ↓の内容を入力し、[Add New Topic Subscription]をクリックします。

項目 入力値
Topic /my/mqtt/sample/testdata
Qos 0

enter image description here

3. 「コンソールプロジェクト」を Visual Studio で起動します

enter image description here

4. Messages エリアに、C#のコードから送信されたメッセージが表示されれば成功です

enter image description here

おわりに

<関連記事>

HTTP REST APIでAzure IoT Hubにメッセージを送信する (C#)

Azure IoT Hubに、HTTP REST APIを使って、メッセージを送信する方法を解説しています。
Device SDKがインストールできない環境で、役に立つ情報です。

スポンサーリンク
スポンサーリンク
スポンサーリンク

コメント

このブログの人気の投稿

axiosの使い方まとめ (GET/POST/例外処理)

axiosの使い方まとめ (GET/POST/例外処理)最近何かとよく使うJavaScriptでAJAX通信を行うaxiosについて、簡単に使い方をまとめました。GETリクエストをaxiosで送るまずはGETリクエストをaxiosで送る方法です。const res =await axios.get('/users') console.log(res.data)分割代入の記法を使うと、以下のようにも書けますconst{data}=await axios.get('/users') console.log(data)クエリパラメータ (URLパラメータ)を指定クエリパラメータを指定する方法は2つあります。1つ目は、axios.getに指定するURLに直接記述する方法です。axios.get('/user?id=123')2つめは、axios.getの第2引数に、オプション指定する方法です。axios.get('/user',{ params:{ id:123}})POSTリクエストをaxiosで送る次はPOSTリクエストをaxiosで送る方法です。JSON形式でPOSTするJSON形式でPOSTする場合は、axios.postの第2引数に、送信するデータをJavaScriptオブジェクトで指定します。const res =await axios.post('/user',{ id:123, name:'Yamada Tarou'})application/x-www-form-urlencoded形式でPOSTするapplication/x-www-form-urlencoded形式でPOSTする場合は、URLSearchParamsを使います。var params =newURLSearchParams() params.append('id',123) params.append('name','Yamada Tarou')const res =await axios.post('/user', params)axios でファイルをアップロードする画像などのファイルを、axiosでアッ…

[VB, C#] Windows 8, Window 10 で ImeModeが制御できない問題を解決する

[VB, C#] Windows 8, Window 10 で ImeModeが制御できない問題を解決するタイトルの通りですが、Windows 8 以降では Windows Form アプリケーションで、コントロールの ImeMode に Katakana や KatakanaHalf を設定しても、カタカナになってくれません。なぜ ImeMode が効かないのか?Windows 8 以降、IME Mode の切り替えは、ユーザー単位で切り替わるようになった為、アプリから IME Mode 制御が出来ないようになりました。
(IME をON にした場合、常に ひらがな モードになます)※ Windows 7までは、IME Modeの切り替えはアプリ単位で行われていた為、問題なくアプリから IME制御が行えました。対処方法Windows 8 以降、IMEの制御は、InputScope クラスの利用が推奨されています。
しかし、InputScope クラスは、WPF、Windows ストアアプリでしか使えない為、Windows Formアプリでは使用できません。
(Windows Form はもう使うな!という事でしょうか (涙) )結論としては、コントールパネルの設定で、IMEの制御をユーザ単位から アプリ単位に変更する事ができます。
これで、Windows Formアプリでも 従来通りIMEの制御を行う事が出来ます。おわりにこの方法だと、アプリをインストールする端末すべてに設定が必要となり、とっても面倒です。。。
しかし、今の所これしか方法がない状態です。
これからは Windows Formではなく、WPFや Windows ストアアプリで作れという事ですかね (^^;)

MailKitの使い方! エンコーディング指定や添付ファイをメールで送信する方法[C#/VB Tips]

MailKitの使い方! エンコーディング指定や添付ファイをメールで送信する方法[C#/VB Tips]MailKitを使ってメールを送るサンプルコードです。(C#)UTF8/iso-2022-jpのエンコーディング指定、GMail/YahooのSMTPサーバで送るなど、4つのサンプルコードでMailKitの使い方を紹介します。MailKitって何?2017年に.NET標準のSystem.Net.Mail.SmtpClientが廃止予定となり、Microsoftより今後はオープンソースライブラリである、MailKitに置き換えるとアナウンスがありました。既にSmtpClientは非推奨になっており、今後は廃止されていきます。現在、SmtpClientを使用したソースコードには、Visual StudioからMailKitを使うよう警告が出るようになっています。さっそく、MailKitを使ってメールを送信するサンプルコードを作っていきます。UTF8でメールを送信文字エンコーディングを、UTF8でメールを送信するサンプルコードです。
MailKitは、デフォルトの文字エンコーディングがUTF8なっている為、シンプルなコードでメールを送信する事ができます。var host ="<smtp server name>"; var port =25;// or 587using(var smtp =new MailKit.Net.Smtp.SmtpClient()){//SMTPサーバに接続する smtp.Connect(host, port, MailKit.Security.SecureSocketOptions.Auto);//認証が必要な場合は、以下のコメントを解除//smtp.Authenticate("<id>", "<password>");//送信するメールを作成する var mail =new MimeKit.MimeMessage(); var builder =new MimeKit.BodyBuilder(); mail.From.Add(new MimeKit.MailboxAddress("",&quo…