From a31a452b9999ba3c811c36b5cb1b3ec0c18d037d Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期三, 08 十一月 2023 02:23:38 +0800
Subject: [PATCH] 提交MQTT相关功能
---
src/main/java/com/fzzy/mqtt/MqttProperties.java | 15 +++++++++------
1 files changed, 9 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/fzzy/mqtt/MqttProperties.java b/src/main/java/com/fzzy/mqtt/MqttProperties.java
index 8a7a554..a7293c9 100644
--- a/src/main/java/com/fzzy/mqtt/MqttProperties.java
+++ b/src/main/java/com/fzzy/mqtt/MqttProperties.java
@@ -1,15 +1,17 @@
package com.fzzy.mqtt;
import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
/**
* MQTT 閰嶇疆淇℃伅
*/
-@Component
-@ConfigurationProperties("mqtt")
+@Slf4j
@Data
+@Component
+@ConfigurationProperties("spring.mqtt")
public class MqttProperties {
/**
@@ -37,13 +39,13 @@
/**
* 瓒呮椂鏃堕棿
*/
- private int clientTimeout;
+ private int clientTimeout = 5000;
/**
* 璁剧疆浼氳瘽蹇冭烦鏃堕棿 鍗曚綅涓虹 鏈嶅姟鍣ㄤ細姣忛殧1.5*20绉掔殑鏃堕棿鍚戝鎴风
* 鍙戦�佷釜娑堟伅鍒ゆ柇瀹㈡埛绔槸鍚﹀湪绾匡紝浣嗚繖涓柟娉曞苟娌℃湁閲嶈繛鐨勬満鍒�
*/
- private int clientAliveTime;
+ private int clientAliveTime = 30000;
private int clientMaxConnectTime;
@@ -52,12 +54,12 @@
/**
* 杩炴帴鏂瑰紡
*/
- private Integer clientQos;
+ private Integer clientQos = 0;
/**
* 榛樿杩炴帴涓婚锛屼互/#缁撳熬琛ㄧず璁㈤槄鎵�鏈変互test寮�澶寸殑涓婚
*/
- private String defaultTopic;
+ private String defaultTopic;
/**
* 璁剧疆鏄惁娓呯┖session,杩欓噷濡傛灉璁剧疆涓篺alse琛ㄧず鏈嶅姟鍣ㄤ細淇濈暀瀹㈡埛绔殑杩�
@@ -75,4 +77,5 @@
*/
private Boolean isOpen;
+
}
--
Gitblit v1.9.3