실습 예시

순서

1. AWS 계정 및 AWS IoT 설정:
AWS 계정에 로그인하고 AWS IoT 콘솔로 이동. "사물"을 선택하고 "사물 등록"을 클릭하여 새 사물을 등록. 사물 등록이 완료되면 "인증서" 탭에서 "인증서 생성"을 클릭하여 사물 인증서를 생성. 인증서를 다운로드하고, "사물 정책" 탭에서 "사물 정책 생성"을 클릭하여 사물 정책을 생성. 사물 정책에는 "게시" 및 "구독" 권한이 포함. 사물 정책을 사물에 연결.


2. Arduino IDE 설정:
Arduino IDE를 열고 "툴" 메뉴에서 "보드"를 선택하고 "ESP32 Dev Module"을 선택. "툴" 메뉴에서 "스케치 라이브러리 포함하기"를 선택하고 필요한 라이브러리를 검색하여 설치. WiFiClientSecure, MQTTClient, ArduinoJson


3. 코드 수정:
WIFI_SSID와 WIFI_PASSWORD를 사용하는 Wi-Fi 네트워크에 맞게 수정. AWS_IOT_ENDPOINT를 사용하는 AWS IoT 엔드포인트로 수정. AWS 인증서 및 개인 키를 적절한 위치에 저장하고 net.setCACert(), net.setCertificate(), net.setPrivateKey()에 경로를 설정. 필요에 따라 게시 및 구독 토픽(AWS_IOT_PUBLISH_TOPIC, AWS_IOT_SUBSCRIBE_TOPIC)을 수정.


4. ESP32에 업로드:
ESP32 보드와 컴퓨터를 연결하고, 보드를 선택한 후 코드를 컴파일하고 ESP32에 업로드. 시리얼 모니터를 열고 전송 속도를 9600으로 설정.


5. 결과 확인:
ESP32가 Wi-Fi에 연결되면 시리얼 모니터에 "Connecting to Wi-Fi"와 "."의 시리즈가 표시. Wi-Fi 연결이 성공하면 "Connecting to AWS IoT"가 표시. AWS IoT 연결이 성공하면 "AWS IoT Connected!"가 표시. 센서 데이터는 publishMessage() 함수에서 JSON 형식으로 생성

코드

                            
    > 라이브러리

    #include ≶pgmspace.h>
    #include "secrets.h"
    #include ≶WiFiClientSecure.h>
    #include ≶MQTTClient.h>
    #include ≶ArduinoJson.h>
    #include "WiFi.h"
    
    > MQTT 클라이언트가 게시(publish) 및 구독(subscribe)할 MQTT 토픽을 정의
    
    #define SECRET
    #define THINGNAME "Mtest"
    // The MQTT topics that this device should publish/subscribe
    #define AWS_IOT_PUBLISH_TOPIC   "outTopic"
    #define AWS_IOT_SUBSCRIBE_TOPIC "inTopic"
    WiFiClientSecure 인스턴스 net과 MQTTClient 인스턴스 client를 생성
    
    WiFiClientSecure net = WiFiClientSecure();
    MQTTClient client = MQTTClient(256);
    const char WIFI_SSID[] = "i2r";
    const char WIFI_PASSWORD[] = "00000000";
    const char AWS_IOT_ENDPOINT[] = "*****************.iot.us-east-2.amazonaws.com";
    void connectAWS()
    {
    WiFi.mode(WIFI_STA);
    WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
    
    // Wi-Fi 연결을 수행합니다.
    // Wi-Fi가 연결될 때까지 연결 상태를 확인합니다.
    
    // Configure WiFiClientSecure to use the AWS IoT device credentials
    net.setCACert(AWS_CERT_CA);
    net.setCertificate(AWS_CERT_CRT);
    net.setPrivateKey(AWS_CERT_PRIVATE);
    
    // AWS IoT의 장치 인증서와 개인 키를 사용하여 WiFiClientSecure를 구성합니다.
    
    // MQTT 브로커에 연결합니다.
    client.begin(AWS_IOT_ENDPOINT, 8883, net);
    
    // Create a message handler
    client.onMessage(messageHandler);
    
    // 메시지 처리기를 생성합니다.
    
    // AWS IoT에 연결을 시도합니다.
    while (!client.connect(THINGNAME)) {
        delay(100);
    }
    
    // AWS IoT에 연결되면 구독을 수행합니다.
    client.subscribe(AWS_IOT_SUBSCRIBE_TOPIC);
    }
    
    void publishMessage()
    {
    // 센서 데이터를 JSON 형식으로 만듭니다.
    StaticJsonDocument<200> doc;
    doc["time"] = millis();
    doc["sensor_a0"] = analogRead(0);
    char jsonBuffer[512];
    serializeJson(doc, jsonBuffer); // print to client
    
    client.publish(AWS_IOT_PUBLISH_TOPIC, jsonBuffer);
    }
    
    void messageHandler(String &topic, String &payload) {
    Serial.println("incoming: " + topic + " - " + payload);
    
    //  StaticJsonDocument<200> doc;
    //  deserializeJson(doc, payload);
    //  const char* message = doc["message"];
    }
    
    void setup() {
    Serial.begin(9600);
    connectAWS();
    }
    
    void loop() {
    publishMessage();
    client.loop();
    delay(1000);
    }