```

feat(mqtt): 重构MQTT服务为MQTT代理并集成Redis和Vert.x - 将spring.application.name从mqtt-service改为mqtt-agent - 升级Vert.x版本从4.5.10到4.5.22 - 重命名VerticleLifeTime为VerticleLifeCycle并移至config包 - 移除Lombok依赖并手动实现getter/setter方法 - 更新全局异常处理器日志实现 ```

```
feat(mqtt): 重构MQTT服务为MQTT代理并集成Redis和Vert.x - 将spring.application.name从mqtt-service改为mqtt-agent - 升级Vert.x版本从4.5.10到4.5.22 - 重命名VerticleLifeTime为VerticleLifeCycle并移至config包 - 移除Lombok依赖并手动实现getter/setter方法 - 更新全局异常处理器日志实现 ```
zhangmeiyang
1 parent a7eeacd5
Showing 10 changed files with 85 additions and 44 deletions
mqtt-boot/src/main/resources/application.properties
mqtt-core/pom.xml
mqtt-core/src/main/java/com/diligrp/mqtt/core/config/GlobalExceptionHandler.java
mqtt-core/src/main/java/com/diligrp/mqtt/core/config/MqttProperties.java
mqtt-core/src/main/java/com/diligrp/mqtt/core/exception/MqttServiceException.java
mqtt-core/src/main/java/com/diligrp/mqtt/core/message/Message.java
mqtt-core/src/main/java/com/diligrp/mqtt/core/message/PageQuery.java
mqtt-vertx/pom.xml
mqtt-vertx/src/main/java/com/diligrp/mqtt/vertx/VerticleLifeTime.java → mqtt-vertx/src/main/java/com/diligrp/mqtt/vertx/config/VerticleLifeCycle.java
pom.xml
-spring.application.name=mqtt-service
+spring.application.name=mqtt-agent
 spring.cloud.nacos.discovery.enabled=true
 spring.cloud.nacos.discovery.group=MICROSERVICE
 spring.cloud.nacos.discovery.server-addr=nacos.diligrp.com:8848
@@ -9,3 +9,12 @@ spring.cloud.nacos.config.server-addr=nacos.diligrp.com:8848
 spring.cloud.nacos.config.namespace=2267e673-b41f-458d-9643-2a03e4fd92fb
 spring.config.import[0]=nacos:${spring.application.name}.properties
 spring.config.import[1]=nacos:${spring.application.name}-${spring.profiles.active}.properties
+
+
+spring.data.redis.host=redis.diligrp.com
+spring.data.redis.port=6379
+spring.data.redis.database=12
+#spring.data.redis.username=
+#spring.data.redis.password=
+spring.data.redis.connect-timeout=15000
+spring.data.redis.timeout=30000
@@ -15,10 +15,6 @@
     </parent>
     <dependencies>
         <dependency>
-            <groupId>org.projectlombok</groupId>
-            <artifactId>lombok</artifactId>
-        </dependency>
-        <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
@@ -6,7 +6,8 @@ import com.diligrp.mqtt.core.message.Message;
 import com.fasterxml.jackson.databind.exc.InvalidFormatException;
 import jakarta.validation.ConstraintViolation;
 import jakarta.validation.ConstraintViolationException;
-import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.context.support.DefaultMessageSourceResolvable;
 import org.springframework.http.converter.HttpMessageNotReadableException;
 import org.springframework.validation.BindException;
@@ -25,8 +26,9 @@ import java.util.stream.Collectors;
  * 统一异常处理器
  */
 @RestControllerAdvice
