{"id":36456,"date":"2023-06-06T08:11:35","date_gmt":"2023-06-05T23:11:35","guid":{"rendered":"https:\/\/m9js.shop\/blog\/?p=36456"},"modified":"2023-06-06T08:11:35","modified_gmt":"2023-06-05T23:11:35","slug":"building-responsive-streams-with-spring-webflux-and-project-reactor","status":"publish","type":"post","link":"https:\/\/m9js.shop\/blog\/development\/building-responsive-streams-with-spring-webflux-and-project-reactor","title":{"rendered":"\uc2a4\ud504\ub9c1 WebFlux\uc640 Project Reactor\ub97c \ud65c\uc6a9\ud55c \ubc18\uc751\ud615 \uc2a4\ud2b8\ub9bc \uad6c\ucd95"},"content":{"rendered":"

\uc2a4\ud504\ub9c1 WebFlux\uc640 Project Reactor\ub780?<\/h1>\n

\"WebFlux\"<\/p>\n

\uc2a4\ud504\ub9c1 \ud504\ub808\uc784\uc6cc\ud06c\ub294 Java \uac1c\ubc1c\uc790\ub4e4\uc774 \uc6f9 \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc744 \uad6c\ucd95\ud558\uace0 \uc2e4\ud589\ud558\uae30 \uc704\ud55c \ub9ce\uc740 \ub3c4\uad6c\ub4e4\uc744 \uc81c\uacf5\ud569\ub2c8\ub2e4. \uadf8 \uc911 \ud558\ub098\uac00 \uc2a4\ud504\ub9c1 WebFlux\uc785\ub2c8\ub2e4. \uc2a4\ud504\ub9c1 WebFlux\ub294 Java 8\uc758 \ud568\uc218\ud615 \ud504\ub85c\uadf8\ub798\ubc0d \uae30\ub2a5\uacfc Reactor \ud504\ub85c\uc81d\ud2b8\uc640 \ud568\uaed8 \uc0ac\uc6a9\ub418\ub294 \ubc18\uc751\ud615 \ud504\ub85c\uadf8\ub798\ubc0d\uc744 \uc0ac\uc6a9\ud558\uc5ec \ube60\ub974\uace0 \ud655\uc7a5 \uac00\ub2a5\ud55c \uc6f9 \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc744 \uad6c\ucd95\ud560 \uc218 \uc788\ub3c4\ub85d \uc9c0\uc6d0\ud569\ub2c8\ub2e4. <\/p>\n

\uc2a4\ud504\ub9c1 WebFlux\ub294 Netty\uc640 Undertow\uc640 \uac19\uc740 \ube44\ub3d9\uae30 \uc11c\ubc84\ub97c \uc0ac\uc6a9\ud558\uba70, Servlet API\uc640\ub294 \ubcc4\uac1c\ub85c \ub3d9\uc791\ud569\ub2c8\ub2e4. \uc774\ub294 \uc2a4\ud504\ub9c1 WebFlux\uac00 \uc11c\ube14\ub9bf \uc2a4\ub808\ub4dc \ud480\uc744 \uc0ac\uc6a9\ud558\uc9c0 \uc54a\uc544\ub3c4 \ub192\uc740 \uc131\ub2a5\uc744 \uc81c\uacf5\ud560 \uc218 \uc788\ub2e4\ub294 \uac83\uc744 \uc758\ubbf8\ud569\ub2c8\ub2e4. <\/p>\n

Project Reactor\ub294 \uc2a4\ud504\ub9c1 WebFlux\uc5d0\uc11c \uc0ac\uc6a9\ub418\ub294 \ubc18\uc751\ud615 \ub77c\uc774\ube0c\ub7ec\ub9ac\uc785\ub2c8\ub2e4. Reactor\ub294 Reactive Streams \uc0ac\uc591\uc744 \uc900\uc218\ud558\uba70, Java 8\uc758 \ud568\uc218\ud615 \ud504\ub85c\uadf8\ub798\ubc0d \uae30\ub2a5\uacfc \ud568\uaed8 \uc0ac\uc6a9\ub418\uc5b4 \ub370\uc774\ud130 \ud750\ub984\uc744 \ucc98\ub9ac\ud558\uace0, \ube44\ub3d9\uae30 \ubc0f \ubc18\uc751\ud615 \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc744 \ube4c\ub4dc\ud560 \uc218 \uc788\ub3c4\ub85d \uc9c0\uc6d0\ud569\ub2c8\ub2e4.<\/p>\n

\ubc18\uc751\ud615 \uc2a4\ud2b8\ub9bc\uc758 \uac1c\ub150\uacfc \uc7a5\uc810<\/h1>\n

\"Reactive<\/p>\n

\ubc18\uc751\ud615 \ud504\ub85c\uadf8\ub798\ubc0d\uc740 \ub370\uc774\ud130 \uc2a4\ud2b8\ub9bc\uc744 \ucc98\ub9ac\ud558\ub294 \ubc29\uc2dd\uc785\ub2c8\ub2e4. \uc774\ub294 \ub370\uc774\ud130\uac00 \uc774\ubca4\ud2b8\ub85c \ubc1c\uc0dd\ud558\ub294 \uacbd\uc6b0\uc5d0 \ud2b9\ud788 \uc720\uc6a9\ud569\ub2c8\ub2e4. \ubc18\uc751\ud615 \uc2a4\ud2b8\ub9bc\uc740 \ub370\uc774\ud130\ub97c \ube44\ub3d9\uae30\uc801\uc73c\ub85c \ucc98\ub9ac\ud558\uba74\uc11c, \ud544\uc694\ud55c \uacbd\uc6b0 \ub370\uc774\ud130 \ucc98\ub9ac\ub97c \uc77c\uc2dc \uc911\uc9c0\ud558\uac70\ub098, \uc0c8\ub85c\uc6b4 \ub370\uc774\ud130\uac00 \uc0dd\uc131\ub420 \ub54c\uae4c\uc9c0 \ub300\uae30\ud558\uace0, \ucc98\ub9ac\ub97c \ub2e4\uc2dc \uc2dc\uc791\ud558\ub294 \ubc29\uc2dd\uc73c\ub85c \ub3d9\uc791\ud569\ub2c8\ub2e4. <\/p>\n

\ubc18\uc751\ud615 \uc2a4\ud2b8\ub9bc\uc744 \uc0ac\uc6a9\ud558\uba74 \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc758 \uc131\ub2a5\uc744 \ud06c\uac8c \ud5a5\uc0c1\uc2dc\ud0ac \uc218 \uc788\uc2b5\ub2c8\ub2e4. \uc774\ub294 \ub370\uc774\ud130\ub97c \ucc98\ub9ac\ud558\ub294 \ub370 \uc18c\uc694\ub418\ub294 \uc2dc\uac04\uc774 \uac10\uc18c\ud558\uace0, \uba54\ubaa8\ub9ac \uc0ac\uc6a9\ub7c9\uc774 \uac10\uc18c\ud558\uae30 \ub54c\ubb38\uc785\ub2c8\ub2e4. \ub610\ud55c, \ubc18\uc751\ud615 \uc2a4\ud2b8\ub9bc\uc740 \ub192\uc740 \ucc98\ub9ac\ub7c9\uacfc \ub0ae\uc740 \uc9c0\uc5f0 \uc2dc\uac04\uc744 \ubcf4\uc7a5\ud558\uba70, \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc758 \ud655\uc7a5\uc131\uc744 \ud5a5\uc0c1\uc2dc\ud0ac \uc218 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n

\uc2a4\ud504\ub9c1 WebFlux\ub97c \uc0ac\uc6a9\ud55c \uad6c\ud604 \ubc29\ubc95<\/h1>\n

\"WebFlux<\/p>\n

\uc2a4\ud504\ub9c1 WebFlux\ub97c \uc0ac\uc6a9\ud558\uc5ec \ubc18\uc751\ud615 \uc2a4\ud2b8\ub9bc\uc744 \uad6c\ud604\ud558\ub294 \ubc29\ubc95\uc740 \uac04\ub2e8\ud569\ub2c8\ub2e4. \uba3c\uc800, \uc2a4\ud504\ub9c1 WebFlux\uc758 Flux<\/code>\uc640 Mono<\/code> \ud0c0\uc785\uc744 \uc0ac\uc6a9\ud558\uc5ec \ub370\uc774\ud130\ub97c \ucc98\ub9ac\ud569\ub2c8\ub2e4. Flux<\/code>\ub294 0\uac1c \uc774\uc0c1\uc758 \ub370\uc774\ud130 \uc2a4\ud2b8\ub9bc\uc744 \ucc98\ub9ac\ud558\uace0, Mono<\/code>\ub294 1\uac1c\uc758 \ub370\uc774\ud130 \uc2a4\ud2b8\ub9bc\uc744 \ucc98\ub9ac\ud569\ub2c8\ub2e4.<\/p>\n

@GetMapping(\"\/api\/articles\")\npublic Flux getArticles() {\n    return articleRepository.findAll();\n}\n\n@GetMapping(\"\/api\/articles\/{id}\")\npublic Mono getArticleById(@PathVariable String id) {\n    return articleRepository.findById(id);\n}\n\n@PostMapping(\"\/api\/articles\")\npublic Mono createArticle(@RequestBody Article article) {\n    return articleRepository.save(article);\n}<\/code><\/pre>\n
\uc704\uc758 \ucf54\ub4dc\ub294 \uc2a4\ud504\ub9c1 WebFlux\ub97c \uc0ac\uc6a9\ud558\uc5ec REST API\ub97c \uad6c\ud604\ud55c \uc608\uc81c\uc785\ub2c8\ub2e4. Flux<\/code>\uc640 Mono<\/code>\ub97c \uc0ac\uc6a9\ud558\uc5ec \ub370\uc774\ud130\ub97c \ucc98\ub9ac\ud558\uace0, GetMapping<\/code>\uacfc PostMapping<\/code>\uc744 \uc0ac\uc6a9\ud558\uc5ec \uc694\uccad\uc744 \ucc98\ub9ac\ud569\ub2c8\ub2e4.<\/p>\n
Project Reactor\ub97c \ud65c\uc6a9\ud55c \ubc18\uc751\ud615 \uc2a4\ud2b8\ub9bc \uc608\uc81c<\/h1>\n
\"Reactor<\/p>\n
Project Reactor\ub97c \uc0ac\uc6a9\ud558\uc5ec \ubc18\uc751\ud615 \uc2a4\ud2b8\ub9bc\uc744 \ucc98\ub9ac\ud558\ub294 \ubc29\ubc95\uc744 \uc0b4\ud3b4\ubcf4\uaca0\uc2b5\ub2c8\ub2e4. \uc544\ub798 \uc608\uc81c\ub294 Project Reactor\uc758 Flux<\/code>\uc640 Mono<\/code> \ud0c0\uc785\uc744 \uc0ac\uc6a9\ud558\uc5ec \ub370\uc774\ud130\ub97c \ucc98\ub9ac\ud558\ub294 \uc608\uc81c\uc785\ub2c8\ub2e4.<\/p>\n
Flux numbers = Flux.range(1, 10);\n\nnumbers.subscribe(System.out::println);\n\nMono message = Mono.just(\"Hello, world!\");\n\nmessage.subscribe(System.out::println);<\/code><\/pre>\n
\uc704\uc758 \ucf54\ub4dc\ub294 Flux<\/code>\uc640 Mono<\/code>\ub97c \uc0ac\uc6a9\ud558\uc5ec \uac01\uac01 1\ubd80\ud130 10\uae4c\uc9c0\uc758 \uc22b\uc790\uc640 "Hello, world!" \uba54\uc2dc\uc9c0\ub97c \ucd9c\ub825\ud558\ub294 \uc608\uc81c\uc785\ub2c8\ub2e4. subscribe<\/code> \uba54\uc11c\ub4dc\ub97c \uc0ac\uc6a9\ud558\uc5ec \ub370\uc774\ud130\ub97c \ucc98\ub9ac\ud569\ub2c8\ub2e4.<\/p>\n
Project Reactor\ub294 map<\/code>, flatMap<\/code>, filter<\/code> \ub4f1\uc758 \uc5f0\uc0b0\uc790\ub97c \uc81c\uacf5\ud569\ub2c8\ub2e4. \uc774\ub97c \uc0ac\uc6a9\ud558\uc5ec \ub370\uc774\ud130\ub97c \ubcc0\uacbd\ud558\uac70\ub098 \ud544\ud130\ub9c1\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n
Flux numbers = Flux.range(1, 10);\n\nnumbers\n    .map(n -> n * 2)\n    .filter(n -> n % 3 == 0)\n    .subscribe(System.out::println);<\/code><\/pre>\n
\uc704\uc758 \ucf54\ub4dc\ub294 map<\/code>\uacfc filter<\/code> \uc5f0\uc0b0\uc790\ub97c \uc0ac\uc6a9\ud558\uc5ec 1\ubd80\ud130 10\uae4c\uc9c0\uc758 \uc22b\uc790 \uc911 3\uc758 \ubc30\uc218\uc778 \uc22b\uc790\ub97c 2\ubc30\ub85c \ub9cc\ub4e0 \ud6c4 \ucd9c\ub825\ud558\ub294 \uc608\uc81c\uc785\ub2c8\ub2e4.<\/p>\n
Project Reactor\ub294 \uc2a4\ub808\ub4dc\ub97c \uc0ac\uc6a9\ud558\uc5ec \ube44\ub3d9\uae30\uc801\uc73c\ub85c \ub370\uc774\ud130\ub97c \ucc98\ub9ac\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4. \uc774\ub97c \uc0ac\uc6a9\ud558\uba74 \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc758 \uc131\ub2a5\uc744 \ud06c\uac8c \ud5a5\uc0c1\uc2dc\ud0ac \uc218 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n
Flux.range(1, 10)\n    .publishOn(Schedulers.newSingle(\"myThread\"))\n    .subscribe(System.out::println);<\/code><\/pre>\n
\uc704\uc758 \ucf54\ub4dc\ub294 publishOn<\/code> \uba54\uc11c\ub4dc\ub97c \uc0ac\uc6a9\ud558\uc5ec \ub370\uc774\ud130\ub97c \ucc98\ub9ac\ud560 \uc2a4\ub808\ub4dc\ub97c \uc9c0\uc815\ud558\ub294 \uc608\uc81c\uc785\ub2c8\ub2e4. Schedulers.newSingle<\/code> \uba54\uc11c\ub4dc\ub97c \uc0ac\uc6a9\ud558\uc5ec \uc0c8\ub85c\uc6b4 \uc2a4\ub808\ub4dc\ub97c \uc0dd\uc131\ud558\uace0, \uc774\ub97c \uc0ac\uc6a9\ud558\uc5ec \ub370\uc774\ud130\ub97c \ucc98\ub9ac\ud569\ub2c8\ub2e4.<\/p>\n
\uacb0\ub860<\/h1>\n
\uc2a4\ud504\ub9c1 WebFlux\uc640 Project Reactor\ub97c \uc0ac\uc6a9\ud558\uc5ec \ubc18\uc751\ud615 \uc2a4\ud2b8\ub9bc\uc744 \uad6c\ucd95\ud558\uba74 \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc758 \uc131\ub2a5\uc744 \ud06c\uac8c \ud5a5\uc0c1\uc2dc\ud0ac \uc218 \uc788\uc2b5\ub2c8\ub2e4. \uc774\ub294 \ub370\uc774\ud130\ub97c \ube44\ub3d9\uae30\uc801\uc73c\ub85c \ucc98\ub9ac\ud558\uace0, \ud544\uc694\ud55c \uacbd\uc6b0 \ub370\uc774\ud130 \ucc98\ub9ac\ub97c \uc77c\uc2dc \uc911\uc9c0\ud558\uac70\ub098, \uc0c8\ub85c\uc6b4 \ub370\uc774\ud130\uac00 \uc0dd\uc131\ub420 \ub54c\uae4c\uc9c0 \ub300\uae30\ud558\uace0, \ucc98\ub9ac\ub97c \ub2e4\uc2dc \uc2dc\uc791\ud558\ub294 \ubc29\uc2dd\uc73c\ub85c \ub3d9\uc791\ud558\uae30 \ub54c\ubb38\uc785\ub2c8\ub2e4. <\/p>\n
\ubc18\uc751\ud615 \ud504\ub85c\uadf8\ub798\ubc0d\uc740 \ub370\uc774\ud130 \uc2a4\ud2b8\ub9bc\uc744 \ucc98\ub9ac\ud558\ub294 \ubc29\uc2dd\uc73c\ub85c, \uc774\ubca4\ud2b8 \uae30\ubc18 \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc5d0\uc11c \ud2b9\ud788 \uc720\uc6a9\ud569\ub2c8\ub2e4. \ubc18\uc751\ud615 \uc2a4\ud2b8\ub9bc\uc740 \ub192\uc740 \ucc98\ub9ac\ub7c9\uacfc \ub0ae\uc740 \uc9c0\uc5f0 \uc2dc\uac04\uc744 \ubcf4\uc7a5\ud558\uba70, \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc758 \ud655\uc7a5\uc131\uc744 \ud5a5\uc0c1\uc2dc\ud0ac \uc218 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n
\uc2a4\ud504\ub9c1 WebFlux\uc640 Project Reactor\ub294 Java 8\uc758 \ud568\uc218\ud615 \ud504\ub85c\uadf8\ub798\ubc0d \uae30\ub2a5\uacfc \ud568\uaed8 \uc0ac\uc6a9\ub418\uc5b4 \ube60\ub974\uace0 \ud655\uc7a5 \uac00\ub2a5\ud55c \uc6f9 \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc744 \uad6c\ucd95\ud560 \uc218 \uc788\ub3c4\ub85d \uc9c0\uc6d0\ud569\ub2c8\ub2e4. \uc774\ub97c \uc0ac\uc6a9\ud558\uc5ec REST API\ub97c \uad6c\ud604\ud558\uac70\ub098, \ub370\uc774\ud130 \ucc98\ub9ac\ub97c \ube44\ub3d9\uae30\uc801\uc73c\ub85c \ucc98\ub9ac\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n","protected":false},"excerpt":{"rendered":"
\uc2a4\ud504\ub9c1 WebFlux\uc640 Project Reactor\ub97c \ud65c\uc6a9\ud55c \ubc18\uc751\ud615 \uc2a4\ud2b8\ub9bc \uad6c\ucd95<\/p>\n","protected":false},"author":1,"featured_media":12882,"comment_status":"closed","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"footnotes":""},"categories":[1957],"tags":[2119,2105,2011,2188,2428,5932,906],"class_list":["post-36456","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-development","tag-api","tag-java","tag-project","tag-public","tag-reactive","tag-spring-boot","tag-world"],"acf":[],"_links":{"self":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts\/36456","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/comments?post=36456"}],"version-history":[{"count":1,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts\/36456\/revisions"}],"predecessor-version":[{"id":36526,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts\/36456\/revisions\/36526"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/media\/12882"}],"wp:attachment":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/media?parent=36456"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/categories?post=36456"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/tags?post=36456"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}