mqtt 포워드 골랭

MQTT Forwarding Golang

사물인터넷(IoT) 시대가 도래하면서 기기 간 통신이 더욱 중요해졌습니다. MQTT(Message Queuing Telemetry Transport)는 낮은 대역폭, 높은 대기 시간 또는 신뢰할 수 없는 네트워크 연결 전반에서 무제한 장치 및 애플리케이션에 효율적인 데이터 교환 메커니즘을 제공하도록 설계된 경량 메시징 프로토콜입니다. 이 기사에서는 다양한 장치가 MQTT 프로토콜을 통해 통신할 수 있도록 Golang을 사용하여 MQTT 전달 프록시 서버를 만드는 방법을 살펴보겠습니다.

먼저 Golang을 설치해야 합니다. 설치가 완료되면 Golang에서 MQTT와 통신하는 데 사용되는 기본 라이브러리인 paho-mqtt 패키지를 설치해야 합니다. 다음 명령을 통해 설치할 수 있습니다.

go get github.com/eclipse/paho.mqtt.golang

완료되면 main.go라는 Golang 파일이 포함된 mqtt-forward라는 프로젝트 폴더를 생성합니다. paho-mqtt 패키지를 코드로 가져와야 합니다.

import (
    "fmt"

    "github.com/eclipse/paho.mqtt.golang"
)

다음으로 MQTT 클라이언트 옵션을 설정해야 합니다.

opts := mqtt.NewClientOptions().AddBroker("tcp://broker.hivemq.com:1883").SetClientID("mqtt-forward")

이 예에서는 HiveMQ 공개 MQTT 브로커에 연결하고 TCP 전송 프로토콜과 포트를 선택합니다. 번호는 1883이고 클라이언트 ID는 "mqtt-forward"로 설정되어 있습니다. MQTT 연결을 위한 사용자 이름과 비밀번호를 설정할 수도 있습니다.

이제 MQTT 클라이언트 연결을 설정하고 mqtt.Client 유형의 클라이언트 포인터 변수를 통해 이를 참조합니다.

client := mqtt.NewClient(opts)
if token := client.Connect(); token.Wait() && token.Error() != nil {
    panic(token.Error())
}
defer client.Disconnect(250)

이 예에서는 mqtt.NewClient(opts) 메서드를 사용하여 MQTT 클라이언트의 새 버전을 생성합니다. 터미널 및 패스 옵션. MQTT 프록시 서버에 연결한 후 MQTT 클라이언트를 닫고 연결이 성공적으로 닫혔는지 확인하기 위해 최대 250밀리초 동안 기다립니다. defer 키워드는 함수가 반환되기 전에 정리 코드를 실행하는 데 사용됩니다. 이를 통해 필요하지 않을 때 MQTT 클라이언트를 적절하게 닫을 수 있습니다.

기기에서 MQTT 메시지를 수신하려면 MQTT 서버에 연결한 후 처리 기능도 생성해야 합니다. 수신된 메시지는 MQTT 주제별로 분류됩니다.

func onMessageReceived(client mqtt.Client, message mqtt.Message) {
    fmt.Printf("Received message: %s from topic: %s
", message.Payload(), message.Topic())
}

이 예제에서는 수신된 MQTT 메시지의 페이로드(페이로드는 실제로 데이터를 전송하는 부분)와 주제를 인쇄합니다.

이제 MQTT 주제를 구독해야 합니다. 다음 코드를 사용하여 클라이언트에 콜백 함수를 추가할 수 있습니다.

if token := client.Subscribe("testtopic/#", byte(0), onMessageReceived); token.Wait() && token.Error() != nil {
    panic(token.Error())
}

이 예에서는 "testtopic"으로 시작하는 모든 주제를 구독합니다. QoS를 바이트 0으로 설정했는데, 이는 수신한 메시지가 한 번만 전송된다는 의미입니다.

전체 주요 기능은 다음과 같습니다.

func main() {
    opts := mqtt.NewClientOptions().AddBroker("tcp://broker.hivemq.com:1883").SetClientID("mqtt-forward")
    client := mqtt.NewClient(opts)

    if token := client.Connect(); token.Wait() && token.Error() != nil {
        panic(token.Error())
    }
    defer client.Disconnect(250)

    if token := client.Subscribe("testtopic/#", byte(0), onMessageReceived); token.Wait() && token.Error() != nil {
        panic(token.Error())
    }

    for {
        time.Sleep(time.Second)
    }
}

func onMessageReceived(client mqtt.Client, message mqtt.Message) {
    fmt.Printf("Received message: %s from topic: %s
", message.Payload(), message.Topic())
}

프로그램이 시작된 후 TCP를 통해 포트 1883의 MQTT 브로커에 연결하고 콜백 기능을 추가하고 "testtopic"으로 시작하는 모든 주제를 구독합니다. 마지막으로 연결을 유지하고 MQTT 메시지를 계속 수신할 수 있도록 무한 루프에 빠지게 됩니다.

다음 명령을 사용하여 Golang 프로그램을 실행할 수 있습니다.

go run main.go

요약하면 Golang 및 paho-mqtt 패키지를 사용하여 MQTT 정방향 프록시 서버를 생성하는 방법을 소개했습니다. MQTT 브로커 서버에 연결하고 특정 주제를 구독하여 다양한 장치에서 메시지를 캡처하는 방법을 이해함으로써 이제 장치 중심 방식으로 MQTT 메시지를 얻을 수 있게 되었으며 이는 IOT 애플리케이션 구축에 매우 유용합니다.

위 내용은 mqtt 포워드 골랭의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!