M5StackとCatM+GNSSモジュールで取得した位置情報をMQTTでNode-REDに送る

#include <M5Stack.h>
#include <WiFi.h>
#include <PubSubClient.h>

// WiFi設定
const char* ssid = "****";  // WiFiのSSID
const char* password = "****";  // WiFiのパスワード

// MQTTブローカーの設定
const char* mqtt_server = "****";  // ホストマシンのIPアドレス
const char* mqtt_topic = "/m5stack/gps";  // MQTTトピック

WiFiClient espClient;
PubSubClient client(espClient);

// GPSモジュールとのシリアル接続を定義
#define SerialGPS Serial2

void setup_wifi() {
  delay(10);
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);

  WiFi.begin(ssid, password);

  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.print("IP address: ");
  Serial.println(WiFi.localIP());
}

void reconnect() {
  // 再接続ループ
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");
    // 接続を試みる
    if (client.connect("M5StackClient")) {
      Serial.println("connected");
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      // 再試行まで5秒待機
      delay(5000);
    }
  }
}

void setup() {
  M5.begin();
  Serial.begin(115200); // デバッグ用シリアル通信
  SerialGPS.begin(9600, SERIAL_8N1, 16, 17); // GPSモジュールとのシリアル接続設定

  Serial.println("Initializing GPS module...");

  // GPSモジュールの初期化
  SerialGPS.println("AT+CGNSPWR=1"); // GNSS電源をオンにする
  delay(1000);
  while (SerialGPS.available()) {
    char c = SerialGPS.read();
    Serial.print(c);
  }
  Serial.println();

  SerialGPS.println("AT+CGNSSEQ=\"RMC\""); // GNSS出力シーケンスを設定
  delay(1000);
  while (SerialGPS.available()) {
    char c = SerialGPS.read();
    Serial.print(c);
  }
  Serial.println();

  Serial.println("GPS initialized");

  setup_wifi();
  client.setServer(mqtt_server, 1883);
}

void loop() {
  if (!client.connected()) {
    reconnect();
  }
  client.loop();

  SerialGPS.println("AT+CGNSINF"); // GNSS情報を照会
  delay(1000);

  String gpsData = "";
  while (SerialGPS.available()) {
    char c = SerialGPS.read();
    gpsData += c;
  }

  if (gpsData.length() > 0) {
    Serial.println("Data received:");
    Serial.println(gpsData);

    // 受信データの解析
    if (gpsData.startsWith("AT+CGNSINF")) {
      int index = gpsData.indexOf(":");
      if (index != -1) {
        String gpsInfo = gpsData.substring(index + 1);
        String jsonPayload = parseGPSData(gpsInfo);

        // MQTTメッセージの送信
        client.publish(mqtt_topic, jsonPayload.c_str());

        // デバッグ用にシリアル出力
        Serial.println("Published GPS data:");
        Serial.println(jsonPayload);
      }
    } else {
      Serial.println("No valid GPS data");
    }
  }
  delay(5000); // 5秒待機後、再度照会
}

String parseGPSData(String gpsInfo) {
  gpsInfo.trim();
  String data[20];
  int index = 0;

  while (gpsInfo.length() > 0 && index < 20) {
    int commaIndex = gpsInfo.indexOf(",");
    if (commaIndex == -1) {
      data[index++] = gpsInfo;
      break;
    } else {
      data[index++] = gpsInfo.substring(0, commaIndex);
      gpsInfo = gpsInfo.substring(commaIndex + 1);
    }
  }

  String jsonPayload = "{";
  jsonPayload += "\"latitude\": " + data + ",";
  jsonPayload += "\"longitude\": " + data + ",";
  jsonPayload += "\"altitude\": " + data[5] + ",";
  jsonPayload += "\"speed\": " + data[6];
  jsonPayload += "}";

  return jsonPayload;
}

net start mosquitto

netstat -an | find "1883"