初始化

.gitignore

@@ -0,0 +1,35 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+/.idea/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store

pom.xml

@@ -0,0 +1,31 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.muyu</groupId>
+    <artifactId>mqtt</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.eclipse.paho</groupId>
+            <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
+            <version>1.2.5</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.28</version>
+        </dependency>
+    </dependencies>
+
+</project>

src/main/java/com/muyu/mqtt/PublishSample.java

@@ -0,0 +1,70 @@
+package com.muyu.mqtt;
+
+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;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.concurrent.CountDownLatch;
+
+public class PublishSample {
+
+    private static CountDownLatch countDownLatch = new CountDownLatch(10);
+
+    public static void main (String[] args) {
+
+        String broker = "tcp://192.168.40.128:1883";
+        String topic = "test";
+        String username = "emqx";
+        String password = "public";
+        String clientId = "publish_client";
+        int qos = 0;
+
+        try {
+            MqttClient client = new MqttClient(broker, clientId, new MemoryPersistence());
+            // 连接参数
+            MqttConnectOptions options = new MqttConnectOptions();
+            // 设置用户名和密码
+//            options.setUserName(username);
+//            options.setPassword(password.toCharArray());
+            options.setConnectionTimeout(60);
+            options.setKeepAliveInterval(60);
+            // 连接
+            client.connect(options);
+            new Thread(() -> {
+                for (int i = 0 ; i < 10 ; i++) {
+                    SimpleDateFormat sdf4 = new SimpleDateFormat("yyyy年MM月dd日  HH时mm分ss秒");
+                    String content = sdf4.format(new Date()) + " - Hello MQTT";
+                    // 创建消息并设置 QoS
+                    MqttMessage message = new MqttMessage(content.getBytes());
+                    message.setQos(qos);
+                    // 发布消息
+                    try {
+                        client.publish(topic, message);
+                    } catch (MqttException e) {
+                        throw new RuntimeException(e);
+                    }
+                    System.out.println("Message published");
+                    System.out.println("topic: " + topic);
+                    System.out.println("message content: " + content);
+                    try {
+                        Thread.sleep(1000);
+                    } catch (InterruptedException e) {
+                        throw new RuntimeException(e);
+                    }
+                    countDownLatch.countDown();
+                }
+            }).start();
+            countDownLatch.await();
+            // 关闭连接
+            client.disconnect();
+            // 关闭客户端
+            client.close();
+        } catch (MqttException | InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}

src/main/java/com/muyu/mqtt/SubscribeSample.java

@@ -0,0 +1,51 @@
+package com.muyu.mqtt;
+
+import org.eclipse.paho.client.mqttv3.*;
+import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
+
+public class SubscribeSample {
+    public static void main (String[] args) {
+        String broker = "tcp://192.168.40.128:1883";
+        String topic = "test";
+        String username = "emqx";
+        String password = "public";
+        String clientid = "subscribe_client";
+        int qos = 0;
+
+        try {
+            MqttClient client = new MqttClient(broker, clientid, new MemoryPersistence());
+            // 连接参数
+            MqttConnectOptions options = new MqttConnectOptions();
+//            options.setUserName(username);
+//            options.setPassword(password.toCharArray());
+            options.setConnectionTimeout(60);
+            options.setKeepAliveInterval(60);
+            // 设置回调
+            client.setCallback(new MqttCallback() {
+
+                public void connectionLost (Throwable cause) {
+                    System.out.println("connectionLost: " + cause.getMessage());
+                }
+
+                public void messageArrived (String topic, MqttMessage message) {
+                    System.out.println("topic: " + topic);
+                    System.out.println("Qos: " + message.getQos());
+                    System.out.println("message content: " + new String(message.getPayload()));
+
+                }
+
+                public void deliveryComplete (IMqttDeliveryToken token) {
+                    System.out.println("deliveryComplete---------" + token.isComplete());
+                }
+
+            });
+            client.connect(options);
+            client.subscribe(topic, qos);
+            Thread.sleep(10000);
+            client.disconnect();
+            client.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+}

src/main/java/com/muyu/mqtt/Test1.java

@@ -0,0 +1,9 @@
+package com.muyu.mqtt;
+
+/**
+ * @author DongZl
+ * @description: 测试1
+ * @Date 2023-11-6 下午 04:15
+ */
+public class Test1 {
+}