자바 로 MQTT 클 라 이언 트 개발

이 장 에 서 는 자바 로 MQTT 클 라 이언 트 를 연결 하여 게시 메시지, 구독 메시지, 수신 메 시 지 를 실현 합 니 다.
관련 의존 도입
이 예 에 서 는 Maven 을 사용 하여 의존 하 는 라 이브 러 리 파일 을 관리 하고 pom.xml 열 고 아래 의 JAR 의존 도 를 추가 하여 관련 JAR 가방 의 다운 로드 를 기다 리 고 있 습 니 다.

    org.eclipse.paho
    org.eclipse.paho.client.mqttv3
    1.2.0

전체 예

package paho_demo;

import java.text.MessageFormat;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

public class Demo {
    public static void main(String[] args) {
        String broker = "tcp://localhost:1883";
        String clientId = "JavaSample";
        //Use the memory persistence
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            MqttClient sampleClient = new MqttClient(broker, clientId, persistence);
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);
            System.out.println("Connecting to broker:" + broker);
            sampleClient.connect(connOpts);
            System.out.println("Connected");
            //    
            String topic = "demo/topics";
            System.out.println("Subscribe to topic:" + topic);
            //    ，topic：    
            sampleClient.subscribe(topic);
            sampleClient.setCallback(new MqttCallback() {
            	//    
                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    String theMsg = MessageFormat.format("{0} is arrived for topic {1}.", new String(message.getPayload()), topic);
                    System.out.println(theMsg);
                }

                public void deliveryComplete(IMqttDeliveryToken token) {
                }

                public void connectionLost(Throwable throwable) {
                }
            });


            String content = "Message from MqttPublishSample";
            int qos = 2;
            System.out.println("Publishing message:" + content);
            //    ，topic：    ，MqttMessage：    
            MqttMessage message = new MqttMessage(content.getBytes());
            message.setQos(qos);
            sampleClient.publish(topic, message);
            System.out.println("Message published");

        } catch (MqttException me) {
            System.out.println("reason" + me.getReasonCode());
            System.out.println("msg" + me.getMessage());
            System.out.println("loc" + me.getLocalizedMessage());
            System.out.println("cause" + me.getCause());
            System.out.println("excep" + me);
            me.printStackTrace();
        }
    }
}

참고 문서:https://docs.emqx.io/tutorial/v4/cn/client_dev/java.html