Arduinoの基礎 - MQTT - 版の履歴

Wiki: /* 受信 (サブスクライバ側) */

2024-12-09T02:53:42Z

受信 (サブスクライバ側)

← 古い版		2024年12月9日 (月) 11:53時点における版
185行目:		185行目:
	const char mqtt_broker[] = "<MQTTブローカーのアドレス例: test.mosquitto.org>";		const char mqtt_broker[] = "<MQTTブローカーのアドレス例: test.mosquitto.org>";
	const int mqtt_port = 1883; // MQTTのポート番号		const int mqtt_port = 1883; // MQTTのポート番号
			const char mqtt_user = "<MQTTユーザ名>";
			const char mqtt_password = "<MQTTユーザのパスワード>";
	const char mqtt_topic[] = "arduino/sensor"; // 投稿するトピック		const char mqtt_topic[] = "arduino/sensor"; // 投稿するトピック

209行目:		211行目:

	// MQTTブローカーへの接続		// MQTTブローカーへの接続
			// クライアントIDを一意に設定
			String clientId = "arduino_client_" + String(random(0xffff), HEX);
			mqttClient.setId(clientId.c_str());

			// 認証情報の設定
			mqttClient.setUsernamePassword(mqtt_user, mqtt_password);

	Serial.print("Connecting to MQTT broker...");		Serial.print("Connecting to MQTT broker...");
	if (!mqttClient.connect(mqtt_broker, mqtt_port)) {		if (!mqttClient.connect(mqtt_broker, mqtt_port)) {

Wiki: /* 送信 (MQTTパブリッシャー側) */

2024-12-09T02:51:58Z

送信 (MQTTパブリッシャー側)

← 古い版		2024年12月9日 (月) 11:51時点における版
101行目:		101行目:
	const char mqtt_broker[] = "<MQTTブローカーのアドレス例: test.mosquitto.org>";		const char mqtt_broker[] = "<MQTTブローカーのアドレス例: test.mosquitto.org>";
	const int mqtt_port = 1883; // MQTTのポート番号		const int mqtt_port = 1883; // MQTTのポート番号
			const char mqtt_user = "<MQTTユーザ名>";
			const char mqtt_password = "<MQTTユーザのパスワード>";
	const char mqtt_topic[] = "arduino/sensor"; // 投稿するトピック		const char mqtt_topic[] = "arduino/sensor"; // 投稿するトピック

125行目:		127行目:

	// MQTTブローカーへの接続		// MQTTブローカーへの接続
			// クライアントIDを一意に設定
			String clientId = "arduino_client_" + String(random(0xffff), HEX);
			mqttClient.setId(clientId.c_str());

			// 認証情報の設定
			mqttClient.setUsernamePassword(mqtt_user, mqtt_password);

	Serial.print("Connecting to MQTT broker...");		Serial.print("Connecting to MQTT broker...");
	if (!mqttClient.connect(mqtt_broker, mqtt_port)) {		if (!mqttClient.connect(mqtt_broker, mqtt_port)) {

Wiki: /* 概要 */

2024-12-09T01:40:02Z

概要

← 古い版		2024年12月9日 (月) 10:40時点における版
40行目:		40行目:
	<br>		<br>
	Arduinoを使用したMQTT通信は、適切に実装することにより、信頼性の高いIoTシステムを構築できるツールである。<br>		Arduinoを使用したMQTT通信は、適切に実装することにより、信頼性の高いIoTシステムを構築できるツールである。<br>
			<br>
			Arduino UNO R4 WiFiは、ESP32-S3モジュールを内蔵しており、、Wi-Fiネットワークに接続・操作することが可能である。<br>
			HTTPS、MQTT、UDPを含むプロトコルがサポートされている。<br>
	<br><br>		<br><br>

Wiki: /* 必要な構成 */

2024-12-09T01:38:55Z

必要な構成

← 古い版		2024年12月9日 (月) 10:38時点における版
50行目:		50行目:
	** Arduino_ConnectionHandlerライブラリ		** Arduino_ConnectionHandlerライブラリ
	** ArduinoMqttClientライブラリ		** ArduinoMqttClientライブラリ
			**: ライブラリマネージャからArduinoMqttClientライブラリをインストールすること。
			**: https://github.com/arduino-libraries/ArduinoMqttClient
	** WiFiS3ライブラリ		** WiFiS3ライブラリ
			**: Arduino UNO R4 Core付属のWiFiS3ライブラリで有効化される。
			**: そのため、Coreをインストールすることにより、自動的にWiFiS3ライブラリもインストールされる。
	*: <br>		*: <br>
	* MQTTブローカー		* MQTTブローカー

Wiki: /* MQTT通信 */

2024-11-15T21:24:45Z

MQTT通信

← 古い版		2024年11月16日 (土) 06:24時点における版
57行目:		57行目:

	== MQTT通信 ==		== MQTT通信 ==
	Arduino R4 WiFiを使用して、MQTT通信でトピックの送受信を行っている。<br>		==== 技術的な制約 ====
			Arduino UNOのようなボードでは、メモリ制約により扱えるメッセージサイズに制限がある。<br>
			また、Wi-Fiモジュールの性能によっては、安定した通信のために適切な待機時間の設定が必要になることがある。<br>
			<br>
			==== デバッグとトラブルシューティング ====
			開発時は、MQTTクライアントツール (例: MQTT Explorer) を使用することにより、通信の様子を視覚的に確認できる。<br>
			また、シリアルモニタを活用して、接続状態やメッセージの送受信を確認する。<br>
			<br>
			==== 使用例 ====
			以下の例では、Arduino R4 WiFiを使用して、MQTT通信でトピックの送受信を行っている。<br>
	<br>		<br>
	* Wi-Fiへの接続		* Wi-Fiへの接続
71行目:		80行目:
	*: また、メッセージの内容をシリアルモニタに出力する。		*: また、メッセージの内容をシリアルモニタに出力する。
	<br>		<br>
	==== 送信 (MQTTパブリッシャー側) ====		===== 送信 (MQTTパブリッシャー側) =====
	以下の例では、5秒ごとにカウンタの値を送信 (パブリッシュ) している。<br>		以下の例では、5秒ごとにカウンタの値を送信 (パブリッシュ) している。<br>
	<br>		<br>
146行目:		155行目:
	</syntaxhighlight>		</syntaxhighlight>
	<br>		<br>
	==== 受信 (サブスクライバ側) ====		===== 受信 (サブスクライバ側) =====
	以下の例では、受信したトピックの購読 (サブスクライブ) している。<br>		以下の例では、受信したトピックの購読 (サブスクライブ) している。<br>
	<br>		<br>

Wiki: /* 必要な構成 */

2024-11-15T21:22:03Z

必要な構成

← 古い版		2024年11月16日 (土) 06:22時点における版
51行目:		51行目:
	** ArduinoMqttClientライブラリ		** ArduinoMqttClientライブラリ
	** WiFiS3ライブラリ		** WiFiS3ライブラリ
			*: <br>
			* MQTTブローカー
			*: MQTTブローカーを構築する場合、あるいは、MQTTブローカーサービスを契約する場合は、[[Web - MQTTブローカー]]のページを参照すること。
	<br><br>		<br><br>

Wiki: /* 概要 */

2024-11-15T21:20:12Z

概要

@@ 1行目: / 1行目: @@
 == 概要 ==
+MQTTは軽量なメッセージング・プロトコルで、IoTデバイスの通信に最適である。<br>
 <br><br>

Wiki: ページの作成:「== 概要 ==

== 必要な構成 == * ハードウェア ** Arduino UNO R4 WiFi :
ソフトウェア Arduino IDE 2.0以降 Arduino_ConnectionHandlerライブラリ ArduinoMqttClientライブラリ WiFiS3ライブラリ

== MQTT通信 == Arduino R4 WiFiを使用して、MQTT通信でトピックの送受信を行っている。

* Wi-Fiへの接続 *: SSIDとパスワードを使用して、Wi-Fiネットワークに接…」

2024-11-15T21:07:10Z

ページの作成:「== 概要 == == 必要な構成 == * ハードウェア ** Arduino UNO R4 WiFi *: * ソフトウェア ** Arduino IDE 2.0以降 ** Arduino_ConnectionHandlerライブラリ ** ArduinoMqttClientライブラリ ** WiFiS3ライブラリ == MQTT通信 == Arduino R4 WiFiを使用して、MQTT通信でトピックの送受信を行っている。 * Wi-Fiへの接続 *: SSIDとパスワードを使用して、Wi-Fiネットワークに接…」

新規ページ

== 概要 ==

 

== 必要な構成 ==
* ハードウェア
** Arduino UNO R4 WiFi
*: 
* ソフトウェア
** Arduino IDE 2.0以降
** Arduino_ConnectionHandlerライブラリ
** ArduinoMqttClientライブラリ
** WiFiS3ライブラリ
 

== MQTT通信 ==
Arduino R4 WiFiを使用して、MQTT通信でトピックの送受信を行っている。 
 
* Wi-Fiへの接続
*: SSIDとパスワードを使用して、Wi-Fiネットワークに接続する。
*: 接続状態をシリアルモニタに表示する。
* MQTTブローカーへの接続
*: 指定されたMQTTブローカーとポートに接続する。
* トピックの送信
*: 5秒ごとにカウンター値をMQTTトピックに送信する。
*: 送信内容はシリアルモニタにも表示する。
* トピックの受信
*: 購読しているトピックからメッセージを受信した場合に表示する。
*: また、メッセージの内容をシリアルモニタに出力する。
 
==== 送信 (MQTTパブリッシャー側) ====
以下の例では、5秒ごとにカウンタの値を送信 (パブリッシュ) している。 
 
<syntaxhighlight lang="c++">
#include <WiFiS3.h>
#include <ArduinoMqttClient.h>

// Wi-Fi設定
const char ssid[] = "<Wi-FiのSSID>"
const char pass[] = "<WiFiのパスワード>"

// MQTTブローカーの設定
const char mqtt_broker[] = "<MQTTブローカーのアドレス例: test.mosquitto.org>";
const int mqtt_port = 1883; // MQTTのポート番号
const char mqtt_topic[] = "arduino/sensor"; // 投稿するトピック

WiFiClient wifiClient;
MqttClient mqttClient(wifiClient);

void setup()
{
Serial.begin(9600);
while (!Serial); // シリアルポートの準備待ち

// Wi-Fi接続
Serial.print("Connecting to WiFi");
WiFi.begin(ssid, pass);

while (WiFi.status() != WL_CONNECTED) {
Serial.print(".");
delay(500);
}

Serial.println("\nConnected to WiFi");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());

// MQTTブローカーへの接続
Serial.print("Connecting to MQTT broker...");
if (!mqttClient.connect(mqtt_broker, mqtt_port)) {
Serial.print("MQTT connection failed! Error code = ");
Serial.println(mqttClient.connectError());

while (1);
}

Serial.println("Connected to MQTT broker!");
}

void loop()
{
// MQTT接続の維持
mqttClient.poll();

// 5秒ごとにメッセージを送信
static unsigned long previousMillis = 0;
unsigned long currentMillis = millis();

if (currentMillis - previousMillis >= 5000) {
previousMillis = currentMillis;

// サンプルデータの作成（ここでは単純なカウンター）
static int counter = 0;
String message = "Count: " + String(counter++);

// メッセージの送信
Serial.print("Sending message: ");
Serial.println(message);
mqttClient.beginMessage(mqtt_topic);
mqttClient.print(message);
mqttClient.endMessage();
}
}
</syntaxhighlight>
 
==== 受信 (サブスクライバ側) ====
以下の例では、受信したトピックの購読 (サブスクライブ) している。 
 
<syntaxhighlight lang="c++">
#include <WiFiS3.h>
#include <ArduinoMqttClient.h>

// Wi-Fi設定
const char ssid[] = "<Wi-FiのSSID>"
const char pass[] = "<WiFiのパスワード>"

// MQTTブローカーの設定
const char mqtt_broker[] = "<MQTTブローカーのアドレス例: test.mosquitto.org>";
const int mqtt_port = 1883; // MQTTのポート番号
const char mqtt_topic[] = "arduino/sensor"; // 投稿するトピック

WiFiClient wifiClient;
MqttClient mqttClient(wifiClient);

void setup()
{
Serial.begin(9600);
while (!Serial); // シリアルポートの準備待ち

// Wi-Fi接続
Serial.print("Connecting to WiFi");
WiFi.begin(ssid, pass);

while (WiFi.status() != WL_CONNECTED) {
Serial.print(".");
delay(500);
}

Serial.println("\nConnected to WiFi");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());

// MQTTブローカーへの接続
Serial.print("Connecting to MQTT broker...");
if (!mqttClient.connect(mqtt_broker, mqtt_port)) {
Serial.print("MQTT connection failed! Error code = ");
Serial.println(mqttClient.connectError());

while (1);
}

Serial.println("Connected to MQTT broker!");

// トピックの購読 (サブスクライブ)
Serial.print("Subscribing to topic: ");
Serial.println(mqtt_topic);

mqttClient.subscribe(mqtt_topic);
}

void loop()
{
// MQTT接続の維持
mqttClient.poll();

// 受信したメッセージの処理
int messageSize = mqttClient.parseMessage();
if (messageSize) {
Serial.print("Received a message with topic '");
Serial.print(mqttClient.messageTopic());
Serial.print("', length ");
Serial.print(messageSize);
Serial.println(" bytes:");

// メッセージの内容を読み取って表示
while (mqttClient.available()) {
Serial.print((char)mqttClient.read());
}

Serial.println();
}
}
</syntaxhighlight>
 

{{#seo:
|title={{PAGENAME}} : Exploring Electronics and SUSE Linux | MochiuWiki
|keywords=MochiuWiki,Mochiu,Wiki,Mochiu Wiki,Electric Circuit,Electric,pcb,Mathematics,AVR,TI,STMicro,AVR,ATmega,MSP430,STM,Arduino,Xilinx,FPGA,Verilog,HDL,PinePhone,Pine Phone,Raspberry,Raspberry Pi,C,C++,C#,Qt,Qml,MFC,Shell,Bash,Zsh,Fish,SUSE,SLE,Suse Enterprise,Suse Linux,openSUSE,open SUSE,Leap,Linux,uCLnux,Podman,電気回路,電子回路,基板,プリント基板
|description={{PAGENAME}} - 電子回路とSUSE Linuxに関する情報 | This page is {{PAGENAME}} in our wiki about electronic circuits and SUSE Linux
|image=/resources/assets/MochiuLogo_Single_Blue.png
}}

__FORCETOC__
[[カテゴリ:Arduino]]