# MQTT 브로커와 통신하려면?

MQTT 란?

MQTT(Message Queuing Telemetry Transport)는 경량 메시지 프로토콜로, 
IoT(사물 인터넷) 환경에서 장치 간 통신을 위해 주로 사용됩니다. 
Pub-Sub(Publish-Subscribe) 모델을 기반으로 동작하며, 
브로커를 중심으로 메시지를 주고받습니다.

 

1. MQTT 주요 개념

• Broker(브로커): 메시지를 중개하는 서버 역할 (ex. Mosquitto, HiveMQ)
• Publisher(발행자): 특정 토픽(Topic)에 메시지를 발행하는 클라이언트
• Subscriber(구독자): 특정 토픽을 구독하고, 해당 토픽에 메시지가 발행되면 수신하는 클라이언트
• QoS(Quality of Service): 메시지 전송의 신뢰성을 보장하는 수준 (0, 1, 2)

2. Java로 MQTT 통신 구현

Java에서는 Eclipse Paho 라이브러리를 사용하여 MQTT 클라이언트를 개발할 수 있습니다.

 

1) Paho MQTT 라이브러리 추가

Maven 프로젝트의 경우, pom.xml에 다음 의존성을 추가합니다.

<dependency>
    <groupId>org.eclipse.paho</groupId>
    <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
    <version>1.2.5</version>
</dependency>

 

브로커와 통신하는 프로그램을 만들려면 어떤걸 수행해야될까?

 

해야 할 작업

• 브로커에 연결하여 데이터 송수신
• Publisher (발행자) 구현 – 데이터 송신
• Subscriber (구독자) 구현 – 데이터 수신
• 예외처리 및 연결 유지 – 재연결, 네트워크 장애 대응
• 보안 설정(필요 시) – 인증 및 암호화 (TLS, 사용자 인증 등)
• 성능 튜닝(필요 시) – 메시지 크기 조절, QoS 설정, 지속적인 연결 유지

 

1) MQTT Publisher (발행자) 구현

import org.eclipse.paho.client.mqttv3.*;

public class MqttPublisher {
    // 브로커가 TLS/SSL을 사용하는 경우 ssl://your-broker-ip:8883 형태로 설정해야 함.
    // 브로커의 접속 정보(IP, 포트, 프로토콜 등) 확인 필요, 접속할 때 사용할 Client ID, 인증 정보(필요 시) 정리
    private static final String BROKER_URL = "tcp://your-broker-ip:1883";
    private static final String CLIENT_ID = "YourClientID";
    private static final String TOPIC = "test/topic";

    public static void main(String[] args) {
        try {
        	// 브로커 연결 설정
            MqttClient client = new MqttClient(BROKER_URL, CLIENT_ID);
            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(true);

            client.connect(options);
			// 데이터 발행 구현 - 메시지의 QoS(Quality of Service) 설정 필요
            String message = "Hello MQTT from Java!";
            MqttMessage mqttMessage = new MqttMessage(message.getBytes());
            mqttMessage.setQos(1);

            client.publish(TOPIC, mqttMessage);

            System.out.println("Message Published: " + message);
			// 연결 후 메시지 전송 및 종료
            client.disconnect();
            client.close();
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

2) MQTT Subscriber (구독자) 구현

import org.eclipse.paho.client.mqttv3.*;

public class MqttSubscriber {
    private static final String BROKER_URL = "tcp://broker.hivemq.com:1883";
    private static final String CLIENT_ID = "JavaSubscriber";
    private static final String TOPIC = "test/topic";

    public static void main(String[] args) {
        try {
            // 연결 유지 및 예외 처리
            MqttClient client = new MqttClient(BROKER_URL, CLIENT_ID);

            // MqttConnectOptions 객체 선언
            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(false);  // 재연결 시 세션 유지
            options.setAutomaticReconnect(true);  // 자동 재연결 활성화
            options.setKeepAliveInterval(30);  // 30초마다 연결 상태 확인

            client.setCallback(new MqttCallback() {
                @Override
                public void connectionLost(Throwable cause) {
                    System.out.println("Connection lost: " + cause.getMessage());
                }

                @Override
                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    System.out.println("Message received: " + new String(message.getPayload()));
                }

                @Override
                public void deliveryComplete(IMqttDeliveryToken token) {
                    // 구독자는 사용하지 않음
                }
            });

            client.connect(options);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

 

현재 코드로 기본적인 MQTT 통신은 가능하지만,

실무 환경에서는 연결 안정성(재연결, Keep Alive 등)과

보안(인증, TLS 적용 등)을 고려해서 추가 개발할 수도 있습니다.

 

실행 순서

제공받은 브로커 정보 확인 (IP, 포트, 인증 방식)
코드 수정 (BROKER_URL, 인증 정보 반영)
Subscriber 실행 → 브로커에서 메시지를 받을 준비
Publisher 실행 → 메시지를 발행하여 브로커로 전송
Subscriber에서 정상적으로 메시지 수신 확인

이제, 제공된 브로커에서 정상 동작하는지 테스트하면 됩니다.