Arduino NANO 33 IoT MQTT Subscriber 예제

5분마다 데이터를 올리기로

제법 잘 돌아가는 코드를 atom 에디터에서 atom-beauty를 설치해 자동으로 정렬하게 한 다음 올리는 코드라고 알려드립니다.

#include <SPI.h>
#include <WiFiNINA.h> // NANO 33 IoT에서 Wi-Fi 기능을 사용하기 위한 라이브러리 입니다.
#include <PubSubClient.h>

const char* ssid = "PISnet_032AC8"; // Wi-Fi의 SSID(이름)를 입력합니다.
const char* password = "82988298"; // Wi-Fi의 페스워드를 입력합니다.
const char* mqtt_server = "192.168.168.109"; // MQTT 서버를 입력합니다.
WiFiClient espClient;
PubSubClient client(espClient);
long lastMsg = 0;
char msg[50];
int value = 0;

void setup_wifi() {
  delay(10);
  WiFi.begin(ssid, password); // 앞서 설정한 ssid와 페스워드로 Wi-Fi에 연결합니다.
  while (WiFi.status() != WL_CONNECTED) { // 연결될 때 까지 0.5초 마다 Wi-Fi 연결상태를 확인합니다.
    delay(500);
  }
  randomSeed(micros()); // 렌덤 문자를 위한 렌덤 시드를 설정합니다.
  
  Serial.println("Connected to WiFi");
  printWifiStatus();
}
int Loop = 0; // LED의 토글을 위해 사용되는 변수입니다.

void callback(char* topic, byte* payload, unsigned int length) {
  // Topic에 메시지가 도착하면 실행되는 콜백입니다.
  
  // 1이 inTopic에 들어오면 LED 토글을 합니다.

  String myString = String((char *)payload);
  Serial.println(myString);
  
  if ((char)payload[0] == '1') {

    Serial.println("receive 1");
    
    if (Loop == 0) {
      digitalWrite(2, HIGH);
      Loop = 1;
    }
    else {
      digitalWrite(2, LOW);
      Loop = 0;
    }    
  }
  if ((char)payload[0] == '2') Serial.println("receive 2");
}

void reconnect() {
  while (!client.connected()) {
    String clientId = "ArduinoNANO33IoTClinet-"; // 클라이언트 ID를 설정합니다.
    clientId += String(random(0xffff), HEX); // 같은 이름을 가진 클라이언트가 발생하는것을 방지하기 위해, 렌덤 문자를 클라이언트 ID에 붙입니다.
    if (client.connect(clientId.c_str())) { // 앞서 설정한 클라이언트 ID로 연결합니다.
      client.subscribe("inTopic"); // inTopic 토픽을 듣습니다.
    } else {
      delay(5000);
    }
  }
}

void setup() {
  pinMode(2, OUTPUT);     // 2번 LED를 토글하기 때문에 OUTPUT으로 설정합니다.
  Serial.begin(9600);
  setup_wifi();
  client.setServer(mqtt_server, 1883); // MQTT 서버에 연결합니다.
  client.setCallback(callback);
}

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

  client.publish("inTopic", "aaaaaa");
  delay(5000);
}

void printWifiStatus() {
  // print the SSID of the network you're attached to:
  Serial.print("SSID: ");
  Serial.println(WiFi.SSID());

  // print your board's IP address:
  IPAddress ip = WiFi.localIP();
  Serial.print("IP Address: ");
  Serial.println(ip);

  // print the received signal strength:
  long rssi = WiFi.RSSI();
  Serial.print("signal strength (RSSI):");
  Serial.print(rssi);
  Serial.println(" dBm");
}