From 4ae7bd543792d1930764f2e966af5930b1d7dd44 Mon Sep 17 00:00:00 2001
From: Bunny <1319900154@qq.com>
Date: Wed, 7 Aug 2024 23:42:45 +0800
Subject: [PATCH] =?UTF-8?q?:sparkles:=20feat(=E6=96=B0=E5=A2=9E):=20Flux?=
 =?UTF-8?q?=E5=92=8CMono=E4=BD=BF=E7=94=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 service/pom.xml                               | 11 ++++
 .../service/controller/WebFluxController.java | 55 +++++++++++++++++++
 .../src/main/resources/application-dev.yml    |  2 +-
 .../src/main/resources/application-prod.yml   |  3 +-
 service/src/main/resources/quartz.properties  |  2 +-
 .../resources/templates/email-template.html   | 45 ---------------
 6 files changed, 69 insertions(+), 49 deletions(-)
 create mode 100644 service/src/main/java/cn/bunny/service/controller/WebFluxController.java
 delete mode 100644 service/src/main/resources/templates/email-template.html

diff --git a/service/pom.xml b/service/pom.xml
index 8f04bc8..8a3483e 100644
--- a/service/pom.xml
+++ b/service/pom.xml
@@ -56,6 +56,17 @@
             <artifactId>spring-context-support</artifactId>
             <version>6.1.6</version>
         </dependency>
+        <!-- webflux -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+            <version>3.3.2</version>
+        </dependency>
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-codec-http</artifactId>
+            <version>4.1.111.Final</version>
+        </dependency>
     </dependencies>
 
     <build>
diff --git a/service/src/main/java/cn/bunny/service/controller/WebFluxController.java b/service/src/main/java/cn/bunny/service/controller/WebFluxController.java
new file mode 100644
index 0000000..c422371
--- /dev/null
+++ b/service/src/main/java/cn/bunny/service/controller/WebFluxController.java
@@ -0,0 +1,55 @@
+package cn.bunny.service.controller;
+
+import cn.bunny.pojo.result.Result;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import java.time.Duration;
+import java.util.ArrayList;
+
+@Tag(name = "webflux测试i请求接口")
+@RequestMapping("/api")
+@RestController
+public class WebFluxController {
+
+    @Operation(summary = "Mono测试")
+    @GetMapping("test1")
+    public Mono<Result<String>> test1() {
+        Result<String> result = Result.success("测试成功啦，第一个Mono");
+        return Mono.just(result);
+    }
+
+    @Operation(summary = "Flux测试")
+    @GetMapping("test2")
+    public Flux<Result<ArrayList<String>>> test2() {
+        ArrayList<String> list = new ArrayList<>() {
+            {
+                add("Flux测试，返回的是数组");
+                add("数组啊啊啊啊");
+            }
+        };
+        Result<ArrayList<String>> result = Result.success(list);
+
+        return Flux.just(result);
+    }
+
+
+    @Operation(summary = "模仿ChatGPT")
+    @GetMapping("test3")
+    public Flux<String> test3() {
+        ArrayList<String> list = new ArrayList<>() {
+            {
+                add("Flux测试，返回的是数组");
+                add("数组啊啊啊啊");
+            }
+        };
+        Result<ArrayList<String>> result = Result.success(list);
+
+        return Flux.range(1, 10).map(i -> "输出：" + i).delayElements(Duration.ofMillis(500));
+    }
+}
diff --git a/service/src/main/resources/application-dev.yml b/service/src/main/resources/application-dev.yml
index 887030d..f274f49 100644
--- a/service/src/main/resources/application-dev.yml
+++ b/service/src/main/resources/application-dev.yml
@@ -4,4 +4,4 @@ bunny:
     port: 3306
     sqlData: myDS
     username: root
-    password: "123456"
+    password: "02120212"
diff --git a/service/src/main/resources/application-prod.yml b/service/src/main/resources/application-prod.yml
index 1ca2051..c069989 100644
--- a/service/src/main/resources/application-prod.yml
+++ b/service/src/main/resources/application-prod.yml
@@ -4,8 +4,7 @@ bunny:
     port: 3306
     sqlData: myDS
     username: root
-    password: "123456"
-
+    password: "02120212"
 
 knife4j:
   enable: true
diff --git a/service/src/main/resources/quartz.properties b/service/src/main/resources/quartz.properties
index ff9d99b..eab2048 100644
--- a/service/src/main/resources/quartz.properties
+++ b/service/src/main/resources/quartz.properties
@@ -7,5 +7,5 @@ org.quartz.jobStore.dataSource=myDS
 org.quartz.dataSource.myDS.driver=com.mysql.cj.jdbc.Driver
 org.quartz.dataSource.myDS.URL=jdbc:mysql://192.168.3.98:3306/myDS?serverTimezone=GMT%2B8&useSSL=false&characterEncoding=utf-8&allowPublicKeyRetrieval=true
 org.quartz.dataSource.myDS.user=root
-org.quartz.dataSource.myDS.password=123456
+org.quartz.dataSource.myDS.password=02120212
 org.quartz.dataSource.myDS.maxConnections=5
\ No newline at end of file
diff --git a/service/src/main/resources/templates/email-template.html b/service/src/main/resources/templates/email-template.html
deleted file mode 100644
index b2b89b4..0000000
--- a/service/src/main/resources/templates/email-template.html
+++ /dev/null
@@ -1,45 +0,0 @@
-<body style="margin: 0; padding: 0; background-color: #f5f5f5;">
-<div style="max-width: 600px; margin: 0 auto;">
-    <table style="width: 100%; border-collapse: collapse; background-color: #ffffff; font-family: Arial, sans-serif;">
-        <tr>
-            <th style="height: 60px; padding: 20px; background-color: #0074d3; border-radius: 5px 5px 0 0;"
-                valign="middle">
-                <h1 style="margin: 0; color: #ffffff; font-size: 24px;">BunnyBBS邮箱验证码</h1>
-            </th>
-        </tr>
-        <tr>
-            <td style="padding: 20px;">
-                <div style="background-color: #ffffff; padding: 25px;">
-                    <h2 style="margin: 10px 0; font-size: 18px; color: #333333;">
-                        尊敬的用户,
-                    </h2>
-                    <p style="margin: 10px 0; font-size: 16px; color: #333333;">
-                        感谢您注册我们的产品. 您的账号正在进行电子邮件验证.
-                    </p>
-                    <p style="margin: 10px 0; font-size: 16px; color: #333333;">
-                        验证码为: <span class="button" style="color: #1100ff;">${verifyCode}</span>
-                    </p>
-                    <p style="margin: 10px 0; font-size: 16px; color: #333333;">
-                        验证码的有效期只有一分钟，请抓紧时间进行验证吧！
-                    </p>
-                    <p style="margin: 10px 0; font-size: 16px; color: #dc1818;">
-                        如果非本人操作,请忽略此邮件
-                    </p>
-                </div>
-            </td>
-        </tr>
-        <tr>
-            <td style="text-align: center; padding: 20px; background-color: #f5f5f5;">
-                <p style="margin: 0; font-size: 12px; color: #747474;">
-                    XXXXX<br>
-                    Contact us: XXXXXXX@qq.com
-                </p>
-                <p style="margin: 10px 0; font-size: 12px; color: #747474;">
-                    This is an automated email, please do not reply.<br>
-                    © Company Name
-                </p>
-            </td>
-        </tr>
-    </table>
-</div>
-</body>
\ No newline at end of file