Spring Reactive on latest technologies stack (JDK 17, Spring Boot 2.6.0)

In this article, I create a sample use Spring Reactive on latest technologies stack: JDK 17, Gradle 7.3 , IntelliJ IDEA 2021.2.3 Ultimate, Spring Boot 2.6.0 , Spring dependency management 1.0.11.RELEASE . Check environment C:Usersdonhu>gradle -v ------------------------------------------------------------ Gradle 7.3 ------------------------------------------------------------ Build time: 2021-11-09 20:40:36 UTC Revision: 96754b8c44399658178a768ac764d727c2addb37 Kotlin: 1.5.31 Groovy: 3.0.9 Ant: Apache Ant(TM) version

In this article, I create a sample use Spring Reactive on latest technologies stack: JDK 17, Gradle 7.3 , IntelliJ IDEA 2021.2.3 Ultimate, Spring Boot 2.6.0 , Spring dependency management 1.0.11.RELEASE .

Check environment

C:Usersdonhu>gradle -v

------------------------------------------------------------
Gradle 7.3
------------------------------------------------------------

Build time:   2021-11-09 20:40:36 UTC
Revision:     96754b8c44399658178a768ac764d727c2addb37

Kotlin:       1.5.31
Groovy:       3.0.9
Ant:          Apache Ant(TM) version 1.10.11 compiled on July 10 2021
JVM:          17.0.1 (Oracle Corporation 17.0.1+12-LTS-39)
OS:           Windows 10 10.0 amd64

C:Usersdonhu>

JDK

C:Usersdonhu>java --version
java 17.0.1 2021-10-19 LTS
Java(TM) SE Runtime Environment (build 17.0.1+12-LTS-39)
Java HotSpot(TM) 64-Bit Server VM (build 17.0.1+12-LTS-39, mixed mode, sharing)

C:Usersdonhu>javac --version
javac 17.0.1

C:Usersdonhu>

File build.gradle

plugins {
	id 'org.springframework.boot' version '2.6.0'
	id 'io.spring.dependency-management' version '1.0.11.RELEASE'
	id 'java'
}

group = 'com.example'
version = '1.0.0-SNAPSHOT'
sourceCompatibility = '17'
targetCompatibility = '17'

repositories {
	mavenLocal()
	mavenCentral()
}

dependencies {
	implementation 'org.springframework.boot:spring-boot-starter-webflux'
	testImplementation 'org.springframework.boot:spring-boot-starter-test'
	testImplementation 'io.projectreactor:reactor-test'
}

test {
	useJUnitPlatform()
}

File Application.java

packageemployee;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.context.ConfigurableApplicationContext;@SpringBootApplicationpublicclassApplication{publicstaticvoidmain(String[] args){ConfigurableApplicationContext context =SpringApplication.run(Application.class, args);EmployeeClient employeeClient = context.getBean(EmployeeClient.class);System.out.println(">>> Client called: "+ employeeClient.getMessage().block());}}

File application.properties

server.port=8087

File Employee.java

packageemployee;importjava.util.Objects;publicclassEmployee{privateString firstName;privateString lastName;privateString dateOfBirth;publicEmployee(){}publicEmployee(String firstName,String lastName,String dateOfBirth){this.firstName = firstName;this.lastName = lastName;this.dateOfBirth = dateOfBirth;}publicStringgetFirstName(){return firstName;}publicvoidsetFirstName(String firstName){this.firstName = firstName;}publicStringgetLastName(){return lastName;}publicvoidsetLastName(String lastName){this.lastName = lastName;}publicStringgetDateOfBirth(){return dateOfBirth;}publicvoidsetDateOfBirth(String dateOfBirth){this.dateOfBirth = dateOfBirth;}@Overridepublicbooleanequals(Object o){if(this== o)returntrue;if(o ==null||getClass()!= o.getClass())returnfalse;Employee employee =(Employee) o;returnObjects.equals(firstName, employee.firstName)&&Objects.equals(lastName, employee.lastName)&&Objects.equals(dateOfBirth, employee.dateOfBirth);}@OverridepublicinthashCode(){returnObjects.hash(firstName, lastName, dateOfBirth);}}

File EmployeeHandler.java

packageemployee;importorg.springframework.http.MediaType;importorg.springframework.stereotype.Component;importorg.springframework.web.reactive.function.BodyInserters;importorg.springframework.web.reactive.function.server.ServerRequest;importorg.springframework.web.reactive.function.server.ServerResponse;importreactor.core.publisher.Mono;@ComponentpublicclassEmployeeHandler{publicMono<ServerResponse>getInfo(ServerRequest request){returnServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(BodyInserters.fromValue(newEmployee("Vy","Do Nhu","26/08/1987")));}}

File EmployeeRouter.java

packageemployee;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.http.MediaType;importorg.springframework.web.reactive.function.server.RouterFunction;importorg.springframework.web.reactive.function.server.RouterFunctions;importorg.springframework.web.reactive.function.server.ServerResponse;importstaticorg.springframework.web.reactive.function.server.RequestPredicates.GET;importstaticorg.springframework.web.reactive.function.server.RequestPredicates.accept;@Configuration(proxyBeanMethods =false)publicclassEmployeeRouter{@BeanpublicRouterFunction<ServerResponse>route(EmployeeHandler employeeHandler){returnRouterFunctions.route(GET("/employee").and(accept(MediaType.APPLICATION_JSON)), employeeHandler::getInfo);}}

File EmployeeClient.java

packageemployee;importorg.springframework.http.MediaType;importorg.springframework.stereotype.Component;importorg.springframework.web.reactive.function.client.WebClient;importreactor.core.publisher.Mono;@ComponentpublicclassEmployeeClient{privatefinalWebClient client;publicEmployeeClient(WebClient.Builder builder){this.client = builder.baseUrl("http://localhost:8087").build();}publicMono<String>getMessage(){returnthis.client.get().uri("/employee").accept(MediaType.APPLICATION_JSON).retrieve().bodyToMono(Employee.class).map(Employee::toString);}}

Run project

Test RESTful API by Postman

Source code: https://github.com/donhuvy/sample_spring_reactive.git

Nguồn: viblo.asia

Bài viết liên quan

Thay đổi Package Name của Android Studio dể dàng với plugin APR

Nếu bạn đang gặp khó khăn hoặc bế tắc trong việc thay đổi package name trong And

Lỗi không Update Meta_Value Khi thay thế hình ảnh cũ bằng hình ảnh mới trong WordPress

Mã dưới đây hoạt động tốt có 1 lỗi không update được postmeta ” meta_key=

Bài 1 – React Native DevOps các khái niệm và các cài đặt căn bản

Hướng dẫn setup jenkins agent để bắt đầu build mobile bằng jenkins cho devloper an t

Chuyển đổi từ monolith sang microservices qua ví dụ

1. Why microservices? Microservices là kiến trúc hệ thống phần mềm hướng dịch vụ,