root/hl_one
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add:接入mqtt2

Browse Source
This commit is contained in:
zhangzq
2024-02-19 14:36:33 +08:00
parent de54a09c5b
commit 990fcb563a
7 changed files with 13 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
wcs/nladmin-system/src/main/java/org/nl/config/mqtt/MQServer.java → wcs/nladmin-system/src/main/java/org/nl/config/mqtt2/MQServer.java
View File

@@ -1,12 +1,12 @@
package org.nl.config.mqtt;
package org.nl.config.mqtt2;
import org.apache.commons.lang3.StringUtils;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.nl.config.mqtt.callback.PublishCallback;
import org.nl.config.mqtt.callback.SubsribeCallback;
import org.nl.config.mqtt.config.MqttConfig;
import org.nl.config.mqtt2.callback.PublishCallback;
import org.nl.config.mqtt2.callback.SubsribeCallback;
import org.nl.config.mqtt2.config.MqttConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Service;

3
wcs/nladmin-system/src/main/java/org/nl/config/mqtt/PublishDemo.java → wcs/nladmin-system/src/main/java/org/nl/config/mqtt2/PublishDemo.java
View File

@@ -1,9 +1,8 @@
package org.nl.config.mqtt;
package org.nl.config.mqtt2;
import cn.dev33.satoken.annotation.SaIgnore;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/*
* @author ZZQ

4
wcs/nladmin-system/src/main/java/org/nl/config/mqtt/callback/PublishCallback.java → wcs/nladmin-system/src/main/java/org/nl/config/mqtt2/callback/PublishCallback.java
View File

@@ -1,10 +1,8 @@
package org.nl.config.mqtt.callback;
package org.nl.config.mqtt2.callback;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.nl.config.mqtt.msg.MsgWorker;
import org.nl.config.mqtt.msg.MsgPoolManager;
/*
* @author ZZQ

6
wcs/nladmin-system/src/main/java/org/nl/config/mqtt/callback/SubsribeCallback.java → wcs/nladmin-system/src/main/java/org/nl/config/mqtt2/callback/SubsribeCallback.java
View File

@@ -1,10 +1,10 @@
package org.nl.config.mqtt.callback;
package org.nl.config.mqtt2.callback;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.nl.config.mqtt.msg.MsgPoolManager;
import org.nl.config.mqtt.msg.MsgWorker;
import org.nl.config.mqtt2.msg.MsgPoolManager;
import org.nl.config.mqtt2.msg.MsgWorker;
/*
* @author ZZQ

7
wcs/nladmin-system/src/main/java/org/nl/config/mqtt/config/MqttConfig.java → wcs/nladmin-system/src/main/java/org/nl/config/mqtt2/config/MqttConfig.java
View File

@@ -1,15 +1,10 @@
package org.nl.config.mqtt.config;
package org.nl.config.mqtt2.config;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;

9
wcs/nladmin-system/src/main/java/org/nl/config/mqtt/msg/MsgPoolManager.java → wcs/nladmin-system/src/main/java/org/nl/config/mqtt2/msg/MsgPoolManager.java
View File

@@ -1,13 +1,8 @@
package org.nl.config.mqtt.msg;
package org.nl.config.mqtt2.msg;
import org.checkerframework.checker.units.qual.C;
import org.nl.config.mqtt.MQServer;
import org.nl.config.mqtt2.MQServer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.SmartLifecycle;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;

2
wcs/nladmin-system/src/main/java/org/nl/config/mqtt/msg/MsgWorker.java → wcs/nladmin-system/src/main/java/org/nl/config/mqtt2/msg/MsgWorker.java
View File

@@ -1,4 +1,4 @@
package org.nl.config.mqtt.msg;
package org.nl.config.mqtt2.msg;
/*
* @author ZZQ