{"id":33057,"date":"2025-04-26T11:25:27","date_gmt":"2025-04-26T03:25:27","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/33057.html"},"modified":"2025-04-26T11:25:27","modified_gmt":"2025-04-26T03:25:27","slug":"spring-ai-%e4%b8%ad%e5%b8%b8%e8%a7%81%e4%bb%a3%e7%a0%81%e8%a7%a3%e8%af%bb-%e7%94%a8-webflux-%e5%81%9a%e9%ab%98%e5%b9%b6%e5%8f%91%e7%9a%84%e6%9c%8d%e5%8a%a1%e5%99%a8%ef%bc%88%e5%85%a5%e9%97%a84","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/33057.html","title":{"rendered":"spring ai \u4e2d\u5e38\u89c1\u4ee3\u7801\u89e3\u8bfb \u7528 webFlux \u505a\u9ad8\u5e76\u53d1\u7684\u670d\u52a1\u5668\uff08\u5165\u95e84\uff09"},"content":{"rendered":"

\u65e0\u8bba\u662f\u5bf9\u63a5\u7b2c\u4e09\u65b9\u5e73\u53f0\u8981\u6c42\u6211\u4eec\u7684\u63a5\u53e3\u8981\u505a\u5230\u9ad8\u5e76\u53d1\u3001\u8fd8\u662f\u81ea\u5df1\u8981\u6c42\u7684\u9ad8\u5e76\u53d1\u5e73\u53f0，\u90fd\u6709\u54ea\u4e9b\u89e3\u51b3\u65b9\u6848 \u6bd4\u5982\u8981\u6c42\u590d\u6742\u4e1a\u52a1\u903b\u8f91\u7684 200\/\u6bcf\u79d2<\/h2>\n

\u5e38\u7528\u65b9\u6cd5：\u589e\u52a0\u786c\u4ef6\u8d44\u6e90<\/h3>\n

\u6700\u5408\u9002\u7684\u65b9\u6cd5 \u8fd8\u662f\u8981\u5728\u4ee3\u7801\u8d28\u91cf\u4e0a \u600e\u4e48\u80fd\u4fdd\u8bc1\u505a\u5230\u9ad8\u5e76\u53d1\u3002<\/h3>\n

\u4e00：\u5177\u4f53\u600e\u4e48\u505a\u5462\u3002\u90a3\u6211\u4eec\u5c31\u770b\u770b spring \u7684webFlux \u529f\u80fd，\u770b\u770b\u4e0b\u9762\u7684\u4ee3\u7801 \u5b83\u4e3a\u4ec0\u4e48\u5c31\u80fd\u505a\u5230\u9ad8\u5e76\u53d1<\/h3>\n

\/\/ \u83b7\u53d6\u6240\u6709\u7528\u6237（\u8fd4\u56de\u7528\u6237\u5217\u8868\u6d41）<\/span>
\n @GetMapping<\/span>(<\/span>"\/users"<\/span>)<\/span>
\n public<\/span> Flux<\/span><<\/span>User<\/span>><\/span><\/span> getAllUsers<\/span>(<\/span>)<\/span> {<\/span>
\n return<\/span> userRepository.<\/span>findAll<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\u4e8c：webFlux \u5b8c\u6574\u7684\u4f8b\u5b50<\/h3>\n

Spring WebFlux \u901a\u4fd7\u793a\u4f8b（\u4ee5 User \u4e3a\u4f8b）<\/h4>\n

\u7528\u4e00\u4e2a\u7b80\u5355\u7684\u201c\u7528\u6237\u7ba1\u7406\u201d\u573a\u666f，\u89e3\u91ca Spring WebFlux \u7684\u6838\u5fc3\u7528\u6cd5，\u5047\u8bbe\u4f60\u6709\u4e00\u4e2a\u7528\u6237\u4fe1\u606f\u63a5\u53e3\u3002<\/p>\n

\n

\u7b2c\u4e00\u6b65：\u5b9a\u4e49\u7528\u6237\u7c7b（User）<\/h5>\n

public<\/span> class<\/span> User<\/span> {<\/span>
\n private<\/span> String<\/span> id;<\/span>
\n private<\/span> String<\/span> name;<\/span>
\n private<\/span> int<\/span> age;<\/span><\/p>\n

\/\/ \u7701\u7565\u6784\u9020\u65b9\u6cd5\u3001Getter\/Setter<\/span>
\n}<\/span><\/p>\n

\n
\u7b2c\u4e8c\u6b65：\u521b\u5efa\u54cd\u5e94\u5f0f Repository（\u6a21\u62df\u6570\u636e）<\/h5>\n

\u8fd9\u91cc\u7528\u5185\u5b58\u5b58\u50a8\u6a21\u62df\u6570\u636e\u5e93，\u5b9e\u9645\u5f00\u53d1\u4e2d\u53ef\u7528 MongoDB Reactive \u7b49\u771f\u6b63\u7684\u54cd\u5e94\u5f0f\u6570\u636e\u5e93\u3002<\/p>\n

@Repository<\/span>
\npublic<\/span> class<\/span> UserRepository<\/span> {<\/span>
\n \/\/ \u6a21\u62df\u4e00\u4e2a\u7528\u6237\u5217\u8868<\/span>
\n private<\/span> final<\/span> List<\/span><<\/span>User<\/span>><\/span><\/span> users =<\/span> Arrays<\/span>.<\/span>asList<\/span>(<\/span>
\n new<\/span> User<\/span>(<\/span>"1"<\/span>,<\/span> "\u5f20\u4e09"<\/span>,<\/span> 25<\/span>)<\/span>,<\/span>
\n new<\/span> User<\/span>(<\/span>"2"<\/span>,<\/span> "\u674e\u56db"<\/span>,<\/span> 30<\/span>)<\/span>
\n )<\/span>;<\/span><\/p>\n

\/\/ \u6839\u636eID\u67e5\u627e\u7528\u6237（\u8fd4\u56de Mono）<\/span>
\n public<\/span> Mono<\/span><<\/span>User<\/span>><\/span><\/span> findById<\/span>(<\/span>String<\/span> id)<\/span> {<\/span>
\n return<\/span> Mono<\/span>.<\/span>justOrEmpty<\/span>(<\/span>
\n users.<\/span>stream<\/span>(<\/span>)<\/span>
\n .<\/span>filter<\/span>(<\/span>user -><\/span> user.<\/span>getId<\/span>(<\/span>)<\/span>.<\/span>equals<\/span>(<\/span>id)<\/span>)<\/span>
\n .<\/span>findFirst<\/span>(<\/span>)<\/span>
\n )<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u67e5\u627e\u6240\u6709\u7528\u6237（\u8fd4\u56de Flux）<\/span>
\n public<\/span> Flux<\/span><<\/span>User<\/span>><\/span><\/span> findAll<\/span>(<\/span>)<\/span> {<\/span>
\n return<\/span> Flux<\/span>.<\/span>fromIterable<\/span>(<\/span>users)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u6dfb\u52a0\u7528\u6237（\u6a21\u62df\u4fdd\u5b58）<\/span>
\n public<\/span> Mono<\/span><<\/span>User<\/span>><\/span><\/span> save<\/span>(<\/span>User<\/span> user)<\/span> {<\/span>
\n users.<\/span>add<\/span>(<\/span>user)<\/span>;<\/span>
\n return<\/span> Mono<\/span>.<\/span>just<\/span>(<\/span>user)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\n
\u7b2c\u4e09\u6b65：\u7f16\u5199 WebFlux \u63a7\u5236\u5668（\u6ce8\u89e3\u9a71\u52a8）<\/h5>\n

\u4f7f\u7528 @RestController \u548c @GetMapping，\u7c7b\u4f3c Spring MVC，\u4f46\u8fd4\u56de\u7684\u662f Mono \u6216 Flux\u3002<\/p>\n

@RestController<\/span>
\npublic<\/span> class<\/span> UserController<\/span> {<\/span><\/p>\n

@Autowired<\/span>
\n private<\/span> UserRepository<\/span> userRepository;<\/span><\/p>\n

\/\/ \u6839\u636eID\u83b7\u53d6\u7528\u6237（\u8fd4\u56de\u5355\u4e2a\u7528\u6237）<\/span>
\n @GetMapping<\/span>(<\/span>"\/users\/{id}"<\/span>)<\/span>
\n public<\/span> Mono<\/span><<\/span>User<\/span>><\/span><\/span> getUserById<\/span>(<\/span>@PathVariable<\/span> String<\/span> id)<\/span> {<\/span>
\n return<\/span> userRepository.<\/span>findById<\/span>(<\/span>id)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u83b7\u53d6\u6240\u6709\u7528\u6237（\u8fd4\u56de\u7528\u6237\u5217\u8868\u6d41）<\/span>
\n @GetMapping<\/span>(<\/span>"\/users"<\/span>)<\/span>
\n public<\/span> Flux<\/span><<\/span>User<\/span>><\/span><\/span> getAllUsers<\/span>(<\/span>)<\/span> {<\/span>
\n return<\/span> userRepository.<\/span>findAll<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ \u6dfb\u52a0\u7528\u6237（\u63a5\u6536JSON\u8bf7\u6c42\u4f53）<\/span>
\n @PostMapping<\/span>(<\/span>"\/users"<\/span>)<\/span>
\n public<\/span> Mono<\/span><<\/span>User<\/span>><\/span><\/span> addUser<\/span>(<\/span>@RequestBody<\/span> Mono<\/span><<\/span>User<\/span>><\/span><\/span> userMono)<\/span> {<\/span>
\n return<\/span> userMono.<\/span>flatMap<\/span>(<\/span>user -><\/span> userRepository.<\/span>save<\/span>(<\/span>user)<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\n

\u5173\u952e\u70b9\u89e3\u91ca<\/h4>\n
  • \n

    \u4e3a\u4ec0\u4e48\u7528 Mono \u548c Flux？<\/p>\n