-@Slf4j
 public class GlobalExceptionHandler {
+
+ private static final Logger log = LoggerFactory.getLogger(GlobalExceptionHandler.class);
     /**
      * 处理业务异常
      */
-package com.diligrp.mqtt.core.config;
-
-import org.springframework.boot.context.properties.ConfigurationProperties;
-
-/**
- * @Author: zhangmeiyang
- * @CreateTime: 2025-12-29 17:41
- * @Version: todo
- */
-@ConfigurationProperties(prefix = "mqtt")
-public class MqttProperties {
-    private String host;
-    private Integer port;
-    private String username;
-    private String password;
-}
@@ -3,12 +3,10 @@ package com.diligrp.mqtt.core.exception;
  
  
 import com.diligrp.mqtt.core.config.MessageConfirmType;
-import lombok.Getter;
  
 /**
  * 所有模块异常类的基类
  */
-@Getter
 public class MqttServiceException extends RuntimeException {
     /**
      * 错误码
@@ -71,4 +69,19 @@ public class MqttServiceException extends RuntimeException {
         return stackTrace ? super.fillInStackTrace() : this;
     }
  
+    public int getCode() {
+        return code;
+    }
+
+    public void setCode(int code) {
+        this.code = code;
+    }
+
+    public boolean isStackTrace() {
+        return stackTrace;
+    }
+
+    public void setStackTrace(boolean stackTrace) {
+        this.stackTrace = stackTrace;
+    }
 }
 package com.diligrp.mqtt.core.message;
  
 import com.diligrp.mqtt.core.config.MessageConfirmType;
-import lombok.Getter;
-import lombok.Setter;
  
-@Setter
-@Getter
 public class Message<T> {
     private Integer code;
     private String message;
@@ -35,4 +31,28 @@ public class Message&lt;T&gt; {
         result.message = message;
         return result;
     }
+
+    public Integer getCode() {
+        return code;
+    }
+
+    public void setCode(Integer code) {
+        this.code = code;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+
+    public T getData() {
+        return data;
+    }
+
+    public void setData(T data) {
+        this.data = data;
+    }
 }
 package com.diligrp.mqtt.core.message;
  
 import jakarta.validation.constraints.NotNull;
-import lombok.Getter;
-import lombok.Setter;
  
 /**
  * @Author: zhangmeiyang
  * @CreateTime: 2025-11-05 15:57
  * @Version: todo
  */
-@Getter
-@Setter
 public abstract class PageQuery {
     /**
      * 页码
@@ -22,4 +18,20 @@ public abstract class PageQuery {
      */
     @NotNull(groups = {Valid.Read.class})
     protected Integer pageSize;
+
+    public Integer getPageNumber() {
+        return pageNumber;
+    }
+
+    public void setPageNumber(Integer pageNumber) {
+        this.pageNumber = pageNumber;
+    }
+
+    public Integer getPageSize() {
+        return pageSize;
+    }
+
+    public void setPageSize(Integer pageSize) {
+        this.pageSize = pageSize;
+    }
 }
@@ -20,6 +20,14 @@
             <artifactId>mqtt-core</artifactId>
             <version>${revision}</version>
         </dependency>
+        <dependency>
+            <groupId>io.vertx</groupId>
+            <artifactId>vertx-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.vertx</groupId>
+            <artifactId>vertx-mqtt</artifactId>
+        </dependency>
     </dependencies>
  
 </project>
-package com.diligrp.mqtt.vertx;
+package com.diligrp.mqtt.vertx.config;
  
 import com.diligrp.mqtt.vertx.verticle.MqttVerticle;
 import io.vertx.core.Vertx;
-import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.DisposableBean;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.stereotype.Component;
  
 /**
- * @Author: zhangmeiyang
- * @CreateTime: 2025-12-26 17:16
- * @Version: todo
+ * verticle生命周期
+ *
+ * @author zhangmeiyang
+ * @date 2025/12/30
  */
 @Component
-@Slf4j
-public class VerticleLifeTime implements CommandLineRunner, DisposableBean {
+public class VerticleLifeCycle implements CommandLineRunner, DisposableBean {
  
     private final Vertx vertx;
  
-    public VerticleLifeTime(Vertx vertx) {
+    public VerticleLifeCycle(Vertx vertx) {
         this.vertx = vertx;
     }
  
     @Override
     public void run(String... args) throws Exception {
         vertx.deployVerticle(new MqttVerticle());
-        log.info("MqttVerticle deployed");
     }
  
     @Override
     public void destroy() throws Exception {
         vertx.close();
-        log.info("Vertx closed");
     }
 }
@@ -30,7 +30,7 @@
         <mybatis-plus.version>3.5.14</mybatis-plus.version>
         <!-- 工具类库 -->
         <lombok.version>1.18.42</lombok.version>
-        <vertx.version>4.5.10</vertx.version>
+        <vertx.version>4.5.22</vertx.version>
     </properties>
  
     <dependencyManagement>