[flutter] 플러터에서의 MQTT 프로토콜을 통한 메시지 브로커 연동 방법

04 Dec 2023

flutter

이번 포스트에서는 Flutter에서 MQTT 프로토콜을 사용하여 메시지 브로커와 연동하는 방법에 대해 알아보겠습니다.

MQTT 프로토콜이란?

MQTT(Message Queuing Telemetry Transport)는 경량 메시징 프로토콜로서, 저전력 디바이스 및 제한된 네트워크 대역폭을 가지고 있는 디바이스들 사이에서 사용되는 것이 주 목적입니다. MQTT는 TCP/IP 기반에서 동작하며, Publish/Subscribe 모델을 통해 메시지를 브로커에 발행하고, 구독자들이 이 메시지를 구독하여 수신할 수 있습니다.

Flutter와 MQTT 연동하는 방법

이제 Flutter 앱에서 MQTT 프로토콜을 사용하여 메시지 브로커와 연동하는 방법을 알아보겠습니다.

flutter_mqtt 패키지 설치

먼저, MQTT 연동을 위해 flutter_mqtt 패키지를 설치해야 합니다. pubspec.yaml 파일에 다음과 같은 의존성을 추가해 주세요:

dependencies:
  flutter_mqtt: ^1.0.0

flutter_mqtt 패키지를 설치하기 위해 flutter pub get 명령어를 실행해 주세요.

MQTT 클라이언트 설정

MQTT 클라이언트를 사용하기 위해선 먼저 클라이언트 설정을 해야 합니다. MQTTClient 클래스의 인스턴스를 생성하고, MQTTClientPayloadBuilder를 사용하여 페이로드 빌더를 설정해 주세요.

import 'package:flutter_mqtt/flutter_mqtt.dart' show MQTTClient, MQTTClientPayloadBuilder;

final client = MQTTClient(
  broker: 'broker.example.com', // MQTT 브로커 주소
  port: 1883, // MQTT 브로커 포트
  clientIdentifier: 'flutter_client', // 클라이언트 식별자
  useWebSocket: false, // WebSocket 사용 여부
  onDisconnected: () => print('MQTT 연결이 끊어졌습니다.'),
);
final builder = MQTTClientPayloadBuilder();

MQTT 연결

이제 클라이언트를 MQTT 브로커에 연결할 차례입니다. connect() 메소드를 사용하여 연결을 시도할 수 있습니다. 연결에 성공하면 onConnected 콜백이 호출됩니다.

await client.connect(
  username: 'your_username', // MQTT 브로커 사용자명
  password: 'your_password', // MQTT 브로커 비밀번호
);

client.onConnected = (bool success) {
  if (success) {
    print('MQTT 연결이 성공적으로 수립되었습니다.');
  } else {
    print('MQTT 연결에 실패했습니다.');
  }
};

메시지 수신 및 발신

이제 메시지를 수신하거나 발신할 수 있습니다. subscribe() 메소드를 사용하여 특정 토픽을 구독하고, publishMessage() 메소드를 사용하여 메시지를 발송할 수 있습니다.

await client.subscribe('your_topic');

client.onMessageReceived = (String topic, String message) {
  print('새로운 메시지 도착: $message');
};

builder.payload = 'Hello, MQTT!';
await client.publishMessage('your_topic', builder.payload);

마무리

지금까지 Flutter에서 MQTT 프로토콜을 통해 메시지 브로커와 연동하는 방법에 대해 알아보았습니다. MQTT를 사용하여 신속하고 효율적인 통신을 구현할 수 있습니다. 추가적인 MQTT 기능 및 설정에 대해서는 flutter_mqtt 패키지의 문서를 참고해 주세요.

목차