From 5766c52d40e90a71f8001ac300ecde81eeb79a62 Mon Sep 17 00:00:00 2001
From: Cool <747682928@qq.com>
Date: Wed, 14 Aug 2024 23:57:26 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=9D=E5=A7=8B=E5=8C=96=E9=98=9F=E5=88=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
pom.xml | 4 +++
.../com/example/chat/ChatApplication.java | 2 ++
.../java/com/example/chat/common/Test.java | 4 ---
.../chat/common/config/RabbitMqConfig.java | 32 +++++++++++++++++++
.../java/com/example/chat/dao/Test01.java | 28 ----------------
.../com/example/chat/service/TaskService.java | 27 ++++++++++++++++
.../java/com/example/chat/test/Test01.java | 17 ----------
src/main/resources/application.yml | 6 ++++
8 files changed, 71 insertions(+), 49 deletions(-)
delete mode 100644 src/main/java/com/example/chat/common/Test.java
create mode 100644 src/main/java/com/example/chat/common/config/RabbitMqConfig.java
delete mode 100644 src/main/java/com/example/chat/dao/Test01.java
create mode 100644 src/main/java/com/example/chat/service/TaskService.java
delete mode 100644 src/main/java/com/example/chat/test/Test01.java
diff --git a/pom.xml b/pom.xml
index a4cd795..2c3b5a2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -25,6 +25,10 @@
org.springframework.boot
spring-boot-starter-test
+
+ org.springframework.boot
+ spring-boot-starter-amqp
+
com.auth0
java-jwt
diff --git a/src/main/java/com/example/chat/ChatApplication.java b/src/main/java/com/example/chat/ChatApplication.java
index 8883925..b67d903 100644
--- a/src/main/java/com/example/chat/ChatApplication.java
+++ b/src/main/java/com/example/chat/ChatApplication.java
@@ -3,10 +3,12 @@ package com.example.chat;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
//@EnableWebSocket
@Mapper
+@EnableScheduling
@SpringBootApplication
public class ChatApplication {
diff --git a/src/main/java/com/example/chat/common/Test.java b/src/main/java/com/example/chat/common/Test.java
deleted file mode 100644
index 8187d19..0000000
--- a/src/main/java/com/example/chat/common/Test.java
+++ /dev/null
@@ -1,4 +0,0 @@
-package com.example.chat.common;
-
-public class Test {
-}
diff --git a/src/main/java/com/example/chat/common/config/RabbitMqConfig.java b/src/main/java/com/example/chat/common/config/RabbitMqConfig.java
new file mode 100644
index 0000000..d893660
--- /dev/null
+++ b/src/main/java/com/example/chat/common/config/RabbitMqConfig.java
@@ -0,0 +1,32 @@
+package com.example.chat.common.config;
+
+import org.springframework.amqp.core.*;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RabbitMqConfig {
+
+ public static final String QUEUE_INFORM_SMS = "queue_inform_sms";
+ public static final String EXCHANGE_TOPICS_INFORM = "exchange_topics_inform";
+ public static final String ROUTING_KEY_SMS = "inform.cool.sms.message";
+
+ @Bean(QUEUE_INFORM_SMS)
+ public Queue smsQueue() {
+ return new Queue(QUEUE_INFORM_SMS);
+ }
+
+ @Bean(EXCHANGE_TOPICS_INFORM)
+ public Exchange taskExchange() {
+ return ExchangeBuilder.topicExchange(EXCHANGE_TOPICS_INFORM).durable(true).build();
+ }
+
+ @Bean
+ public Binding bindingSMSQueue(@Qualifier(QUEUE_INFORM_SMS) Queue queue,
+ @Qualifier(EXCHANGE_TOPICS_INFORM) Exchange exchange
+ ) {
+ return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY_SMS).noargs();
+ }
+
+}
diff --git a/src/main/java/com/example/chat/dao/Test01.java b/src/main/java/com/example/chat/dao/Test01.java
deleted file mode 100644
index 5322911..0000000
--- a/src/main/java/com/example/chat/dao/Test01.java
+++ /dev/null
@@ -1,28 +0,0 @@
-package com.example.chat.dao;
-
-import com.example.chat.dao.mybatis.MybatisSingleton;
-import com.example.chat.entity.User;
-import org.apache.ibatis.session.SqlSession;
-import org.springframework.boot.CommandLineRunner;
-import org.springframework.stereotype.Component;
-
-import java.util.concurrent.TimeUnit;
-
-@Component
-public class Test01 implements CommandLineRunner {
-
-
- @Override
- public void run(String... args) throws Exception {
- while (true) {
- SqlSession sqlSession = MybatisSingleton.getSqlSessionFactory().openSession();
- User user = sqlSession.selectOne("dao.Login.getUser", "img/123/123");
- if (user != null) {
- System.out.println(user);
- }
- sqlSession.close();
- System.out.println("sleep");
- TimeUnit.MINUTES.sleep(10);
- }
- }
-}
diff --git a/src/main/java/com/example/chat/service/TaskService.java b/src/main/java/com/example/chat/service/TaskService.java
new file mode 100644
index 0000000..d28cb97
--- /dev/null
+++ b/src/main/java/com/example/chat/service/TaskService.java
@@ -0,0 +1,27 @@
+package com.example.chat.service;
+
+import com.example.chat.common.config.RabbitMqConfig;
+import com.example.chat.entity.chat.Message;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+@Service
+public class TaskService {
+
+ @Autowired
+ RabbitTemplate rabbitTemplate;
+
+ @Scheduled(cron = "0 * 23 * * ?")
+ public void test() throws JsonProcessingException {
+ Message message = new Message();
+ message.setMessage("哈哈哈哈哈哈");
+ ObjectMapper mapper=new ObjectMapper();
+ rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_TOPICS_INFORM,RabbitMqConfig.ROUTING_KEY_SMS,mapper.writeValueAsString(message));
+ System.out.println("test定时任务执行了123");
+ }
+
+}
diff --git a/src/main/java/com/example/chat/test/Test01.java b/src/main/java/com/example/chat/test/Test01.java
deleted file mode 100644
index 61f5f75..0000000
--- a/src/main/java/com/example/chat/test/Test01.java
+++ /dev/null
@@ -1,17 +0,0 @@
-package com.example.chat.test;
-
-import org.junit.Test;
-
-public class Test01 {
-
- @Test
- public void Test11(){
- String currentDir = System.getProperty("user.dir");
- System.out.println("当前项目的路径是：" + currentDir+"\\com\\example");
-
- ClassLoader classLoader = getClass().getClassLoader();
- String currentDir1 = classLoader.getResource("").getPath();
- System.out.println("当前项目的路径是：" + currentDir1);
-
- }
-}
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 3e2cb1e..a37ae21 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -5,3 +5,9 @@ spring:
port: 6379
password: ob666666
host: 119.29.254.99
+ rabbitmq:
+ host: 119.29.254.99
+ port: 5672
+ username: cool
+ password: cool
+ virtualHost: /