mqtt

config/nacos/seata-server.properties

@@ -2,6 +2,7 @@ service.vgroupMapping.dk-auth-group=default
 service.vgroupMapping.dk-system-group=default
 service.vgroupMapping.dk-resource-group=default
 service.vgroupMapping.dk-workflow-group=default
+service.vgroupMapping.sample-group=default
 
 service.enableDegrade=false
 service.disableGlobalTransaction=false

dk-modules/sample/src/main/java/org/dromara/sample/CloudApiSampleApplication.java

@@ -8,10 +8,9 @@ import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
-
+@MapperScan("org.dromara.sample.*.dao")
 @EnableDubbo
-@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
+@SpringBootApplication(scanBasePackages = {"org.dromara.common.sdk.**","org.dromara.sample.**"}, exclude = DataSourceAutoConfiguration.class)
-@ComponentScan(basePackages = "org.dromara.common.sdk.mqtt")
 public class CloudApiSampleApplication {
 
 	public static void main(String[] args) {

dk-modules/sample/src/main/resources/application.yml

@@ -6,12 +6,17 @@ spring:
     allow-bean-definition-overriding: true
   application:
     # 应用名称
-    name: cloud-sample
+    name: sample
 
   profiles:
     # 环境配置
     active: @profiles.active@
 
+cloud-sdk:
+  mqtt:
+    # Topics that need to be subscribed when initially connecting to mqtt, multiple topics are divided by ",".
+    inbound-topic: sys/product/+/status,thing/product/+/requests
+
 --- # nacos 配置
 spring:
   cloud:
@@ -36,3 +41,5 @@ spring:
 
 
 
+
+