Added code for WebFlux getting started module

Author: Bikraji

webflux-00-controller-approach/pom.xml

@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+     http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+  <parent>
+    <artifactId>spring-webflux-tutorial</artifactId>
+    <groupId>com.jstobigdata</groupId>
+    <version>1.0-SNAPSHOT</version>
+  </parent>
+  <modelVersion>4.0.0</modelVersion>
+  <artifactId>webflux-00-controller-approach</artifactId>
+  <description>First WebFlux project in Spring boot</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-00-controller-approach/src/main/java/c/jbd/webflux/AppConfig.java

@@ -0,0 +1,11 @@
+package c.jbd.webflux;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class AppConfig {
+  public static void main(String[] args) {
+    SpringApplication.run(AppConfig.class, args);
+  }
+}

webflux-00-controller-approach/src/main/java/c/jbd/webflux/model/Message.java

@@ -0,0 +1,46 @@
+package c.jbd.webflux.model;
+
+import java.time.LocalDate;
+import java.util.StringJoiner;
+
+public class Message {
+  private LocalDate date;
+  private String greeting;
+  private String ipAddress;
+
+  public LocalDate getDate() {
+    return date;
+  }
+
+  public Message setDate(LocalDate date) {
+    this.date = date;
+    return this;
+  }
+
+  public String getGreeting() {
+    return greeting;
+  }
+
+  public Message setGreeting(String greeting) {
+    this.greeting = greeting;
+    return this;
+  }
+
+  public String getIpAddress() {
+    return ipAddress;
+  }
+
+  public Message setIpAddress(String ipAddress) {
+    this.ipAddress = ipAddress;
+    return this;
+  }
+
+  @Override
+  public String toString() {
+    return new StringJoiner(", ", Message.class.getSimpleName() + "[", "]")
+      .add("date=" + date)
+      .add("greeting='" + greeting + "'")
+      .add("ipAddress='" + ipAddress + "'")
+      .toString();
+  }
+}

webflux-00-controller-approach/src/main/java/c/jbd/webflux/resources/HelloController.java

@@ -0,0 +1,27 @@
+package c.jbd.webflux.resources;
+
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import java.time.Duration;
+
+@RestController
+@RequestMapping("/hello")
+public class HelloController {
+
+  @GetMapping(path = "/mono")
+  public Mono<String> getMono(){
+    return Mono.just("Welcome to JstoBigdata.com");
+  }
+
+  @GetMapping(path = "/flux", produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
+  public Flux<String> getFlux(){
+    Flux<String> msg$ = Flux.just("Welcome ", "to ", "JstoBigdata.com")
+      .delayElements(Duration.ofSeconds(1)).log();
+    return msg$;
+  }
+
+  //@GetMapping
+}

webflux-00-controller-approach/src/main/java/c/jbd/webflux/resources/RestAdvice.java

@@ -0,0 +1,9 @@
+package c.jbd.webflux.resources;
+
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+@RestControllerAdvice
+public class RestAdvice {
+
+}

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

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