Protokol MQTT: Rozdiel medzi revíziami
Z SensorWiki
(→MQTT cez Shiftr.IO) |
|||
(3 medziľahlé úpravy od rovnakého používateľa nie sú zobrazené.) | |||
Riadok 1: | Riadok 1: | ||
+ | Modifikované cvičenie na DOMA: | ||
+ | |||
+ | |||
+ | |||
'''Úloha''' | '''Úloha''' | ||
Riadok 19: | Riadok 23: | ||
+ | |||
+ | '''Tipy''' | ||
+ | |||
+ | Kontrola, či vám to správne funguje je možná tu: https://shiftr.io/try | ||
+ | |||
+ | <center> | ||
+ | [[Súbor:ShiftrIOtest.png|500px]]<BR> | ||
+ | [[Súbor:ShiftrIOtestMsg.png|500px]]<BR> | ||
+ | ''Kontrola funkcie na Shiftr.IO'' | ||
+ | </center> | ||
V Processingu treba pridat kniznicu Joela Gaehwillera MQTT: | V Processingu treba pridat kniznicu Joela Gaehwillera MQTT: | ||
Sketch -> Import Library -> Add Library -> MQTT -> Install | Sketch -> Import Library -> Add Library -> MQTT -> Install | ||
+ | |||
+ | <center> | ||
+ | [[Súbor:ProcessingAddLibrary.png|500px]]<BR> | ||
+ | ''Pridávanie knižnice v Processingu.'' | ||
+ | </center> | ||
+ | Na vytvorenie JSON reťazca využite JSONobject, potom pridávajte jednotlivé položky napr. takto | ||
+ | message.setFloat("XXX-Lat", 49.1634); | ||
− | + | Ak sa vám podarí úspešne poslať správu na shiftr.io a vidíte ju tam správne formátovanú, zmeňte riadky | |
− | |||
client.connect("mqtt://try:try@broker.shiftr.io", "Ferdinand"); | client.connect("mqtt://try:try@broker.shiftr.io", "Ferdinand"); | ||
... | ... | ||
− | client.publish("/feistu/misa/2020/XXX", | + | client.publish("/feistu/misa/2020/XXX", message.toString()); |
− | + | takto | |
− | + | client.connect("mqtt://9RYd7rPhakMm9CCwPBJG@demo.thingsboard.io"); // no username here | |
− | |||
− | |||
− | client.connect("mqtt://9RYd7rPhakMm9CCwPBJG@demo.thingsboard.io"); | ||
... | ... | ||
− | client.publish("v1/devices/me/telemetry", | + | client.publish("v1/devices/me/telemetry", message.toString()); |
− | + | ||
+ | |||
+ | Ukážkové programy máte nižšie. | ||
Riadok 116: | Riadok 135: | ||
} | } | ||
</source> | </source> | ||
+ | |||
+ | |||
+ | [[MEMS inteligentné senzory a aktuátory#Cvi.C4.8Denia|Návrat na zoznam cvičení...]] | ||
+ | |||
+ | [[Category:MEMS]] |
Verzia zo dňa a času 11:55, 28. apríl 2020
Modifikované cvičenie na DOMA:
Úloha
Vyskúšajte si posielanie protokolom MQTT. Pošlite jednoduchú správu
- Najprv na
- MQTT server mqtt://try:try@broker.shiftr.io (username vase priezvisko)
- do topicu /feistu/misa/2020/XXX
- a potom na
- MQTT server mqtt://9RYd7rPhakMm9CCwPBJG@demo.thingsboard.io
- do topicu v1/devices/me/telemetry
Správa vo formáte JSON má vyzerať takto:
{"XXX-Lat": 49.1634, "XXX-Lon": 20.1349, "XXX-Temp": 18.2}
kde
- XXX su prve tri pismena vasho priezviska
- Lat je zemepisna sirka na styri desatinne miesta
- Lon je zemepisna dlzka na styri desatinne miesta a
- Temp aktualna vonkajsia teplota
Tipy
Kontrola, či vám to správne funguje je možná tu: https://shiftr.io/try
V Processingu treba pridat kniznicu Joela Gaehwillera MQTT:
Sketch -> Import Library -> Add Library -> MQTT -> Install
Na vytvorenie JSON reťazca využite JSONobject, potom pridávajte jednotlivé položky napr. takto
message.setFloat("XXX-Lat", 49.1634);
Ak sa vám podarí úspešne poslať správu na shiftr.io a vidíte ju tam správne formátovanú, zmeňte riadky
client.connect("mqtt://try:try@broker.shiftr.io", "Ferdinand"); ... client.publish("/feistu/misa/2020/XXX", message.toString());
takto
client.connect("mqtt://9RYd7rPhakMm9CCwPBJG@demo.thingsboard.io"); // no username here ... client.publish("v1/devices/me/telemetry", message.toString());
Ukážkové programy máte nižšie.
MQTT cez Shiftr.IO
import mqtt.*;
MQTTClient client;
void setup()
{
client = new MQTTClient(this);
client.connect("mqtt://try:try@broker.shiftr.io", "Ferdinand");
}
void draw() { /* nerob nic, len cakaj na klavesu */}
void keyPressed()
{
client.publish("/feistu/BlokB/temperature", "27.0");
client.publish("/feistu/BlokB/humidity", "38.1");
client.publish("/feistu/BlokA", "InReconstruction...");
}
void clientConnected() {
println("client connected");
client.subscribe("/feistu/#");
client.subscribe("/hello/#");
}
void messageReceived(String topic, byte[] payload) {
println("new message: " + topic + " - " + new String(payload));
}
void connectionLost() {
println("connection lost");
}
JSON
JSONObject message;
float temperature = 0.0;
int status = 0;
void setup()
{
message = new JSONObject();
message.setFloat("temperature", 10.0);
message.setInt("state",2);
message.setString("name", "Lion");
saveJSONObject(message, "data/new.json");
int aktualnyStav = message.getInt("state");
float aktualnaTeplota = message.getFloat("temperature");
String realName = message.getString("name");
println("Stav: " + aktualnyStav
+ ", Teplota: " + aktualnaTeplota + ", Meno: " + realName);
}
void draw() { /* nic nekreslime */ }
void keyPressed() {
temperature = random(-10, 32.5);
message.setFloat("temperature", temperature);
println(message.toString());
}