\/\/ M1_HelloWorld.ino\n\n\/\/ https:\/\/github.com\/emqx\/MQTT-Client-Examples\/blob\/master\/mqtt-client-ESP8266\/esp8266_connect_mqtt_via_tls.ino\n\/\/\u3092\u53c2\u7167\u3057\u307e\u3057\u305f (github)\n\n\/\/************************************************\/\n\/\/ EMQX Serverless MQTT Broker \u3092\u4f7f\u7528\u3059\u308b *\/\n\/\/************************************************\/\n\/\/* NodeMCU MQTT client *\/\n\/\/* MQTT \u306e TLS\/SSL \u8a8d\u8a3c\u3092\u7528\u3044\u308b *\/\n\/\/* \u30dd\u30fc\u30c8\u756a\u53f7\u30008883 *\/\n\/\/* NodeMCU \u304b\u3089 "HelloWorld" \u3092 PC \u306e MXTTX Web \u306b\u9001\u308b *\/\n\/\/* *\/\n\/\/* NodeMCU\u7528\u306eMQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u30e9\u30a4\u30d6\u30e9\u30ea *\/\n\/\/* pubsubclient\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3059\u308b\u3053\u3068 Nick O'Leary\u4f5c *\/\n\/\/* 2025.12.18 *\/\n\/\/***********************************************\/\n#include <ESP8266WiFi.h>\n#include <PubSubClient.h>\n#include <time.h> \/\/ TLS\/SSL \u8a8d\u8a3c\u3092\u884c\u3046\u3068\u304d\u306f time.h \u304c\u5fc5\u8981\u306e\u3088\u3046\u3067\u3059\n\n\/\/ WiFi credentials\nconst char *ssid = "*******"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password = "******"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker = "*******************"; \/\/ EMQX serverless \u306e\u63a5\u7d9a\u5148URL \u3092\u66f8\u304d\u307e\u3059\nconst char *mqtt_topic = "topi"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username = "system"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password = "seigyo"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port = 8883; \/\/ MQTT SSL\/TLS Port\n\n\/\/ NTP Server settings\nconst char *ntp_server = "pool.ntp.org"; \/\/ Default NTP server\n\/\/ \u4e0b\u306e gmt_offset_sec = 0 \u306e\u307e\u307e\u3067\u3088\u3055\u305d\u3046\u3067\u3059\nconst long gmt_offset_sec = 0; \/\/ GMT offset in seconds (adjust for your time zone)\nconst int daylight_offset_sec = 0; \/\/ Daylight saving time offset in seconds\n\n\/\/ WiFi and MQTT client initialization\nBearSSL::WiFiClientSecure espClient;\nPubSubClient mqtt_client(espClient); \/\/MQTT client\u751f\u6210\n\n\/\/ Root CA Certificate\n\/\/ Load DigiCert Global Root CA ca_cert, which is used by EMQX Cloud Serverless Deployment\n\/\/ EMQX Serverless Deployment\u3067\u4f7f\u7528\u3055\u308c\u308b\u8a3c\u660e\u66f8\u3067\u3059\nstatic const char ca_cert[]\nPROGMEM = R"EOF(\n-----BEGIN CERTIFICATE-----\nMIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\nMQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\nd3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\nQTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\nMRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\nb20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\nCSDMAZOnTjC3U\/dDxGkAV53ijSLdhwZAAIEJzs4bg7\/fzTtxRuLWZscFs3YnFo97\nnh6Vfe63SKMI2tavegw5BmV\/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n43C\/dxC\/\/AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\nT19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr\/y7vrTC0LUq7dBMtoM1O\/4\ngdW7jVg\/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\nBgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH\/BAUwAwEB\/zAdBgNVHQ4EFgQUA95QNVbR\nTLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\nDQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY\/Esr\nhMAtudXH\/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp\/2PV5Adg\n06O\/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\nPnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\nYSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\nCAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n-----END CERTIFICATE-----\n)EOF";\n\n\/\/ \u95a2\u6570\u30d7\u30ed\u30c8\u30bf\u30a4\u30d7\u5ba3\u8a00\nvoid connectToWiFi();\nvoid connectToMQTT();\nvoid syncTime();\nvoid mqttCallback(char *topic, byte *payload, unsigned int length);\n\nvoid setup() {\n Serial.begin(115200);\n connectToWiFi();\n syncTime(); \/\/ X.509 validation requires synchronization time\n mqtt_client.setServer(mqtt_broker, mqtt_port);\n mqtt_client.setCallback(mqttCallback);\n connectToMQTT();\n}\n\nvoid connectToWiFi() {\n WiFi.begin(ssid, password);\n Serial.print("Connecting to WiFi");\n while (WiFi.status() != WL_CONNECTED) {\n delay(500);\n Serial.println("Connecting to WiFi...");\n }\n Serial.println("Connected to WiFi");\n}\n\nvoid syncTime() {\n configTime(gmt_offset_sec, daylight_offset_sec, ntp_server);\n Serial.print("Waiting for NTP time sync: ");\n while (time(nullptr) < 8 * 3600 * 2) {\n delay(1000);\n Serial.print(".");\n }\n Serial.println("Time synchronized");\n struct tm timeinfo;\n if (getLocalTime(&timeinfo)) {\n Serial.print("Current time: ");\n Serial.println(asctime(&timeinfo));\n } else {\n Serial.println("Failed to obtain local time");\n }\n}\n\nvoid connectToMQTT() {\n BearSSL::X509List serverTrustedCA(ca_cert);\n espClient.setTrustAnchors(&serverTrustedCA);\n while (!mqtt_client.connected()) {\n String client_id = "esp8266-client-" + String(WiFi.macAddress());\/\/ macAddress\u3092\u4f7f\u3063\u3066client_id\u751f\u6210\n Serial.printf("Connecting to MQTT Broker as %s...\\n", client_id.c_str());\n if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {\n Serial.println("Connected to MQTT broker");\n mqtt_client.subscribe(mqtt_topic);\n mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); \/\/ Publish message upon connection\n } else {\n char err_buf[128];\n espClient.getLastSSLError(err_buf, sizeof(err_buf)); \n Serial.print("Failed to connect to MQTT broker, rc=");\n Serial.print(mqtt_client.state());\n Serial.print("SSL error: ");\n Serial.println(err_buf);\n Serial.println(" Retrying in 3 seconds.");\n delay(3000);\n }\n }\n}\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u3053\u306e callback \u95a2\u6570\u306f\u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089 NodeMCU \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u304c \/\/\n\/\/ \u9001\u3089\u308c\u308b\u3068\u5b9f\u884c\u3055\u308c\u307e\u3059 \/\/\n\/\/ MQTT\u306e\u4ed5\u69d8\u3067\u306f\u3001\u30d6\u30ed\u30fc\u30ab\u30fc\u304c\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8 \/\/\n\/\/ \uff08\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u306f NodeMCU \u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c\u306b\u3001 \/\/\n\/\/ \u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u30d6\u30ed\u30fc\u30ab\u30fc\u81ea\u8eab\u304c\u518d\u3073\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\uff08NodeMCU\uff09\u306b \/\/\n\/\/ \u914d\u4fe1\uff08\u30a8\u30b3\u30fc\uff09\u3059\u308b\u8a2d\u5b9a\u304c\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u6709\u52b9\u306b\u306a\u3063\u3066\u3044\u307e\u3059\u3002 \/\/\n\/\/ \u3053\u308c\u3092\u7121\u52b9\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u305d\u3046\u3067\u3059\u304c\u3001\u3044\u307e\u306e\u3068\u3053\u308d\u4e0d\u660e \/\/\n\/\/ \u305d\u306e\u305f\u3081\u3001NodeMCU \u304b\u3089\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u3068\u3001 \/\/\n\/\/ \u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089\u30a8\u30b3\u30fc\u3055\u308c\u305f\u540c\u3058\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u3001\u3053\u306ecallback \u95a2\u6570\u304c\u53d7\u3051\u53d6\u308a \/\/\n\/\/ \u4ee5\u4e0b\u306e Serial.print() \u3067\u30b7\u30ea\u30a2\u30eb\u30e2\u30cb\u30bf\u3067\u8868\u793a\u3055\u308c\u307e\u3059\u3002 \/\/ \n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nvoid mqttCallback(char *topic, byte *payload, unsigned int length) {\n Serial.print("Message received on topic: ");\n Serial.println(topic);\n Serial.print("Message: ");\n for (unsigned int i = 0; i < length; i++) {\n Serial.print((char)payload[i]);\n }\n Serial.println("\\n-----------------------");\n}\n\nunsigned long lastMsg = 0;\n#define MSG_BUFFER_SIZE (50)\nchar msg[MSG_BUFFER_SIZE];\nint value = 0;\nint ii=0;\n\nvoid loop() {\n if (!mqtt_client.connected()) {\n connectToMQTT();\n }\n mqtt_client.loop();\n\n \/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n \/\/ \u4ee5\u4e0b\u3067 NodeMCU \u304b\u3089 "Hello World" \u3092\uff12\u79d2\u3054\u3068\u306b\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u9001\u308a\u307e\u3059 \/\/\n \/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n unsigned long now = millis(); \/\/ NodeMCU\u30de\u30a4\u30b3\u30f3\u306e\u73fe\u5728\u6642\u9593\u3092\n \/\/ \u30df\u30ea\u79d2\u5358\u4f4d\u3067\u53d6\u5f97\n if (now - lastMsg > 2000) {\n \/\/ 2\u79d2\u9593\u5f85\u6a5f\n lastMsg = now;\n ++value;\n snprintf (msg, MSG_BUFFER_SIZE, "#%ld: Hello World ", value);\n\/\/ Serial.print("[ Publish message ] ");\n\/\/ Serial.println(msg);\n mqtt_client.publish(mqtt_topic, msg);\n } \n}<\/code><\/pre><\/div>\n\n\n\nM2_LED LED\u306e\u5229\u7528<\/strong>
\u3000\u3000MQTTX Web \u304b\u3089 NodeMCU \u306e LED \u3092\u70b9\u706f\u30fb\u6d88\u706f\u3055\u305b\u308b<\/strong>
\uff08\u4e0a\u306e\u56de\u8def\u56f3 B \u53c2\u7167\uff09<\/strong><\/p>\n\n\n\n\u3000NodeMCU \u306b\u5bfe\u3057\u3066\u3001MQTTX Web \u304b\u3089\u6570\u5b57\u306e \uff11 \u306e\u6587\u5b57\u304c\u9001\u3089\u308c\u308b\u3068 LED \u304c\u70b9\u706f\u3057\u3001\u6570\u5b57\u306e 0 \u306e\u6587\u5b57\u304c\u9001\u3089\u308c\u308b\u3068 LED \u304c\u6d88\u706f\u3057\u307e\u3059\u3000\uff08\u4e0a\u306e\u56de\u8def\u56f3 B \u53c2\u7167\uff09\u3002<\/p>\n\n\n\n
\/\/ M2_LED.ino\n\n\/\/ https:\/\/github.com\/emqx\/MQTT-Client-Examples\/blob\/master\/mqtt-client-ESP8266\/esp8266_connect_mqtt_via_tls.ino\n\/\/\u3092\u53c2\u7167\u3057\u307e\u3057\u305f (github)\n\n\/\/************************************************\/\n\/\/ EMQX Serverless MQTT Broker \u3092\u4f7f\u7528\u3059\u308b *\/\n\/\/************************************************\/\n\/\/* NodeMCU MQTT client *\/\n\/\/* MQTT \u306e TLS\/SSL \u8a8d\u8a3c\u3092\u7528\u3044\u308b *\/\n\/\/* \u30dd\u30fc\u30c8\u756a\u53f7\u30008883 *\/\n\/\/* PC -> NodeMCU : \u6570\u5b57\u3092\u9001\u308b *\/\n\/\/* \u6570\u5b57 1 \u3067 LED \u3092\u70b9\u706f\u3059\u308b *\/\n\/\/* \u6570\u5b57 0 \u3067 LED \u3092\u6d88\u706f\u3059\u308b *\/ \n\/\/* NodeMCU\u7528\u306eMQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u30e9\u30a4\u30d6\u30e9\u30ea *\/\n\/\/* pubsubclient\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3059\u308b\u3053\u3068 Nick O'Leary\u4f5c *\/\n\/\/* 2025.12.19 *\/\n\/\/***********************************************\/\n#include <ESP8266WiFi.h>\n#include <PubSubClient.h>\n#include <time.h> \/\/ TLS\/SSL \u8a8d\u8a3c\u3092\u884c\u3046\u3068\u304d\u306f time.h \u304c\u5fc5\u8981\u306e\u3088\u3046\u3067\u3059\n\n\/\/ WiFi credentials\nconst char *ssid = "*******"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password = "******"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker = "********************"; \/\/ EMQX serverless \u306e\u63a5\u7d9a\u5148URL \u3092\u66f8\u304d\u307e\u3059\nconst char *mqtt_topic = "topi"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username = "system"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password = "seigyo"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port = 8883; \/\/ MQTT SSL\/TLS Port\n\n\/\/ NTP Server settings\nconst char *ntp_server = "pool.ntp.org"; \/\/ Default NTP server\n\/\/ \u4e0b\u306e gmt_offset_sec = 0 \u306e\u307e\u307e\u3067\u3088\u3055\u305d\u3046\u3067\u3059\nconst long gmt_offset_sec = 0; \/\/ GMT offset in seconds (adjust for your time zone)\nconst int daylight_offset_sec = 0; \/\/ Daylight saving time offset in seconds\n\n\/\/ WiFi and MQTT client initialization\nBearSSL::WiFiClientSecure espClient;\nPubSubClient mqtt_client(espClient); \/\/MQTT client\u751f\u6210\n\n\/\/ Root CA Certificate\n\/\/ Load DigiCert Global Root CA ca_cert, which is used by EMQX Cloud Serverless Deployment\n\/\/ EMQX Serverless Deployment\u3067\u4f7f\u7528\u3055\u308c\u308b\u8a3c\u660e\u66f8\u3067\u3059\nstatic const char ca_cert[]\nPROGMEM = R"EOF(\n-----BEGIN CERTIFICATE-----\nMIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\nMQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\nd3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\nQTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\nMRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\nb20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\nCSDMAZOnTjC3U\/dDxGkAV53ijSLdhwZAAIEJzs4bg7\/fzTtxRuLWZscFs3YnFo97\nnh6Vfe63SKMI2tavegw5BmV\/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n43C\/dxC\/\/AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\nT19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr\/y7vrTC0LUq7dBMtoM1O\/4\ngdW7jVg\/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\nBgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH\/BAUwAwEB\/zAdBgNVHQ4EFgQUA95QNVbR\nTLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\nDQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY\/Esr\nhMAtudXH\/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp\/2PV5Adg\n06O\/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\nPnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\nYSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\nCAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n-----END CERTIFICATE-----\n)EOF";\n\n\/\/ \u95a2\u6570\u30d7\u30ed\u30c8\u30bf\u30a4\u30d7\u5ba3\u8a00\nvoid connectToWiFi();\nvoid connectToMQTT();\nvoid syncTime();\nvoid mqttCallback(char *topic, byte *payload, unsigned int length);\n\nint red_led = 5;\n\nvoid setup() {\n pinMode( red_led, OUTPUT ); \/\/ GPIO5 ( D1pin ) \u3092\u51fa\u529b\u30d4\u30f3\u306b\u3059\u308b\u8a2d\u5b9a\n Serial.begin(115200);\n connectToWiFi();\n syncTime(); \/\/ X.509 validation requires synchronization time\n mqtt_client.setServer(mqtt_broker, mqtt_port);\n mqtt_client.setCallback(mqttCallback);\n connectToMQTT();\n}\n\nvoid connectToWiFi() {\n WiFi.begin(ssid, password);\n Serial.print("Connecting to WiFi");\n while (WiFi.status() != WL_CONNECTED) {\n delay(500);\n Serial.println("Connecting to WiFi...");\n }\n Serial.println("Connected to WiFi");\n}\n\nvoid syncTime() {\n configTime(gmt_offset_sec, daylight_offset_sec, ntp_server);\n Serial.print("Waiting for NTP time sync: ");\n while (time(nullptr) < 8 * 3600 * 2) {\n delay(1000);\n Serial.print(".");\n }\n Serial.println("Time synchronized");\n struct tm timeinfo;\n if (getLocalTime(&timeinfo)) {\n Serial.print("Current time: ");\n Serial.println(asctime(&timeinfo));\n } else {\n Serial.println("Failed to obtain local time");\n }\n}\n\nvoid connectToMQTT() {\n BearSSL::X509List serverTrustedCA(ca_cert);\n espClient.setTrustAnchors(&serverTrustedCA);\n while (!mqtt_client.connected()) {\n String client_id = "esp8266-client-" + String(WiFi.macAddress());\/\/ macAddress\u3092\u4f7f\u3063\u3066client_id\u751f\u6210\n Serial.printf("Connecting to MQTT Broker as %s...\\n", client_id.c_str());\n if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {\n Serial.println("Connected to MQTT broker");\n mqtt_client.subscribe(mqtt_topic);\n mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); \/\/ Publish message upon connection\n } else {\n char err_buf[128];\n espClient.getLastSSLError(err_buf, sizeof(err_buf)); \n Serial.print("Failed to connect to MQTT broker, rc=");\n Serial.print(mqtt_client.state());\n Serial.print("SSL error: ");\n Serial.println(err_buf);\n Serial.println(" Retrying in 3 seconds.");\n delay(3000);\n }\n }\n}\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u3053\u306e callback \u95a2\u6570\u306f\u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089 NodeMCU \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u304c \/\/\n\/\/ \u9001\u3089\u308c\u308b\u3068\u5b9f\u884c\u3055\u308c\u307e\u3059 \/\/\n\/\/ MQTT\u306e\u4ed5\u69d8\u3067\u306f\u3001\u30d6\u30ed\u30fc\u30ab\u30fc\u304c\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8 \/\/\n\/\/ \uff08\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u306f NodeMCU \u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c\u306b\u3001 \/\/\n\/\/ \u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u30d6\u30ed\u30fc\u30ab\u30fc\u81ea\u8eab\u304c\u518d\u3073\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\uff08NodeMCU\uff09\u306b \/\/\n\/\/ \u914d\u4fe1\uff08\u30a8\u30b3\u30fc\uff09\u3059\u308b\u8a2d\u5b9a\u304c\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u6709\u52b9\u306b\u306a\u3063\u3066\u3044\u307e\u3059\u3002 \/\/\n\/\/ \u3053\u308c\u3092\u7121\u52b9\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u305d\u3046\u3067\u3059\u304c\u3001\u3044\u307e\u306e\u3068\u3053\u308d\u4e0d\u660e \/\/\n\/\/ \u305d\u306e\u305f\u3081\u3001NodeMCU \u304b\u3089\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u3068\u3001 \/\/\n\/\/ \u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089\u30a8\u30b3\u30fc\u3055\u308c\u305f\u540c\u3058\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u3001\u3053\u306ecallback \u95a2\u6570\u304c\u53d7\u3051\u53d6\u308a \/\/\n\/\/ \u4ee5\u4e0b\u306e Serial.print() \u3067\u30b7\u30ea\u30a2\u30eb\u30e2\u30cb\u30bf\u3067\u8868\u793a\u3055\u308c\u307e\u3059\u3002 \/\/ \n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nvoid mqttCallback(char *topic, byte *payload, unsigned int length) {\n Serial.print("Message received on topic: ");\n Serial.println(topic);\n Serial.print("Message: ");\n for (unsigned int i = 0; i < length; i++) {\n Serial.print((char)payload[i]);\n }\n Serial.println("\\n-----------------------");\n\n \/\/********************************************************************\/\/\n \/\/ \u6ce8\u610f\uff01\uff01\u3000SSSL\/TLS\u8a8d\u8a3c\u306e\u8a2d\u5b9a\u3092\u3057\u305f\u3068\u304d\u306f\u3001NodeMCU \u306e Builtin_LED \u306f\u4f7f\u3048\u306a\u3044\u3088\u3046\u3067\u3059 \/\/\n \/\/\u3000\u3000\u3000\u5fc5\u305a\u5916\u4ed8\u3051\u306e LED \u3092\u4f7f\u7528\u3057\u3066\u304f\u3060\u3055\u3044 \/\/\n \/\/ \/\/\n \/\/ \u4ee5\u4e0b\u306f PC \u304b\u3089\u9001\u3089\u308c\u308b\u6570\u5b57\u306b\u3088\u3063\u3066\u3001LED \u3092\u70b9\u706f\u3001\u6d88\u706f\u3057\u307e\u3059 \/\/\n \/\/ \u6570\u5b57 \uff11 \u3067LED\u70b9\u706f\u3001\u6570\u5b57 \uff10 \u3067LED\u6d88\u706f\u3067\u3059 \/\/\n \/\/*******************************************************************\/\/\n if ((char)payload[0] == '1') {\n digitalWrite( red_led, HIGH ); \/\/LED \u70b9\u706f\n } else if((char)payload[0] == '0'){\n digitalWrite( red_led, LOW ); \/\/LED \u6d88\u706f\n } \n}\n\nunsigned long lastMsg = 0;\n#define MSG_BUFFER_SIZE (50)\nchar msg[MSG_BUFFER_SIZE];\nint value = 0;\nint ii=0;\n\nvoid loop() {\n if (!mqtt_client.connected()) {\n connectToMQTT();\n }\n mqtt_client.loop();\n}<\/code><\/pre><\/div>\n\n\n\nM3_RELAY RELAY \u306e\u5229\u7528<\/strong>
\u3000\u3000MQTTX Web \u304b\u3089 NodeMCU \u306e RELAY \u3092 ON\u30fbOFF \u3055\u305b\u308b<\/strong>
\uff08\u4e0a\u306e\u56de\u8def\u56f3 E \u53c2\u7167\uff09<\/strong><\/p>\n\n\n\n\u3000NodeMCU \u306b\u5bfe\u3057\u3066\u3001MQTTX Web \u304b\u3089\u6570\u5b57\u306e \uff11 \u306e\u6587\u5b57\u304c\u9001\u3089\u308c\u308b\u3068 RELAY \u3092ON\u3057\u3001\u6570\u5b57\u306e 0 \u306e\u6587\u5b57\u304c\u9001\u3089\u308c\u308b\u3068 RELAY \u3092 OFF\u3057\u307e\u3059\u3000\uff08\u4e0a\u306e\u56de\u8def\u56f3 E \u53c2\u7167\uff09\u3002<\/p>\n\n\n\n
\/\/ M3_RELAY.ino\n\n\/\/ https:\/\/github.com\/emqx\/MQTT-Client-Examples\/blob\/master\/mqtt-client-ESP8266\/esp8266_connect_mqtt_via_tls.ino\n\/\/\u3092\u53c2\u7167\u3057\u307e\u3057\u305f (github)\n\n\/\/************************************************\/\n\/\/ EMQX Serverless MQTT Broker \u3092\u4f7f\u7528\u3059\u308b *\/\n\/\/************************************************\/\n\/\/* NodeMCU MQTT client *\/\n\/\/* MQTT \u306e TLS\/SSL \u8a8d\u8a3c\u3092\u7528\u3044\u308b *\/\n\/\/* \u30dd\u30fc\u30c8\u756a\u53f7\u30008883 *\/\n\/\/* PC -> NodeMCU : \u6570\u5b57\u3092\u9001\u308b *\/\n\/\/* \u6570\u5b57 1 \u3067 LELAY \u3092ON\u3059\u308b *\/\n\/\/* \u6570\u5b57 0 \u3067 LELAY \u3092OFF\u3059\u308b *\/ \n\/\/* NodeMCU\u7528\u306eMQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u30e9\u30a4\u30d6\u30e9\u30ea *\/\n\/\/* pubsubclient\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3059\u308b\u3053\u3068 Nick O'Leary\u4f5c *\/\n\/\/* 2025.12.20 *\/\n\/\/***********************************************\/\n#include <ESP8266WiFi.h>\n#include <PubSubClient.h>\n#include <time.h> \/\/ TLS\/SSL \u8a8d\u8a3c\u3092\u884c\u3046\u3068\u304d\u306f time.h \u304c\u5fc5\u8981\u306e\u3088\u3046\u3067\u3059\n\n\/\/ WiFi credentials\nconst char *ssid = "*********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password = "********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker = "*******************"; \/\/ EMQX serverless \u306e\u63a5\u7d9a\u5148URL \u3092\u66f8\u304d\u307e\u3059\nconst char *mqtt_topic = "topi"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username = "system"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password = "seigyo"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port = 8883; \/\/ MQTT SSL\/TLS Port\n\n\/\/ NTP Server settings\nconst char *ntp_server = "pool.ntp.org"; \/\/ Default NTP server\n\/\/ \u4e0b\u306e gmt_offset_sec = 0 \u306e\u307e\u307e\u3067\u3088\u3055\u305d\u3046\u3067\u3059\nconst long gmt_offset_sec = 0; \/\/ GMT offset in seconds (adjust for your time zone)\nconst int daylight_offset_sec = 0; \/\/ Daylight saving time offset in seconds\n\n\/\/ WiFi and MQTT client initialization\nBearSSL::WiFiClientSecure espClient;\nPubSubClient mqtt_client(espClient); \/\/MQTT client\u751f\u6210\n\n\/\/ Root CA Certificate\n\/\/ Load DigiCert Global Root CA ca_cert, which is used by EMQX Cloud Serverless Deployment\n\/\/ EMQX Serverless Deployment\u3067\u4f7f\u7528\u3055\u308c\u308b\u8a3c\u660e\u66f8\u3067\u3059\nstatic const char ca_cert[]\nPROGMEM = R"EOF(\n-----BEGIN CERTIFICATE-----\nMIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\nMQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\nd3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\nQTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\nMRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\nb20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\nCSDMAZOnTjC3U\/dDxGkAV53ijSLdhwZAAIEJzs4bg7\/fzTtxRuLWZscFs3YnFo97\nnh6Vfe63SKMI2tavegw5BmV\/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n43C\/dxC\/\/AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\nT19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr\/y7vrTC0LUq7dBMtoM1O\/4\ngdW7jVg\/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\nBgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH\/BAUwAwEB\/zAdBgNVHQ4EFgQUA95QNVbR\nTLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\nDQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY\/Esr\nhMAtudXH\/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp\/2PV5Adg\n06O\/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\nPnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\nYSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\nCAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n-----END CERTIFICATE-----\n)EOF";\n\n\/\/ \u95a2\u6570\u30d7\u30ed\u30c8\u30bf\u30a4\u30d7\u5ba3\u8a00\nvoid connectToWiFi();\nvoid connectToMQTT();\nvoid syncTime();\nvoid mqttCallback(char *topic, byte *payload, unsigned int length);\n\nint relay = 4;\n\nvoid setup() {\n pinMode( relay, OUTPUT ); \/\/ GPIO4 ( D2pin ) \u3092\u51fa\u529b\u30d4\u30f3\u306b\u3059\u308b\u8a2d\u5b9a\n Serial.begin(115200);\n connectToWiFi();\n syncTime(); \/\/ X.509 validation requires synchronization time\n mqtt_client.setServer(mqtt_broker, mqtt_port);\n mqtt_client.setCallback(mqttCallback);\n connectToMQTT();\n}\n\nvoid connectToWiFi() {\n WiFi.begin(ssid, password);\n Serial.print("Connecting to WiFi");\n while (WiFi.status() != WL_CONNECTED) {\n delay(500);\n Serial.println("Connecting to WiFi...");\n }\n Serial.println("Connected to WiFi");\n}\n\nvoid syncTime() {\n configTime(gmt_offset_sec, daylight_offset_sec, ntp_server);\n Serial.print("Waiting for NTP time sync: ");\n while (time(nullptr) < 8 * 3600 * 2) {\n delay(1000);\n Serial.print(".");\n }\n Serial.println("Time synchronized");\n struct tm timeinfo;\n if (getLocalTime(&timeinfo)) {\n Serial.print("Current time: ");\n Serial.println(asctime(&timeinfo));\n } else {\n Serial.println("Failed to obtain local time");\n }\n}\n\nvoid connectToMQTT() {\n BearSSL::X509List serverTrustedCA(ca_cert);\n espClient.setTrustAnchors(&serverTrustedCA);\n while (!mqtt_client.connected()) {\n String client_id = "esp8266-client-" + String(WiFi.macAddress());\/\/ macAddress\u3092\u4f7f\u3063\u3066client_id\u751f\u6210\n Serial.printf("Connecting to MQTT Broker as %s...\\n", client_id.c_str());\n if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {\n Serial.println("Connected to MQTT broker");\n mqtt_client.subscribe(mqtt_topic);\n mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); \/\/ Publish message upon connection\n } else {\n char err_buf[128];\n espClient.getLastSSLError(err_buf, sizeof(err_buf)); \n Serial.print("Failed to connect to MQTT broker, rc=");\n Serial.print(mqtt_client.state());\n Serial.print("SSL error: ");\n Serial.println(err_buf);\n Serial.println(" Retrying in 3 seconds.");\n delay(3000);\n }\n }\n}\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u3053\u306e callback \u95a2\u6570\u306f\u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089 NodeMCU \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u304c \/\/\n\/\/ \u9001\u3089\u308c\u308b\u3068\u5b9f\u884c\u3055\u308c\u307e\u3059 \/\/\n\/\/ MQTT\u306e\u4ed5\u69d8\u3067\u306f\u3001\u30d6\u30ed\u30fc\u30ab\u30fc\u304c\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8 \/\/\n\/\/ \uff08\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u306f NodeMCU \u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c\u306b\u3001 \/\/\n\/\/ \u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u30d6\u30ed\u30fc\u30ab\u30fc\u81ea\u8eab\u304c\u518d\u3073\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\uff08NodeMCU\uff09\u306b \/\/\n\/\/ \u914d\u4fe1\uff08\u30a8\u30b3\u30fc\uff09\u3059\u308b\u8a2d\u5b9a\u304c\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u6709\u52b9\u306b\u306a\u3063\u3066\u3044\u307e\u3059\u3002 \/\/\n\/\/ \u3053\u308c\u3092\u7121\u52b9\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u305d\u3046\u3067\u3059\u304c\u3001\u3044\u307e\u306e\u3068\u3053\u308d\u4e0d\u660e \/\/\n\/\/ \u305d\u306e\u305f\u3081\u3001NodeMCU \u304b\u3089\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u3068\u3001 \/\/\n\/\/ \u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089\u30a8\u30b3\u30fc\u3055\u308c\u305f\u540c\u3058\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u3001\u3053\u306ecallback \u95a2\u6570\u304c\u53d7\u3051\u53d6\u308a \/\/\n\/\/ \u4ee5\u4e0b\u306e Serial.print() \u3067\u30b7\u30ea\u30a2\u30eb\u30e2\u30cb\u30bf\u3067\u8868\u793a\u3055\u308c\u307e\u3059\u3002 \/\/ \n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nvoid mqttCallback(char *topic, byte *payload, unsigned int length) {\n Serial.print("Message received on topic: ");\n Serial.println(topic);\n Serial.print("Message: ");\n for (unsigned int i = 0; i < length; i++) {\n Serial.print((char)payload[i]);\n }\n Serial.println("\\n-----------------------");\n\n \/\/********************************************************************\/\/\n \/\/ \u6ce8\u610f\uff01\uff01\u3000SSSL\/TLS\u8a8d\u8a3c\u306e\u8a2d\u5b9a\u3092\u3057\u305f\u3068\u304d\u306f\u3001NodeMCU \u306e Builtin_LED \/\/\n \/\/ \u306f\u4f7f\u3048\u306a\u3044\u3088\u3046\u3067\u3059 \/\/\n \/\/\u3000\u3000\u3000\u5fc5\u305a\u5916\u4ed8\u3051\u306e LED \u3092\u4f7f\u7528\u3057\u3066\u304f\u3060\u3055\u3044 \/\/\n \/\/ \/\/\n \/\/ \u4ee5\u4e0b\u306f PC \u304b\u3089\u9001\u3089\u308c\u308b\u6570\u5b57\u306b\u3088\u3063\u3066\u3001relay \u3092 ON\u3001OFF \u3057\u307e\u3059 \/\/\n \/\/ \u6570\u5b57 \uff11 \u3067 relay \u3092ON\u3001\u6570\u5b57 \uff10 \u3067 relay \u3092OFF \u3067\u3059 \/\/\n \/\/*******************************************************************\/\/\n if ((char)payload[0] == '1') {\n digitalWrite( relay, HIGH ); \/\/relay ON\n } else if((char)payload[0] == '0'){\n digitalWrite( relay, LOW ); \/\/relay OFF \u6d88\u706f\n } \n}\n\nunsigned long lastMsg = 0;\n#define MSG_BUFFER_SIZE (50)\nchar msg[MSG_BUFFER_SIZE];\nint value = 0;\nint ii=0;\n\nvoid loop() {\n if (!mqtt_client.connected()) {\n connectToMQTT();\n }\n mqtt_client.loop();\n}<\/code><\/pre><\/div>\n\n\n\nM4_READING_SWITCH<\/strong>
\u30b9\u30a4\u30c3\u30c1\u306e ON \u3068 OFF \u3092\u8aad\u307f\u53d6\u308d\u3046\uff08\u4e0a\u306e\u56de\u8def\u56f3 C \u53c2\u7167\uff09<\/strong><\/p>\n\n\n\n\/\/ M4_READING_SWITCH.ino\n\n\/\/ https:\/\/github.com\/emqx\/MQTT-Client-Examples\/blob\/master\/mqtt-client-ESP8266\/esp8266_connect_mqtt_via_tls.ino\n\/\/\u3092\u53c2\u7167\u3057\u307e\u3057\u305f (github)\n\n\/\/************************************************\/\n\/\/ EMQX Serverless MQTT Broker \u3092\u4f7f\u7528\u3059\u308b *\/\n\/\/************************************************\/\n\/\/* NodeMCU MQTT client *\/\n\/\/* MQTT \u306e TLS\/SSL \u8a8d\u8a3c\u3092\u7528\u3044\u308b *\/\n\/\/* \u30dd\u30fc\u30c8\u756a\u53f7\u30008883 *\/\n\/\/* PC -> NodeMCU : \u30b9\u30a4\u30c3\u30c1ON\u3001OFF \u3092\u9001\u308b *\/\n\/\/* \u30b9\u30a4\u30c3\u30c1 OFF \u3067 HIGH (3.3V) *\/\n\/\/* \u30b9\u30a4\u30c3\u30c1 ON \u3067 LOW (0V) *\/ \n\/\/* NodeMCU\u7528\u306eMQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u30e9\u30a4\u30d6\u30e9\u30ea *\/\n\/\/* pubsubclient\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3059\u308b\u3053\u3068 Nick O'Leary\u4f5c *\/\n\/\/* 2025.12.20 *\/\n\/\/***********************************************\/\n#include <ESP8266WiFi.h>\n#include <PubSubClient.h>\n#include <time.h> \/\/ TLS\/SSL \u8a8d\u8a3c\u3092\u884c\u3046\u3068\u304d\u306f time.h \u304c\u5fc5\u8981\u306e\u3088\u3046\u3067\u3059\n\n\/\/ WiFi credentials\nconst char *ssid = "********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password = "*******"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker = "***********************"; \/\/ EMQX serverless \u306e\u63a5\u7d9a\u5148URL \u3092\u66f8\u304d\u307e\u3059\nconst char *mqtt_topic = "topi"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username = "system"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password = "seigyo"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port = 8883; \/\/ MQTT SSL\/TLS Port\n\n\/\/ NTP Server settings\nconst char *ntp_server = "pool.ntp.org"; \/\/ Default NTP server\n\/\/ \u4e0b\u306e gmt_offset_sec = 0 \u306e\u307e\u307e\u3067\u3088\u3055\u305d\u3046\u3067\u3059\nconst long gmt_offset_sec = 0; \/\/ GMT offset in seconds (adjust for your time zone)\nconst int daylight_offset_sec = 0; \/\/ Daylight saving time offset in seconds\n\n\/\/ WiFi and MQTT client initialization\nBearSSL::WiFiClientSecure espClient;\nPubSubClient mqtt_client(espClient); \/\/MQTT client\u751f\u6210\n\n\/\/ Root CA Certificate\n\/\/ Load DigiCert Global Root CA ca_cert, which is used by EMQX Cloud Serverless Deployment\n\/\/ EMQX Serverless Deployment\u3067\u4f7f\u7528\u3055\u308c\u308b\u8a3c\u660e\u66f8\u3067\u3059\nstatic const char ca_cert[]\nPROGMEM = R"EOF(\n-----BEGIN CERTIFICATE-----\nMIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\nMQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\nd3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\nQTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\nMRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\nb20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\nCSDMAZOnTjC3U\/dDxGkAV53ijSLdhwZAAIEJzs4bg7\/fzTtxRuLWZscFs3YnFo97\nnh6Vfe63SKMI2tavegw5BmV\/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n43C\/dxC\/\/AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\nT19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr\/y7vrTC0LUq7dBMtoM1O\/4\ngdW7jVg\/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\nBgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH\/BAUwAwEB\/zAdBgNVHQ4EFgQUA95QNVbR\nTLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\nDQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY\/Esr\nhMAtudXH\/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp\/2PV5Adg\n06O\/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\nPnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\nYSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\nCAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n-----END CERTIFICATE-----\n)EOF";\n\n\/\/ \u95a2\u6570\u30d7\u30ed\u30c8\u30bf\u30a4\u30d7\u5ba3\u8a00\nvoid connectToWiFi();\nvoid connectToMQTT();\nvoid syncTime();\nvoid mqttCallback(char *topic, byte *payload, unsigned int length);\n\nint switch_onoff = 4;\n\nvoid setup() {\n pinMode( switch_onoff, INPUT ); \/\/ GPIO4 ( D2pin ) \u3092\u5165\u529b\u30d4\u30f3\u306b\u3059\u308b\u8a2d\u5b9a\n Serial.begin(115200);\n connectToWiFi();\n syncTime(); \/\/ X.509 validation requires synchronization time\n mqtt_client.setServer(mqtt_broker, mqtt_port);\n mqtt_client.setCallback(mqttCallback);\n connectToMQTT();\n}\n\nvoid connectToWiFi() {\n WiFi.begin(ssid, password);\n Serial.print("Connecting to WiFi");\n while (WiFi.status() != WL_CONNECTED) {\n delay(500);\n Serial.println("Connecting to WiFi...");\n }\n Serial.println("Connected to WiFi");\n}\n\nvoid syncTime() {\n configTime(gmt_offset_sec, daylight_offset_sec, ntp_server);\n Serial.print("Waiting for NTP time sync: ");\n while (time(nullptr) < 8 * 3600 * 2) {\n delay(1000);\n Serial.print(".");\n }\n Serial.println("Time synchronized");\n struct tm timeinfo;\n if (getLocalTime(&timeinfo)) {\n Serial.print("Current time: ");\n Serial.println(asctime(&timeinfo));\n } else {\n Serial.println("Failed to obtain local time");\n }\n}\n\nvoid connectToMQTT() {\n BearSSL::X509List serverTrustedCA(ca_cert);\n espClient.setTrustAnchors(&serverTrustedCA);\n while (!mqtt_client.connected()) {\n String client_id = "esp8266-client-" + String(WiFi.macAddress());\/\/ macAddress\u3092\u4f7f\u3063\u3066client_id\u751f\u6210\n Serial.printf("Connecting to MQTT Broker as %s...\\n", client_id.c_str());\n if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {\n Serial.println("Connected to MQTT broker");\n mqtt_client.subscribe(mqtt_topic);\n mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); \/\/ Publish message upon connection\n } else {\n char err_buf[128];\n espClient.getLastSSLError(err_buf, sizeof(err_buf)); \n Serial.print("Failed to connect to MQTT broker, rc=");\n Serial.print(mqtt_client.state());\n Serial.print("SSL error: ");\n Serial.println(err_buf);\n Serial.println(" Retrying in 3 seconds.");\n delay(3000);\n }\n }\n}\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u3053\u306e callback \u95a2\u6570\u306f\u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089 NodeMCU \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u304c \/\/\n\/\/ \u9001\u3089\u308c\u308b\u3068\u5b9f\u884c\u3055\u308c\u307e\u3059 \/\/\n\/\/ MQTT\u306e\u4ed5\u69d8\u3067\u306f\u3001\u30d6\u30ed\u30fc\u30ab\u30fc\u304c\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8 \/\/\n\/\/ \uff08\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u306f NodeMCU \u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c\u306b\u3001 \/\/\n\/\/ \u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u30d6\u30ed\u30fc\u30ab\u30fc\u81ea\u8eab\u304c\u518d\u3073\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\uff08NodeMCU\uff09\u306b \/\/\n\/\/ \u914d\u4fe1\uff08\u30a8\u30b3\u30fc\uff09\u3059\u308b\u8a2d\u5b9a\u304c\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u6709\u52b9\u306b\u306a\u3063\u3066\u3044\u307e\u3059\u3002 \/\/\n\/\/ \u3053\u308c\u3092\u7121\u52b9\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u305d\u3046\u3067\u3059\u304c\u3001\u3044\u307e\u306e\u3068\u3053\u308d\u4e0d\u660e \/\/\n\/\/ \u305d\u306e\u305f\u3081\u3001NodeMCU \u304b\u3089\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u3068\u3001 \/\/\n\/\/ \u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089\u30a8\u30b3\u30fc\u3055\u308c\u305f\u540c\u3058\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u3001\u3053\u306ecallback \u95a2\u6570\u304c\u53d7\u3051\u53d6\u308a \/\/\n\/\/ \u4ee5\u4e0b\u306e Serial.print() \u3067\u30b7\u30ea\u30a2\u30eb\u30e2\u30cb\u30bf\u3067\u8868\u793a\u3055\u308c\u307e\u3059\u3002 \/\/ \n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nvoid mqttCallback(char *topic, byte *payload, unsigned int length) {\n Serial.print("Message received on topic: ");\n Serial.println(topic);\n Serial.print("Message: ");\n for (unsigned int i = 0; i < length; i++) {\n Serial.print((char)payload[i]);\n }\n Serial.println("\\n-----------------------"); \n}\n\n\/\/unsigned long lastMsg = 0;\n#define MSG_BUFFER_SIZE (50)\nchar msg[MSG_BUFFER_SIZE];\nint value = 0;\nint flag_i = 0;\n\nvoid loop() {\n if (!mqtt_client.connected()) {\n connectToMQTT();\n }\n mqtt_client.loop();\n\n \/\/************************************************************\/\/\n \/\/ \u4ee5\u4e0b\u3067 NodeMCU \u304b\u3089\u30b9\u30a4\u30c3\u30c1\u306e\u72b6\u614b\u3092 PC \u306b\u9001\u308b \/\/\n \/\/ \/\/\n \/\/ \u30b9\u30a4\u30c3\u30c1\u304c HIGH \u306a\u3089\u3070\u3001\u30b9\u30a4\u30c3\u30c1 OFF \u3067\u3059 \/\/\n \/\/ \u30b9\u30a4\u30c3\u30c1\u304c LOW \u306a\u3089\u3070\u3001\u30b9\u30a4\u30c3\u30c1 ON \u3067\u3059 \/\/\n \/\/**********************************************************\/\/\n int switchState = digitalRead( switch_onoff );\n if ((switchState == HIGH)&&(flag_i == 0)) { \/\/ SWITCH OFF\n flag_i = 1;\n ++value;\n snprintf(msg, MSG_BUFFER_SIZE, "#%ld: Swtch OFF ", value);\n mqtt_client.publish(mqtt_topic, msg);\n } else if ((switchState == LOW)&&(flag_i == 1)) { \/\/ SWITCH ON\n flag_i = 0;\n ++value;\n snprintf(msg, MSG_BUFFER_SIZE, "#%ld: Swtch ON ", value);\n mqtt_client.publish(mqtt_topic, msg);\n } \n}<\/code><\/pre><\/div>\n\n\n\nM6_READING_VR <\/strong>
MQTTX Web \u3067\u53ef\u5909\u62b5\u6297\u306e\u96fb\u5727\u3092\u8aad\u307f\u53d6\u308d\u3046 \uff08\u4e0a\u306e\u56de\u8def\u56f3 C \u53c2\u7167\uff09<\/strong><\/p>\n\n\n\n\/\/ M6_READING_VR.ino\n\n\/\/ https:\/\/github.com\/emqx\/MQTT-Client-Examples\/blob\/master\/mqtt-client-ESP8266\/esp8266_connect_mqtt_via_tls.ino\n\/\/\u3092\u53c2\u7167\u3057\u307e\u3057\u305f (github)\n\n\/\/************************************************\/\n\/\/ EMQX Serverless MQTT Broker \u3092\u4f7f\u7528\u3059\u308b *\/\n\/\/************************************************\/\n\/\/* NodeMCU MQTT client *\/\n\/\/* MQTT \u306e TLS\/SSL \u8a8d\u8a3c\u3092\u7528\u3044\u308b *\/\n\/\/* \u30dd\u30fc\u30c8\u756a\u53f7\u30008883 *\/\n\/\/* PC <- NodeMCU : \u53ef\u5909\u62b5\u6297\u306e AD \u5909\u63db\u5024\u3092 *\/\n\/\/* MQTTX Web \u306b\u9001\u308b *\/\n\/\/* A0\u30d4\u30f3\u306b\u5165\u529b\u3055\u308c\u305f 0-3.3V \u306e\u96fb\u5727\u3092AD\u5909\u63db\u3059\u308b *\/\n\/\/* NodeMCU\u7528\u306eMQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u30e9\u30a4\u30d6\u30e9\u30ea *\/\n\/\/* pubsubclient\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3059\u308b\u3053\u3068 Nick O'Leary\u4f5c *\/\n\/\/* 2025.12.21 *\/\n\/\/***********************************************\/\n#include <ESP8266WiFi.h>\n#include <PubSubClient.h>\n#include <time.h> \/\/ TLS\/SSL \u8a8d\u8a3c\u3092\u884c\u3046\u3068\u304d\u306f time.h \u304c\u5fc5\u8981\u306e\u3088\u3046\u3067\u3059\n\n\/\/ WiFi credentials\nconst char *ssid = "**********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password = "*********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker = "************************"; \/\/ EMQX serverless \u306e\u63a5\u7d9a\u5148URL \u3092\u66f8\u304d\u307e\u3059\nconst char *mqtt_topic = "topi"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username = "system"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password = "seigyo"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port = 8883; \/\/ MQTT SSL\/TLS Port\n\n\/\/ NTP Server settings\nconst char *ntp_server = "pool.ntp.org"; \/\/ Default NTP server\n\/\/ \u4e0b\u306e gmt_offset_sec = 0 \u306e\u307e\u307e\u3067\u3088\u3055\u305d\u3046\u3067\u3059\nconst long gmt_offset_sec = 0; \/\/ GMT offset in seconds (adjust for your time zone)\nconst int daylight_offset_sec = 0; \/\/ Daylight saving time offset in seconds\n\n\/\/ WiFi and MQTT client initialization\nBearSSL::WiFiClientSecure espClient;\nPubSubClient mqtt_client(espClient); \/\/MQTT client\u751f\u6210\n\n\/\/ Root CA Certificate\n\/\/ Load DigiCert Global Root CA ca_cert, which is used by EMQX Cloud Serverless Deployment\n\/\/ EMQX Serverless Deployment\u3067\u4f7f\u7528\u3055\u308c\u308b\u8a3c\u660e\u66f8\u3067\u3059\nstatic const char ca_cert[]\nPROGMEM = R"EOF(\n-----BEGIN CERTIFICATE-----\nMIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\nMQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\nd3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\nQTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\nMRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\nb20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\nCSDMAZOnTjC3U\/dDxGkAV53ijSLdhwZAAIEJzs4bg7\/fzTtxRuLWZscFs3YnFo97\nnh6Vfe63SKMI2tavegw5BmV\/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n43C\/dxC\/\/AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\nT19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr\/y7vrTC0LUq7dBMtoM1O\/4\ngdW7jVg\/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\nBgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH\/BAUwAwEB\/zAdBgNVHQ4EFgQUA95QNVbR\nTLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\nDQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY\/Esr\nhMAtudXH\/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp\/2PV5Adg\n06O\/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\nPnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\nYSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\nCAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n-----END CERTIFICATE-----\n)EOF";\n\n\/\/ \u95a2\u6570\u30d7\u30ed\u30c8\u30bf\u30a4\u30d7\u5ba3\u8a00\nvoid connectToWiFi();\nvoid connectToMQTT();\nvoid syncTime();\nvoid mqttCallback(char *topic, byte *payload, unsigned int length);\n\nvoid setup() {\n Serial.begin(115200);\n connectToWiFi();\n syncTime(); \/\/ X.509 validation requires synchronization time\n mqtt_client.setServer(mqtt_broker, mqtt_port);\n mqtt_client.setCallback(mqttCallback);\n connectToMQTT();\n}\n\nvoid connectToWiFi() {\n WiFi.begin(ssid, password);\n Serial.print("Connecting to WiFi");\n while (WiFi.status() != WL_CONNECTED) {\n delay(500);\n Serial.println("Connecting to WiFi...");\n }\n Serial.println("Connected to WiFi");\n}\n\nvoid syncTime() {\n configTime(gmt_offset_sec, daylight_offset_sec, ntp_server);\n Serial.print("Waiting for NTP time sync: ");\n while (time(nullptr) < 8 * 3600 * 2) {\n delay(1000);\n Serial.print(".");\n }\n Serial.println("Time synchronized");\n struct tm timeinfo;\n if (getLocalTime(&timeinfo)) {\n Serial.print("Current time: ");\n Serial.println(asctime(&timeinfo));\n } else {\n Serial.println("Failed to obtain local time");\n }\n}\n\nvoid connectToMQTT() {\n BearSSL::X509List serverTrustedCA(ca_cert);\n espClient.setTrustAnchors(&serverTrustedCA);\n while (!mqtt_client.connected()) {\n String client_id = "esp8266-client-" + String(WiFi.macAddress());\/\/ macAddress\u3092\u4f7f\u3063\u3066client_id\u751f\u6210\n Serial.printf("Connecting to MQTT Broker as %s...\\n", client_id.c_str());\n if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {\n Serial.println("Connected to MQTT broker");\n mqtt_client.subscribe(mqtt_topic);\n mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); \/\/ Publish message upon connection\n } else {\n char err_buf[128];\n espClient.getLastSSLError(err_buf, sizeof(err_buf)); \n Serial.print("Failed to connect to MQTT broker, rc=");\n Serial.print(mqtt_client.state());\n Serial.print("SSL error: ");\n Serial.println(err_buf);\n Serial.println(" Retrying in 3 seconds.");\n delay(3000);\n }\n }\n}\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u3053\u306e callback \u95a2\u6570\u306f\u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089 NodeMCU \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u304c \/\/\n\/\/ \u9001\u3089\u308c\u308b\u3068\u5b9f\u884c\u3055\u308c\u307e\u3059 \/\/\n\/\/ MQTT\u306e\u4ed5\u69d8\u3067\u306f\u3001\u30d6\u30ed\u30fc\u30ab\u30fc\u304c\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8 \/\/\n\/\/ \uff08\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u306f NodeMCU \u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c\u306b\u3001 \/\/\n\/\/ \u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u30d6\u30ed\u30fc\u30ab\u30fc\u81ea\u8eab\u304c\u518d\u3073\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\uff08NodeMCU\uff09\u306b \/\/\n\/\/ \u914d\u4fe1\uff08\u30a8\u30b3\u30fc\uff09\u3059\u308b\u8a2d\u5b9a\u304c\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u6709\u52b9\u306b\u306a\u3063\u3066\u3044\u307e\u3059\u3002 \/\/\n\/\/ \u3053\u308c\u3092\u7121\u52b9\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u305d\u3046\u3067\u3059\u304c\u3001\u3044\u307e\u306e\u3068\u3053\u308d\u4e0d\u660e \/\/\n\/\/ \u305d\u306e\u305f\u3081\u3001NodeMCU \u304b\u3089\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u3068\u3001 \/\/\n\/\/ \u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089\u30a8\u30b3\u30fc\u3055\u308c\u305f\u540c\u3058\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u3001\u3053\u306ecallback \u95a2\u6570\u304c\u53d7\u3051\u53d6\u308a \/\/\n\/\/ \u4ee5\u4e0b\u306e Serial.print() \u3067\u30b7\u30ea\u30a2\u30eb\u30e2\u30cb\u30bf\u3067\u8868\u793a\u3055\u308c\u307e\u3059\u3002 \/\/ \n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nvoid mqttCallback(char *topic, byte *payload, unsigned int length) {\n Serial.print("Message received on topic: ");\n Serial.println(topic);\n Serial.print("Message: ");\n for (unsigned int i = 0; i < length; i++) {\n Serial.print((char)payload[i]);\n }\n Serial.println("\\n-----------------------"); \n}\n\nunsigned long lastMsg = 0;\n#define MSG_BUFFER_SIZE (50)\nchar msg[MSG_BUFFER_SIZE];\n\/\/int value = 0;\n\/\/int flag_i = 0;\n\nint val; \/\/ AD\u5909\u63db\u5f8c\u306e\u5024\u3092\u4ee3\u5165\u3059\u308bint\u578b\u5909\u6570\uff1a\uff10\uff5e\uff11\uff10\uff12\uff13\u306e\u5024\nfloat vol; \/\/ AD\u5909\u63db\u3055\u308c\u305fint\u578b\u5909\u6570\u30920-3.3V \u306b\u3059\u308b\n\nvoid loop() {\n if (!mqtt_client.connected()) {\n connectToMQTT();\n }\n mqtt_client.loop();\n\n \/\/***************************************************************\/\/\n \/\/ \u4ee5\u4e0b\u3067 NodeMCU \u304b\u3089\u53ef\u5909\u62b5\u6297\u306e\u96fb\u5727\u5024\u3092\uff11\u79d2\u3054\u3068\u306b\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u9001\u308a\u307e\u3059 \/\/\n \/\/**************************************************************\/\/\n unsigned long now = millis(); \/\/ NodeMCU\u30de\u30a4\u30b3\u30f3\u306e\u73fe\u5728\u6642\u9593\u3092\n \/\/ \u30df\u30ea\u79d2\u5358\u4f4d\u3067\u53d6\u5f97\n if (now - lastMsg > 1000) {\n \/\/ 1\u79d2\u9593\u5f85\u6a5f\n lastMsg = now;\n val = analogRead(A0); \/\/ A0 \u30d4\u30f3\u304b\u3089\u53ef\u5909\u62b5\u6297\u306e\u96fb\u5727\u5024\u3092\u8aad\u307f\u3001\n \/\/ AD \u5909\u63db\u7d50\u679c\u3092 val \u306b\u5165\u529b\u3059\u308b\n vol = val * 3.3 \/ 1024; \n snprintf(msg, MSG_BUFFER_SIZE, "AD\u5024 %4d : \u96fb\u5727\u5024 %3.2fV", val, vol ); \n mqtt_client.publish(mqtt_topic, msg);\n } \n}<\/code><\/pre><\/div>\n\n\n\nM7_OLED MQTTX Web \u304b\u3089\u6587\u5b57\u5217\u3092 NodeMCU \u306b\u9001\u308a <\/strong>
OLED \u30e2\u30b8\u30e5\u30fc\u30eb\u3067\u8868\u793a\u3057\u3088\u3046\uff08\u4e0a\u306e\u56de\u8def\u56f3 A \u53c2\u7167\uff09\u3002
\u3000\uff08 OLED \u3068\u306f Organic Light Emitting Diode \u306e\u7565\u3067\u3001\u767a\u5149\u6750\u6599\u306b
\u6709\u6a5f\u7269\u8cea( Organic ) \u3092\u4f7f\u3063\u305f LED\uff08\u767a\u5149\u30c0\u30a4\u30aa\u30fc\u30c9\uff09\u306e\u3053\u3068\u3067\u3059 \uff09<\/strong><\/p>\n\n\n\n\/\/ M7_OLED.ino\n\n\/\/ https:\/\/github.com\/emqx\/MQTT-Client-Examples\/blob\/master\/mqtt-client-ESP8266\/esp8266_connect_mqtt_via_tls.ino\n\/\/\u3092\u53c2\u7167\u3057\u307e\u3057\u305f (github)\n\n\/\/************************************************\/\n\/\/ EMQX Serverless MQTT Broker \u3092\u4f7f\u7528\u3059\u308b *\/\n\/\/************************************************\/\n\/\/* NodeMCU MQTT client *\/\n\/\/* MQTT \u306e TLS\/SSL \u8a8d\u8a3c\u3092\u7528\u3044\u308b *\/\n\/\/* \u30dd\u30fc\u30c8\u756a\u53f7\u30008883 *\/\n\/\/* PC -> NodeMCU : MQTTX Web \u304b\u3089\u306e\u6587\u5b57\u5217\u3092 *\/\n\/\/* NodeMCU \u306e OLED \u306b\u8868\u793a\u3059\u308b *\/\n\/\/* OLED \u30e2\u30b8\u30e5\u30fc\u30eb\u4f7f\u3044\u307e\u3059\u3002\u7aef\u5b50\u306e\u63a5\u7d9a\u306f\u4ee5\u4e0b\u3067\u3059\u3002*\/\/\u3000\n\/\/* OLED\u30b3\u30f3\u30c8\u30ed\u30fc\u30e9\u30fc\u306f SSD1306 \u3067\u3059 *\/\/\n\/\/* I2C \u3067NodeMCU\u3068\u63a5\u7d9a\u3057\u307e\u3059 *\/\/\n\/\/* VDD -- 3.3V *\/\/\n\/\/* GND -- GND *\/\/\n\/\/* SCK -- D1 *\/\/\n\/\/* SDA -- D2 *\/\/\n\/\/* D1,D2 \u3092 I2C \u30d4\u30f3\u3068\u3057\u3066\u4f7f\u3044\u307e\u3059 *\/\/\n\/\/* NodeMCU\u7528\u306eMQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u30e9\u30a4\u30d6\u30e9\u30ea *\/\n\/\/* pubsubclient\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3059\u308b\u3053\u3068 Nick O'Leary\u4f5c *\/\n\/\/* 2025.12.21 *\/\n\/\/***********************************************\/\n#include <ESP8266WiFi.h>\n#include <PubSubClient.h>\n#include <time.h> \/\/ TLS\/SSL \u8a8d\u8a3c\u3092\u884c\u3046\u3068\u304d\u306f time.h \u304c\u5fc5\u8981\u306e\u3088\u3046\u3067\u3059\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/ OLED Setting \/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n#include <SPI.h>\n#include <Wire.h>\n#include <Adafruit_GFX.h>\n#include <Adafruit_SSD1306.h>\n#define SCREEN_WIDTH 128 \/\/OLED display width, in pixels\n#define SCREEN_HEIGHT 64 \/\/OLED display height, in pixels\n\/\/ Declaration for SSD1306 display connected using I2C\n#define OLED_RESET -1 \/\/ Reset pin\u3000\u3053\u306eOLED\u306f\n \/\/ Reset\u30d4\u30f3\u304c\u306a\u3044\u306e\u3067\u4f7f\u7528\u3057\u306a\u3044\u3053\u3068\u3092\u793a\u3059\n#define SCREEN_ADDRESS 0x3C \/\/ OLED \u306e I2C\u30a2\u30c9\u30ec\u30b9\n\/\/ \u6b21\u306f Adafruit_SSD1306\u30af\u30e9\u30b9\u306e\u30aa\u30d6\u30b8\u30a7\u30af\u30c8\u3092\u4f5c\u308b\u305f\u3081\u306e\u30b3\u30f3\u30b9\u30c8\u30e9\u30af\u30bf\u3067\u3059\nAdafruit_SSD1306 display(SCREEN_WIDTH, \nSCREEN_HEIGHT, &Wire, OLED_RESET);\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\n\/\/ WiFi credentials\nconst char *ssid = "*******"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password = "********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker = "************************"; \/\/ EMQX serverless \u306e\u63a5\u7d9a\u5148URL \u3092\u66f8\u304d\u307e\u3059\nconst char *mqtt_topic = "topi"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username = "system"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password = "seigyo"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port = 8883; \/\/ MQTT SSL\/TLS Port\n\n\/\/ NTP Server settings\nconst char *ntp_server = "pool.ntp.org"; \/\/ Default NTP server\n\/\/ \u4e0b\u306e gmt_offset_sec = 0 \u306e\u307e\u307e\u3067\u3088\u3055\u305d\u3046\u3067\u3059\nconst long gmt_offset_sec = 0; \/\/ GMT offset in seconds (adjust for your time zone)\nconst int daylight_offset_sec = 0; \/\/ Daylight saving time offset in seconds\n\n\/\/ WiFi and MQTT client initialization\nBearSSL::WiFiClientSecure espClient;\nPubSubClient mqtt_client(espClient); \/\/MQTT client\u751f\u6210\n\n\/\/ Root CA Certificate\n\/\/ Load DigiCert Global Root CA ca_cert, which is used by EMQX Cloud Serverless Deployment\n\/\/ EMQX Serverless Deployment\u3067\u4f7f\u7528\u3055\u308c\u308b\u8a3c\u660e\u66f8\u3067\u3059\nstatic const char ca_cert[]\nPROGMEM = R"EOF(\n-----BEGIN CERTIFICATE-----\nMIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\nMQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\nd3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\nQTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\nMRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\nb20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\nCSDMAZOnTjC3U\/dDxGkAV53ijSLdhwZAAIEJzs4bg7\/fzTtxRuLWZscFs3YnFo97\nnh6Vfe63SKMI2tavegw5BmV\/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n43C\/dxC\/\/AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\nT19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr\/y7vrTC0LUq7dBMtoM1O\/4\ngdW7jVg\/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\nBgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH\/BAUwAwEB\/zAdBgNVHQ4EFgQUA95QNVbR\nTLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\nDQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY\/Esr\nhMAtudXH\/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp\/2PV5Adg\n06O\/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\nPnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\nYSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\nCAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n-----END CERTIFICATE-----\n)EOF";\n\n\/\/ \u95a2\u6570\u30d7\u30ed\u30c8\u30bf\u30a4\u30d7\u5ba3\u8a00\nvoid connectToWiFi();\nvoid connectToMQTT();\nvoid syncTime();\nvoid mqttCallback(char *topic, byte *payload, unsigned int length);\n\nvoid setup() {\n Serial.begin(115200);\n connectToWiFi();\n syncTime(); \/\/ X.509 validation requires synchronization time\n mqtt_client.setServer(mqtt_broker, mqtt_port);\n mqtt_client.setCallback(mqttCallback);\n connectToMQTT();\n\n \/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n \/\/ OLED Initialize \/\/\n \/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n \/\/ initialize the OLED object : display.begin\n \/\/ SSID1306_SWITCHCAPVCC \u3067 OLED\u5185\u90e8\u306e\u96fb\u5727\u3092\u4e0a\u3052\u308b\n \/\/\u30c1\u30e3\u30fc\u30b8\u30dd\u30f3\u30d7\u3092 ON \u306b\u3059\u308b\n if(!display.begin(SSD1306_SWITCHCAPVCC, SCREEN_ADDRESS)) {\n Serial.println(F("SSD1306 allocation failed"));\n for(;;); \/\/ Don't proceed, loop forever\n }\n\n \/\/ Clear the buffer. OLED \u306e\u753b\u9762\u7528\u30e1\u30e2\u30ea\u30af\u30ea\u30a2\n display.clearDisplay();\n\n \/\/ Display Text\u3000"I am ready!"\u3092\u8868\u793a\u3057\u307e\u3059\n display.setTextSize(1); \/\/\u30d5\u30a9\u30f3\u30c8\u30b5\u30a4\u30ba\u8a2d\u5b9a\n display.setTextColor(WHITE); \/\/\u9ed2\u3044\u80cc\u666f\u306e\u3068\u304dWHITE\u3000\n \/\/\u660e\u308b\u3044\u80cc\u666f\u306e\u3068\u304dBLACK \u3068\u66f8\u304f\n display.setCursor(0,28); \/\/\u30ab\u30fc\u30bd\u30eb\u4f4d\u7f6e\u306e\u8a2d\u5b9a\n \/\/ (X,Y) X=horizontal, Y=vertical\n \/\/(0,0)\u306f\u5de6\u4e0a\u7aef\u3067\u3059\u3002(63,127)\u304c\u53f3\u4e0b\u7aef\u3067\u3059\u3002\n display.println("I am ready!"); \/\/\u753b\u9762\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u51fa\u529b\u3057\u307e\u3059\n \/\/ print(" ")\u306f\u6539\u884c\u7121\u3057\u3001println(" ")\u306f\u6539\u884c\u3057\u307e\u3059\u3002\n display.display();\/\/\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u753b\u9762\u306b\u8868\u793a\u3057\u307e\u3059\n delay(2000);\n display.clearDisplay(); \/\/OLED \u306e\u753b\u9762\u7528\u30e1\u30e2\u30ea\u30af\u30ea\u30a2\n}\n\nvoid connectToWiFi() {\n WiFi.begin(ssid, password);\n Serial.print("Connecting to WiFi");\n while (WiFi.status() != WL_CONNECTED) {\n delay(500);\n Serial.println("Connecting to WiFi...");\n }\n Serial.println("Connected to WiFi");\n}\n\nvoid syncTime() {\n configTime(gmt_offset_sec, daylight_offset_sec, ntp_server);\n Serial.print("Waiting for NTP time sync: ");\n while (time(nullptr) < 8 * 3600 * 2) {\n delay(1000);\n Serial.print(".");\n }\n Serial.println("Time synchronized");\n struct tm timeinfo;\n if (getLocalTime(&timeinfo)) {\n Serial.print("Current time: ");\n Serial.println(asctime(&timeinfo));\n } else {\n Serial.println("Failed to obtain local time");\n }\n}\n\nvoid connectToMQTT() {\n BearSSL::X509List serverTrustedCA(ca_cert);\n espClient.setTrustAnchors(&serverTrustedCA);\n while (!mqtt_client.connected()) {\n String client_id = "esp8266-client-" + String(WiFi.macAddress());\/\/ macAddress\u3092\u4f7f\u3063\u3066client_id\u751f\u6210\n Serial.printf("Connecting to MQTT Broker as %s...\\n", client_id.c_str());\n if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {\n Serial.println("Connected to MQTT broker");\n mqtt_client.subscribe(mqtt_topic);\n mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); \/\/ Publish message upon connection\n } else {\n char err_buf[128];\n espClient.getLastSSLError(err_buf, sizeof(err_buf)); \n Serial.print("Failed to connect to MQTT broker, rc=");\n Serial.print(mqtt_client.state());\n Serial.print("SSL error: ");\n Serial.println(err_buf);\n Serial.println(" Retrying in 3 seconds.");\n delay(3000);\n }\n }\n}\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u3053\u306e callback \u95a2\u6570\u306f\u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089 NodeMCU \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u304c \/\/\n\/\/ \u9001\u3089\u308c\u308b\u3068\u5b9f\u884c\u3055\u308c\u307e\u3059 \/\/\n\/\/ MQTT\u306e\u4ed5\u69d8\u3067\u306f\u3001\u30d6\u30ed\u30fc\u30ab\u30fc\u304c\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8 \/\/\n\/\/ \uff08\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u306f NodeMCU \u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c\u306b\u3001 \/\/\n\/\/ \u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u30d6\u30ed\u30fc\u30ab\u30fc\u81ea\u8eab\u304c\u518d\u3073\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\uff08NodeMCU\uff09\u306b \/\/\n\/\/ \u914d\u4fe1\uff08\u30a8\u30b3\u30fc\uff09\u3059\u308b\u8a2d\u5b9a\u304c\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u6709\u52b9\u306b\u306a\u3063\u3066\u3044\u307e\u3059\u3002 \/\/\n\/\/ \u3053\u308c\u3092\u7121\u52b9\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u305d\u3046\u3067\u3059\u304c\u3001\u3044\u307e\u306e\u3068\u3053\u308d\u4e0d\u660e \/\/\n\/\/ \u305d\u306e\u305f\u3081\u3001NodeMCU \u304b\u3089\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u3068\u3001 \/\/\n\/\/ \u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089\u30a8\u30b3\u30fc\u3055\u308c\u305f\u540c\u3058\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u3001\u3053\u306ecallback \u95a2\u6570\u304c\u53d7\u3051\u53d6\u308a \/\/\n\/\/ \u4ee5\u4e0b\u306e Serial.print() \u3067\u30b7\u30ea\u30a2\u30eb\u30e2\u30cb\u30bf\u3067\u8868\u793a\u3055\u308c\u307e\u3059\u3002 \/\/ \n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nvoid mqttCallback(char *topic, byte *payload, unsigned int length) {\n Serial.print("Message received on topic: ");\n Serial.println(topic);\n Serial.print("Message: ");\n for (unsigned int i = 0; i < length; i++) {\n Serial.print((char)payload[i]);\n }\n Serial.println("\\n-----------------------"); \n\n \/\/********************************************************************\/\/\n \/\/ \u6ce8\u610f\uff01\uff01\u3000SSSL\/TLS\u8a8d\u8a3c\u306e\u8a2d\u5b9a\u3092\u3057\u305f\u3068\u304d\u306f\u3001NodeMCU \u306e Builtin_LED \/\/\n \/\/ \u306f\u4f7f\u3048\u306a\u3044\u3088\u3046\u3067\u3059 \/\/\n \/\/\u3000\u3000\u3000\u5fc5\u305a\u5916\u4ed8\u3051\u306e LED \u3092\u4f7f\u7528\u3057\u3066\u304f\u3060\u3055\u3044 \/\/\n \/\/ \/\/\n \/\/ \u4ee5\u4e0b\u306f MQTTX Web \u304b\u3089\u9001\u3089\u308c\u305f\u6587\u5b57\u5217\u3092 OLED \u306b\u8868\u793a\u3057\u307e\u3059 \/\/\n \/\/*******************************************************************\/\/\n display.clearDisplay(); \/\/OLED \u306e\u753b\u9762\u7528\u30e1\u30e2\u30ea\u30af\u30ea\u30a2 \n display.display(); \/\/\u63cf\u753b\u753b\u9762\u30af\u30ea\u30a2 \n \/\/ (X,Y) X=horizontal, Y=vertical\n \/\/(0,0)\u306f\u5de6\u4e0a\u7aef\u3067\u3059\u3002(63,127)\u304c\u53f3\u4e0b\u7aef\u3067\u3059\u3002\n display.setCursor(0,28); \/\/\u30ab\u30fc\u30bd\u30eb\u4f4d\u7f6e\u306e\u8a2d\u5b9a\n for (unsigned int ii = 0; ii < length; ii++) { \n display.print( (char)payload[ii]); \/\/\u753b\u9762\u306b\u6587\u5b57\u5217\u3092\u51fa\u529b\u3057\u307e\u3059\u3002\u6539\u884c\u7121\u3057\u3002\n \/\/ print(" ")\u306f\u6539\u884c\u7121\u3057\u3001println(" ")\u306f\u6539\u884c\u3057\u307e\u3059\u3002\n }\n display.display();\/\/\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u753b\u9762\u306b\u8868\u793a\u3057\u307e\u3059\n delay(2000);\n memset(payload, '\\0', length); \/\/\u914d\u5217 payload \u521d\u671f\u5316\n}\n\nvoid loop() {\n if (!mqtt_client.connected()) {\n connectToMQTT();\n }\n mqtt_client.loop(); \n}<\/code><\/pre><\/div>\n\n\n\nM8_DHT22<\/strong>
MQTTX Web \u3067\u6e29\u5ea6\u30bb\u30f3\u30b5 DHT22 \u306e\u5024\u3092\u8aad\u307f\u53d6\u308d\u3046\u3002<\/strong>
\uff08\u4e0a\u306e\u56de\u8def\u56f3 B \u53c2\u7167\uff09\u3000
\u3000DHT22 ( AM2302 ) \u306f\u30c7\u30fc\u30bf\u4ea4\u63db\u3068\u5236\u5fa1\u304c1\u672c\u306e\u30c7\u30fc\u30bf\u7dda\u3067\u884c\u3046\u30b7\u30f3\u30b0\u30eb\u30ef\u30a4\u30e4\u901a\u4fe1\u3092\u63a1\u7528\u3057\u3066\u3044\u307e\u3059\u3002\u30b7\u30f3\u30b0\u30eb\u30ef\u30a4\u30e4\u901a\u4fe1\u306f\u30011-WIre \u3068\u66f8\u304d\u307e\u3059\u3002\u305d\u306e\u305f\u3081\u3001\u96fb\u6e90VCC\u3001GND\u3001\u30c7\u30fc\u30bf\u7dda\u306e\uff13\u672c\u3067\u6e29\u5ea6\u30fb\u6e7f\u5ea6\u30c7\u30fc\u30bf\u3092\u51fa\u529b\u3067\u304d\u307e\u3059\u3002<\/strong><\/p>\n\n\n\n\/\/ M8_DHT22.ino\n\n\/\/ https:\/\/github.com\/emqx\/MQTT-Client-Examples\/blob\/master\/mqtt-client-ESP8266\/esp8266_connect_mqtt_via_tls.ino\n\/\/\u3092\u53c2\u7167\u3057\u307e\u3057\u305f (github)\n\n\/\/************************************************\/\n\/\/ EMQX Serverless MQTT Broker \u3092\u4f7f\u7528\u3059\u308b *\/\n\/\/************************************************\/\n\/\/* NodeMCU MQTT client *\/\n\/\/* MQTT \u306e TLS\/SSL \u8a8d\u8a3c\u3092\u7528\u3044\u308b \u3000\u3000\u3000 *\/\n\/\/* \u30dd\u30fc\u30c8\u756a\u53f7\u30008883 \u3000\u3000\u3000\u3000 *\/\n\/\/* PC <- NodeMCU : \u6e29\u5ea6\u30bb\u30f3\u30b5 DHT22 \u304b\u3089\u306e\u6e29\u5ea6\u3068\u6e7f\u5ea6\u3092 *\/\n\/\/* MQTTX Web \u306b\u9001\u308b *\/\n\/\/* \u30d4\u30f3\u306e\u63a5\u7d9a *\/\/\n\/\/* VCC = 3.3V *\/\/\n\/\/* S = GPIO13 ( D7pin ) *\/\/\n\/\/* GND = GND *\/\/\n\/\/* NodeMCU\u7528\u306eMQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u30e9\u30a4\u30d6\u30e9\u30ea *\/\n\/\/* pubsubclient\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3059\u308b\u3053\u3068 Nick O'Leary\u4f5c *\/\n\/\/* 2025.12.23 *\/\n\/\/***********************************************\/\n#include <ESP8266WiFi.h>\n#include <PubSubClient.h>\n#include <time.h> \/\/ TLS\/SSL \u8a8d\u8a3c\u3092\u884c\u3046\u3068\u304d\u306f time.h \u304c\u5fc5\u8981\u306e\u3088\u3046\u3067\u3059\n\n\/\/ WiFi credentials\nconst char *ssid = "********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password = "********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker = "*********************"; \/\/ EMQX serverless \u306e\u63a5\u7d9a\u5148URL \u3092\u66f8\u304d\u307e\u3059\nconst char *mqtt_topic = "topi"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username = "system"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password = "seigyo"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port = 8883; \/\/ MQTT SSL\/TLS Port\n\n\/\/ NTP Server settings\nconst char *ntp_server = "pool.ntp.org"; \/\/ Default NTP server\n\/\/ \u4e0b\u306e gmt_offset_sec = 0 \u306e\u307e\u307e\u3067\u3088\u3055\u305d\u3046\u3067\u3059\nconst long gmt_offset_sec = 0; \/\/ GMT offset in seconds (adjust for your time zone)\nconst int daylight_offset_sec = 0; \/\/ Daylight saving time offset in seconds\n\n\/\/ WiFi and MQTT client initialization\nBearSSL::WiFiClientSecure espClient;\nPubSubClient mqtt_client(espClient); \/\/MQTT client\u751f\u6210\n\n\/\/ Root CA Certificate\n\/\/ Load DigiCert Global Root CA ca_cert, which is used by EMQX Cloud Serverless Deployment\n\/\/ EMQX Serverless Deployment\u3067\u4f7f\u7528\u3055\u308c\u308b\u8a3c\u660e\u66f8\u3067\u3059\nstatic const char ca_cert[]\nPROGMEM = R"EOF(\n-----BEGIN CERTIFICATE-----\nMIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\nMQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\nd3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\nQTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\nMRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\nb20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\nCSDMAZOnTjC3U\/dDxGkAV53ijSLdhwZAAIEJzs4bg7\/fzTtxRuLWZscFs3YnFo97\nnh6Vfe63SKMI2tavegw5BmV\/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n43C\/dxC\/\/AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\nT19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr\/y7vrTC0LUq7dBMtoM1O\/4\ngdW7jVg\/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\nBgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH\/BAUwAwEB\/zAdBgNVHQ4EFgQUA95QNVbR\nTLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\nDQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY\/Esr\nhMAtudXH\/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp\/2PV5Adg\n06O\/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\nPnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\nYSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\nCAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n-----END CERTIFICATE-----\n)EOF";\n\n\/\/ \u95a2\u6570\u30d7\u30ed\u30c8\u30bf\u30a4\u30d7\u5ba3\u8a00\nvoid connectToWiFi();\nvoid connectToMQTT();\nvoid syncTime();\nvoid mqttCallback(char *topic, byte *payload, unsigned int length);\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/\/\/\/\/\/\/\/\/\/ \u6e29\u5ea6\u30bb\u30f3\u30b5\u3000\u8a2d\u5b9a \/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n#include "DHT.h"\n#define DHTPIN 13 \/\/ NodeMCU D7pin = GPIO13\n\/\/ Uncomment whatever type you're using!\n\/\/#define DHTTYPE DHT11 \/\/ DHT 11 \n#define DHTTYPE DHT22 \/\/ DHT 22 (AM2302)\n\/\/ Initialize DHT sensor.\nDHT dht(DHTPIN, DHTTYPE);\n\nvoid setup() {\n Serial.begin(115200);\n connectToWiFi();\n syncTime(); \/\/ X.509 validation requires synchronization time\n mqtt_client.setServer(mqtt_broker, mqtt_port);\n mqtt_client.setCallback(mqttCallback);\n connectToMQTT();\n\n Serial.println("DHTxx test!");\n dht.begin(); \n}\n\nvoid connectToWiFi() {\n WiFi.begin(ssid, password);\n Serial.print("Connecting to WiFi");\n while (WiFi.status() != WL_CONNECTED) {\n delay(500);\n Serial.println("Connecting to WiFi...");\n }\n Serial.println("Connected to WiFi");\n}\n\nvoid syncTime() {\n configTime(gmt_offset_sec, daylight_offset_sec, ntp_server);\n Serial.print("Waiting for NTP time sync: ");\n while (time(nullptr) < 8 * 3600 * 2) {\n delay(1000);\n Serial.print(".");\n }\n Serial.println("Time synchronized");\n struct tm timeinfo;\n if (getLocalTime(&timeinfo)) {\n Serial.print("Current time: ");\n Serial.println(asctime(&timeinfo));\n } else {\n Serial.println("Failed to obtain local time");\n }\n}\n\nvoid connectToMQTT() {\n BearSSL::X509List serverTrustedCA(ca_cert);\n espClient.setTrustAnchors(&serverTrustedCA);\n while (!mqtt_client.connected()) {\n String client_id = "esp8266-client-" + String(WiFi.macAddress());\/\/ macAddress\u3092\u4f7f\u3063\u3066client_id\u751f\u6210\n Serial.printf("Connecting to MQTT Broker as %s...\\n", client_id.c_str());\n if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {\n Serial.println("Connected to MQTT broker");\n mqtt_client.subscribe(mqtt_topic);\n mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); \/\/ Publish message upon connection\n } else {\n char err_buf[128];\n espClient.getLastSSLError(err_buf, sizeof(err_buf)); \n Serial.print("Failed to connect to MQTT broker, rc=");\n Serial.print(mqtt_client.state());\n Serial.print("SSL error: ");\n Serial.println(err_buf);\n Serial.println(" Retrying in 3 seconds.");\n delay(3000);\n }\n }\n}\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u3053\u306e callback \u95a2\u6570\u306f\u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089 NodeMCU \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u304c \/\/\n\/\/ \u9001\u3089\u308c\u308b\u3068\u5b9f\u884c\u3055\u308c\u307e\u3059 \/\/\n\/\/ MQTT\u306e\u4ed5\u69d8\u3067\u306f\u3001\u30d6\u30ed\u30fc\u30ab\u30fc\u304c\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8 \/\/\n\/\/ \uff08\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u306f NodeMCU \u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c\u306b\u3001 \/\/\n\/\/ \u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u30d6\u30ed\u30fc\u30ab\u30fc\u81ea\u8eab\u304c\u518d\u3073\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\uff08NodeMCU\uff09\u306b \/\/\n\/\/ \u914d\u4fe1\uff08\u30a8\u30b3\u30fc\uff09\u3059\u308b\u8a2d\u5b9a\u304c\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u6709\u52b9\u306b\u306a\u3063\u3066\u3044\u307e\u3059\u3002 \/\/\n\/\/ \u3053\u308c\u3092\u7121\u52b9\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u305d\u3046\u3067\u3059\u304c\u3001\u3044\u307e\u306e\u3068\u3053\u308d\u4e0d\u660e \/\/\n\/\/ \u305d\u306e\u305f\u3081\u3001NodeMCU \u304b\u3089\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u3068\u3001 \/\/\n\/\/ \u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089\u30a8\u30b3\u30fc\u3055\u308c\u305f\u540c\u3058\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u3001\u3053\u306ecallback \u95a2\u6570\u304c\u53d7\u3051\u53d6\u308a \/\/\n\/\/ \u4ee5\u4e0b\u306e Serial.print() \u3067\u30b7\u30ea\u30a2\u30eb\u30e2\u30cb\u30bf\u3067\u8868\u793a\u3055\u308c\u307e\u3059\u3002 \/\/ \n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nvoid mqttCallback(char *topic, byte *payload, unsigned int length) {\n Serial.print("Message received on topic: ");\n Serial.println(topic);\n Serial.print("Message: ");\n for (unsigned int i = 0; i < length; i++) {\n Serial.print((char)payload[i]);\n }\n Serial.println("\\n-----------------------"); \n}\n\nunsigned long lastMsg = 0;\n#define MSG_BUFFER_SIZE (50)\nchar msg[MSG_BUFFER_SIZE];\n\nvoid loop() {\n if (!mqtt_client.connected()) {\n connectToMQTT();\n }\n mqtt_client.loop();\n\n \/\/***********************************************************************\/\/\n \/\/ \u4ee5\u4e0b\u3067 NodeMCU \u304b\u3089\u6e29\u5ea6\u30bb\u30f3\u30b5DHT22\u306e\u6e29\u5ea6\u3068\u6e7f\u5ea6\u3092\uff12\u79d2\u3054\u3068\u306b\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u9001\u308a\u307e\u3059 \/\/\n \/\/***********************************************************************\/\/\n unsigned long now = millis(); \/\/ NodeMCU\u30de\u30a4\u30b3\u30f3\u306e\u73fe\u5728\u6642\u9593\u3092\n \/\/ \u30df\u30ea\u79d2\u5358\u4f4d\u3067\u53d6\u5f97\n if (now - lastMsg > 2000) {\n \/\/ 1\u79d2\u9593\u5f85\u6a5f\n lastMsg = now;\n \/\/ Reading temperature or humidity takes about 250 milliseconds!\n \/\/ Sensor readings may also be up to 2 seconds 'old' (its a very slow sensor)\n \/\/ humidity \u6e7f\u5ea6\n float h = dht.readHumidity();\n \/\/ Read temperature as Celsius \u30bb\u30eb\u30b7\u30a6\u30b9\u6e29\u5ea6 (the default)\n float t = dht.readTemperature();\n \/\/ Read temperature as Fahrenheit \u3000\u83ef\u6c0f\u6e29\u5ea6 (isFahrenheit = true)\n float f = dht.readTemperature(true);\n \n \/\/ Check if any reads failed and exit early (to try again).\n if (isnan(h) || isnan(t) || isnan(f)) {\n Serial.println("Failed to read from DHT sensor!");\n return;\n }\n\n snprintf(msg, MSG_BUFFER_SIZE, "\u6e7f\u5ea6 %5.2f% : \u6e29\u5ea6 %5.2f\u5ea6", h, t ); \n mqtt_client.publish(mqtt_topic, msg);\n \n Serial.print("Humidity: "); \n Serial.print(h);\n Serial.print(" %\\t");\n Serial.print("Temperature: "); \n Serial.print(t);\n Serial.println(" *C ");\n } \n}<\/code><\/pre><\/div>\n\n\n\nM9_HCSR04 <\/strong>
\u3000MQTTX Web \u3067\u8d85\u97f3\u6ce2\u30bb\u30f3\u30b5 HC-SR04 \u306e\u5024\u3092\u8aad\u307f\u53d6\u308d\u3046\u3002<\/strong>
\uff08\u4e0a\u306e\u56de\u8def\u56f3 B \u53c2\u7167\uff09<\/strong><\/p>\n\n\n\n\/\/ M9_HCSR04.ino\n\n\/\/ https:\/\/github.com\/emqx\/MQTT-Client-Examples\/blob\/master\/mqtt-client-ESP8266\/esp8266_connect_mqtt_via_tls.ino\n\/\/\u3092\u53c2\u7167\u3057\u307e\u3057\u305f (github)\n\n\/\/************************************************\/\n\/\/ EMQX Serverless MQTT Broker \u3092\u4f7f\u7528\u3059\u308b *\/\n\/\/************************************************\/\n\/\/* NodeMCU MQTT client *\/\n\/\/* MQTT \u306e TLS\/SSL \u8a8d\u8a3c\u3092\u7528\u3044\u308b \u3000\u3000\u3000 *\/\n\/\/* \u30dd\u30fc\u30c8\u756a\u53f7\u30008883 \u3000\u3000\u3000\u3000 *\/\n\/\/* PC <- NodeMCU : \u8d85\u97f3\u6ce2\u30bb\u30f3\u30b5 HC-SR04 \u304b\u3089\u306e\u8ddd\u96e2\u30c7\u30fc\u30bf\u3092 *\/\n\/\/* MQTTX Web \u306b\u9001\u308b *\/\n\/\/* \u30d4\u30f3\u306e\u63a5\u7d9a *\/\/\n\/\/* VCC = VIN 5V *\/\/\n\/\/* Trig = GPIO12 ( D6pin ) *\/\/\n\/\/* Echo = GPIO14 ( D5pin ) *\/\/\n\/\/* GND = GND *\/\/\n\/\/* NodeMCU\u7528\u306eMQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u30e9\u30a4\u30d6\u30e9\u30ea *\/\n\/\/* pubsubclient\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3059\u308b\u3053\u3068 Nick O'Leary\u4f5c *\/\n\/\/* 2025.12.23 *\/\n\/\/***********************************************\/\n#include <ESP8266WiFi.h>\n#include <PubSubClient.h>\n#include <time.h> \/\/ TLS\/SSL \u8a8d\u8a3c\u3092\u884c\u3046\u3068\u304d\u306f time.h \u304c\u5fc5\u8981\u306e\u3088\u3046\u3067\u3059\n\n\/\/ WiFi credentials\nconst char *ssid = "********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password = "********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker = "**************************"; \/\/ EMQX serverless \u306e\u63a5\u7d9a\u5148URL \u3092\u66f8\u304d\u307e\u3059\nconst char *mqtt_topic = "topi"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username = "system"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password = "seigyo"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port = 8883; \/\/ MQTT SSL\/TLS Port\n\n\/\/ NTP Server settings\nconst char *ntp_server = "pool.ntp.org"; \/\/ Default NTP server\n\/\/ \u4e0b\u306e gmt_offset_sec = 0 \u306e\u307e\u307e\u3067\u3088\u3055\u305d\u3046\u3067\u3059\nconst long gmt_offset_sec = 0; \/\/ GMT offset in seconds (adjust for your time zone)\nconst int daylight_offset_sec = 0; \/\/ Daylight saving time offset in seconds\n\n\/\/ WiFi and MQTT client initialization\nBearSSL::WiFiClientSecure espClient;\nPubSubClient mqtt_client(espClient); \/\/MQTT client\u751f\u6210\n\n\/\/ Root CA Certificate\n\/\/ Load DigiCert Global Root CA ca_cert, which is used by EMQX Cloud Serverless Deployment\n\/\/ EMQX Serverless Deployment\u3067\u4f7f\u7528\u3055\u308c\u308b\u8a3c\u660e\u66f8\u3067\u3059\nstatic const char ca_cert[]\nPROGMEM = R"EOF(\n-----BEGIN CERTIFICATE-----\nMIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\nMQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\nd3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\nQTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\nMRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\nb20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\nCSDMAZOnTjC3U\/dDxGkAV53ijSLdhwZAAIEJzs4bg7\/fzTtxRuLWZscFs3YnFo97\nnh6Vfe63SKMI2tavegw5BmV\/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n43C\/dxC\/\/AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\nT19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr\/y7vrTC0LUq7dBMtoM1O\/4\ngdW7jVg\/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\nBgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH\/BAUwAwEB\/zAdBgNVHQ4EFgQUA95QNVbR\nTLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\nDQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY\/Esr\nhMAtudXH\/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp\/2PV5Adg\n06O\/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\nPnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\nYSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\nCAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n-----END CERTIFICATE-----\n)EOF";\n\n\/\/ \u95a2\u6570\u30d7\u30ed\u30c8\u30bf\u30a4\u30d7\u5ba3\u8a00\nvoid connectToWiFi();\nvoid connectToMQTT();\nvoid syncTime();\nvoid mqttCallback(char *topic, byte *payload, unsigned int length);\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/\/\/\/\/\/\/\/\/\/ \u8d85\u97f3\u6ce2\u30bb\u30f3\u30b5 HC-SR04 \u8a2d\u5b9a \/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nconst int trigPin = 12;\nconst int echoPin = 14;\n\/\/define sound velocity in cm\/uS\n#define SOUND_VELOCITY 0.034\nlong duration;\nfloat distanceCm;\n\nvoid setup() {\n Serial.begin(115200);\n connectToWiFi();\n syncTime(); \/\/ X.509 validation requires synchronization time\n mqtt_client.setServer(mqtt_broker, mqtt_port);\n mqtt_client.setCallback(mqttCallback);\n connectToMQTT();\n\n \/\/\/\/ HC-SR04 pin setting \/\/\/\/\n pinMode(trigPin, OUTPUT); \/\/ Sets the trigPin as an Output\n pinMode(echoPin, INPUT); \/\/ Sets the echoPin as an Input\n}\n\nvoid connectToWiFi() {\n WiFi.begin(ssid, password);\n Serial.print("Connecting to WiFi");\n while (WiFi.status() != WL_CONNECTED) {\n delay(500);\n Serial.println("Connecting to WiFi...");\n }\n Serial.println("Connected to WiFi");\n}\n\nvoid syncTime() {\n configTime(gmt_offset_sec, daylight_offset_sec, ntp_server);\n Serial.print("Waiting for NTP time sync: ");\n while (time(nullptr) < 8 * 3600 * 2) {\n delay(1000);\n Serial.print(".");\n }\n Serial.println("Time synchronized");\n struct tm timeinfo;\n if (getLocalTime(&timeinfo)) {\n Serial.print("Current time: ");\n Serial.println(asctime(&timeinfo));\n } else {\n Serial.println("Failed to obtain local time");\n }\n}\n\nvoid connectToMQTT() {\n BearSSL::X509List serverTrustedCA(ca_cert);\n espClient.setTrustAnchors(&serverTrustedCA);\n while (!mqtt_client.connected()) {\n String client_id = "esp8266-client-" + String(WiFi.macAddress());\/\/ macAddress\u3092\u4f7f\u3063\u3066client_id\u751f\u6210\n Serial.printf("Connecting to MQTT Broker as %s...\\n", client_id.c_str());\n if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {\n Serial.println("Connected to MQTT broker");\n mqtt_client.subscribe(mqtt_topic);\n mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); \/\/ Publish message upon connection\n } else {\n char err_buf[128];\n espClient.getLastSSLError(err_buf, sizeof(err_buf)); \n Serial.print("Failed to connect to MQTT broker, rc=");\n Serial.print(mqtt_client.state());\n Serial.print("SSL error: ");\n Serial.println(err_buf);\n Serial.println(" Retrying in 3 seconds.");\n delay(3000);\n }\n }\n}\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u3053\u306e callback \u95a2\u6570\u306f\u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089 NodeMCU \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u304c \/\/\n\/\/ \u9001\u3089\u308c\u308b\u3068\u5b9f\u884c\u3055\u308c\u307e\u3059 \/\/\n\/\/ MQTT\u306e\u4ed5\u69d8\u3067\u306f\u3001\u30d6\u30ed\u30fc\u30ab\u30fc\u304c\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8 \/\/\n\/\/ \uff08\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u306f NodeMCU \u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c\u306b\u3001 \/\/\n\/\/ \u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u30d6\u30ed\u30fc\u30ab\u30fc\u81ea\u8eab\u304c\u518d\u3073\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\uff08NodeMCU\uff09\u306b \/\/\n\/\/ \u914d\u4fe1\uff08\u30a8\u30b3\u30fc\uff09\u3059\u308b\u8a2d\u5b9a\u304c\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u6709\u52b9\u306b\u306a\u3063\u3066\u3044\u307e\u3059\u3002 \/\/\n\/\/ \u3053\u308c\u3092\u7121\u52b9\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u305d\u3046\u3067\u3059\u304c\u3001\u3044\u307e\u306e\u3068\u3053\u308d\u4e0d\u660e \/\/\n\/\/ \u305d\u306e\u305f\u3081\u3001NodeMCU \u304b\u3089\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u3068\u3001 \/\/\n\/\/ \u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089\u30a8\u30b3\u30fc\u3055\u308c\u305f\u540c\u3058\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u3001\u3053\u306ecallback \u95a2\u6570\u304c\u53d7\u3051\u53d6\u308a \/\/\n\/\/ \u4ee5\u4e0b\u306e Serial.print() \u3067\u30b7\u30ea\u30a2\u30eb\u30e2\u30cb\u30bf\u3067\u8868\u793a\u3055\u308c\u307e\u3059\u3002 \/\/ \n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nvoid mqttCallback(char *topic, byte *payload, unsigned int length) {\n Serial.print("Message received on topic: ");\n Serial.println(topic);\n Serial.print("Message: ");\n for (unsigned int i = 0; i < length; i++) {\n Serial.print((char)payload[i]);\n }\n Serial.println("\\n-----------------------"); \n}\n\nunsigned long lastMsg = 0;\n#define MSG_BUFFER_SIZE (50)\nchar msg[MSG_BUFFER_SIZE];\n\nvoid loop() {\n if (!mqtt_client.connected()) {\n connectToMQTT();\n }\n mqtt_client.loop();\n\n \/\/***********************************************************************\/\/\n \/\/ \u4ee5\u4e0b\u3067 NodeMCU \u304b\u3089\u8d85\u97f3\u6ce2\u30bb\u30f3\u30b5\u306e\u6e2c\u5b9a\u8ddd\u96e2\u3092\uff11\u79d2\u3054\u3068\u306b\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u9001\u308a\u307e\u3059 \/\/\n \/\/***********************************************************************\/\/\n unsigned long now = millis(); \/\/ NodeMCU\u30de\u30a4\u30b3\u30f3\u306e\u73fe\u5728\u6642\u9593\u3092\n \/\/ \u30df\u30ea\u79d2\u5358\u4f4d\u3067\u53d6\u5f97\n if (now - lastMsg > 1000) {\n \/\/ 1\u79d2\u9593\u5f85\u6a5f\n lastMsg = now;\n \/\/ Clears the trigPin\n digitalWrite(trigPin, LOW);\n delayMicroseconds(2);\n \/\/ Sets the trigPin on HIGH state for 10 micro seconds\n digitalWrite(trigPin, HIGH);\n delayMicroseconds(10);\n digitalWrite(trigPin, LOW);\n \n \/\/ Reads the echoPin, returns the sound wave travel time in microseconds\n duration = pulseIn(echoPin, HIGH);\n \n \/\/ Calculate the distance\n distanceCm = duration * SOUND_VELOCITY\/2;\n \n snprintf(msg, MSG_BUFFER_SIZE, "\u8ddd\u96e2 %7.2f cm", distanceCm ); \n mqtt_client.publish(mqtt_topic, msg);\n \n \/\/ Prints the distance on the Serial Monitor\n Serial.print("Distance (cm): ");\n Serial.println(distanceCm); \n } \n}<\/code><\/pre><\/div>\n\n\n\nM10_IRremote_MQTT<\/strong>
\u3000MQTTX Web \u3067\u8d64\u5916\u7dda\u30ea\u30e2\u30b3\u30f3\u306e\u5024\u3092\u8aad\u307f\u53d6\u308d\u3046\u3002
\u3000\u8d64\u5916\u7dda\u30ec\u30b7\u30fc\u30d0\u306f VS1838B \u3092\u4f7f\u7528\u3057\u307e\u3059\u3002\uff08\u4e0a\u306e\u56de\u8def\u56f3 C \u53c2\u7167\uff09<\/strong><\/p>\n\n\n\n\/\/ M10_IRremote_MQTT.ino\n\/* \n * \u3000\u8d64\u5916\u7dda\u30ec\u30b7\u30fc\u30d0\u3092 NodeMCU \u306b\u63a5\u7d9a\u3057\u3001\u8d64\u5916\u7dda\u30ea\u30e2\u30b3\u30f3\u306e\u30ad\u30fc\u304c\u62bc\u3055\u308c\u308b\u3068\u9001\u51fa\u3055\u308c\u308b\n * \u3000\u8d64\u5916\u7dda\u4fe1\u53f7\u3092\u3001\u3053\u306e\u8d64\u5916\u7dda\u30ec\u30b7\u30fc\u30d0\u3067\u53d7\u4fe1\u3057\u3001NodeMCU \u306b IR\u30b3\u30fc\u30c9\u3092\u9001\u4fe1\u3057\u307e\u3059\u3002\n * \u3055\u3089\u306b\u8aad\u307f\u53d6\u3063\u305fIR\u30b3\u30fc\u30c9\u3092\u3001MQTT\u3092\u7528\u3044\u3066\u3001MQTTX Web \u306b publish\u3057\u307e\u3059\n * MQTT\u30d6\u30ed\u30fc\u30ab\u30fc\u306f EMQX serverless \u3092\u4f7f\u7528\u3057\u307e\u3059\u3002\n * 2026.2.7\n * IRremoteESP8266 \u30e9\u30a4\u30d6\u30e9\u30ea\u306f\u30d0\u30fc\u30b8\u30e7\u30f3 2.8.6 \u3067\u3059\u30022025\u5e7412\u670824\u65e5\u306b\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u3057\u307e\u3057\u305f\u3002\n * 2025.12.24\n *\/\n \/\/\/\/\/\/ \u8d64\u5916\u7dda\u306b\u95a2\u3059\u308b\u8a2d\u5b9a \/\/\/\/\/\/\n#include <Arduino.h>\n#include <IRremoteESP8266.h>\n#include <IRrecv.h>\n#include <IRutils.h>\n\/\/ An IR detector\/demodulator is connected to GPIO pin 14(D5 on a NodeMCU\n\/\/ board).\n\/\/ Note: GPIO 16 won't work on the ESP8266 as it does not have interrupts.\n\/\/ Note: GPIO 14 won't work on the ESP32-C3 as it causes the board to reboot.\n#ifdef ARDUINO_ESP32C3_DEV\nconst uint16_t kRecvPin = 10; \/\/ 14 on a ESP32-C3 causes a boot loop.\n#else \/\/ NodeMCU\nconst uint16_t kRecvPin = 14;\n#endif\nIRrecv irrecv(kRecvPin);\ndecode_results results;\n\n\/\/\/\/\/\/ \u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u30fbMQTT\u306b\u95a2\u3059\u308b\u8a2d\u5b9a \/\/\/\/\/\/\n#include <ESP8266WiFi.h>\n#include <PubSubClient.h>\n#include <time.h> \/\/ TLS\/SSL \u8a8d\u8a3c\u3092\u884c\u3046\u3068\u304d\u306f time.h \u304c\u5fc5\u8981\u306e\u3088\u3046\u3067\u3059\n\/\/ WiFi credentials\nconst char *ssid = "**********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password = "*********"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker = "*******************"; \/\/ EMQX serverless \u306e\u63a5\u7d9a\u5148URL \u3092\u66f8\u304d\u307e\u3059\nconst char *mqtt_topic = "topi"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username = "system"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password = "seigyo"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port = 8883; \/\/ MQTT SSL\/TLS Port\n\/\/ NTP Server settings\nconst char *ntp_server = "pool.ntp.org"; \/\/ Default NTP server\n\/\/ \u4e0b\u306e gmt_offset_sec = 0 \u306e\u307e\u307e\u3067\u3088\u3055\u305d\u3046\u3067\u3059\nconst long gmt_offset_sec = 0; \/\/ GMT offset in seconds (adjust for your time zone)\nconst int daylight_offset_sec = 0; \/\/ Daylight saving time offset in seconds\n\/\/ WiFi and MQTT client initialization\nBearSSL::WiFiClientSecure espClient;\nPubSubClient mqtt_client(espClient); \/\/MQTT client\u751f\u6210\n\/\/ Root CA Certificate\n\/\/ Load DigiCert Global Root CA ca_cert, which is used by EMQX Cloud Serverless Deployment\n\/\/ EMQX Serverless Deployment\u3067\u4f7f\u7528\u3055\u308c\u308b\u8a3c\u660e\u66f8\u3067\u3059\nstatic const char ca_cert[]\nPROGMEM = R"EOF(\n-----BEGIN CERTIFICATE-----\nMIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\nMQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\nd3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\nQTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\nMRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\nb20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\nCSDMAZOnTjC3U\/dDxGkAV53ijSLdhwZAAIEJzs4bg7\/fzTtxRuLWZscFs3YnFo97\nnh6Vfe63SKMI2tavegw5BmV\/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n43C\/dxC\/\/AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\nT19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr\/y7vrTC0LUq7dBMtoM1O\/4\ngdW7jVg\/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\nBgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH\/BAUwAwEB\/zAdBgNVHQ4EFgQUA95QNVbR\nTLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\nDQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY\/Esr\nhMAtudXH\/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp\/2PV5Adg\n06O\/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\nPnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\nYSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\nCAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n-----END CERTIFICATE-----\n)EOF";\n\n\/\/ \u95a2\u6570\u30d7\u30ed\u30c8\u30bf\u30a4\u30d7\u5ba3\u8a00\nvoid connectToWiFi();\nvoid connectToMQTT();\nvoid syncTime();\nvoid mqttCallback(char *topic, byte *payload, unsigned int length);\n\nvoid setup() {\n Serial.begin(115200);\n irrecv.enableIRIn(); \/\/ Start the receiver\n while (!Serial) \/\/ Wait for the serial connection to be establised.\n delay(50);\n\n connectToWiFi();\n syncTime(); \/\/ X.509 validation requires synchronization time\n mqtt_client.setServer(mqtt_broker, mqtt_port);\n mqtt_client.setCallback(mqttCallback);\n connectToMQTT();\n \n Serial.println();\n Serial.print("IRrecvDemo is now running and waiting for IR message on Pin ");\n Serial.println(kRecvPin);\n}\n\nvoid connectToWiFi() {\n WiFi.begin(ssid, password);\n Serial.print("Connecting to WiFi");\n while (WiFi.status() != WL_CONNECTED) {\n delay(500);\n Serial.println("Connecting to WiFi...");\n }\n Serial.println("Connected to WiFi");\n}\n\nvoid syncTime() {\n configTime(gmt_offset_sec, daylight_offset_sec, ntp_server);\n Serial.print("Waiting for NTP time sync: ");\n while (time(nullptr) < 8 * 3600 * 2) {\n delay(1000);\n Serial.print(".");\n }\n Serial.println("Time synchronized");\n struct tm timeinfo;\n if (getLocalTime(&timeinfo)) {\n Serial.print("Current time: ");\n Serial.println(asctime(&timeinfo));\n } else {\n Serial.println("Failed to obtain local time");\n }\n}\n\nvoid connectToMQTT() {\n BearSSL::X509List serverTrustedCA(ca_cert);\n espClient.setTrustAnchors(&serverTrustedCA);\n while (!mqtt_client.connected()) {\n String client_id = "esp8266-client-" + String(WiFi.macAddress());\/\/ macAddress\u3092\u4f7f\u3063\u3066client_id\u751f\u6210\n Serial.printf("Connecting to MQTT Broker as %s...\\n", client_id.c_str());\n if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {\n Serial.println("Connected to MQTT broker");\n mqtt_client.subscribe(mqtt_topic);\n mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); \/\/ Publish message upon connection\n } else {\n char err_buf[128];\n espClient.getLastSSLError(err_buf, sizeof(err_buf)); \n Serial.print("Failed to connect to MQTT broker, rc=");\n Serial.print(mqtt_client.state());\n Serial.print("SSL error: ");\n Serial.println(err_buf);\n Serial.println(" Retrying in 3 seconds.");\n delay(3000);\n }\n }\n}\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u3053\u306e callback \u95a2\u6570\u306f\u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089 NodeMCU \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u304c \/\/\n\/\/ \u9001\u3089\u308c\u308b\u3068\u5b9f\u884c\u3055\u308c\u307e\u3059 \/\/\n\/\/ MQTT\u306e\u4ed5\u69d8\u3067\u306f\u3001\u30d6\u30ed\u30fc\u30ab\u30fc\u304c\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8 \/\/\n\/\/ \uff08\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u306f NodeMCU \u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c\u306b\u3001 \/\/\n\/\/ \u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u30d6\u30ed\u30fc\u30ab\u30fc\u81ea\u8eab\u304c\u518d\u3073\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\uff08NodeMCU\uff09\u306b \/\/\n\/\/ \u914d\u4fe1\uff08\u30a8\u30b3\u30fc\uff09\u3059\u308b\u8a2d\u5b9a\u304c\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u6709\u52b9\u306b\u306a\u3063\u3066\u3044\u307e\u3059\u3002 \/\/\n\/\/ \u3053\u308c\u3092\u7121\u52b9\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u305d\u3046\u3067\u3059\u304c\u3001\u3044\u307e\u306e\u3068\u3053\u308d\u4e0d\u660e \/\/\n\/\/ \u305d\u306e\u305f\u3081\u3001NodeMCU \u304b\u3089\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u3068\u3001 \/\/\n\/\/ \u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089\u30a8\u30b3\u30fc\u3055\u308c\u305f\u540c\u3058\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u3001\u3053\u306ecallback \u95a2\u6570\u304c\u53d7\u3051\u53d6\u308a \/\/\n\/\/ \u4ee5\u4e0b\u306e Serial.print() \u3067\u30b7\u30ea\u30a2\u30eb\u30e2\u30cb\u30bf\u3067\u8868\u793a\u3055\u308c\u307e\u3059\u3002 \/\/ \n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nvoid mqttCallback(char *topic, byte *payload, unsigned int length) {\n Serial.print("Message received on topic: ");\n Serial.println(topic);\n Serial.print("Message: ");\n for (unsigned int i = 0; i < length; i++) {\n Serial.print((char)payload[i]);\n }\n Serial.println("\\n-----------------------"); \n}\n\nunsigned long lastMsg = 0;\n#define MSG_BUFFER_SIZE (50)\nchar msg[MSG_BUFFER_SIZE];\n\nvoid loop() {\nunsigned long IRvalue; \n if (!mqtt_client.connected()) {\n connectToMQTT();\n }\n mqtt_client.loop(); \n\n \/\/***************************************************************\/\/\n \/\/ \u4ee5\u4e0b\u3067 NodeMCU \u304b\u3089IR\u30ea\u30e2\u30b3\u30f3\u306e\u30b3\u30fc\u30c9\u3092\uff11\u79d2\u3054\u3068\u306b\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u9001\u308a\u307e\u3059 \/\/\n \/\/************************************************************\n long now = millis();\n\n if (now - lastMsg > 1000) {\n lastMsg = now;\n if (irrecv.decode(&results)) {\n \/\/ results.value is typically a 32-bit integer\n Serial.print(results.value, HEX);Serial.print(" "); Serial.println(results.value);\n IRvalue = results.value;\n snprintf(msg, MSG_BUFFER_SIZE, "IR\u5024 %#X", IRvalue ); \n mqtt_client.publish(mqtt_topic, msg);\n irrecv.resume(); \/\/ Receive the next value\n }\n }\n}<\/code><\/pre><\/div>\n\n\n\nM11_IR_LED_MQTT<\/strong>
\u3000MQTTX Web \u304b\u3089\u8d64\u5916\u7dda\u30ea\u30e2\u30b3\u30f3\u306e\u30b9\u30a4\u30c3\u30c1\u756a\u53f7\u3092\u9001\u308a\u3001NodeMCU \u306b\u63a5\u7d9a\u3057\u3066\u3044\u308b\u8d64\u5916\u7ddaLED \u3067\u30b9\u30a4\u30c3\u30c1\u756a\u53f7\u306b\u5bfe\u5fdc\u3057\u305f\u4fe1\u53f7\u5024\u3092\u9001\u308a\u3001\u30c0\u30a4\u30bd\u30fc\u306e\u30ea\u30e2\u30b3\u30f3\u30e9\u30a4\u30c8\u3092\u70b9\u706f\u3055\u305b\u3088\u3046\u3002
\uff08\u4e0a\u306e\u56de\u8def\u56f3 F \u53c2\u7167\uff09<\/strong>
\u6ce8\u610f\uff01\uff01<\/mark><\/strong>\u3000\u5fc5\u305aNO_1 \u306e ON\u30b9\u30a4\u30c3\u30c1\u3092\u62bc\u3057\u3066\u304b\u3089\u3001\u4ed6\u306e\u8272\u30b9\u30a4\u30c3\u30c1\u3092\u62bc\u3057\u3066\u304f\u3060\u3055\u3044\u3002 NO_2 \u306e OFF\u30b9\u30a4\u30c3\u30c1\u3092\u62bc\u3057\u3066\u6d88\u706f\u3057\u305f\u5f8c\u3067\u8272\u30b9\u30a4\u30c3\u30c1\u3092\u62bc\u3057\u3066\u3082\u70b9\u706f\u3057\u307e\u305b\u3093<\/mark>\u3002\u3000\u307e\u305f\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u306f\u30ea\u30e2\u30b3\u30f3\u306e\u30b9\u30a4\u30c3\u30c1\u756a\u53f7 NO_1\u3001NO_2 \u3068NO_7 \uff5e NO_18\u3092\u6307\u5b9a\u3057\u305f\u3068\u304d\u3060\u3051\u52d5\u4f5c\u3057\u307e\u3059\u3002NO_3 \uff5e NO_6 \u306f\u7121\u53cd\u5fdc\u3067\u3059\u3002<\/mark><\/p>\n\n\n\n\/\/ M11_IR_LED_MQTT.ino\n\/* \n * \u3000MQTTX Web\u304b\u3089 Publish \u3055\u308c\u305f\u3001\u8d64\u5916\u7dda\u30ea\u30e2\u30b3\u30f3\u306e\u30b9\u30a4\u30c3\u30c1\u756a\u53f7\u3092\u53d7\u3051\u53d6\u308a\u3001\n * NodeMCU \u306b\u63a5\u7d9a\u3057\u3066\u3044\u308b\u8d64\u5916\u7ddaLED\u3067\u3001\u30b9\u30a4\u30c3\u30c1\u756a\u53f7\u306b\u5bfe\u5fdc\u3057\u305f \n * IR\u30b3\u30fc\u30c9\u3092\u30c0\u30a4\u30bd\u30fc\u30ea\u30e2\u30b3\u30f3\u30e9\u30a4\u30c8\u306b\u9001\u308a\u70b9\u706f\u3057\u307e\u3059\u3002\n * MQTT\u30d6\u30ed\u30fc\u30ab\u30fc\u306f EMQX serverless \u3092\u4f7f\u7528\u3057\u307e\u3059\u3002\n * 2026.2.7\n * IRremoteESP8266 \u30e9\u30a4\u30d6\u30e9\u30ea\u306f\u30d0\u30fc\u30b8\u30e7\u30f3 2.8.6 \u3067\u3059\u30022025\u5e7412\u670824\u65e5\u306b\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u3057\u307e\u3057\u305f\u3002\n * 2025.12.24\n *\/\n \/\/\/\/\/\/ \u8d64\u5916\u7dda\u306b\u95a2\u3059\u308b\u8a2d\u5b9a \/\/\/\/\/\/\n#include <Arduino.h>\n#include <IRremoteESP8266.h>\n#include <IRsend.h>\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u8d64\u5916\u7ddaLED \u304b\u3089\u9001\u51fa\u3055\u308c\u308b\u4fe1\u53f7\u306e \u300c\u8868\u300d\u3000\u3067\u3059 \/\/\n\/\/ \/\/\n\/\/ \u30d7\u30ed\u30b0\u30e9\u30e0 N11_IRremote \u3067\u8aad\u307f\u8fbc\u3093\u3060 \/\/\n\/\/ \u8d64\u5916\u7dda\u30ea\u30e2\u30b3\u30f3\u306e\u30b9\u30a4\u30c3\u30c1\u3092\u62bc\u3057\u305f\u3068\u304d\u306b\u70b9\u706f\u3059\u308b \/\/\n\/\/ \u8d64\u5916\u7ddaLED \u304b\u3089\u9001\u51fa\u3055\u308c\u308b\u4fe1\u53f7\u306e\u5185\u5bb9\u3092\u4ee5\u4e0b\u306b\u8a18\u5165\u3057\u307e\u3057\u3087\u3046 \/\/\n\/\/ \uff11\uff16\u9032\u6570\u3067\u66f8\u3044\u3066\u306d\uff1a 0x1FE1234 \u3068\u304b \/\/\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u30b9\u30a4\u30c3\u30c1\u756a\u53f7 \/ \u4fe1\u53f7\uff11\uff16\u9032\u6570 \/ \u30b9\u30a4\u30c3\u30c1\u306e\u610f\u5473\n\/\/ 1 \/ \/ ON \u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_1 = 0x0 ;\n\/\/ 2 \/ \/ OFF \u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_2 = 0x0 ;\n\/\/ 3 \/ \/ Mode \u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_3 = 0x0 ;\n\/\/ 4 \/ \/ 4 hour timer\nconst uint32_t NO_4 = 0x0 ;\n\/\/ 5 \/ \/ 8 hour timer\nconst uint32_t NO_5 = 0x0 ;\n\/\/ 6 \/ \/ Multi \u70b9\u706f\nconst uint32_t NO_6 = 0x0 ;\n\/\/ 7 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_7 = 0x0 ;\n\/\/ 8 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_8 = 0x0 ;\n\/\/ 9 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_9 = 0x0 ;\n\/\/ 10 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_10 = 0x0 ;\n\/\/ 11 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_11 = 0x0 ;\n\/\/ 12 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_12 = 0x0 ;\n\/\/ 13 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_13 = 0x0 ;\n\/\/ 14 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_14 = 0x0 ;\n\/\/ 15 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_15 = 0x0 ;\n\/\/ 16 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_16 = 0x0 ;\n\/\/ 17 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_17 = 0x0 ;\n\/\/ 18 \/ \/ \u8272\u30b9\u30a4\u30c3\u30c1\nconst uint32_t NO_18 = 0x0 ;\n\n\/\/ \u8d64\u5916\u7ddaLED\u3092\u63a5\u7d9a\u3057\u305f\u30d4\u30f3 (D2 = GPIO4)\nconst uint16_t kIrLed = 4;\nIRsend irsend(kIrLed);\n\n\/\/\/\/\/\/ \u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u30fbMQTT\u306b\u95a2\u3059\u308b\u8a2d\u5b9a \/\/\/\/\/\/\n#include <ESP8266WiFi.h>\n#include <PubSubClient.h>\n#include <time.h> \/\/ TLS\/SSL \u8a8d\u8a3c\u3092\u884c\u3046\u3068\u304d\u306f time.h \u304c\u5fc5\u8981\u306e\u3088\u3046\u3067\u3059\n\/\/ WiFi credentials\nconst char *ssid = "*******"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password = "*******"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker = "********************"; \/\/ EMQX serverless \u306e\u63a5\u7d9a\u5148URL \u3092\u66f8\u304d\u307e\u3059\nconst char *mqtt_topic = "topi"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username = "system"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password = "seigyo"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port = 8883; \/\/ MQTT SSL\/TLS Port\n\/\/ NTP Server settings\nconst char *ntp_server = "pool.ntp.org"; \/\/ Default NTP server\n\/\/ \u4e0b\u306e gmt_offset_sec = 0 \u306e\u307e\u307e\u3067\u3088\u3055\u305d\u3046\u3067\u3059\nconst long gmt_offset_sec = 0; \/\/ GMT offset in seconds (adjust for your time zone)\nconst int daylight_offset_sec = 0; \/\/ Daylight saving time offset in seconds\n\/\/ WiFi and MQTT client initialization\nBearSSL::WiFiClientSecure espClient;\nPubSubClient mqtt_client(espClient); \/\/MQTT client\u751f\u6210\n\/\/ Root CA Certificate\n\/\/ Load DigiCert Global Root CA ca_cert, which is used by EMQX Cloud Serverless Deployment\n\/\/ EMQX Serverless Deployment\u3067\u4f7f\u7528\u3055\u308c\u308b\u8a3c\u660e\u66f8\u3067\u3059\nstatic const char ca_cert[]\nPROGMEM = R"EOF(\n-----BEGIN CERTIFICATE-----\nMIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\nMQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\nd3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\nQTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\nMRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\nb20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\nCSDMAZOnTjC3U\/dDxGkAV53ijSLdhwZAAIEJzs4bg7\/fzTtxRuLWZscFs3YnFo97\nnh6Vfe63SKMI2tavegw5BmV\/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n43C\/dxC\/\/AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\nT19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr\/y7vrTC0LUq7dBMtoM1O\/4\ngdW7jVg\/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\nBgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH\/BAUwAwEB\/zAdBgNVHQ4EFgQUA95QNVbR\nTLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\nDQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY\/Esr\nhMAtudXH\/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp\/2PV5Adg\n06O\/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\nPnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\nYSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\nCAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n-----END CERTIFICATE-----\n)EOF";\n\n\/\/ \u95a2\u6570\u30d7\u30ed\u30c8\u30bf\u30a4\u30d7\u5ba3\u8a00\nvoid connectToWiFi();\nvoid connectToMQTT();\nvoid syncTime();\nvoid mqttCallback(char *topic, byte *payload, unsigned int length);\n\nvoid setup() {\n Serial.begin(115200);\n irsend.begin();\n while (!Serial) \/\/ Wait for the serial connection to be establised.\n delay(50);\n\n connectToWiFi();\n syncTime(); \/\/ X.509 validation requires synchronization time\n mqtt_client.setServer(mqtt_broker, mqtt_port);\n mqtt_client.setCallback(mqttCallback);\n connectToMQTT();\n \n Serial.println();\n Serial.println("IR Sender Ready");\n}\n\nvoid connectToWiFi() {\n WiFi.begin(ssid, password);\n Serial.print("Connecting to WiFi");\n while (WiFi.status() != WL_CONNECTED) {\n delay(500);\n Serial.println("Connecting to WiFi...");\n }\n Serial.println("Connected to WiFi");\n}\n\nvoid syncTime() {\n configTime(gmt_offset_sec, daylight_offset_sec, ntp_server);\n Serial.print("Waiting for NTP time sync: ");\n while (time(nullptr) < 8 * 3600 * 2) {\n delay(1000);\n Serial.print(".");\n }\n Serial.println("Time synchronized");\n struct tm timeinfo;\n if (getLocalTime(&timeinfo)) {\n Serial.print("Current time: ");\n Serial.println(asctime(&timeinfo));\n } else {\n Serial.println("Failed to obtain local time");\n }\n}\n\nvoid connectToMQTT() {\n BearSSL::X509List serverTrustedCA(ca_cert);\n espClient.setTrustAnchors(&serverTrustedCA);\n while (!mqtt_client.connected()) {\n String client_id = "esp8266-client-" + String(WiFi.macAddress());\/\/ macAddress\u3092\u4f7f\u3063\u3066client_id\u751f\u6210\n Serial.printf("Connecting to MQTT Broker as %s...\\n", client_id.c_str());\n if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {\n Serial.println("Connected to MQTT broker");\n mqtt_client.subscribe(mqtt_topic);\n mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); \/\/ Publish message upon connection\n } else {\n char err_buf[128];\n espClient.getLastSSLError(err_buf, sizeof(err_buf)); \n Serial.print("Failed to connect to MQTT broker, rc=");\n Serial.print(mqtt_client.state());\n Serial.print("SSL error: ");\n Serial.println(err_buf);\n Serial.println(" Retrying in 3 seconds.");\n delay(3000);\n }\n }\n}\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u3053\u306e callback \u95a2\u6570\u306f\u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089 NodeMCU \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u304c \/\/\n\/\/ \u9001\u3089\u308c\u308b\u3068\u5b9f\u884c\u3055\u308c\u307e\u3059 \/\/\n\/\/ MQTT\u306e\u4ed5\u69d8\u3067\u306f\u3001\u30d6\u30ed\u30fc\u30ab\u30fc\u304c\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8 \/\/\n\/\/ \uff08\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u306f NodeMCU \u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c\u306b\u3001 \/\/\n\/\/ \u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u30d6\u30ed\u30fc\u30ab\u30fc\u81ea\u8eab\u304c\u518d\u3073\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\uff08NodeMCU\uff09\u306b \/\/\n\/\/ \u914d\u4fe1\uff08\u30a8\u30b3\u30fc\uff09\u3059\u308b\u8a2d\u5b9a\u304c\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u6709\u52b9\u306b\u306a\u3063\u3066\u3044\u307e\u3059\u3002 \/\/\n\/\/ \u3053\u308c\u3092\u7121\u52b9\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u305d\u3046\u3067\u3059\u304c\u3001\u3044\u307e\u306e\u3068\u3053\u308d\u4e0d\u660e \/\/\n\/\/ \u305d\u306e\u305f\u3081\u3001NodeMCU \u304b\u3089\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u3068\u3001 \/\/\n\/\/ \u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089\u30a8\u30b3\u30fc\u3055\u308c\u305f\u540c\u3058\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u3001\u3053\u306ecallback \u95a2\u6570\u304c\u53d7\u3051\u53d6\u308a \/\/\n\/\/ \u4ee5\u4e0b\u306e Serial.print() \u3067\u30b7\u30ea\u30a2\u30eb\u30e2\u30cb\u30bf\u3067\u8868\u793a\u3055\u308c\u307e\u3059\u3002 \/\/ \n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nvoid mqttCallback(char *topic, byte *payload, unsigned int length) {\n Serial.print("Message received on topic: ");\n Serial.println(topic);\n Serial.print("Message: ");\n for (unsigned int i = 0; i < length; i++) {\n Serial.print((char)payload[i]);\n }\n Serial.println("\\n-----------------------"); \n\n \/\/********************************************************************\/\/\n \/\/ \u6ce8\u610f\uff01\uff01\u3000SSSL\/TLS\u8a8d\u8a3c\u306e\u8a2d\u5b9a\u3092\u3057\u305f\u3068\u304d\u306f\u3001NodeMCU \u306e Builtin_LED \/\/\n \/\/ \u306f\u4f7f\u3048\u306a\u3044\u3088\u3046\u3067\u3059 \/\/\n \/\/\u3000\u3000\u3000\u5fc5\u305a\u5916\u4ed8\u3051\u306e LED \u3092\u4f7f\u7528\u3057\u3066\u304f\u3060\u3055\u3044 \/\/\n \/\/ \/\/\n \/\/ \u4ee5\u4e0b\u306f MQTTX Web \u304b\u3089\u9001\u3089\u308c\u305f\u30c0\u30a4\u30bd\u30fc\u30ea\u30e2\u30b3\u30f3\u306e\u30b9\u30a4\u30c3\u30c1\u756a\u53f7\u3092\u53d7\u3051\u53d6\u308a \/\/\n \/\/ \u30b9\u30a4\u30c3\u30c1\u756a\u53f7\u306b\u5bfe\u5fdc\u3059\u308bIR\u30b3\u30fc\u30c9\u3092\u8d64\u5916\u7ddaLED\u304b\u3089\u767a\u5149\u3057\u3066 \/\/\n \/\/ \u30ea\u30e2\u30b3\u30f3\u30e9\u30a4\u30c8\u3092\u70b9\u706f\u3057\u307e\u3059\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\u3000\/\/\n \/\/ \u6ce8\u610f\uff01\uff01\u3000\u5fc5\u305aNO_1\u306eON\u30b9\u30a4\u30c3\u30c1\u3092\u62bc\u3057\u3066\u304b\u3089\u3001\u4ed6\u306e\u8272\u30b9\u30a4\u30c3\u30c1\u3092\u62bc\u3057\u3066\u304f\u3060\u3055\u3044\u3002 \/\/\n \/\/ NO_2\u306eOFF\u30b9\u30a4\u30c3\u30c1\u3092\u62bc\u3057\u3066\u6d88\u706f\u3057\u305f\u5f8c\u3067\u8272\u30b9\u30a4\u30c3\u30c1\u3092\u62bc\u3057\u3066\u3082\u70b9\u706f\u3057\u307e\u305b\u3093 \/\/\n \/\/*******************************************************************\/\/\n if( length == 1 ){\n if((char)payload[0] == '1') irsend.sendNEC(NO_1, 32); \/\/ ON \u30b9\u30a4\u30c3\u30c1 \n else if((char)payload[0] == '2') irsend.sendNEC(NO_2, 32); \/\/ OFF \u30b9\u30a4\u30c3\u30c1\n else if((char)payload[0] == '7') irsend.sendNEC(NO_7, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1 \n else if((char)payload[0] == '8') irsend.sendNEC(NO_8, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1 \n else if((char)payload[0] == '9') irsend.sendNEC(NO_9, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1 \n }\n else if(( length == 2 )&&( (char)payload[0] == '1' )){\n if((char)payload[1] == '0') irsend.sendNEC(NO_10, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1 \n else if((char)payload[1] == '1') irsend.sendNEC(NO_11, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1 \n else if((char)payload[1] == '2') irsend.sendNEC(NO_12, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1 \n else if((char)payload[1] == '3') irsend.sendNEC(NO_13, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1 \n else if((char)payload[1] == '4') irsend.sendNEC(NO_14, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1 \n else if((char)payload[1] == '5') irsend.sendNEC(NO_15, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1\n else if((char)payload[1] == '6') irsend.sendNEC(NO_16, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1 \n else if((char)payload[1] == '7') irsend.sendNEC(NO_17, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1 \n else if((char)payload[1] == '8') irsend.sendNEC(NO_18, 32); \/\/ \u8272 \u30b9\u30a4\u30c3\u30c1 \n }\n}\n\nvoid loop() {\n if (!mqtt_client.connected()) {\n connectToMQTT();\n }\n mqtt_client.loop(); \n}<\/code><\/pre><\/div>\n\n\n\n\u3007 \u4ee5\u4e0b\u306f\u53c2\u8003\u30da\u30fc\u30b8\u3067\u3059<\/h2>\n\n\n\n
\u30fbEMQX Serverless \u306e \u30aa\u30f3\u30e9\u30a4\u30f3\u30c7\u30d0\u30c3\u30b0<\/mark><\/strong>
\u30fbMQTT \u30b9\u30de\u30db\u30a2\u30d7\u30ea<\/strong> MyMQTT<\/mark><\/strong>
\u306b\u8208\u5473\u306e\u3042\u308b\u65b9\u306f\u3054\u89a7\u304f\u3060\u3055\u3044\u3002<\/p>\n\n\n\n<\/p>\n\n\n\n
\u30d7\u30ed\u30b0\u30e9\u30e0\u306e\u53c2\u8003\u306b\u3057\u305f URL \u306f\u4ee5\u4e0b\u3067\u3059\u3002
https:\/\/docs.emqx.com\/ja\/cloud\/latest\/connect_to_deployments\/esp8266.html<\/a> \u3000\u3000\uff08\u8a73\u3057\u3044\u8aac\u660e\u304c\u8f09\u3063\u3066\u3044\u307e\u3059\uff09
https:\/\/github.com\/emqx\/MQTT-Client-Examples\/blob\/master\/mqtt-client-ESP8266\/esp8266_connect_mqtt_via_tls.ino<\/a>\u3000\u3000\uff08\u4e0a\u8a18URL\u3068\u540c\u3058\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u3059\uff09<\/p>\n\n\n\n\u3000\u3000\u3000\u3000\u30d7\u30ed\u30b0\u30e9\u30e0\uff11<\/strong><\/mark><\/p>\n\n\n\n\/\/ E1_MQTT_via_TLS_Rellay_LED.ino\n\n\/\/ https:\/\/github.com\/emqx\/MQTT-Client-Examples\/blob\/master\/mqtt-client-ESP8266\/esp8266_connect_mqtt_via_tls.ino\n\/\/\u3092\u53c2\u7167\u3057\u307e\u3057\u305f (github)\n\n\/\/************************************************\/\n\/\/ EMQX Serverless MQTT Broker \u3092\u4f7f\u7528\u3059\u308b *\/\n\/\/************************************************\/\n\/\/* NodeMCU MQTT client *\/\n\/\/* MQTT \u306e TLS\/SSL \u8a8d\u8a3c\u3092\u7528\u3044\u308b *\/\n\/\/* \u30dd\u30fc\u30c8\u756a\u53f7\u30008883 *\/\n\/\/* PC -> NodeMCU : \u6570\u5b57\u3092\u9001\u308b *\/\n\/\/* \u6570\u5b57 1 \u3067 LED \u3092\u70b9\u706f\u3057\u3001\u30ea\u30ec\u30fc\u3092 ON \u306b\u3059\u308b *\/\n\/\/* \u6570\u5b57 0 \u3067 LED \u3092\u6d88\u706f\u3057\u3001\u30ea\u30ec\u30fc\u3092 OFF \u306b\u3059\u308b *\/ \n\/\/* NodeMCU\u7528\u306eMQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u30e9\u30a4\u30d6\u30e9\u30ea *\/\n\/\/* pubsubclient\u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3059\u308b\u3053\u3068 Nick O'Leary\u4f5c *\/\n\/\/* 2025.8.7 *\/\n\/\/***********************************************\/\n#include <ESP8266WiFi.h>\n#include <PubSubClient.h>\n#include <time.h> \/\/ TLS\/SSL \u8a8d\u8a3c\u3092\u884c\u3046\u3068\u304d\u306f time.h \u304c\u5fc5\u8981\u306e\u3088\u3046\u3067\u3059\n\n\/\/ WiFi credentials\nconst char *ssid = "WiFi\u306essid"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password = "WiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker = "EMQX serverless \u306e\u63a5\u7d9a\u5148\u3092\u66f8\u304d\u307e\u3059";\nconst char *mqtt_topic = "topi"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username = "system"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password = "seigyo"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port = 8883; \/\/ MQTT SSL\/TLS Port\n\n\/\/ NTP Server settings\nconst char *ntp_server = "pool.ntp.org"; \/\/ Default NTP server\n\/\/ \u4e0b\u306e gmt_offset_sec = 0 \u306e\u307e\u307e\u3067\u3088\u3055\u305d\u3046\u3067\u3059\nconst long gmt_offset_sec = 0; \/\/ GMT offset in seconds (adjust for your time zone)\nconst int daylight_offset_sec = 0; \/\/ Daylight saving time offset in seconds\n\n\/\/ WiFi and MQTT client initialization\nBearSSL::WiFiClientSecure espClient;\nPubSubClient mqtt_client(espClient); \/\/MQTT client\u751f\u6210\n\n\/\/ Root CA Certificate\n\/\/ Load DigiCert Global Root CA ca_cert, which is used by EMQX Cloud Serverless Deployment\n\/\/ EMQX Serverless Deployment\u3067\u4f7f\u7528\u3055\u308c\u308b\u8a3c\u660e\u66f8\u3067\u3059\nstatic const char ca_cert[]\nPROGMEM = R"EOF(\n-----BEGIN CERTIFICATE-----\nMIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh\nMQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3\nd3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD\nQTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT\nMRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j\nb20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG\n9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB\nCSDMAZOnTjC3U\/dDxGkAV53ijSLdhwZAAIEJzs4bg7\/fzTtxRuLWZscFs3YnFo97\nnh6Vfe63SKMI2tavegw5BmV\/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt\n43C\/dxC\/\/AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P\nT19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr\/y7vrTC0LUq7dBMtoM1O\/4\ngdW7jVg\/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO\nBgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH\/BAUwAwEB\/zAdBgNVHQ4EFgQUA95QNVbR\nTLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw\nDQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY\/Esr\nhMAtudXH\/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp\/2PV5Adg\n06O\/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF\nPnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls\nYSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk\nCAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=\n-----END CERTIFICATE-----\n)EOF";\n\n\/\/ \u95a2\u6570\u30d7\u30ed\u30c8\u30bf\u30a4\u30d7\u5ba3\u8a00\nvoid connectToWiFi();\nvoid connectToMQTT();\nvoid syncTime();\nvoid mqttCallback(char *topic, byte *payload, unsigned int length);\n\nint red_led = 5;\nint RELLAY = 4;\n\nvoid setup() {\n pinMode( red_led, OUTPUT ); \/\/ GPIO5 ( D1pin ) \u3092\u51fa\u529b\u30d4\u30f3\u306b\u3059\u308b\u8a2d\u5b9a\n pinMode( RELLAY, OUTPUT ); \/\/ GPIO4 ( D2pin ) \u3092\u51fa\u529b\u30d4\u30f3\u306b\u3059\u308b\u8a2d\u5b9a\n Serial.begin(115200);\n connectToWiFi();\n syncTime(); \/\/ X.509 validation requires synchronization time\n mqtt_client.setServer(mqtt_broker, mqtt_port);\n mqtt_client.setCallback(mqttCallback);\n connectToMQTT();\n}\n\nvoid connectToWiFi() {\n WiFi.begin(ssid, password);\n Serial.print("Connecting to WiFi");\n while (WiFi.status() != WL_CONNECTED) {\n delay(500);\n Serial.println("Connecting to WiFi...");\n }\n Serial.println("Connected to WiFi");\n}\n\nvoid syncTime() {\n configTime(gmt_offset_sec, daylight_offset_sec, ntp_server);\n Serial.print("Waiting for NTP time sync: ");\n while (time(nullptr) < 8 * 3600 * 2) {\n delay(1000);\n Serial.print(".");\n }\n Serial.println("Time synchronized");\n struct tm timeinfo;\n if (getLocalTime(&timeinfo)) {\n Serial.print("Current time: ");\n Serial.println(asctime(&timeinfo));\n } else {\n Serial.println("Failed to obtain local time");\n }\n}\n\nvoid connectToMQTT() {\n BearSSL::X509List serverTrustedCA(ca_cert);\n espClient.setTrustAnchors(&serverTrustedCA);\n while (!mqtt_client.connected()) {\n String client_id = "esp8266-client-" + String(WiFi.macAddress());\/\/ macAddress\u3092\u4f7f\u3063\u3066client_id\u751f\u6210\n Serial.printf("Connecting to MQTT Broker as %s...\\n", client_id.c_str());\n if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {\n Serial.println("Connected to MQTT broker");\n mqtt_client.subscribe(mqtt_topic);\n mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); \/\/ Publish message upon connection\n } else {\n char err_buf[128];\n espClient.getLastSSLError(err_buf, sizeof(err_buf)); \n Serial.print("Failed to connect to MQTT broker, rc=");\n Serial.print(mqtt_client.state());\n Serial.print("SSL error: ");\n Serial.println(err_buf);\n Serial.println(" Retrying in 3 seconds.");\n delay(3000);\n }\n }\n}\n\n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ \u3053\u306e callback \u95a2\u6570\u306f\u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089 NodeMCU \u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u304c \/\/\n\/\/ \u9001\u3089\u308c\u308b\u3068\u5b9f\u884c\u3055\u308c\u307e\u3059 \/\/\n\/\/ MQTT\u306e\u4ed5\u69d8\u3067\u306f\u3001\u30d6\u30ed\u30fc\u30ab\u30fc\u304c\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8 \/\/\n\/\/ \uff08\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u306f NodeMCU \u304b\u3089\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c\u306b\u3001 \/\/\n\/\/ \u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u30d6\u30ed\u30fc\u30ab\u30fc\u81ea\u8eab\u304c\u518d\u3073\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\uff08NodeMCU\uff09\u306b \/\/\n\/\/ \u914d\u4fe1\uff08\u30a8\u30b3\u30fc\uff09\u3059\u308b\u8a2d\u5b9a\u304c\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u6709\u52b9\u306b\u306a\u3063\u3066\u3044\u307e\u3059\u3002 \/\/\n\/\/ \u3053\u308c\u3092\u7121\u52b9\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u305d\u3046\u3067\u3059\u304c\u3001\u3044\u307e\u306e\u3068\u3053\u308d\u4e0d\u660e \/\/\n\/\/ \u305d\u306e\u305f\u3081\u3001NodeMCU \u304b\u3089\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u3068\u3001 \/\/\n\/\/ \u30d6\u30ed\u30fc\u30ab\u30fc\u304b\u3089\u30a8\u30b3\u30fc\u3055\u308c\u305f\u540c\u3058\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u3001\u3053\u306ecallback \u95a2\u6570\u304c\u53d7\u3051\u53d6\u308a \/\/\n\/\/ \u4ee5\u4e0b\u306e Serial.print() \u3067\u30b7\u30ea\u30a2\u30eb\u30e2\u30cb\u30bf\u3067\u8868\u793a\u3055\u308c\u307e\u3059\u3002 \/\/ \n\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\nvoid mqttCallback(char *topic, byte *payload, unsigned int length) {\n Serial.print("Message received on topic: ");\n Serial.println(topic);\n Serial.print("Message: ");\n for (unsigned int i = 0; i < length; i++) {\n Serial.print((char)payload[i]);\n }\n Serial.println("\\n-----------------------");\n\n \/\/********************************************************************\/\/\n \/\/ \u6ce8\u610f\uff01\uff01\u3000SSSL\/TLS\u8a8d\u8a3c\u306e\u8a2d\u5b9a\u3092\u3057\u305f\u3068\u304d\u306f\u3001NodeMCU \u306e Builtin_LED \u306f\u4f7f\u3048\u306a\u3044\u3088\u3046\u3067\u3059 \/\/\n \/\/\u3000\u3000\u3000\u5fc5\u305a\u5916\u4ed8\u3051\u306e LED \u3092\u4f7f\u7528\u3057\u3066\u304f\u3060\u3055\u3044 \/\/\n \/\/ \/\/\n \/\/\u4ee5\u4e0b\u306f PC \u304b\u3089\u9001\u3089\u308c\u308b\u6570\u5b57\u306b\u3088\u3063\u3066\u3001LED \u3092\u70b9\u706f\u3001\u6d88\u706f\u3001 \u30ea\u30ec\u30fc\u3092\u30aa\u30f3\u3001\u30aa\u30d5\u3057\u307e\u3059 \/\/\n \/\/ \u6570\u5b57 \uff11 \u3067LED\u70b9\u706f\u3001\u30ea\u30ec\u30fc\u30aa\u30f3\u3001\u6570\u5b57 \uff10 \u3067LED\u6d88\u706f,\u30ea\u30ec\u30fc\u30aa\u30d5\u3067\u3059 \/\/\n \/\/*******************************************************************\/\/\n if ((char)payload[0] == '1') {\n digitalWrite( red_led, HIGH ); \/\/LED \u70b9\u706f\n digitalWrite( RELLAY, HIGH ); \/\/\u30ea\u30ec\u30fcON\n } else if((char)payload[0] == '0'){\n digitalWrite( red_led, LOW ); \/\/LED \u6d88\u706f\n digitalWrite( RELLAY, LOW ); \/\/\u30ea\u30ec\u30fcOFF\n } \n}\n\nunsigned long lastMsg = 0;\n#define MSG_BUFFER_SIZE (50)\nchar msg[MSG_BUFFER_SIZE];\nint value = 0;\nint ii=0;\n\nvoid loop() {\n if (!mqtt_client.connected()) {\n connectToMQTT();\n }\n mqtt_client.loop();\n\n \/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n \/\/ \u4ee5\u4e0b\u3067 NodeMCU \u304b\u3089value \u306e\u30ab\u30a6\u30f3\u30c8\u5024\u3092\uff12\u79d2\u3054\u3068\u306b\u30d6\u30ed\u30fc\u30ab\u30fc\u306b\u9001\u308a\u307e\u3059 \/\/\n \/\/ \u4f7f\u7528\u3059\u308b\u6642\u306b\u30b3\u30e1\u30f3\u30c8\u3092\u6d88\u3057\u3066\u4f7f\u3063\u3066\u304f\u3060\u3055\u3044\n \/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\/\n\/\/ unsigned long now = millis(); \/\/ NodeMCU\u30de\u30a4\u30b3\u30f3\u306e\u73fe\u5728\u6642\u9593\u3092\n\/\/ \/\/ \u30df\u30ea\u79d2\u5358\u4f4d\u3067\u53d6\u5f97\n\/\/ if (now - lastMsg > 2000) {\n\/\/ \/\/ 2\u79d2\u9593\u5f85\u6a5f\n\/\/ lastMsg = now;\n\/\/ ++value;\n\/\/ snprintf (msg, MSG_BUFFER_SIZE, "#%ld", value);\n\/\/ Serial.print("[ Publish message ] ");\n\/\/ Serial.println(msg);\n\/\/ mqtt_client.publish(mqtt_topic, msg);\n\/\/ } \n}<\/code><\/pre><\/div>\n\n\n\n\u3053\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\uff11\u3067\u91cd\u8981\u306a\u7b87\u6240\u306f23\u884c\u76ee\u304b\u308932\u884c\u76ee\u3067\u3059\u3002<\/p>\n\n\n\n
** \u30d7\u30ed\u30b0\u30e9\u30e0\uff11\u306e\u300123\u884c\u76ee\u304b\u308932\u884c\u76ee **\n\/\/ WiFi credentials\nconst char *ssid<\/strong><\/mark> = \"WiFi\u306essid<\/strong>\"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306essid\nconst char *password<\/strong><\/mark> = \"WiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9<\/strong>\"; \/\/ \u63a5\u7d9a\u3059\u308bWiFi\u306e\u30d1\u30b9\u30ef\u30fc\u30c9\n\n\/\/ EMQX Serverless type broker\nconst char *mqtt_broker<\/mark><\/strong> = \"EMQX serverless \u306e\u63a5\u7d9a\u5148\u3092\u66f8\u304d\u307e\u3059\"<\/strong>;\nconst char *mqtt_topic<\/mark><\/strong> = \"topi<\/strong>\"; \/\/ \u4f8b\u3068\u3057\u3066 topi \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_username<\/mark><\/strong> = \"system<\/strong>\"; \/\/ \u4f8b\u3068\u3057\u3066 system \u3068\u3057\u307e\u3057\u305f\nconst char *mqtt_password<\/mark><\/strong> = \"seigyo<\/strong>\"; \/\/ \u4f8b\u3068\u3057\u3066 seigyo \u3068\u3057\u307e\u3057\u305f\nconst int mqtt_port<\/mark><\/strong> = 8883; \/\/ MQTT SSL\/TLS Port \u306e 8883 \u306b\u3057\u307e\u3059<\/code><\/pre>\n\n\n\n\u3000ssid <\/strong>\u306b\u306f NodeMCU \u304c\u63a5\u7d9a\u3059\u308b WiFi \u306e SSID \u3092\u66f8\u304d\u3001password<\/strong> \u306b\u306f\u63a5\u7d9a\u3059\u308b WiFi \u306e\u30d1\u30b9\u30ef\u30fc\u30c9\u3092\u66f8\u304d\u307e\u3059\u3002
\u3000mqtt_broker<\/strong> \u306b\u306f\u5148\u8ff0\u3057\u305f\u3001EMQX Serverless \u306e\u300c\u6982\u8981\u300d\u306b\u8868\u793a\u3055\u308c\u308b\u300cMQTT\u63a5\u7d9a\u60c5\u5831\u300d\uff08\u4e0b\u56f3\uff09\u306e\u300c\u63a5\u7d9a\u5148\u300d\u306b\u66f8\u304b\u308c\u3066\u3044\u308b\u30a2\u30c9\u30ec\u30b9\u3092\u30b3\u30d4\u30fc\u3057\u307e\u3059\u3002<\/span>
\u3000mqtt_topic<\/strong> \u306b\u306f\u3001publish \/ subscribe \u3067\u4f7f\u7528\u3059\u308b\u30c8\u30d4\u30c3\u30af\u540d\u3092\u66f8\u304d\u307e\u3059\u3002
\u3000mqtt_username<\/strong> \u306b\u306f\u3001\u30e6\u30fc\u30b6\u30fc\u540d\u3092\u66f8\u304d\u307e\u3059\u3002EMQX Serverless\u3000\u306e\u300c\u8a8d\u8a3c\u300d\u3067\u767b\u9332\u3059\u308b\u30e6\u30fc\u30b6\u30fc\u540d\u306b\u306a\u308a\u307e\u3059\u3002
\u3000mqtt_password<\/strong> \u306b\u306f\u3001\u30d1\u30b9\u30ef\u30fc\u30c9\u3092\u66f8\u304d\u307e\u3059\u3002EMQX Serverless\u3000\u306e\u300c\u8a8d\u8a3c\u300d\u3067\u767b\u9332\u3059\u308b\u30d1\u30b9\u30ef\u30fc\u30c9\u306b\u306a\u308a\u307e\u3059\u3002<\/p>\n\n\n\n![\"\"](\"https:\/\/onshape.thick.jp\/onshape\/wp-content\/uploads\/2025\/08\/MQTT\u63a5\u7d9a\u60c5\u5831-1.png\")
<\/figure>\n\n\n\n\u6b21\u306b\u91cd\u8981\u306a\u500b\u6240\u306f171\u884c\u76ee\u304b\u3089177\u884c\u76ee\u3067\u3059\u3002<\/p>\n\n\n\n
** \u30d7\u30ed\u30b0\u30e9\u30e0\uff11\u306e\u3001171\u884c\u76ee\u304b\u3089177\u884c\u76ee **\n if ((char)payload[0] == '1') {\n digitalWrite( red_led, HIGH ); \/\/LED \u70b9\u706f\n digitalWrite( RELLAY, HIGH ); \/\/\u30ea\u30ec\u30fcON<\/mark>\n } else if((char)payload[0] == '0'){\n digitalWrite( red_led, LOW ); \/\/LED \u6d88\u706f\n digitalWrite( RELLAY, LOW ); \/\/\u30ea\u30ec\u30fcOFF<\/mark>\n <\/mark>}<\/mark> <\/mark><\/code><\/pre>\n\n\n\n\u6570\u5b57\uff11\u3092NodeMCU\u304c\u53d7\u4fe1\u3057\u305f\u3089<\/strong>\u3001
\u3000digitalWrite( red_led, HIGH ); \/\/ LE\u3092\u70b9\u706f\u3055\u305b\u308b
\u3000digitalWrite( RELLAY, HIGH ); \/\/ \u30ea\u30ec\u30fcON<\/mark>\u3055\u305b\u308b
\u6570\u5b57\uff10\u3092NodeMCU\u304c\u53d7\u4fe1\u3057\u305f\u3089<\/strong>\u3001
\u3000digitalWrite( red_led, LOW ); \/\/ LED\u3092\u6d88\u706f\u3055\u305b\u308b
\u3000digitalWrite( RELLAY, LOW ); \/\/ \u30ea\u30ec\u30fcOFF<\/mark>\u3055\u305b\u308b<\/p>\n\n\n\n\u3007\u3000NodeMCU \u306e\u30d7\u30ed\u30b0\u30e9\u30e0\uff11\u3067MQTT \u306b\u3088\u308b\u901a\u4fe1\u306e\u30c7\u30d0\u30c3\u30b0\u3092\u884c\u3044\u307e\u3059\u3002<\/mark><\/strong>
\u3000\u30d7\u30ed\u30b0\u30e9\u30e0\uff11\u3092 NodeMCU \u306b\u66f8\u304d\u8fbc\u3093\u3060\u5f8c\u3001MQTT \u306b\u3088\u308b\u901a\u4fe1\u304c\u6b63\u3057\u304f\u884c\u308f\u308c\u3066\u3044\u308b\u304b\u30c7\u30d0\u30c3\u30b0\u3092\u884c\u3044\u307e\u3059\u304c\u3001 \u306a\u3093\u3068\u3001EMQX Serverless \u306e\u8a2d\u5b9a\u30da\u30fc\u30b8\u304b\u3089\u300c\u30aa\u30f3\u30e9\u30a4\u30f3\u30c7\u30d0\u30c3\u30b0<\/mark><\/strong>\u300d\u3092\u884c\u3046\u3053\u3068\u304c\u3067\u304d\u307e\u3059\u306e\u3067\u3001\u4f7f\u3066\u307f\u307e\u3057\u3087\u3046\u3002<\/p>\n\n\n\n\u3000\u4ee5\u4e0b\u306b\u300c\u30aa\u30f3\u30e9\u30a4\u30f3\u30c7\u30d0\u30c3\u30b0<\/mark><\/strong>\u300d\u306e\u4f7f\u3044\u65b9\u3092\u8aac\u660e\u3057\u307e\u3059\u3002<\/p>\n\n\n\n