-------------------mqttx OK (mosquitto als ok)-------------------https://qiita.com/emqx_japan/items/634a5b91f0b760664711 にある
mqttx client for desktop::arm64version get and click deb file for install success!
ubuntu/raspiで成功 mqttxでport1883で起動
https://mqttx.app/web-client#/recent_connections/32a3a13e-7aef-4224-8ddc-6226007aa6ca でもうごくがもはやwebsocketのみ対応している！間違えないこと
cf
https://qiita.com/ekzemplaro/items/168a4a98fe65aa24abb9 でbroker.emqx.ioに
sample/imageTopicをsubしておいて（mqttxにて）mosquitto.shでpubして成功
----------------------------------------------------------------
https://www.emqx.com/ja/blog/use-mqtt-with-raspberry-pi より
# subscriber.py
from gpiozero import LED # もらったメッセージでLED操作する
from time import sleep,time #そのため、この２行必要
import paho.mqtt.client as mqtt
led = LED(17)
def on_connect(client, userdata, flags, rc):
print(f"Connected with result code {rc}")
# Subscribe, which need to put into on_connect
# If reconnect after losing the connection with the broker,
# it will continue to subscribe to the raspberry/topic topic
client.subscribe("raspberry/topic")
# The callback function, it will be triggered when receiving messages
def on_message(client, userdata, msg):
print(f"{msg.topic} {msg.payload}")
if msg.payload == b'4':
led.on()
sleep(10)
led.off()
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
# Set the will message, when the Raspberry Pi is powered off, or the network is interrupted abnormally, it will send the will message to other clients
client.will_set('rasp', b'{"status": "Off"}')
# Create connection, the three parameters are broker address, broker port number, and keep-alive time respectively
client.connect("broker.emqx.io", 1883, 60)
# Set the network loop blocking, it will not actively end the program before calling disconnect() or the program crash
client.loop_forever()
上記を起動しておいて、下記を実行するとサブにでてくる
# publish.py
import paho.mqtt.client as mqtt
import time
def on_connect(client, userdata, flags, rc):
print(f"Connected with result code {rc}")
for i in range(5):
client.publish('raspberry/topic', payload=i, qos=0, retain=False)
print(f"send {i} to raspberry/topic")
client = mqtt.Client()
client.on_connect = on_connect
client.connect("broker.emqx.io", 1883, 60)
client.loop_forever()-------mqtt and esp32------------------------------------
https://diysmartmatter.com/archives/355 にてモスキートクライアントをインスト
https://qiita.com/koichi_baseball/items/8fa9e0bdbe6d0aebe57d also refferd!
broker.emqx.ioにかえて成功 -t # でなく -t test/# -vだった 上記パブサブ成功
https://qiita.com/emqx_japan/items/6ddf82d90c506312d875 をインストして
mosquitto_sub -h broker.emqx.io -t emqx/esp32 -v でサブモードで
こんにちは、ESP32です ^^ うけとれた
mosquitto_pub -h broker.emqx.io -t emqx/esp32 -m goodbye でパブモードで
goodbyeおくれた
-------------mqtt and esp8266------------------------------------------------
https://qiita.com/emqx_japan/items/f74e9d108c7ecaa4f2ddを改変して成功
公開emqxブローカーへのコネクションはどんな名前でもログインOK
esp8266/ledなどのトピックをつくる！mqttx画面でplain textモードになっていること！
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
// GPIO 5 D1
#define LED 5
// WiFi
const char *ssid = "HUAWEI@nova@lite@3+"; // WiFi名を入力
const char *password = "99991111"; // WiFiパスワードを入力
// MQTTブローカー
const char *mqtt_broker = "broker.emqx.io";
const char *topic = "esp8266/led";
const char *mqtt_username = "emqx";
const char *mqtt_password = "public";
const int mqtt_port = 1883;
bool ledState = false;
WiFiClient espClient;
PubSubClient client(espClient);
void setup() {
// ソフトウェアシリアルのボーレートを115200に設定;
Serial.begin(115200);
delay(1000); // 安定性のために遅延
// WiFiネットワークに接続
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.println("WiFiに接続中...");
}
Serial.println("WiFiネットワークに接続しました");
// LEDピンを出力として設定
pinMode(LED, OUTPUT);
digitalWrite(LED,HIGH);
delay(1000);
digitalWrite(LED, LOW); // 最初はLEDを消灯
// MQTTブローカーに接続
client.setServer(mqtt_broker, mqtt_port);
client.setCallback(callback);
while (!client.connected()) {
String client_id = "esp8266-client-";
client_id += String(WiFi.macAddress());
Serial.printf("クライアント %s が公開MQTTブローカーに接続しています\n", client_id.c_str());
if (client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {
Serial.println("公開EMQX MQTTブローカーに接続しました");
} else {
Serial.print("失敗しました ステート ");
Serial.print(client.state());
delay(2000);
}
}
// メッセージの公開と購読
client.publish(topic, "hello emqx");
client.subscribe(topic);
}
void callback(char *topic, byte *payload, unsigned int length) {
Serial.print("トピックにメッセージが到着: ");
Serial.println(topic);
Serial.print("メッセージ: ");
String message;
for (int i = 0; i < length; i++) {
message += (char) payload[i]; // byteをStringに変換
}
Serial.println(message);
if (message.indexOf("on")==1 && !ledState) { // replaced by me
Serial.println("ledon");
digitalWrite(LED, HIGH); // LEDを点灯
ledState = true;
}
if (message.indexOf("off")==1 && ledState) { // replaced by me
Serial.println("ledoff");
digitalWrite(LED, LOW); // LEDを消灯
ledState = false;
}
Serial.println();
Serial.println("-----------------------");
}
void loop() {
client.loop();
delay(100); // ループの各反復で短い遅延
}
