diff --git a/yxt-supervise-monitor-biz/pom.xml b/yxt-supervise-monitor-biz/pom.xml index fa221be..dbc75af 100644 --- a/yxt-supervise-monitor-biz/pom.xml +++ b/yxt-supervise-monitor-biz/pom.xml @@ -59,6 +59,12 @@ 2.2.3 + + org.springframework.boot + spring-boot-starter-test + test + + org.bytedeco diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/YxtSuperviseMonitorApplication.java b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/YxtSuperviseMonitorApplication.java index a9b45b4..a2c2238 100644 --- a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/YxtSuperviseMonitorApplication.java +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/YxtSuperviseMonitorApplication.java @@ -9,7 +9,8 @@ import org.springframework.boot.autoconfigure.SpringBootApplication; */ @SpringBootApplication(scanBasePackages = { "com.yxt.common.base.config", - "com.yxt.supervise.monitor" + "com.yxt.supervise.monitor", + "demo.rocketmq" }) public class YxtSuperviseMonitorApplication { public static void main(String[] args) { diff --git a/yxt-supervise-monitor-biz/src/main/java/demo/rocketmq/MqClientListener.java b/yxt-supervise-monitor-biz/src/main/java/demo/rocketmq/MqClientListener.java new file mode 100644 index 0000000..6cd47f5 --- /dev/null +++ b/yxt-supervise-monitor-biz/src/main/java/demo/rocketmq/MqClientListener.java @@ -0,0 +1,15 @@ +package demo.rocketmq; + +import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; +import org.apache.rocketmq.spring.core.RocketMQListener; +import org.springframework.stereotype.Component; + +//@Component +//@RocketMQMessageListener(consumerGroup = "monitorConsumer", topic = "sanyouTopic") +public class MqClientListener implements RocketMQListener { + + @Override + public void onMessage(String msg) { + System.out.println("接收到消息:" + msg); + } +} diff --git a/yxt-supervise-monitor-biz/src/main/resources/application-pro.yml b/yxt-supervise-monitor-biz/src/main/resources/application-pro.yml index be94367..0020dab 100644 --- a/yxt-supervise-monitor-biz/src/main/resources/application-pro.yml +++ b/yxt-supervise-monitor-biz/src/main/resources/application-pro.yml @@ -1,9 +1,9 @@ spring: datasource: driver-class-name: com.mysql.cj.jdbc.Driver - url: jdbc:mysql://127.0.0.1:3306/supervise_crm?serverTimezone=GMT%2B8&autoReconnect=true&useUnicode=true&characterEncoding=UTF-8 + url: jdbc:mysql://127.0.0.1:3306/yxt_supervise_monitor?serverTimezone=GMT%2B8&autoReconnect=true&useUnicode=true&characterEncoding=UTF-8&nullCatalogMeansCurrent=true username: root - password: root + password: 1LAiGz$t1*Iw cloud: nacos: discovery: diff --git a/yxt-supervise-monitor-biz/src/main/resources/application-test.yml b/yxt-supervise-monitor-biz/src/main/resources/application-test.yml index d11ece2..53ffe9f 100644 --- a/yxt-supervise-monitor-biz/src/main/resources/application-test.yml +++ b/yxt-supervise-monitor-biz/src/main/resources/application-test.yml @@ -1,9 +1,9 @@ spring: datasource: driver-class-name: com.mysql.cj.jdbc.Driver - url: jdbc:mysql://127.0.0.1:3306/yxt_supervise_monitor?serverTimezone=GMT%2B8&autoReconnect=true&useUnicode=true&characterEncoding=UTF-8&nullCatalogMeansCurrent=true - username: root - password: 1LAiGz$t1*Iw + url: jdbc:mysql://39.104.100.138:3306/yxt_supervise_monitor?serverTimezone=GMT%2B8&autoReconnect=true&useUnicode=true&characterEncoding=UTF-8&nullCatalogMeansCurrent=true&allowPublicKeyRetrieval=true + username: monitor + password: monitor cloud: nacos: discovery: @@ -17,7 +17,7 @@ spring: max-idle: 8 #连接池中的最大空闲连接 max-wait: -1 # 连接池最大阻塞等待时间(使用负值表示没有限制) min-idle: 0 # 连接池中的最小空闲连接 - password: 123456 + password: port: 6379 timeout: 0 # 连接超时时间(毫秒) diff --git a/yxt-supervise-monitor-biz/src/main/resources/application.yml b/yxt-supervise-monitor-biz/src/main/resources/application.yml index b0056c8..3d24cf6 100644 --- a/yxt-supervise-monitor-biz/src/main/resources/application.yml +++ b/yxt-supervise-monitor-biz/src/main/resources/application.yml @@ -2,8 +2,8 @@ spring: application: name: yxt-supervise-monitor profiles: - active: devv -# active: test +# active: devv + active: test messages: # 国际化资源文件路径 basename: i18n/messages @@ -41,6 +41,10 @@ mybatis-plus: call-setters-on-nulls: true log-impl: org.apache.ibatis.logging.stdout.StdOutImpl +#rocketmq: +# producer: +# group: yxt-supervise-monitor +# name-server: 127.0.0.1:9876 diff --git a/yxt-supervise-monitor-biz/src/test/java/demo/rocketmq/RocketMQTest.java b/yxt-supervise-monitor-biz/src/test/java/demo/rocketmq/RocketMQTest.java new file mode 100644 index 0000000..e69de29