spring webflux 示例

Author: YunaiV

lab-27/lab-27-webflux-01/src/test/java/cn/iocoder/springboot/lab27/springwebflux/controller/UserControllerTest.java

@@ -5,7 +5,6 @@
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.autoconfigure.web.reactive.AutoConfigureWebFlux;
 import org.springframework.boot.test.autoconfigure.web.reactive.AutoConfigureWebTestClient;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
@@ -22,7 +21,6 @@
  */
 @RunWith(SpringRunner.class)
 @SpringBootTest(classes = Application.class)
-@AutoConfigureWebFlux
 @AutoConfigureWebTestClient
 public class UserControllerTest {
 
@@ -51,7 +49,7 @@ public void testList() {
     }
 
     @Test
-    public void testGet() throws Exception {
+    public void testGet() {
         // 获得指定用户编号的用户
         webClient.get().uri("/users/get?id=1")
                 .exchange() // 执行请求
@@ -63,7 +61,7 @@ public void testGet() throws Exception {
     }
 
     @Test
-    public void testGet2() throws Exception {
+    public void testGet2() {
         // 获得指定用户编号的用户
         webClient.get().uri("/users/v2/get?id=1")
                 .exchange() // 执行请求
@@ -75,7 +73,7 @@ public void testGet2() throws Exception {
     }
 
     @Test
-    public void testAdd() throws Exception {
+    public void testAdd() {
         Map<String, Object> params = new HashMap<>();
         params.put("username", "yudaoyuanma");
         params.put("password", "nicai");
@@ -88,7 +86,7 @@ public void testAdd() throws Exception {
     }
 
     @Test
-    public void testAdd2() throws Exception {
+    public void testAdd2() { // 发送文件的测试，可以参考 https://dev.to/shavz/sending-multipart-form-data-using-spring-webtestclient-2gb7 文章
         BodyInserters.FormInserter<String> formData = // Form Data 数据，需要这么拼凑
                 BodyInserters.fromFormData("username", "yudaoyuanma")
                 .with("password", "nicai");
@@ -102,7 +100,7 @@ public void testAdd2() throws Exception {
 
 
     @Test
-    public void testUpdate() throws Exception {
+    public void testUpdate() {
         Map<String, Object> params = new HashMap<>();
         params.put("id", 1);
         params.put("username", "yudaoyuanma");
@@ -117,14 +115,15 @@ public void testUpdate() throws Exception {
     }
 
     @Test
-    public void testDelete() throws Exception {
+    public void testDelete() {
         // 删除用户
         webClient.post().uri("/users/delete?id=1")
                 .exchange() // 执行请求
                 .expectStatus().isOk() // 响应状态码 200
                 .expectBody(Boolean.class) // 期望返回值类型是 Boolean
-                .consumeWith((Consumer<EntityExchangeResult<Boolean>>) result -> // 通过消费结果，判断符合是 true 。
-                        Assert.assertTrue("返回结果需要为 true", result.getResponseBody()));
+                .isEqualTo(true); // 这样更加简洁一些
+//                .consumeWith((Consumer<EntityExchangeResult<Boolean>>) result -> // 通过消费结果，判断符合是 true 。
+//                        Assert.assertTrue("返回结果需要为 true", result.getResponseBody()));
     }
 
 }