Added mongo-docker/docker-compose.yml

Author: Bikraji

.gitignore

@@ -67,4 +67,6 @@ Temporary Items
 hs_err_pid*
 
 #Auto-import
-*.iml
+*.iml
+/mongo-docker/.mongo-volume/
+/code_examples/

mongo-docker/docker-compose.yml

@@ -1,12 +1,14 @@
 # Mongo docker image
-version: '3.1'
+version: '3.7'
 
 services:
   mongo:
     image: 'mongo:4.4.0-rc8-bionic'
     restart: on-failure
     ports:
     - 27017:27017
+    volumes:
+    - ./.mongo-volume:/data/db
     environment:
       MONGO_INITDB_ROOT_USERNAME: root
       MONGO_INITDB_ROOT_PASSWORD: root@123

pom.xml

@@ -16,9 +16,12 @@
 
   <modules>
     <module>project-reactor</module>
+    <module>webflux-00-controller-approach</module>
+    <module>webflux-01-functional-approach</module>
+    <module>webflux-03-mongo-rest-controller-approach</module>
+    <module>webflux-02-mongo-rest-functional-approach</module>
   </modules>
 
-
   <properties>
     <java.version>11</java.version>
   </properties>

webflux-00-controller-approach/README.md

@@ -0,0 +1,14 @@
+1. To run the application
+```shell script
+mvn spring-boot:run
+```
+
+2. Visit the below urls in a browser:
+```
+http://localhost:8080/hello/mono
+```
+
+```
+http://localhost:8080/hello/flux
+```
+3. If needed, change the app-server #port in `src/main/resources/application.yml`

webflux-00-controller-approach/pom.xml

@@ -11,7 +11,7 @@
   </parent>
   <modelVersion>4.0.0</modelVersion>
   <artifactId>webflux-00-controller-approach</artifactId>
-  <description>First WebFlux project in Spring boot</description>
+  <description>Annotation approach WebFlux project in Spring boot</description>
 
   <dependencies>
     <dependency>

webflux-00-controller-approach/src/main/resources/application.yml

@@ -1,2 +1,3 @@
 server:
-  port: 8080
+  port: 8080
+

webflux-00-controller-approach/src/test/java/c/jbd/webflux/resources/CorrectTestController.java

@@ -1,4 +1,50 @@
 package c.jbd.webflux.resources;
 
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.web.reactive.WebFluxTest;
+import org.springframework.http.MediaType;
+import org.springframework.test.web.reactive.server.WebTestClient;
+import reactor.core.publisher.Flux;
+import reactor.test.StepVerifier;
+
+//@SpringJUnitConfig(AppConfig.class)
+@WebFluxTest
 public class CorrectTestController {
+  @Autowired
+  private WebTestClient webTestClient;
+
+  private final String TEST_MESSAGE = "Welcome to JstoBigdata.com";
+
+  @Test
+  public void testMonoEndpoint() {
+    Flux<String> msg$ = webTestClient.get()
+      .uri("/hello/mono")
+      .exchange()
+      .expectStatus().isOk()
+      .returnResult(String.class).getResponseBody()
+      .log();
+
+    msg$.subscribe(System.out::println);
+
+    StepVerifier.create(msg$)
+      .expectNext(TEST_MESSAGE)
+      .verifyComplete();
+    //.expectComplete(); - do not use
+  }
+
+  @Test
+  public void testFluxEndpoint() {
+    Flux<String> msg$ = webTestClient.get()
+      .uri("/hello/flux")
+      .accept(MediaType.APPLICATION_STREAM_JSON)
+      .exchange()
+      .expectStatus().isOk()
+      .returnResult(String.class).getResponseBody()
+      .log();
+
+    StepVerifier.create(msg$)
+      .expectNext(TEST_MESSAGE)
+      .verifyComplete();
+  }
 }

webflux-00-controller-approach/src/test/java/c/jbd/webflux/resources/TestHelloController.java

@@ -1,4 +1,44 @@
 package c.jbd.webflux.resources;
 
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+import org.springframework.http.MediaType;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
+
 public class TestHelloController {
+
+  private static WebClient webClient;
+
+  @BeforeAll
+  private static void setWebClient() {
+    webClient = WebClient.create("http://localhost:8080");
+  }
+
+  @Test
+  public void testMonoEndpoint() {
+    Mono<String> msg$ = webClient.get()
+      .uri("/hello/mono")
+      .retrieve()
+      .bodyToMono(String.class).log();
+
+    StepVerifier.create(msg$)
+      .expectNext("Welcome to JstoBigdata.com")
+      .expectComplete();
+  }
+
+  @Test
+  public void testFluxEndpoint() {
+    Flux<String> msg$ = webClient.get()
+      .uri("/hello/flux")
+      .accept(MediaType.APPLICATION_STREAM_JSON)
+      .retrieve()
+      .bodyToFlux(String.class);
+
+    StepVerifier.create(msg$)
+      .expectNext("Welcome to JstoBigdata.com")
+      .verifyComplete();
+  }
 }

webflux-01-functional-approach/pom.xml

@@ -10,6 +10,38 @@
   <modelVersion>4.0.0</modelVersion>
 
   <artifactId>webflux-01-functional-approach</artifactId>
+  <description>Functional approach in WebFlux endpoints</description>
 
+  <dependencies>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-webflux</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-test</artifactId>
+      <scope>test</scope>
+      <exclusions>
+        <exclusion>
+          <groupId>org.junit.vintage</groupId>
+          <artifactId>junit-vintage-engine</artifactId>
+        </exclusion>
+      </exclusions>
+    </dependency>
+
+    <dependency>
+      <groupId>io.projectreactor</groupId>
+      <artifactId>reactor-test</artifactId>
+      <scope>test</scope>
+    </dependency>
+
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-devtools</artifactId>
+      <optional>true</optional>
+      <scope>runtime</scope>
+    </dependency>
+  </dependencies>
 
 </project>

webflux-01-functional-approach/src/main/java/c/jbd/webflux/FunctionalAppConfig.java

@@ -6,6 +6,6 @@
 @SpringBootApplication
 public class FunctionalAppConfig {
   public static void main(String[] args) {
-    SpringApplication.run(AppConfig.class, args);
+    SpringApplication.run(FunctionalAppConfig.class, args);
   }
 }