Spring webflux 函數語言程式設計web框架

摘要： Spring 5.0 Spring webflux 是一個全新的非堵塞的函式式 Reactive Web 框架，可以用來構建非同步的、非堵塞的、事件驅動的服務。 springboot2.0釋出不久，最近研究了一下springboot2.0的新特性,其中就發現了webflux。 下面是spr...

Spring 5.0 Spring webflux 是一個全新的非堵塞的函式式 Reactive Web 框架，可以用來構建非同步的、非堵塞的、事件驅動的服務。 springboot2.0釋出不久，最近研究了一下springboot2.0的新特性,其中就發現了webflux。

下面是spring-flux的一個demo話不多少上程式碼

使用webflux和MVC的區別就是在artifacId後面加上flux

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.0.RELEASE</version>
</parent>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
複製程式碼

@RestController
public class HelloController {
@GetMapping("/hello")
public String hello() {
return "hello world";
}
}
複製程式碼

在webflux中有Handler和Router 的概念，分別與springmvc中的controllerr和equest mapper相對應,通俗的將就是handler就是真正處理請求的bean，可以在handler中編寫處理請求的邏輯，而Router就是如何讓請求找到對應的handler中的方法處理，下面我們來實現一個簡單的handler和router。

@Component
public class HelloWorldHandler {

public Mono<ServerResponse> helloWorld(ServerRequest request){
return ServerResponse.ok()
.contentType(MediaType.TEXT_PLAIN)
.body(BodyInserters.fromObject("hello flux"));
}

}
複製程式碼

上面是一個簡單的handler只相應了一個“hello flux” 字串！

@Configuration
public class RouterConfig {

@Autowired
private HelloWorldHandler helloWorldHandler;

@Bean
public RouterFunction<?> helloRouter() {
return RouterFunctions.route(RequestPredicates.GET("/hello"), helloWorldHandler::helloWorld);
}

}
複製程式碼

上面是對應的router對應的是匹配一個get方式的/hello請求，然後呼叫helloWorldHandler中的helloWorld方法向瀏覽器輸出一個文字型別的字串

再來一個例子

@Component
public class UserHandler {

@Autowired
private ReactiveRedisConnection connection;

public Mono<ServerResponse> getTime(ServerRequest request) {
return ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
.body(Mono.just("Now is " + new SimpleDateFormat("HH:mm:ss").format(new Date())), String.class);
}
public Mono<ServerResponse> getDate(ServerRequest request) {
return ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
.body(Mono.just("Today is " + new SimpleDateFormat("yyyy-MM-dd").format(new Date())), String.class);
}

public Mono<ServerResponse> sendTimePerSec(ServerRequest request) {
return ServerResponse.ok().contentType(MediaType.TEXT_EVENT_STREAM)
.body(Flux.interval(Duration.ofSeconds(1)).map(l -> new SimpleDateFormat("HH:mm:ss").format(new Date())), String.class);
}


public Mono<ServerResponse> register(ServerRequest request) {
Mono<Map> body = request.bodyToMono(Map.class);
return body.flatMap(map -> {
String username = (String) map.get("username");
String password = (String) map.get("password");
String hashedPassword = BCrypt.hashpw(password, BCrypt.gensalt());
return connection.stringCommands()
.set(ByteBuffer.wrap(username.getBytes()), ByteBuffer.wrap(hashedPassword.getBytes()));
}).flatMap(aBoolean -> {
Map<String, String> result = new HashMap<>();
ServerResponse serverResponse = null;
if (aBoolean){
result.put("message", "successful");
return ServerResponse.ok()
.contentType(MediaType.APPLICATION_JSON_UTF8)
.body(BodyInserters.fromObject(result));
}else {
result.put("message", "failed");
return ServerResponse.status(HttpStatus.BAD_REQUEST)
.contentType(MediaType.APPLICATION_JSON_UTF8)
.body(BodyInserters.fromObject(request));
}
});

}

public Mono<ServerResponse> login(ServerRequest request) {
Mono<Map> body = request.bodyToMono(Map.class);
return body.flatMap(map -> {
String username = (String) map.get("username");
String password = (String) map.get("password");
return connection.stringCommands().get(ByteBuffer.wrap(username.getBytes())).flatMap(byteBuffer -> {
byte[] bytes = new byte[byteBuffer.remaining()];
byteBuffer.get(bytes, 0, bytes.length);
String hashedPassword = null;
try {
hashedPassword = new String(bytes, "UTF-8");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
Map<String, String> result = new HashMap<>();
if (hashedPassword == null || !BCrypt.checkpw(password, hashedPassword)) {
result.put("message", "賬號或密碼錯誤");
return ServerResponse.status(HttpStatus.UNAUTHORIZED)
.contentType(MediaType.APPLICATION_JSON_UTF8)
.body(BodyInserters.fromObject(result));
} else {
result.put("token", "無效token");
return ServerResponse.ok()
.contentType(MediaType.APPLICATION_JSON_UTF8)
.body(BodyInserters.fromObject(result));
}
});
});
}


}
複製程式碼

@Configuration
public class RouterConfig {

@Autowired
private HelloWorldHandler helloWorldHandler;

@Bean
public RouterFunction<?> helloRouter() {
return RouterFunctions.route(RequestPredicates.GET("/hello"), helloWorldHandler::helloWorld);
}

@Autowired
private UserHandler userHandler;

@Bean
public RouterFunction<ServerResponse> timerRouter() {
return RouterFunctions.route(RequestPredicates.GET("/time"), userHandler::getTime)
.andRoute(RequestPredicates.GET("/date"), userHandler::getDate);
}

@Bean
public RouterFunction<?> routerFunction() {
return RouterFunctions.route(RequestPredicates.GET("/hello"), helloWorldHandler::helloWorld)
.andRoute(RequestPredicates.POST("/register"), userHandler::register)
.andRoute(RequestPredicates.POST("/login"), userHandler::login)
.andRoute(RequestPredicates.GET("/times"), userHandler::sendTimePerSec);
}

}
複製程式碼