如何解决无法将数据发布到我的本地mqtt服务器
请我希望有人可以帮助我。几周以来,我一直在努力工作,对此我还很陌生。
我想将数据从ESP32 SIM800L发送到mqtt代理。 mqtt服务器在我的本地机器上运行,ESP32 SIM800可以完美地连接到APN。 我看到许多教程都是通过WIFI连接实现的,但没有GPRS(我正在使用的是GPRS)。
我终于找到了:tinyGSM和这个:arduino mqtt mongodb
我按如下方法进行了修改,但仍然无法连接:
// Your GPRS credentials (leave empty,if not needed)
const char apn[] = "internet.tn"; // APN (example: internet.vodafone.pt) use https://wiki.apnchanger.org
const char gprsUser[] = ""; // GPRS User
const char gprsPass[] = ""; // GPRS Password
// SIM card PIN (leave empty,if not defined)
const char simPIN[] = "";
uint32_t lastReconnectAttempt = 0;
// TTGO T-Call pins
#define MODEM_RST 5
#define MODEM_PWKEY 4
#define MODEM_POWER_ON 23
#define MODEM_TX 27
#define MODEM_RX 26
#define I2C_SDA 21
#define I2C_SCL 22
// Set serial for debug console (to Serial Monitor,default speed 115200)
#define SerialMon Serial
// Set serial for AT commands (to SIM800 module)
#define SerialAT Serial1
// Configure TinyGSM library
#define TINY_GSM_MODEM_SIM800 // Modem is SIM800
#define TINY_GSM_RX_BUFFER 1024 // Set RX buffer to 1Kb
#include <Wire.h>
#include <TinyGsmClient.h>
#include <PubSubClient.h>
#ifdef DUMP_AT_COMMANDS
#include <StreamDebugger.h>
StreamDebugger debugger(SerialAT,SerialMon);
TinyGsm modem(debugger);
#else
TinyGsm modem(SerialAT);
#endif
// I2C for SIM800 (to keep it running when powered from battery)
TwoWire I2CPower = TwoWire(0);
const char* broker = "localhost";
const char* topicInit = "GsmClientTest/init";
// Function prototypes
void subscribeReceive(char* topic,byte* payload,unsigned int length);
// TinyGSM Client for Internet connection
// gsm and MQTT related objects
TinyGsmClient client(modem);
PubSubClient mqtt(client);
long mqtttimer = 0; // Timer for counting 5 seconds and retrying mqtt connection
byte mqtttarea = 1;
#define uS_TO_S_FACTOR 1000000 /* Conversion factor for micro seconds to seconds */
#define TIME_TO_SLEEP 3600 /* Time ESP32 will go to sleep (in seconds) 3600 seconds = 1 hour */
void mqttCallback(char* topic,unsigned int len) {
SerialMon.print("Message arrived [");
SerialMon.print(topic);
SerialMon.print("]: ");
SerialMon.write(payload,len);
SerialMon.println();}
boolean mqttConnect() {
SerialMon.print("Connecting to ");
SerialMon.print(broker);
// Connect to MQTT Broker
boolean status = mqtt.connect("GsmClientTest");
// Or,if you want to authenticate MQTT:
//boolean status = mqtt.connect("GsmClientName","mqtt_user","mqtt_pass");
if (status == false) {
SerialMon.println(" fail");
return false;
}
SerialMon.println(" success");
mqtt.publish(topicInit,"GsmClientTest started");
// mqtt.subscribe(topicLed);
return mqtt.connected();}
void setup() {
SerialMon.begin(9600);
// Start I2C communication
I2CPower.begin(I2C_SDA,I2C_SCL,400000);
// Set modem reset,enable,power pins
pinMode(MODEM_PWKEY,OUTPUT);
pinMode(MODEM_RST,OUTPUT);
pinMode(MODEM_POWER_ON,OUTPUT);
digitalWrite(MODEM_PWKEY,LOW);
digitalWrite(MODEM_RST,HIGH);
digitalWrite(MODEM_POWER_ON,HIGH);
// Set GSM module baud rate and UART pins
SerialAT.begin(9600,SERIAL_8N1,MODEM_RX,MODEM_TX);
delay(3000);
// Restart SIM800 module,it takes quite some time
// To skip it,call init() instead of restart()
SerialMon.println("Initializing modem...");
modem.restart();
// use modem.init() if you don't need the complete restart
// Unlock your SIM card with a PIN if needed
if (strlen(simPIN) && modem.getSimStatus() != 3 ) {
modem.simUnlock(simPIN);
}
SerialMon.print("Connecting to APN: ");
SerialMon.print(apn);
if (!modem.gprsConnect(apn,gprsUser,gprsPass)) {
SerialMon.println(" fail");
}
else {
SerialMon.println(" OK");
}
// MQTT Broker setup
mqtt.setServer(broker,1883);
mqtt.setCallback(mqttCallback);
esp_sleep_enable_timer_wakeup(TIME_TO_SLEEP * uS_TO_S_FACTOR);
}
void loop() {
// This is needed at the top of the loop!
if (!mqtt.connected()) {
SerialMon.println("=== MQTT NOT CONNECTED ===");
// Reconnect every 10 seconds
uint32_t t = millis();
if (t - lastReconnectAttempt > 10000L) {
lastReconnectAttempt = t;
if (mqttConnect()) {
lastReconnectAttempt = 0;
}
}
delay(100);
return;
}
mqtt.publish(topicInit,"Hello");
mqtt.loop();
}
解决方法
您将经纪人的名称设置为localhost
:
const char* broker = "localhost";
localhost
和IP地址127.0.0.1表示“此代码在其上运行的主机”。在运行代理的计算机上键入命令时,localhost
表示该计算机。它无法在ESP32上运行。
您需要运行代理的计算机的名称或IP地址。如何找到将取决于您正在运行的操作系统。
如果该计算机位于您的本地网络上,则可能使用的是专用IP地址,例如10.0.1.x
或192.168.1.x
。如果是这种情况,您将需要在路由器中使用端口转发将数据包转发到该端口(然后,您将使用路由器的IP地址而不是代理的IP地址)。
如果您使用的是路由器的IP地址,该地址可能会更改而不会发出警告,因此您需要使用类似Dynamic DNS的名称来保持其当前IP地址的最新状态。
您最好在基于云的虚拟服务器上在网络外部运行代理,或者使用其中的几种商业MQTT服务之一。他们中的大多数都有免费套餐,每月可以允许相当数量的流量。
无论如何,localhost
永远不会在这里工作。您需要真实,公开的IP地址或您的经纪人名称。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。