建站
咨詢
售后
建站咨詢
新聞中心
引言
Spring Boot 是一款用于構(gòu)建基于 Spring 框架的快速應(yīng)用程序的開源框架。它的目標(biāo)是簡化 Spring 應(yīng)用程序的開發(fā)和部署過程，Spring Boot 通過提供一些默認(rèn)配置和自動配置，可以讓開發(fā)者更快的創(chuàng)建一個獨(dú)立的、產(chǎn)品級別的 Spring 應(yīng)用程序。
在永德等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒng)性、市場前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務(wù)理念，為客戶提供成都網(wǎng)站建設(shè)、網(wǎng)站設(shè)計(jì) 網(wǎng)站設(shè)計(jì)制作按需制作,公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),高端網(wǎng)站設(shè)計(jì),成都全網(wǎng)營銷推廣,成都外貿(mào)網(wǎng)站建設(shè)公司,永德網(wǎng)站建設(shè)費(fèi)用合理。
MQTT 是一種輕量級的消息傳輸協(xié)議，它被設(shè)計(jì)用于 IoT（物聯(lián)網(wǎng)）中的低帶寬和不可靠的網(wǎng)絡(luò)環(huán)境中。MQTT 協(xié)議具有簡單、開銷小、可擴(kuò)展等特點(diǎn)，非常適用于物聯(lián)網(wǎng)場景。
本文將介紹如何使用 Spring Boot 和 MQTT 實(shí)現(xiàn)訂閱與消費(fèi)的功能，并通過工廠模式進(jìn)行實(shí)現(xiàn)。
1、準(zhǔn)備工作
在開始本文的實(shí)現(xiàn)過程之前，我們需要準(zhǔn)備一些環(huán)境和工具。
（1）Spring Boot
首先，我們需要安裝和配置 Spring Boot。在這里，我們將使用 Spring Initializr 工具來快速創(chuàng)建一個 Spring Boot 項(xiàng)目。您可以訪問 https://start.spring.io/ 創(chuàng)建一個新的 Spring Boot 項(xiàng)目，也可以使用您自己的 IDE 或構(gòu)建工具創(chuàng)建項(xiàng)目。
（2）MQTT
接下來，我們需要使用 MQTT 客戶端用來連接和通信 MQTT 服務(wù)器。在這里，我們將使用 Eclipse Paho MQTT 客戶端庫。您可以訪問
https://www.eclipse.org/paho/clients/java/ 下載 Eclipse Paho MQTT 客戶端庫。
（3）MQTT 服務(wù)器
最后，我們需要一個 MQTT 服務(wù)器。在這里，我們將使用 Eclipse Mosquitto 作為我們的 MQTT 服務(wù)器。您可以訪問 https://mosquitto.org/ 下載和安裝 Eclipse Mosquitto。
2、創(chuàng)建工廠類
我們將使用工廠模式來創(chuàng)建 MQTT 連接和訂閱的對象。我們將創(chuàng)建一個 MQTTFactory 類來管理 MQTT 連接和訂閱的對象。
（1） 創(chuàng)建 MQTTFactory 類
首先，我們創(chuàng)建一個 MQTTFactory 類。這個類將會是一個單例類，它將會負(fù)責(zé)管理 MQTT 連接和訂閱的對象。我們使用靜態(tài)塊來初始化 MQTT 連接。
public class MQTTFactory {
private static final String MQTT_SERVER_URL = "tcp://localhost:1883";
private static final String MQTT_CLIENT_ID = "mqtt-client";
private static final String MQTT_TOPIC = "mqtt-topic";
private static MqttClient mqttClient;
static {
try {
mqttClient = new MqttClient(MQTT_SERVER_URL, MQTT_CLIENT_ID);
mqttClient.connect();
} catch (MqttException e) {
e.printStackTrace();
}
}
private static MQTTFactory instance;
private MQTTFactory() {}
public static MQTTFactory getInstance() {
if (instance == null) {
instance = new MQTTFactory();
}
return instance;
}
}在這個類中，我們定義了一些常量來設(shè)置 MQTT 服務(wù)器的地址、客戶端 ID 和訂閱的主題。在靜態(tài)塊中，我們使用 Eclipse Paho MQTT 客戶端庫創(chuàng)建了一個 MqttClient 對象，并連接到了 MQTT 服務(wù)器。在 getInstance() 方法中，我們使用懶漢式單例模式創(chuàng)建了一個 MQTTFactory 對象。
（2）創(chuàng)建 MQTTSubscriber 類
接下來，我們創(chuàng)建一個 MQTTSubscriber 類來訂閱 MQTT 主題。在 MQTTSubscriber 類中，我們定義了一個 subscribe() 方法，用于訂閱 MQTT 主題。
public class MQTTSubscriber {
private String topic;
private MqttClient mqttClient;
public MQTTSubscriber(String topic, MqttClient mqttClient) {
this.topic = topic;
this.mqttClient = mqttClient;
}
public void subscribe() throws MqttException {
mqttClient.subscribe(topic, new IMqttMessageListener() {
@Override
public void messageArrived(String topic, MqttMessage message) throws Exception {
System.out.println(String.format("Received message: %s from topic: %s", new String(message.getPayload()), topic));
}
});
}
}在這個類中，我們使用構(gòu)造方法來傳遞訂閱的主題和 MQTT 客戶端對象。在 subscribe() 方法中，我們使用 Eclipse Paho MQTT 客戶端庫的 subscribe() 方法來訂閱 MQTT 主題。在 messageArrived() 方法中，我們使用 System.out.println() 方法來打印收到的消息。
3、創(chuàng)建 Spring Boot 應(yīng)用程序
接下來，我們創(chuàng)建一個 Spring Boot 應(yīng)用程序，來測試我們實(shí)現(xiàn)的 MQTT 訂閱和消費(fèi)的功能。
（1）創(chuàng)建 Spring Boot 應(yīng)用程序
我們可以使用 Spring Initializr 工具創(chuàng)建一個新的 Spring Boot 應(yīng)用程序。在這里，我們創(chuàng)建一個名為 "mqtt-subscriber" 的應(yīng)用程序。我們添加了如下的依賴：
- spring-boot-starter-web
- eclipse-paho-mqtt-client
在 pom.xml 文件中，我們添加了如下的依賴：
org.eclipse.paho
org.eclipse.paho.client.mqttv3
1.2.5
這個依賴用于引入 Eclipse Paho MQTT 客戶端庫。
（2）創(chuàng)建 Spring Boot 控制器
我們創(chuàng)建一個名為 "MQTTSubscriberController" 的 Spring Boot 控制器。在這個控制器中，我們注入了一個 MQTTSubscriber 對象，并使用 @PostConstruct 注解來訂閱 MQTT 主題。
@RestController
public class MQTTSubscriberController {
private final MQTTSubscriber mqttSubscriber;
public MQTTSubscriberController(MQTTSubscriber mqttSubscriber) {
this.mqttSubscriber = mqttSubscriber;
}
@PostConstruct
public void init() {
try {
mqttSubscriber.subscribe();
} catch (MqttException e) {
e.printStackTrace();
}
}
}
在 init() 方法中，我們調(diào)用了 MQTTSubscriber 的 subscribe() 方法來訂閱 MQTT 主題。
（3）測試應(yīng)用程序
現(xiàn)在，我們可以啟動應(yīng)用程序并測試 MQTT 訂閱和消費(fèi)的功能了。我們可以使用 Eclipse Mosquitto 的命令行客戶端來發(fā)布消息到訂閱的主題中。
在命令行中，我們可以使用以下命令來發(fā)布消息：
mosquitto_pub -t myTopic -m "Hello, World!"
在這個命令中，我們使用 "mosquitto_pub" 命令行客戶端來發(fā)布一條消息到 "myTopic" 主題中。消息內(nèi)容為 "Hello, World!"。
如果一切正常，我們應(yīng)該可以在控制臺中看到如下的輸出：
Received message: Hello, World! from topic: myTopic
這表明我們已經(jīng)成功訂閱并消費(fèi)了 MQTT 主題中的消息。
4、總結(jié)
在本文中，我們使用工廠模式實(shí)現(xiàn)了一個 MQTT 訂閱和消費(fèi)的示例應(yīng)用程序。我們使用 Eclipse Paho MQTT 客戶端庫來連接 MQTT 服務(wù)器，并訂閱指定的主題。我們還使用 Spring Boot 框架來創(chuàng)建應(yīng)用程序，并使用 @PostConstruct 注解來訂閱 MQTT 主題。最后，我們使用 Eclipse Mosquitto 的命令行客戶端來發(fā)布消息到訂閱的主題中，并在控制臺中查看已消費(fèi)的消息。
5、進(jìn)一步改進(jìn)
在實(shí)際的應(yīng)用程序中，我們可能需要進(jìn)一步改進(jìn)我們的實(shí)現(xiàn)。以下是一些可能的改進(jìn)方案：
（1）使用配置文件
在我們的示例應(yīng)用程序中，我們硬編碼了 MQTT 服務(wù)器的地址、端口號、訂閱主題等信息。在實(shí)際的應(yīng)用程序中，我們可能希望將這些信息放到配置文件中，以便在部署應(yīng)用程序時能夠輕松地修改這些信息。
我們可以在 application.properties 或 application.yml 文件中添加以下內(nèi)容：
mqtt.server.host=mqtt.cdxwcx.com
mqtt.server.port=1883
mqtt.topic=myTopic
然后，我們可以在 MQTTFactory 類中讀取這些配置信息：
@Configuration
public class MQTTConfig {
@Value("${mqtt.server.host}")
private String mqttServerHost;
@Value("${mqtt.server.port}")
private int mqttServerPort;
@Value("${mqtt.topic}")
private String mqttTopic;
@Bean
public MqttClient mqttClient() throws MqttException {
String brokerUrl = String.format("tcp://%s:%d", mqttServerHost, mqttServerPort);
MqttClient mqttClient = new MqttClient(brokerUrl, MqttClient.generateClientId());
mqttClient.connect();
return mqttClient;
}
@Bean
public MQTTSubscriber mqttSubscriber() throws MqttException {
MqttClient mqttClient = mqttClient();
return new MQTTSubscriber(mqttTopic, mqttClient);
}
@Bean
public MQTTFactory mqttFactory() {
return MQTTFactory.getInstance();
}
}
現(xiàn)在，我們不再需要在代碼中硬編碼 MQTT 服務(wù)器的地址、端口號、訂閱主題等信息，而是從配置文件中讀取這些信息。
（2）使用注解
在我們的示例應(yīng)用程序中，我們使用 @PostConstruct 注解來訂閱 MQTT 主題。在實(shí)際的應(yīng)用程序中，我們可能希望使用更具有語義化的注解來標(biāo)識哪些方法是用于訂閱 MQTT 主題的。
我們可以定義一個 @MQTTSubscriber 注解，并在需要訂閱 MQTT 主題的方法上使用該注解：
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface MQTTSubscriber {
}
然后，在 MQTTSubscriberController 類中，我們可以使用 @MQTTSubscriber 注解來標(biāo)識訂閱 MQTT 主題的方法：
@RestController
public class MQTTSubscriberController {
private final MQTTSubscriber mqttSubscriber;
public MQTTSubscriberController(MQTTSubscriber mqttSubscriber) {
this.mqttSubscriber = mqttSubscriber;
}
@MQTTSubscriber
public void onMessage(String topic, String message) {
System.out.println(String.format("Received message: %s from topic: %s", message, topic));
}
}
在這個例子中，我們定義了一個名為 "onMessage" 的方法，并使用 @MQTTSubscriber 注解來標(biāo)識該方法是用于訂閱 MQTT 主題的。在這個方法中，我們使用兩個參數(shù)來接收收到的消息的主題和內(nèi)容。
在我們的應(yīng)用程序啟動時，我們可以使用 Spring AOP 框架來自動掃描 @MQTTSubscriber 注解，并將被注解的方法注冊為 MQTT 主題的訂閱者。我們可以在 MQTTSubscriberAspect 類中實(shí)現(xiàn)這個功能：
@Aspect
@Component
public class MQTTSubscriberAspect {
private final MQTTSubscriber mqttSubscriber;
public MQTTSubscriberAspect(MQTTSubscriber mqttSubscriber) {
this.mqttSubscriber = mqttSubscriber;
}
@PostConstruct
public void subscribe() throws MqttException {
MqttClient mqttClient = mqttSubscriber.getMqttClient();
mqttClient.subscribe(mqttSubscriber.getTopic(), (topic, message) -> {
String payload = new String(message.getPayload(), StandardCharsets.UTF_8);
Object bean = mqttSubscriber.getBean();
Method[] methods = bean.getClass().getMethods();
for (Method method : methods) {
if (method.isAnnotationPresent(MQTTSubscriber.class) &&
method.getParameterCount() == 2 &&
method.getParameterTypes()[0].equals(String.class) &&
method.getParameterTypes()[1].equals(String.class)) {
method.setAccessible(true);
try {
method.invoke(bean, topic, payload);
} catch (IllegalAccessException | InvocationTargetException e) {
e.printStackTrace();
}
}
}
});
}
}
在這個類中，我們使用 Spring AOP 框架的 @Aspect 注解來標(biāo)識該類是一個切面類。在 @PostConstruct 方法中，我們獲取 MQTT 訂閱者的 MqttClient 實(shí)例，并使用該實(shí)例訂閱指定的主題。然后，我們獲取被注解的方法，并遍歷這些方法，如果發(fā)現(xiàn)某個方法被標(biāo)注為 @MQTTSubscriber，并且參數(shù)個數(shù)為 2，第一個參數(shù)為 String 類型，第二個參數(shù)也為 String 類型，則將該方法注冊為訂閱者。
現(xiàn)在，我們可以在任何需要訂閱 MQTT 主題的方法上使用 @MQTTSubscriber 注解，而不必再使用 @PostConstruct 注解。這使得我們的代碼更加具有語義化，并且更加容易閱讀和維護(hù)。
6、結(jié)論
在本文中，我們使用工廠模式實(shí)現(xiàn)了一個 MQTT 訂閱和消費(fèi)的示例應(yīng)用程序。我們使用 Eclipse Paho MQTT 客戶端庫來連接 MQTT 服務(wù)器，并訂閱指定的主題。我們還使用 Spring Boot 框架來創(chuàng)建應(yīng)用程序，并使用 @PostConstruct 注解來訂閱 MQTT 主題。最后，我們介紹了使用配置文件和注解來改進(jìn)我們的實(shí)現(xiàn)的方法。這些改進(jìn)方案使我們的代碼更加具有語義化，并且更加容易閱讀和維護(hù)。
MQTT 是一種輕量級的消息傳遞協(xié)議，適用于物聯(lián)網(wǎng)等場景中的消息傳遞。它具有簡單、可靠、高效等特點(diǎn)，已經(jīng)被廣泛應(yīng)用于各種場景中。使用工廠模式和 Spring Boot 框架來實(shí)現(xiàn) MQTT 訂閱和消費(fèi)，可以使我們的代碼更加清晰和易于維護(hù)。
網(wǎng)站欄目：一文讀懂通過工廠模式實(shí)現(xiàn)springboot+MQTT-訂閱與消費(fèi)
網(wǎng)頁網(wǎng)址：http://www.dlmjj.cn/article/cddhsoj.html
