SpringBoo WebFlux+MongoDB實現(xiàn)非阻塞API過程
一、引言
在當(dāng)今高并發(fā)的互聯(lián)網(wǎng)環(huán)境下，傳統(tǒng)的阻塞式編程模型在處理大量請求時往往會遇到性能瓶頸。
響應(yīng)式編程作為一種異步、非阻塞的編程范式，能夠更好地應(yīng)對高并發(fā)場景，提高系統(tǒng)的吞吐量和響應(yīng)性能。
Spring Boot WebFlux 是 Spring 框架提供的響應(yīng)式 Web 編程框架，結(jié)合 MongoDB 這種非關(guān)系型數(shù)據(jù)庫，能夠輕松實現(xiàn)高性能的非阻塞 API。
本文將詳細(xì)介紹如何使用 Spring Boot WebFlux 和 MongoDB 實現(xiàn)非阻塞 API。
二、響應(yīng)式編程基礎(chǔ)
2.1 響應(yīng)式編程概念
響應(yīng)式編程是一種基于異步數(shù)據(jù)流的編程范式，它強調(diào)數(shù)據(jù)的流動和傳播，通過異步和非阻塞的方式處理數(shù)據(jù)流。在響應(yīng)式編程中，數(shù)據(jù)被看作是一個流，任何數(shù)據(jù)的變化都會自動觸發(fā)相應(yīng)的操作。
2.2 響應(yīng)式編程的優(yōu)勢
- 高吞吐量：非阻塞的特性使得系統(tǒng)能夠在等待 I/O 操作完成時處理其他請求，從而提高系統(tǒng)的吞吐量。
- 資源利用率高：減少了線程的阻塞時間，使得線程可以更高效地利用系統(tǒng)資源。
- 更好的可伸縮性：能夠更好地應(yīng)對高并發(fā)場景，隨著請求量的增加，系統(tǒng)可以通過增加資源來實現(xiàn)線性擴展。
2.3 響應(yīng)式編程相關(guān)技術(shù)
Reactor：Spring WebFlux 底層使用的響應(yīng)式庫，提供了 Flux 和 Mono 兩種響應(yīng)式類型。
- Flux：表示 0 到 N 個元素的異步序列。
- Mono：表示 0 或 1 個元素的異步序列。
三、項目搭建
3.1 創(chuàng)建 Spring Boot 項目
可以使用 Spring Initializr（https://start.spring.io/） 來創(chuàng)建一個新的 Spring Boot 項目，選擇以下依賴：
- Spring WebFlux
- Spring Data Reactive MongoDB
3.2 配置 MongoDB
在 application.properties 或 application.yml 中配置 MongoDB 的連接信息，示例如下：
spring.data.mongodb.host=localhost spring.data.mongodb.port=27017 spring.data.mongodb.database=testdb
3.3 項目結(jié)構(gòu)
創(chuàng)建以下目錄結(jié)構(gòu)：
com.example.demo
controller：存放控制器類model：存放數(shù)據(jù)模型類repository：存放數(shù)據(jù)訪問接口service：存放業(yè)務(wù)邏輯類
四、定義數(shù)據(jù)模型
在 model 包下創(chuàng)建一個簡單的實體類，例如 User：
package com.example.demo.model;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
@Document(collection = "users")
public class User {
@Id
private String id;
private String name;
private int age;
public User() {
}
public User(String name, int age) {
this.name = name;
this.age = age;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
}
五、創(chuàng)建數(shù)據(jù)訪問接口
在 repository 包下創(chuàng)建一個繼承自 ReactiveMongoRepository 的接口，用于對 User 實體進行數(shù)據(jù)訪問：
package com.example.demo.repository;
import com.example.demo.model.User;
import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
import reactor.core.publisher.Flux;
public interface UserRepository extends ReactiveMongoRepository<User, String> {
Flux<User> findByAgeGreaterThan(int age);
}
六、實現(xiàn)業(yè)務(wù)邏輯
在 service 包下創(chuàng)建一個服務(wù)類，實現(xiàn)對 User 實體的業(yè)務(wù)邏輯：
package com.example.demo.service;
import com.example.demo.model.User;
import com.example.demo.repository.UserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@Service
public class UserService {
@Autowired
private UserRepository userRepository;
public Mono<User> saveUser(User user) {
return userRepository.save(user);
}
public Flux<User> getAllUsers() {
return userRepository.findAll();
}
public Flux<User> getUsersByAgeGreaterThan(int age) {
return userRepository.findByAgeGreaterThan(age);
}
public Mono<User> getUserById(String id) {
return userRepository.findById(id);
}
public Mono<Void> deleteUser(String id) {
return userRepository.deleteById(id);
}
}
七、創(chuàng)建控制器
在 controller 包下創(chuàng)建一個控制器類，處理 HTTP 請求：
package com.example.demo.controller;
import com.example.demo.model.User;
import com.example.demo.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@RestController
@RequestMapping("/users")
public class UserController {
@Autowired
private UserService userService;
@PostMapping
public Mono<User> saveUser(@RequestBody User user) {
return userService.saveUser(user);
}
@GetMapping(produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public Flux<User> getAllUsers() {
return userService.getAllUsers();
}
@GetMapping("/age/{age}")
public Flux<User> getUsersByAgeGreaterThan(@PathVariable int age) {
return userService.getUsersByAgeGreaterThan(age);
}
@GetMapping("/{id}")
public Mono<User> getUserById(@PathVariable String id) {
return userService.getUserById(id);
}
@DeleteMapping("/{id}")
public Mono<Void> deleteUser(@PathVariable String id) {
return userService.deleteUser(id);
}
}
八、測試非阻塞 API
8.1 啟動應(yīng)用程序
運行 Spring Boot 應(yīng)用程序，確保 MongoDB 服務(wù)也已啟動。
8.2 使用工具測試 API
可以使用 Postman 或 curl 等工具來測試 API：
- 保存用戶：
curl -X POST http://localhost:8080/users -H "Content-Type: application/json" -d '{"name": "John", "age": 25}'
- 獲取所有用戶：
curl http://localhost:8080/users
- 根據(jù)年齡獲取用戶：
curl http://localhost:8080/users/age/20
- 根據(jù) ID 獲取用戶：
curl http://localhost:8080/users/123
- 刪除用戶：
curl -X DELETE http://localhost:8080/users/123
九、總結(jié)
通過本文的介紹，我們學(xué)習(xí)了如何使用 Spring Boot WebFlux 和 MongoDB 實現(xiàn)非阻塞 API。
響應(yīng)式編程的異步、非阻塞特性使得系統(tǒng)能夠更好地應(yīng)對高并發(fā)場景，提高系統(tǒng)的性能和可伸縮性。
在實際開發(fā)中，可以根據(jù)具體需求進一步擴展和優(yōu)化代碼，以滿足不同的業(yè)務(wù)場景。
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
- SpringBoot3中Spring?WebFlux?SSE服務(wù)器發(fā)送事件的實現(xiàn)步驟
- SpringBoot3 Spring WebFlux簡介(推薦)
- SpringBoot深入分析webmvc和webflux的區(qū)別
- springboot webflux 過濾器(使用RouterFunction實現(xiàn))
- SpringBoot之webflux全面解析
- SpringBoot?Webflux創(chuàng)建TCP/UDP?server并使用handler解析數(shù)據(jù)
- 關(guān)于springboot響應(yīng)式編程整合webFlux的問題
- Springboot WebFlux集成Spring Security實現(xiàn)JWT認(rèn)證的示例
- SpringBoot2使用WebFlux函數(shù)式編程的方法
相關(guān)文章
這篇文章主要介紹了eclipse自動提示和自動補全的相關(guān)內(nèi)容，文中向大家分享了二者的實現(xiàn)方法代碼，需要的朋友可以了解下。2017-09-09
這篇文章主要介紹了淺談list.removeAll()刪除失敗的原因及解決方案，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-12-12
Java語言實現(xiàn)簡單FTP軟件 FTP軟件本地窗口實現(xiàn)（5）
這篇文章主要為大家詳細(xì)介紹了Java語言實現(xiàn)簡單FTP軟件，F(xiàn)TP軟件本地窗口的實現(xiàn)方法，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-03-03
Java微信公眾平臺開發(fā)（6） 微信開發(fā)中的token獲取
這篇文章主要為大家詳細(xì)介紹了Java微信公眾平臺開發(fā)第六步，微信開發(fā)中的token獲取，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-04-04
JoinPoint是Spring AOP中獲取方法運行時信息的核心接口,可以獲取方法參數(shù)、類名、方法名、Method對象、注解等,下面就來介紹一下Spring AOP JoinPoint 使用,感興趣的可以了解一下2026-02-02
AQS ( AbstractQueuedSynchronizer)是一個用來構(gòu)建鎖和同步器的框架，使用AQS能簡單且高效地構(gòu)造出應(yīng)用廣泛的大量的同步器，下面小編和大家來一起學(xué)習(xí)一下吧2021-09-09
sharding-jdbc實現(xiàn)分頁查詢的示例代碼
sharding-jdbc是一個輕量級Java框架,它提供了分布式數(shù)據(jù)庫中間件的功能,支持水平分表和分庫分表,在分頁查詢方面,sharding-jdbc支持兩種方式：基于物理分頁和基于邏輯分頁,本文給大家介紹sharding-jdbc如何實現(xiàn)分頁查詢,需要的朋友可以參考下2024-05-05
剖析Java中在Collection集合中使用contains和remove為什么要重寫equals
這篇文章主要介紹了Collection集合的contains和remove方法詳解remove以及相關(guān)的經(jīng)驗技巧，通過簡要的案例,講解了該項技術(shù)的了解與使用,以下就是詳細(xì)內(nèi)容,需要的朋友可以參考下2021-09-09
這篇文章主要介紹了分享Java多線程實現(xiàn)的四種方式，文章基于?Java的相關(guān)資料展開多線程的詳細(xì)介紹，具有一的的參考價值，需要的小伙伴可以參考一下2022-05-05
公共接口,定義了對第三方平臺進行授權(quán)、登錄、撤銷授權(quán)和刷新 token 的操作,本文將詳細(xì)分析Java中的AuthRequest類（附Demo）,文中通過代碼示例介紹的非常詳細(xì),具有一定的參考價值,需要的朋友可以參考下2024-04-04