4refr0nt
commented
4 years ago Hi!
You must use topics with simple rule: prefix/device/widget, for example:
/IoTmanager/sim800/led and publish config JSON to topic /IoTmanager/sim800/led/config once, after receiving HELLO message from mobile device from topic /IoTmanager. Then, you pubish only changed LED state to topic /IoTmanager/sim800/led/status -> {"status":'LED OFF'}
You can see https://github.com/4refr0nt/iotmanager-heroku/blob/master/index.js#L50
iranweld
Hi
how its possible we use sim800 and esp8266 for MQTT by 4refr0nt projects
`#define TINY_GSM_MODEM_SIM800
// Set serial for debug console (to the Serial Monitor, default speed 115200)
// Set serial for AT commands (to the module) // Use Hardware Serial on Mega, Leonardo, Micro //#define SerialAT Serial1
// or Software Serial on Uno, Nano
define SerialMon Serial
include
include
include
SoftwareSerial SerialAT(8, 7); // RX, TX
// See all AT commands, if wanted //#define DUMP_AT_COMMANDS
// Define the serial console for debug prints, if needed
define TINY_GSM_DEBUG SerialMon
// Range to attempt to autobaud
define GSM_AUTOBAUD_MIN 9600
define GSM_AUTOBAUD_MAX 115200
// Add a reception delay - may be needed for a fast processor at a slow baud rate //#define TINY_GSM_YIELD() { delay(2); }
// Define how you're planning to connect to the internet
define TINY_GSM_USE_GPRS true
define TINY_GSM_USE_WIFI false
// set GSM PIN, if any
define GSM_PIN ""
// Your GPRS credentials, if any const char apn[] = "mtnirancell"; const char gprsUser[] = ""; const char gprsPass[] = "";
int r ;
const char* deviceid = "iot912560" ;
// Your WiFi connection credentials, if applicable const char wifiSSID[] = "YourSSID"; const char wifiPass[] = "YourWiFiPass";
// MQTT details const char* broker = "m12.cloudmqtt.com";
const char topicLed = "/IoTmanager/led"; const char topicInit = "/IoTmanager/init"; const char* topicLedStatus = "/IoTmanager/ledStatus";
// Just in case someone defined the wrong thing..
if TINY_GSM_USE_GPRS && not defined TINY_GSM_MODEM_HAS_GPRS
undef TINY_GSM_USE_GPRS
undef TINY_GSM_USE_WIFI
define TINY_GSM_USE_GPRS false
define TINY_GSM_USE_WIFI true
endif
if TINY_GSM_USE_WIFI && not defined TINY_GSM_MODEM_HAS_WIFI
undef TINY_GSM_USE_GPRS
undef TINY_GSM_USE_WIFI
define TINY_GSM_USE_GPRS true
define TINY_GSM_USE_WIFI false
endif
ifdef DUMP_AT_COMMANDS
include
StreamDebugger debugger(SerialAT, SerialMon); TinyGsm modem(debugger);
else
TinyGsm modem(SerialAT);
endif
TinyGsmClient client(modem); PubSubClient mqtt(client);
define LED_PIN 13
int ledStatus = LOW;
long lastReconnectAttempt = 0;
void mqttCallback(char topic, byte payload, unsigned int len) { SerialMon.print("Message arrived ["); SerialMon.print(topic); SerialMon.print("]: "); SerialMon.write(payload, len); SerialMon.println();
// Only proceed if incoming message's topic matches if (String(topic) == "/IoTmanager" ) { ledStatus = !ledStatus; digitalWrite(LED_PIN, ledStatus); mqtt.publish("/IoTmanager/iot912/status", "{\"status\":\"iot5814\"}"); } }
boolean mqttConnect() { SerialMon.print("Connecting to "); SerialMon.print(broker);
// Connect to MQTT Broker // boolean status = mqtt.connect("/IoTmanager");
// Or, if you want to authenticate MQTT: boolean status = mqtt.connect(deviceid, "test", "test");
if (status == false) { SerialMon.println(" fail"); return false; } SerialMon.println(" success"); mqtt.publish(topicInit, "/IoTmanager started"); mqtt.subscribe("/IoTmanager/#"); return mqtt.connected(); }
void setup() { // Set console baud rate SerialMon.begin(115200); delay(10);
pinMode(LED_PIN, OUTPUT);
// !!!!!!!!!!! // Set your reset, enable, power pins here // !!!!!!!!!!!
SerialMon.println("Wait...");
// Set GSM module baud rate // TinyGsmAutoBaud(SerialAT,GSM_AUTOBAUD_MIN,GSM_AUTOBAUD_MAX); SerialAT.begin(9600); delay(3000);
// Restart takes quite some time // To skip it, call init() instead of restart() SerialMon.println("Initializing modem..."); modem.restart(); // modem.init();
String modemInfo = modem.getModemInfo(); SerialMon.print("Modem Info: "); SerialMon.println(modemInfo);
if TINY_GSM_USE_GPRS
// Unlock your SIM card with a PIN if needed if ( GSM_PIN && modem.getSimStatus() != 3 ) { modem.simUnlock(GSM_PIN); }
endif
if TINY_GSM_USE_WIFI
SerialMon.print(F("Setting SSID/password...")); if (!modem.networkConnect(wifiSSID, wifiPass)) { SerialMon.println(" fail"); delay(10000); return; } SerialMon.println(" success");
endif
if TINY_GSM_USE_GPRS && defined TINY_GSM_MODEM_XBEE
// The XBee must run the gprsConnect function BEFORE waiting for network! modem.gprsConnect(apn, gprsUser, gprsPass);
endif
SerialMon.print("Waiting for network..."); if (!modem.waitForNetwork()) { SerialMon.println(" fail"); delay(5000); return; } SerialMon.println(" success");
if (modem.isNetworkConnected()) { SerialMon.println("Network connected"); }
if TINY_GSM_USE_GPRS
// GPRS connection parameters are usually set after network registration SerialMon.print(F("Connecting to ")); SerialMon.print(apn); if (!modem.gprsConnect(apn, gprsUser, gprsPass)) { SerialMon.println(" fail"); delay(10000); return; } SerialMon.println(" success");
if (modem.isGprsConnected()) { SerialMon.println("GPRS connected"); }
endif
// MQTT Broker setup mqtt.setServer(broker, 10515); mqtt.setCallback(mqttCallback); }
void loop() {
if (!mqtt.connected()) { SerialMon.println("=== MQTT NOT CONNECTED ===");
}
mqtt.loop(); }`