{"id":40468,"date":"2022-11-26T07:44:37","date_gmt":"2023-11-10T23:49:08","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/"},"modified":"2024-04-29T02:31:55","modified_gmt":"2024-04-28T18:31:55","slug":"%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/","title":{"rendered":"\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6"},"content":{"rendered":"<h1>\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\uff0c\u4f7f\u7528Server-Sent Events\u3002<\/h1>\n<h2>\u9054\u6210\u7684\u76ee\u6a19<\/h2>\n<p>\u4f7f\u7528Spring WebFlux\u6784\u5efa\u652f\u6301SSE\u7684WEB\u670d\u52a1\u6765\u589e\u8fdb\u7406\u89e3\u3002<\/p>\n<h2>\u5b9e\u73b0<\/h2>\n<p>\u5728\u672c\u5730\u73af\u5883\uff08Ubuntu\uff09\u4e0a\u6784\u5efa\u548c\u542f\u52a8Spring WebFlux\u5e94\u7528\u7a0b\u5e8f\u3002<br \/>\n\u4f7f\u7528curl\u547d\u4ee4\u4eceWeb\u670d\u52a1\u8bbf\u95ee\u5e76\u786e\u8ba4Server-Sent Events\u7684\u529f\u80fd\u3002<\/p>\n<h2>\u6280\u672f\u80cc\u666f<\/h2>\n<h3>\u4ec0\u4e48\u662fSpring WebFlux\uff1f<\/h3>\n<details>\u8fd9\u91cc\u5c55\u793a\u7ed9\u60a8\u3002Spring WebFlux<\/p>\n<p>\u8fd9\u662f\u7528\u4e8e\u5f00\u53d1\u5f02\u6b65\u548c\u53cd\u5e94\u5f0fweb\u5e94\u7528\u7a0b\u5e8f\u7684Spring Framework\u6a21\u5757\u3002<br \/>\nSpring WebFlux\u7684\u4e3b\u8981\u7279\u70b9\u548c\u4f18\u52bf\u5982\u4e0b\uff1a<\/p>\n<p>\u5f02\u6b65\u548c\u53cd\u5e94\u5f0f\u7684\u8bf7\u6c42\u5904\u7406<br \/>\nSpring WebFlux\u4f7f\u7528\u79f0\u4e3a\u54cd\u5e94\u5f0f\u6d41\u7684\u673a\u5236\u6765\u5f02\u6b65\u5904\u7406\u8bf7\u6c42\u3002\u8fd9\u6837\u53ef\u4ee5\u5728\u63d0\u4f9b\u8f83\u5c11\u8d44\u6e90\u7684\u60c5\u51b5\u4e0b\u5b9e\u73b0\u8f83\u9ad8\u7684\u541e\u5410\u91cf\u3002<\/p>\n<p>WebFlux\u670d\u52a1\u5668<br \/>\nSpring WebFlux\u5305\u542b\u4e86\u57fa\u4e8eNetty\u7684WebFlux\u670d\u52a1\u5668\u3002\u8fd9\u4e2a\u670d\u52a1\u5668\u53ef\u4ee5\u5b9e\u73b0\u8f83\u9ad8\u7684\u541e\u5410\u91cf\u548c\u8f83\u4f4e\u7684\u5ef6\u8fdf\u3002<\/p>\n<p>\u652f\u6301Reactive Streams API<br \/>\nSpring WebFlux\u7b26\u5408\u88ab\u79f0\u4e3aReactive Streams API\u7684\u89c4\u8303\uff0c\u53ef\u4ee5\u4e0e\u5176\u4ed6\u4f7f\u7528Reactive Streams API\u7684\u5e93\u8fdb\u884c\u96c6\u6210\u3002\u8fd9\u53ef\u4ee5\u5b9e\u73b0\u66f4\u7075\u6d3b\u3001\u53ef\u6269\u5c55\u7684\u5e94\u7528\u7a0b\u5e8f\u5f00\u53d1\u3002<\/p>\n<\/details>\n<h3>Server-Sent Events (SSE) \u662f\u4ec0\u4e48\uff1f<\/h3>\n<details>\u60a8\u53ef\u4ee5\u5c55\u5f00\u67e5\u770b\u8fd9\u91cc\u3002\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6<\/p>\n<p>\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6\uff08SSE\uff09\u662f\u4e00\u79cd\u4e13\u95e8\u7528\u4e8e\u670d\u52a1\u5668\u5411\u5ba2\u6237\u7aef\u8fdb\u884c\u5355\u5411\u5b9e\u65f6\u901a\u4fe1\u7684\u6280\u672f\uff0c\u670d\u52a1\u5668\u53ef\u4ee5\u5b9e\u65f6\u63a8\u9001\u66f4\u65b0\u4fe1\u606f\u7ed9\u5ba2\u6237\u7aef\u3002\u901a\u8fc7\u7ef4\u6301\u957f\u65f6\u95f4\u8fde\u63a5\uff0c\u5ba2\u6237\u7aef\u53ef\u4ee5\u5b9e\u65f6\u63a5\u6536\u6765\u81ea\u670d\u52a1\u5668\u7684\u66f4\u65b0\u4fe1\u606f\u3002<br \/>\nSSE \u4e3b\u8981\u7528\u4e8e\u9700\u8981\u5b9e\u65f6\u4fe1\u606f\u4f20\u9012\u7684 Web \u5e94\u7528\u7a0b\u5e8f\u3002\u4f8b\u5982\uff0c\u4ee5\u4e0b\u60c5\u51b5\u53ef\u80fd\u4f1a\u4f7f\u7528 SSE\uff1a<\/p>\n<p>\u793e\u4ea4\u5a92\u4f53\u7684\u5b9e\u65f6\u66f4\u65b0<br \/>\n\u5728\u50cf\u793e\u4ea4\u5a92\u4f53\u8fd9\u6837\u7684 Web \u5e94\u7528\u7a0b\u5e8f\u4e2d\uff0c\u9700\u8981\u5b9e\u65f6\u66f4\u65b0\u7528\u6237\u53d1\u5e03\u7684\u65b0\u4fe1\u606f\u4ee5\u53ca\u6240\u5173\u6ce8\u7684\u4eba\u7684\u6d3b\u52a8\u4fe1\u606f\u3002\u4f7f\u7528 SSE\uff0c\u670d\u52a1\u5668\u53ef\u4ee5\u6bcf\u6b21\u63a5\u6536\u5230\u65b0\u4fe1\u606f\u90fd\u5c06\u8be5\u4fe1\u606f\u63a8\u9001\u7ed9\u5ba2\u6237\u7aef\u3002<\/p>\n<p>\u80a1\u7968\u4fe1\u606f\u7684\u5b9e\u65f6\u66f4\u65b0<br \/>\n\u5728\u50cf\u80a1\u7968\u5e02\u573a\u8fd9\u6837\u7684\u884c\u4e1a\u4e2d\uff0c\u9700\u8981\u5b9e\u65f6\u4fe1\u606f\uff0c\u5982\u80a1\u7968\u4ef7\u683c\u7684\u6ce2\u52a8\u3002\u4f7f\u7528 SSE\uff0c\u53ef\u4ee5\u5b9e\u65f6\u4f20\u9012\u80a1\u7968\u4ef7\u683c\u548c\u4ea4\u6613\u66f4\u65b0\u4fe1\u606f\u3002<\/p>\n<p>\u5728\u7ebf\u6e38\u620f\u7684\u5b9e\u65f6\u66f4\u65b0<br \/>\n\u5728\u7ebf\u6e38\u620f\u9700\u8981\u5b9e\u65f6\u4f20\u9012\u73a9\u5bb6\u7684\u884c\u52a8\u548c\u5176\u4ed6\u73a9\u5bb6\u7684\u52a8\u4f5c\u7b49\u5b9e\u65f6\u4fe1\u606f\u3002\u4f7f\u7528 SSE\uff0c\u53ef\u4ee5\u5b9e\u65f6\u4f20\u9012\u4fe1\u606f\u7ed9\u73a9\u5bb6\u3002<br \/>\n\u8fd9\u4e9b\u53ea\u662f\u793a\u4f8b\uff0c\u5728\u9700\u8981\u5b9e\u65f6\u4fe1\u606f\u4f20\u9012\u7684\u5404\u79cd\u7c7b\u578b\u7684 Web \u5e94\u7528\u7a0b\u5e8f\u4e2d\uff0c\u53ef\u80fd\u4f1a\u4f7f\u7528 SSE\u3002<\/p>\n<\/details>\n<h2>\u5f00\u53d1\u73af\u5883<\/h2>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">Windows 11 Home 22H2 \u3092\u4f7f\u7528\u3057\u3066\u3044\u307e\u3059\u3002<\/ul>\n<\/li>\n<\/ul>\n<p>WSL \u306e Ubuntu \u3092\u64cd\u4f5c\u3057\u3066\u3044\u304d\u307e\u3059\u306e\u3067 macOS \u306e\u65b9\u3082\u53c2\u8003\u306b\u3057\u3066\u9802\u3051\u307e\u3059\u3002<\/p>\n<details>WSL\uff08Microsoft Store\u5e94\u7528\u7248\uff09<br \/>\n&gt; wsl &#8211;version<br \/>\nWSL\u7248\u672c\uff1a1.0.3.0<br \/>\n\u5185\u6838\u7248\u672c\uff1a5.15.79.1<br \/>\nWSLg\u7248\u672c\uff1a1.0.47Ubuntu<br \/>\n$ lsb_release -a<br \/>\n\u6ca1\u6709\u53ef\u7528\u7684LSB\u6a21\u5757\u3002<br \/>\n\u53d1\u884c\u5546ID\uff1aUbuntu<br \/>\n\u63cf\u8ff0\uff1aUbuntu 22.04.1 LTS<br \/>\n\u7248\u672c\uff1a22.04<\/p>\n<p>Java JDK \u203b \u6700\u5c0f\u69cb\u6210 Java JDK\u7684\u5b89\u88c5\u548cHello World\uff01<br \/>\n$ java -version<br \/>\nopenjdk\u7248\u672c\u201c11.0.17\u201d2022-10-18<br \/>\nOpenJDK\u8fd0\u884c\u65f6\u73af\u5883\uff08\u6784\u5efa11.0.17+8-post-Ubuntu-1ubuntu222.04\uff09<br \/>\nOpenJDK 64\u4f4d\u670d\u52a1\u5668VM\uff08\u6784\u5efa11.0.17+8-post-Ubuntu-1ubuntu222.04\uff0c\u6df7\u5408\u6a21\u5f0f\uff0c\u5171\u4eab\uff09<\/p>\n<p>Maven \u203b \u6700\u5c0f\u69cb\u6210 Maven\u7684\u5b89\u88c5\u548cHello World\uff01<br \/>\n$ mvn -version<br \/>\nApache Maven 3.6.3<br \/>\nMaven\u4e3b\u76ee\u5f55\uff1a\/usr\/share\/maven<br \/>\nJava\u7248\u672c\uff1a11.0.17\uff0c\u4f9b\u5e94\u5546\uff1aUbuntu\uff0c\u8fd0\u884c\u65f6\uff1a\/usr\/lib\/jvm\/java-11-openjdk-amd64<\/p>\n<\/details>\n<p>\u5728\u8fd9\u7bc7\u6587\u7ae0\u4e2d\uff0c\u4e3b\u8981\u662f\u901a\u8fc7Ubuntu\u7684\u7ec8\u7aef\u8fdb\u884c\u64cd\u4f5c\u3002<\/p>\n<h2>\u521b\u5efaSpring MVC WEB\u670d\u52a1\u65f6\u9700\u8981\u8003\u8651\u7684[\u5e76\u53d1\u5904\u7406]\u3002<\/h2>\n<p>\u203b \u6211\u4eec\u5c06\u4f7f\u7528Spring Boot\u8fdb\u884c\u521b\u5efa\u3002<br \/>\n\u203b \u8fd9\u662f\u4e3a\u4e86\u6bd4\u8f83\u540c\u6b65\u5904\u7406\u548c\u5f02\u6b65\u5904\u7406\u800c\u521b\u5efa\u7684\uff0c\u8bf7\u5ffd\u7565\u4e0d\u9700\u8981\u7684\u90e8\u5206?\u200d\u2642\ufe0f<\/p>\n<details>\u8bf7\u770b\u4e0b\u9762\u7684\u90e8\u7f72\u3002 \u521b\u5efa\u9879\u76ee\u6587\u4ef6\u5939\u3002 \u203b\u5c06 ~\/tmp\/sync-spring-mvc \u4f5c\u4e3a\u9879\u76ee\u6587\u4ef6\u5939\u3002 $ cd ~ $ mkdir -p tmp\/sync-spring-mvc $ cd ~\/tmp\/sync-spring-mvc \u521b\u5efa\u5e94\u7528\u7a0b\u5e8f\u7c7b\u3002 \u203b\u4e3a\u4e86\u7b80\u5316\u7ed3\u6784\uff0c\u5c06\u6240\u6709\u5143\u7d20\u90fd\u5199\u5728\u8fd9\u91cc\u3002 $ mkdir -p src\/main\/java\/com\/example\/springmvc $ vim src\/main\/java\/com\/example\/springmvc\/SpringbootApplication.java \u6587\u4ef6\u5185\u5bb9 SpringbootApplication.java package com.example.springmvc; import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; import lombok.extern.slf4j.Slf4j; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; @Slf4j @RestController @SpringBootApplication public class SpringbootApplication { public static void main(String[] args) { SpringApplication.run(SpringbootApplication.class, args); } @GetMapping(&#8220;\/one&#8221;) public Map&lt;String, String&gt; getOne() throws InterruptedException { Map&lt;String, String&gt; map = Map.of(&#8220;message&#8221;, &#8220;Hello Object!&#8221;); TimeUnit.SECONDS.sleep(2); log.info(&#8220;Sending message: {}&#8221;, map); return map; } @GetMapping(&#8220;\/list&#8221;) public List&lt;Map&lt;String, String&gt;&gt; getList() throws InterruptedException { List&lt;Map&lt;String, String&gt;&gt; list = List.of( Map.of(&#8220;message&#8221;, &#8220;Hello List 1!&#8221;), Map.of(&#8220;message&#8221;, &#8220;Hello List 2!&#8221;), Map.of(&#8220;message&#8221;, &#8220;Hello List 3!&#8221;), Map.of(&#8220;message&#8221;, &#8220;Hello List 4!&#8221;), Map.of(&#8220;message&#8221;, &#8220;Hello List 5!&#8221;)); list.forEach(map -&gt; { try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { log.error(e.getMessage()); throw new RuntimeException(e); } log.info(&#8220;Sending message: {}&#8221;, map); }); return list; } } \u203b\u6bcf\u4e2a\u5904\u7406\u90fd\u8bbe\u7f6e\u4e862\u79d2\u7684\u5ef6\u8fdf\u3002 \u521b\u5efapom.xml $ vim pom.xml \u6587\u4ef6\u5185\u5bb9 pom.xml <!--?xml version=\"1.0\" encoding=\"UTF-8\"?--> 4.0.0 org.springframework.boot spring-boot-starter-parent 2.7.8 <!-- lookup parent from repository --> com.example sync-spring-mvc 1.0 sync-spring-mvc 11 UTF-8 org.springframework.boot spring-boot-starter-webflux <!-- Lombok --> org.projectlombok lombok 1.18.26 provided <!-- Log --> ch.qos.logback logback-core 1.2.6 ch.qos.logback logback-classic 1.2.6 org.slf4j slf4j-api 1.7.30 app org.springframework.boot spring-boot-maven-plugin \u521b\u5efaSpring Boot\u914d\u7f6e\u6587\u4ef6 application.properties \u521b\u5efa\u65e5\u5fd7\u914d\u7f6e\u6587\u4ef6 logback-spring.xml \u203b\u53ef\u4ee5\u53c2\u8003\u4ee5\u524d\u7684\u6587\u7ae0\u521b\u5efa\u4e0a\u8ff0\u4e24\u4e2a\u914d\u7f6e\u6587\u4ef6\u3002 \u8fd0\u884cSpring MVC\u5e94\u7528\u7a0b\u5e8f Java\u5e94\u7528\u7a0b\u5e8f\u6784\u5efa $ mvn clean install \u542f\u52a8Java\u5e94\u7528\u7a0b\u5e8f\uff08\u4f7f\u7528Ctrl + C\u505c\u6b62\uff09 $ mvn spring-boot:run<\/details>\n<h2>\u4f7f\u7528curl\u547d\u4ee4\u6765\u9a8c\u8bc1Spring MVC\u5e94\u7528\u7a0b\u5e8f<\/h2>\n<p>\u203b \u6211\u5c06\u4ece\u53e6\u4e00\u4e2a\u7ec8\u7aef\u786e\u8ba4\u3002<br \/>\n\u203b \u4e3a\u4e86\u65b9\u4fbf\u9605\u8bfb\uff0c\u6211\u5728\u90e8\u5206\u6587\u5b57\u95f4\u52a0\u5165\u4e86\u6362\u884c\u3002<\/p>\n<h3>\u5982\u679c\u83b7\u53d6\u5230\u5bf9\u8c61(Map)<\/h3>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span>curl <span class=\"nt\">-v<\/span> http:\/\/localhost:8080\/one\r\n<span class=\"k\">*<\/span>   Trying 127.0.0.1:8080...\r\n<span class=\"k\">*<\/span> Connected to localhost <span class=\"o\">(<\/span>127.0.0.1<span class=\"o\">)<\/span> port 8080 <span class=\"o\">(<\/span><span class=\"c\">#0)<\/span>\r\n<span class=\"o\">&gt;<\/span> GET \/one HTTP\/1.1\r\n<span class=\"o\">&gt;<\/span> Host: localhost:8080\r\n<span class=\"o\">&gt;<\/span> User-Agent: curl\/7.81.0\r\n<span class=\"o\">&gt;<\/span> Accept: <span class=\"k\">*<\/span>\/<span class=\"k\">*<\/span>\r\n<span class=\"o\">&gt;<\/span>\r\n<span class=\"k\">*<\/span> Mark bundle as not supporting multiuse\r\n&lt; HTTP\/1.1 200\r\n&lt; Content-Type: application\/json\r\n&lt; Transfer-Encoding: chunked\r\n&lt; Date: Tue, 21 Feb 2023 10:52:42 GMT\r\n&lt;\r\n<span class=\"k\">*<\/span> Connection <span class=\"c\">#0 to host localhost left intact<\/span>\r\n<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Object!\"<\/span><span class=\"o\">}<\/span>\r\n<\/code><\/pre>\n<p>\u65e5\u5fd7\u6587\u4ef6<\/p>\n<pre class=\"post-pre\"><code>2023-02-21 19:52:30.673 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>main] org.springframework.boot.web.embedded.tomcat.TomcatWebServer.start:220 - Tomcat started on port<span class=\"o\">(<\/span>s<span class=\"o\">)<\/span>: 8080 <span class=\"o\">(<\/span>http<span class=\"o\">)<\/span> with context path <span class=\"s1\">''<\/span>\r\n2023-02-21 19:52:30.682 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>main] org.springframework.boot.StartupInfoLogger.logStarted:61 - Started SpringbootApplication <span class=\"k\">in <\/span>1.248 seconds <span class=\"o\">(<\/span>JVM running <span class=\"k\">for <\/span>1.459<span class=\"o\">)<\/span>\r\n2023-02-21 19:52:40.319 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>http-nio-8080-exec-1] org.springframework.web.servlet.FrameworkServlet.initServletBean:525 - Initializing Servlet <span class=\"s1\">'dispatcherServlet'<\/span>\r\n2023-02-21 19:52:40.321 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>http-nio-8080-exec-1] org.springframework.web.servlet.FrameworkServlet.initServletBean:547 - Completed initialization <span class=\"k\">in <\/span>1 ms\r\n2023-02-21 19:52:42.338 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>http-nio-8080-exec-1] com.example.springmvc.SpringbootApplication.getOne:26 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Object!<span class=\"o\">}<\/span>\r\n<\/code><\/pre>\n<p>\u53ef\u4ee5\u63a8\u6d4b\u8be5\u7ebf\u7a0b\u540d\u4e3a&#8221;http-nio-8080-exec-1&#8243;\u7684\u7ebf\u7a0b\u662fSpring MVC\u4e2dTomcat\u5904\u7406\u7684\u7ebf\u7a0b\u3002<\/p>\n<h3>\u5982\u679c\u83b7\u53d6\u5230\u4e00\u4e2a\u5217\u8868<\/h3>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span>curl <span class=\"nt\">-v<\/span> http:\/\/localhost:8080\/list\r\n<span class=\"k\">*<\/span>   Trying 127.0.0.1:8080...\r\n<span class=\"k\">*<\/span> Connected to localhost <span class=\"o\">(<\/span>127.0.0.1<span class=\"o\">)<\/span> port 8080 <span class=\"o\">(<\/span><span class=\"c\">#0)<\/span>\r\n<span class=\"o\">&gt;<\/span> GET \/list HTTP\/1.1\r\n<span class=\"o\">&gt;<\/span> Host: localhost:8080\r\n<span class=\"o\">&gt;<\/span> User-Agent: curl\/7.81.0\r\n<span class=\"o\">&gt;<\/span> Accept: <span class=\"k\">*<\/span>\/<span class=\"k\">*<\/span>\r\n<span class=\"o\">&gt;<\/span>\r\n<span class=\"k\">*<\/span> Mark bundle as not supporting multiuse\r\n&lt; HTTP\/1.1 200\r\n&lt; Content-Type: application\/json\r\n&lt; Transfer-Encoding: chunked\r\n&lt; Date: Tue, 21 Feb 2023 10:41:12 GMT\r\n&lt;\r\n<span class=\"k\">*<\/span> Connection <span class=\"c\">#0 to host localhost left intact<\/span>\r\n<span class=\"o\">[{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello List 1!\"<\/span><span class=\"o\">}<\/span>,<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello List 2!\"<\/span><span class=\"o\">}<\/span>,<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello List 3!\"<\/span><span class=\"o\">}<\/span>,<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello List 4!\"<\/span><span class=\"o\">}<\/span>,<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello List 5!\"<\/span><span class=\"o\">}]<\/span>\r\n<\/code><\/pre>\n<p>\u65e5\u5fd7\u6587\u4ef6<\/p>\n<pre class=\"post-pre\"><code>2023-02-21 19:40:50.087 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>main] org.springframework.boot.web.embedded.tomcat.TomcatWebServer.start:220 - Tomcat started on port<span class=\"o\">(<\/span>s<span class=\"o\">)<\/span>: 8080 <span class=\"o\">(<\/span>http<span class=\"o\">)<\/span> with context path <span class=\"s1\">''<\/span>\r\n2023-02-21 19:40:50.095 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>main] org.springframework.boot.StartupInfoLogger.logStarted:61 - Started SpringbootApplication <span class=\"k\">in <\/span>1.194 seconds <span class=\"o\">(<\/span>JVM running <span class=\"k\">for <\/span>1.405<span class=\"o\">)<\/span>\r\n2023-02-21 19:41:02.171 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>http-nio-8080-exec-1] org.springframework.web.servlet.FrameworkServlet.initServletBean:525 - Initializing Servlet <span class=\"s1\">'dispatcherServlet'<\/span>\r\n2023-02-21 19:41:02.174 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>http-nio-8080-exec-1] org.springframework.web.servlet.FrameworkServlet.initServletBean:547 - Completed initialization <span class=\"k\">in <\/span>1 ms\r\n2023-02-21 19:41:04.192 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>http-nio-8080-exec-1] com.example.springmvc.SpringbootApplication.lambda<span class=\"nv\">$0<\/span>:45 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello List 1!<span class=\"o\">}<\/span>\r\n2023-02-21 19:41:06.196 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>http-nio-8080-exec-1] com.example.springmvc.SpringbootApplication.lambda<span class=\"nv\">$0<\/span>:45 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello List 2!<span class=\"o\">}<\/span>\r\n2023-02-21 19:41:08.197 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>http-nio-8080-exec-1] com.example.springmvc.SpringbootApplication.lambda<span class=\"nv\">$0<\/span>:45 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello List 3!<span class=\"o\">}<\/span>\r\n2023-02-21 19:41:10.198 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>http-nio-8080-exec-1] com.example.springmvc.SpringbootApplication.lambda<span class=\"nv\">$0<\/span>:45 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello List 4!<span class=\"o\">}<\/span>\r\n2023-02-21 19:41:12.200 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>http-nio-8080-exec-1] com.example.springmvc.SpringbootApplication.lambda<span class=\"nv\">$0<\/span>:45 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello List 5!<span class=\"o\">}<\/span>\r\n<\/code><\/pre>\n<p>\u53ef\u4ee5\u63a8\u6d4b\u51fa\uff0c\u4ece\u7ebf\u7a0b\u540dhttp-nio-8080-exec-1\u6765\u770b\uff0c\u8be5\u7ebf\u7a0b\u662fSpring MVC\u4e2dTomcat\u5904\u7406\u7684\u7ebf\u7a0b\u3002<br \/>\n\u5047\u8bbe\u6570\u636e\u4f1a\u4ee5\u4e00\u6b21\u83b7\u53d6\u7684\u65b9\u5f0f\u5728\u5ba2\u6237\u7aef(curl)\u7aef\u65f6\u95f4\u7ecf\u8fc7\u4e00\u6bb5\u65f6\u95f4\u540e\u88ab\u83b7\u53d6\u3002<\/p>\n<h2>\u4f7f\u7528Spring WebFlux\u521b\u5efa\u975e\u540c\u6b65\u5904\u7406\u7684WEB\u670d\u52a1<\/h2>\n<p>\u203b \u6211\u4eec\u4f1a\u4f7f\u7528Spring Boot\u6765\u521b\u5efa\u3002<\/p>\n<h3>\u521b\u5efa\u9879\u76ee\u6587\u4ef6\u5939<\/h3>\n<p>\u5047\u8bbe~\/tmp\/async-spring-webflux\u662f\u9879\u76ee\u6587\u4ef6\u5939\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span><span class=\"nb\">cd<\/span> ~\r\n<span class=\"nv\">$ <\/span><span class=\"nb\">mkdir<\/span> <span class=\"nt\">-p<\/span> tmp\/async-spring-webflux\r\n<span class=\"nv\">$ <\/span><span class=\"nb\">cd<\/span> ~\/tmp\/async-spring-webflux\r\n<\/code><\/pre>\n<h3>\u521b\u5efa\u5e94\u7528\u7a0b\u5e8f\u7c7b<\/h3>\n<p>\u203b \u4e3a\u4e86\u7b80\u5316\u6784\u6210\uff0c\u6211\u63cf\u8ff0\u4e86\u6240\u6709\u7684\u8981\u7d20\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span><span class=\"nb\">mkdir<\/span> <span class=\"nt\">-p<\/span> src\/main\/java\/com\/example\/springwebflux\r\n<span class=\"nv\">$ <\/span>vim src\/main\/java\/com\/example\/springwebflux\/SpringbootApplication.java\r\n<\/code><\/pre>\n<p>\u6587\u4ef6\u7684\u5185\u5bb9 de<\/p>\n<pre class=\"post-pre\"><code><span class=\"kn\">package<\/span> <span class=\"nn\">com.example.springwebflux<\/span><span class=\"o\">;<\/span>\r\n\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">java.time.Duration<\/span><span class=\"o\">;<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">java.util.Map<\/span><span class=\"o\">;<\/span>\r\n\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">reactor.core.publisher.Flux<\/span><span class=\"o\">;<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">reactor.core.publisher.Mono<\/span><span class=\"o\">;<\/span>\r\n\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">lombok.extern.slf4j.Slf4j<\/span><span class=\"o\">;<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">org.springframework.boot.SpringApplication<\/span><span class=\"o\">;<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">org.springframework.boot.autoconfigure.SpringBootApplication<\/span><span class=\"o\">;<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">org.springframework.http.codec.ServerSentEvent<\/span><span class=\"o\">;<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">org.springframework.web.bind.annotation.CrossOrigin<\/span><span class=\"o\">;<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">org.springframework.web.bind.annotation.GetMapping<\/span><span class=\"o\">;<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">org.springframework.web.bind.annotation.RestController<\/span><span class=\"o\">;<\/span>\r\n\r\n<span class=\"nd\">@Slf4j<\/span>\r\n<span class=\"nd\">@CrossOrigin<\/span><span class=\"o\">(<\/span><span class=\"n\">origins<\/span> <span class=\"o\">=<\/span> <span class=\"s\">\"*\"<\/span><span class=\"o\">,<\/span> <span class=\"n\">allowedHeaders<\/span> <span class=\"o\">=<\/span> <span class=\"s\">\"*\"<\/span><span class=\"o\">)<\/span>\r\n<span class=\"nd\">@RestController<\/span>\r\n<span class=\"nd\">@SpringBootApplication<\/span>\r\n<span class=\"kd\">public<\/span> <span class=\"kd\">class<\/span> <span class=\"nc\">SpringbootApplication<\/span> <span class=\"o\">{<\/span>\r\n\r\n    <span class=\"kd\">public<\/span> <span class=\"kd\">static<\/span> <span class=\"kt\">void<\/span> <span class=\"nf\">main<\/span><span class=\"o\">(<\/span><span class=\"nc\">String<\/span><span class=\"o\">[]<\/span> <span class=\"n\">args<\/span><span class=\"o\">)<\/span> <span class=\"o\">{<\/span>\r\n        <span class=\"nc\">SpringApplication<\/span><span class=\"o\">.<\/span><span class=\"na\">run<\/span><span class=\"o\">(<\/span><span class=\"nc\">SpringbootApplication<\/span><span class=\"o\">.<\/span><span class=\"na\">class<\/span><span class=\"o\">,<\/span> <span class=\"n\">args<\/span><span class=\"o\">);<\/span>\r\n    <span class=\"o\">}<\/span>\r\n\r\n    <span class=\"nd\">@GetMapping<\/span><span class=\"o\">(<\/span><span class=\"s\">\"\/mono\"<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"kd\">public<\/span> <span class=\"nc\">Mono<\/span><span class=\"o\">&lt;<\/span><span class=\"nc\">Map<\/span><span class=\"o\">&lt;<\/span><span class=\"nc\">String<\/span><span class=\"o\">,<\/span> <span class=\"nc\">String<\/span><span class=\"o\">&gt;&gt;<\/span> <span class=\"nf\">getMono<\/span><span class=\"o\">()<\/span> <span class=\"o\">{<\/span>\r\n        <span class=\"k\">return<\/span> <span class=\"nc\">Mono<\/span><span class=\"o\">.<\/span><span class=\"na\">just<\/span><span class=\"o\">(<\/span>\r\n            <span class=\"nc\">Map<\/span><span class=\"o\">.<\/span><span class=\"na\">of<\/span><span class=\"o\">(<\/span><span class=\"s\">\"message\"<\/span><span class=\"o\">,<\/span> <span class=\"s\">\"Hello Mono!\"<\/span><span class=\"o\">))<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">delayElement<\/span><span class=\"o\">(<\/span><span class=\"nc\">Duration<\/span><span class=\"o\">.<\/span><span class=\"na\">ofSeconds<\/span><span class=\"o\">(<\/span><span class=\"mi\">2<\/span><span class=\"o\">))<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">doOnNext<\/span><span class=\"o\">(<\/span><span class=\"n\">map<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"n\">log<\/span><span class=\"o\">.<\/span><span class=\"na\">info<\/span><span class=\"o\">(<\/span><span class=\"s\">\"Sending message: {}\"<\/span><span class=\"o\">,<\/span> <span class=\"n\">map<\/span><span class=\"o\">));<\/span>\r\n    <span class=\"o\">}<\/span>\r\n\r\n    <span class=\"nd\">@GetMapping<\/span><span class=\"o\">(<\/span><span class=\"s\">\"\/flux\"<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"kd\">public<\/span> <span class=\"nc\">Flux<\/span><span class=\"o\">&lt;<\/span><span class=\"nc\">Map<\/span><span class=\"o\">&lt;<\/span><span class=\"nc\">String<\/span><span class=\"o\">,<\/span> <span class=\"nc\">String<\/span><span class=\"o\">&gt;&gt;<\/span> <span class=\"nf\">getFlux<\/span><span class=\"o\">()<\/span> <span class=\"o\">{<\/span>\r\n        <span class=\"k\">return<\/span> <span class=\"nc\">Flux<\/span><span class=\"o\">.<\/span><span class=\"na\">range<\/span><span class=\"o\">(<\/span><span class=\"mi\">1<\/span><span class=\"o\">,<\/span> <span class=\"mi\">5<\/span><span class=\"o\">)<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">map<\/span><span class=\"o\">(<\/span><span class=\"n\">idx<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"nc\">Map<\/span><span class=\"o\">.<\/span><span class=\"na\">of<\/span><span class=\"o\">(<\/span><span class=\"s\">\"message\"<\/span><span class=\"o\">,<\/span> <span class=\"s\">\"Hello Flux \"<\/span> <span class=\"o\">+<\/span> <span class=\"n\">idx<\/span> <span class=\"o\">+<\/span> <span class=\"s\">\"!\"<\/span><span class=\"o\">))<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">delayElements<\/span><span class=\"o\">(<\/span><span class=\"nc\">Duration<\/span><span class=\"o\">.<\/span><span class=\"na\">ofSeconds<\/span><span class=\"o\">(<\/span><span class=\"mi\">2<\/span><span class=\"o\">))<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">doOnNext<\/span><span class=\"o\">(<\/span><span class=\"n\">map<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"n\">log<\/span><span class=\"o\">.<\/span><span class=\"na\">info<\/span><span class=\"o\">(<\/span><span class=\"s\">\"Sending message: {}\"<\/span><span class=\"o\">,<\/span> <span class=\"n\">map<\/span><span class=\"o\">));<\/span>\r\n    <span class=\"o\">}<\/span>\r\n\r\n    <span class=\"nd\">@GetMapping<\/span><span class=\"o\">(<\/span><span class=\"s\">\"\/flux-sse\"<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"kd\">public<\/span> <span class=\"nc\">Flux<\/span><span class=\"o\">&lt;<\/span><span class=\"nc\">ServerSentEvent<\/span><span class=\"o\">&lt;<\/span><span class=\"nc\">Map<\/span><span class=\"o\">&lt;<\/span><span class=\"nc\">String<\/span><span class=\"o\">,<\/span> <span class=\"nc\">String<\/span><span class=\"o\">&gt;&gt;&gt;<\/span> <span class=\"nf\">getFluxWithSSE<\/span><span class=\"o\">()<\/span> <span class=\"o\">{<\/span>\r\n        <span class=\"k\">return<\/span> <span class=\"nc\">Flux<\/span><span class=\"o\">.<\/span><span class=\"na\">range<\/span><span class=\"o\">(<\/span><span class=\"mi\">1<\/span><span class=\"o\">,<\/span> <span class=\"mi\">5<\/span><span class=\"o\">)<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">map<\/span><span class=\"o\">(<\/span><span class=\"n\">idx<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"nc\">Map<\/span><span class=\"o\">.<\/span><span class=\"na\">of<\/span><span class=\"o\">(<\/span><span class=\"s\">\"message\"<\/span><span class=\"o\">,<\/span> <span class=\"s\">\"Hello Flux \"<\/span> <span class=\"o\">+<\/span> <span class=\"n\">idx<\/span> <span class=\"o\">+<\/span> <span class=\"s\">\"!\"<\/span><span class=\"o\">))<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">delayElements<\/span><span class=\"o\">(<\/span><span class=\"nc\">Duration<\/span><span class=\"o\">.<\/span><span class=\"na\">ofSeconds<\/span><span class=\"o\">(<\/span><span class=\"mi\">2<\/span><span class=\"o\">))<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">doOnNext<\/span><span class=\"o\">(<\/span><span class=\"n\">map<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"n\">log<\/span><span class=\"o\">.<\/span><span class=\"na\">info<\/span><span class=\"o\">(<\/span><span class=\"s\">\"Sending message: {}\"<\/span><span class=\"o\">,<\/span> <span class=\"n\">map<\/span><span class=\"o\">))<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">map<\/span><span class=\"o\">(<\/span><span class=\"n\">map<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"nc\">ServerSentEvent<\/span><span class=\"o\">.<\/span><span class=\"na\">builder<\/span><span class=\"o\">(<\/span><span class=\"n\">map<\/span><span class=\"o\">).<\/span><span class=\"na\">build<\/span><span class=\"o\">())<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">concatWith<\/span><span class=\"o\">(<\/span><span class=\"nc\">Mono<\/span><span class=\"o\">.<\/span><span class=\"na\">just<\/span><span class=\"o\">(<\/span><span class=\"nc\">ServerSentEvent<\/span><span class=\"o\">.&lt;<\/span><span class=\"nc\">Map<\/span><span class=\"o\">&lt;<\/span><span class=\"nc\">String<\/span><span class=\"o\">,<\/span> <span class=\"nc\">String<\/span><span class=\"o\">&gt;&gt;<\/span><span class=\"n\">builder<\/span><span class=\"o\">().<\/span><span class=\"na\">event<\/span><span class=\"o\">(<\/span><span class=\"s\">\"end\"<\/span><span class=\"o\">).<\/span><span class=\"na\">build<\/span><span class=\"o\">()));<\/span>\r\n    <span class=\"o\">}<\/span>\r\n<span class=\"o\">}<\/span>\r\n<\/code><\/pre>\n<p>\u203b \u6bcf\u4e2a\u5904\u7406\u90fd\u8bbe\u7f6e\u4e862\u79d2\u7684\u5ef6\u8fdf\u3002<br \/>\n\u203b \u63d0\u793a\uff1a\u5982\u679c\u4f7f\u7528Spring WebFlux\u5728\u670d\u52a1\u5668\u7aef\u5b9e\u73b0SSE\uff0c\u9700\u8981\u660e\u786e\u5730\u5411\u63a5\u6536\u7aef\u7684\u5ba2\u6237\u7aef\u53d1\u9001 &#8220;event: end&#8221;\u3002<\/p>\n<details>\u8bf4\u660e@GetMapping(&#8220;\/mono&#8221;) \u6ce8\u91ca\u5c06\u63a5\u6536 HTTP GET \u8bf7\u6c42\uff0c\u5e76\u6620\u5c04\u5230 &#8220;\/mono&#8221; \u7aef\u70b9\u3002<\/p>\n<p>Mono&lt;Map&lt;String, String&gt;&gt; \u662f\u8868\u793a\u5355\u4e2a\u5f02\u6b65\u503c\u7684 Reactive Streams \u7c7b\u578b\u3002\u5728\u8fd9\u79cd\u60c5\u51b5\u4e0b\uff0c\u5b83\u8868\u793a\u5355\u4e2a Map \u5bf9\u8c61\u3002<\/p>\n<p>Mono.just(Map.of(&#8220;message&#8221;, &#8220;Hello Mono!&#8221;)) \u521b\u5efa\u4e00\u4e2a\u5177\u6709 &#8220;message&#8221; \u952e\u548c\u5176\u503c\u7684 Map \u5bf9\u8c61\uff0c\u5e76\u5c06\u5176\u5305\u88c5\u5728 Mono \u4e2d\u8fd4\u56de\u3002<\/p>\n<p>.delayElement(Duration.ofSeconds(2)) \u662f\u5c06 Mono \u8f6c\u6362\u4e3a\u5728\u54cd\u5e94\u4e2d\u5ef6\u8fdf 2 \u79d2\u7684\u64cd\u4f5c\u7b26\u3002<\/p>\n<p>.doOnNext(map -&gt; log.info(&#8220;Sending message: {}&#8221;, map)) \u662f\u6dfb\u52a0\u526f\u4f5c\u7528\u4ee5\u5728\u6bcf\u6b21\u503c\u88ab\u901a\u77e5\u65f6\u5c06\u6d88\u606f\u8f93\u51fa\u5230\u65e5\u5fd7\u7684\u64cd\u4f5c\u7b26\u3002<\/p>\n<p>\u56e0\u6b64\uff0c\u8be5\u7aef\u70b9\u5c06\u5728\u7b49\u5f85 2 \u79d2\u540e\u8fd4\u56de\u5305\u542b &#8220;Hello Mono!&#8221; \u6d88\u606f\u7684 Map \u5bf9\u8c61\u4f5c\u4e3a\u5355\u4e2a\u503c\u3002\u7136\u540e\uff0c\u65e5\u5fd7\u5c06\u8f93\u51fa\u7c7b\u4f3c\u4e8e &#8220;Sending message: {message=Hello Mono!}&#8221; \u7684\u6d88\u606f\u3002<\/p>\n<p>\u7ed9\u5ba2\u6237\u7aef\u8fd4\u56de\u591a\u4e2a\u5f02\u6b65\u503c\u54cd\u5e94\u7684\u7aef\u70b9<\/p>\n<p>@GetMapping(&#8220;\/flux&#8221;) \u6ce8\u91ca\u5c06\u63a5\u6536 HTTP GET \u8bf7\u6c42\uff0c\u5e76\u6620\u5c04\u5230 &#8220;\/flux&#8221; \u7aef\u70b9\u3002<\/p>\n<p>Flux&lt;Map&lt;String, String&gt;&gt; \u662f\u8868\u793a\u591a\u4e2a\u5f02\u6b65\u503c\u7684 Reactive Streams \u7c7b\u578b\u3002\u5728\u8fd9\u79cd\u60c5\u51b5\u4e0b\uff0c\u5b83\u8868\u793a\u591a\u4e2a Map \u5bf9\u8c61\u3002<\/p>\n<p>Flux.range(1, 5) \u751f\u6210\u4e00\u4e2a\u5305\u542b\u4ece 1 \u5230 5 \u7684\u6574\u6570\u7684 Flux\u3002<\/p>\n<p>.map(idx -&gt; Map.of(&#8220;message&#8221;, &#8220;Hello Flux &#8221; + idx + &#8220;!&#8221;)) \u662f\u7528\u4e8e\u521b\u5efa\u5305\u542b\u5e26\u6709 &#8220;message&#8221; \u952e\u548c\u5176\u503c\u7684 Map \u5bf9\u8c61\u7684\u64cd\u4f5c\u7b26\u3002<\/p>\n<p>.delayElements(Duration.ofSeconds(2)) \u662f\u4e00\u4e2a\u64cd\u4f5c\u7b26\uff0c\u7528\u4e8e\u5c06\u6bcf\u4e2a\u5143\u7d20\u5ef6\u8fdf 2 \u79d2\u3002<\/p>\n<p>.doOnNext(map -&gt; log.info(&#8220;Sending message: {}&#8221;, map)) \u662f\u6dfb\u52a0\u526f\u4f5c\u7528\u4ee5\u5728\u6bcf\u6b21\u503c\u88ab\u901a\u77e5\u65f6\u5c06\u6d88\u606f\u8f93\u51fa\u5230\u65e5\u5fd7\u7684\u64cd\u4f5c\u7b26\u3002<\/p>\n<p>\u56e0\u6b64\uff0c\u8be5\u7aef\u70b9\u5c06\u8fd4\u56de\u5305\u542b\u4ee5 2 \u79d2\u95f4\u9694\u901a\u77e5\u7684\u5e26\u6709 &#8220;Hello Flux {index}!&#8221; \u6d88\u606f\u7684 Map \u5bf9\u8c61\u7684\u591a\u4e2a\u503c\u3002\u7136\u540e\uff0c\u65e5\u5fd7\u5c06\u8f93\u51fa\u7c7b\u4f3c\u4e8e &#8220;Sending message: {message=Hello Flux {index}!}&#8221; \u7684\u6d88\u606f\u3002<\/p>\n<p>\u4f7f\u7528 Server-Sent Events\uff08SSE\uff09\u534f\u8bae\u5f02\u6b65\u53d1\u9001\u6570\u636e\u7ed9\u5ba2\u6237\u7aef\u7684\u7aef\u70b9<\/p>\n<p>@GetMapping(&#8220;\/flux-sse&#8221;) \u6ce8\u91ca\u5c06\u63a5\u6536 HTTP GET \u8bf7\u6c42\uff0c\u5e76\u6620\u5c04\u5230 &#8220;\/flux-sse&#8221; \u7aef\u70b9\u3002<\/p>\n<p>Flux&lt;ServerSentEvent&lt;Map&lt;String, String&gt;&gt;&gt; \u662f\u8868\u793a\u591a\u4e2a\u5f02\u6b65\u503c\u7684 Reactive Streams \u7c7b\u578b\uff0c\u5e76\u4f7f\u7528 Server-Sent Events \u683c\u5f0f\u3002\u5728\u8fd9\u79cd\u60c5\u51b5\u4e0b\uff0c\u5b83\u8868\u793a\u591a\u4e2a Map \u5bf9\u8c61\u3002<\/p>\n<p>Flux.range(1, 5) \u751f\u6210\u4e00\u4e2a\u5305\u542b\u4ece 1 \u5230 5 \u7684\u6574\u6570\u7684 Flux\u3002<\/p>\n<p>.map(idx -&gt; Map.of(&#8220;message&#8221;, &#8220;Hello Flux &#8221; + idx + &#8220;!&#8221;)) \u662f\u7528\u4e8e\u521b\u5efa\u5305\u542b\u5e26\u6709 &#8220;message&#8221; \u952e\u548c\u5176\u503c\u7684 Map \u5bf9\u8c61\u7684\u64cd\u4f5c\u7b26\u3002<\/p>\n<p>.delayElements(Duration.ofSeconds(2)) \u662f\u4e00\u4e2a\u7528\u4e8e\u5c06\u6bcf\u4e2a\u5143\u7d20\u5ef6\u8fdf 2 \u79d2\u7684\u64cd\u4f5c\u7b26\u3002<\/p>\n<p>.doOnNext(map -&gt; log.info(&#8220;Sending message: {}&#8221;, map)) \u662f\u6dfb\u52a0\u526f\u4f5c\u7528\u4ee5\u5728\u6bcf\u6b21\u503c\u88ab\u901a\u77e5\u65f6\u5c06\u6d88\u606f\u8f93\u51fa\u5230\u65e5\u5fd7\u7684\u64cd\u4f5c\u7b26\u3002<\/p>\n<p>.map(map -&gt; ServerSentEvent.builder(map).build()) \u662f\u7528\u4e8e\u5c06\u6bcf\u4e2a Map \u5bf9\u8c61\u8f6c\u6362\u4e3a ServerSentEvent \u5bf9\u8c61\u7684\u64cd\u4f5c\u7b26\u3002<\/p>\n<p>.concatWith(Mono.just(ServerSentEvent.&lt;Map&lt;String, String&gt;&gt;builder().event(&#8220;end&#8221;).build())) \u662f\u4e00\u4e2a\u64cd\u4f5c\u7b26\uff0c\u7528\u4e8e\u5728\u6d41\u7684\u672b\u5c3e\u6dfb\u52a0\u4e00\u4e2a ServerSentEvent \u5bf9\u8c61\u3002\u8fd9\u6837\u53ef\u4ee5\u53d1\u9001\u4e00\u4e2a\u8868\u793a SSE \u6d41\u7ed3\u675f\u7684 event: end \u6807\u8bb0\u3002<\/p>\n<p>\u56e0\u6b64\uff0c\u8be5\u7aef\u70b9\u5c06\u4ee5 2 \u79d2\u95f4\u9694\u901a\u77e5\u7684\u5e26\u6709 &#8220;Hello Flux {index}!&#8221; \u6d88\u606f\u7684 Map \u5bf9\u8c61\u4f5c\u4e3a\u591a\u4e2a\u503c\uff0c\u4f7f\u7528 Server-Sent Events \u683c\u5f0f\u8fd4\u56de\u3002\u7136\u540e\uff0c\u65e5\u5fd7\u5c06\u8f93\u51fa\u7c7b\u4f3c\u4e8e &#8220;Sending message: {message=Hello Flux {index}!}&#8221; \u7684\u6d88\u606f\u3002<\/p>\n<\/details>\n<h3>\u521b\u5efapom.xml<\/h3>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span>vim pom.xml\r\n<\/code><\/pre>\n<details>\u6587\u4ef6\u5185\u5bb9pom.xml<br \/>\n<!--?xml version=\"1.0\" encoding=\"UTF-8\"?--><br \/>\n4.0.0<br \/>\norg.springframework.boot<br \/>\nspring-boot-starter-parent<br \/>\n2.7.8<br \/>\n<!-- \u4ece\u4ed3\u5e93\u4e2d\u67e5\u627e\u7236\u9879 --><br \/>\ncom.example<br \/>\nsync-spring-webflux<br \/>\n1.0<br \/>\nsync-spring-webflux<\/p>\n<p>11<br \/>\nUTF-8<\/p>\n<p>org.springframework.boot<br \/>\nspring-boot-starter-webflux<\/p>\n<p><!-- Lombok --><\/p>\n<p>org.projectlombok<br \/>\nlombok<br \/>\n1.18.26<br \/>\nprovided<\/p>\n<p><!-- Log --><\/p>\n<p>ch.qos.logback<br \/>\nlogback-core<br \/>\n1.2.6<\/p>\n<p>ch.qos.logback<br \/>\nlogback-classic<br \/>\n1.2.6<\/p>\n<p>org.slf4j<br \/>\nslf4j-api<br \/>\n1.7.30<\/p>\n<p>app<br \/>\norg.springframework.boot<br \/>\nspring-boot-maven-plugin<\/p>\n<\/details>\n<h3>\u521b\u5efaSpring Boot\u914d\u7f6e\u6587\u4ef6<\/h3>\n<ul class=\"post-ul\">application.properties<\/ul>\n<h3>\u521b\u5efa\u65e5\u5fd7\u8bbe\u7f6e\u6587\u4ef6<\/h3>\n<ul class=\"post-ul\">logback-spring.xml<\/ul>\n<p>\u203b \u60a8\u53ef\u4ee5\u53c2\u8003\u4e4b\u524d\u7684\u6587\u7ae0\u6765\u521b\u5efa\u4e0a\u8ff0\u4e24\u4e2a\u8bbe\u7f6e\u6587\u4ef6\u3002<\/p>\n<h3>\u8fd0\u884cSpring WebFlux\u5e94\u7528\u7a0b\u5e8f<\/h3>\n<p>Java \u5e94\u7528\u7a0b\u5e8f\u6784\u5efa<\/p>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span>mvn clean <span class=\"nb\">install<\/span>\r\n<\/code><\/pre>\n<p>\u6309\u4e0bCtrl + C\u5373\u53ef\u505c\u6b62Java\u5e94\u7528\u7a0b\u5e8f\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span>mvn spring-boot:run\r\n<\/code><\/pre>\n<h2>\u7528curl\u547d\u4ee4\u786e\u8ba4Spring WebFlux\u5e94\u7528\u7a0b\u5e8f\u3002<\/h2>\n<p>\u203b \u6211\u4f1a\u4ece\u53e6\u4e00\u4e2a\u7ec8\u7aef\u786e\u8ba4\u3002<br \/>\n\u203b \u4e3a\u4e86\u65b9\u4fbf\u9605\u8bfb\uff0c\u6211\u589e\u52a0\u4e86\u4e00\u4e9b\u6362\u884c\u3002<\/p>\n<h3>\u5982\u679c\u4ee5\u666e\u901a\u7684HTTP\u8bf7\u6c42\u5355\u8272\u8fdb\u884c\u8bf7\u6c42\u7684\u60c5\u51b5\u4e0b<\/h3>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span>curl <span class=\"nt\">-v<\/span> http:\/\/localhost:8080\/mono\r\n<span class=\"k\">*<\/span>   Trying 127.0.0.1:8080...\r\n<span class=\"k\">*<\/span> Connected to localhost <span class=\"o\">(<\/span>127.0.0.1<span class=\"o\">)<\/span> port 8080 <span class=\"o\">(<\/span><span class=\"c\">#0)<\/span>\r\n<span class=\"o\">&gt;<\/span> GET \/mono HTTP\/1.1\r\n<span class=\"o\">&gt;<\/span> Host: localhost:8080\r\n<span class=\"o\">&gt;<\/span> User-Agent: curl\/7.81.0\r\n<span class=\"o\">&gt;<\/span> Accept: <span class=\"k\">*<\/span>\/<span class=\"k\">*<\/span>\r\n<span class=\"o\">&gt;<\/span>\r\n<span class=\"k\">*<\/span> Mark bundle as not supporting multiuse\r\n&lt; HTTP\/1.1 200 OK\r\n&lt; Vary: Origin\r\n&lt; Vary: Access-Control-Request-Method\r\n&lt; Vary: Access-Control-Request-Headers\r\n&lt; Content-Type: application\/json\r\n&lt; Content-Length: 25\r\n&lt;\r\n<span class=\"k\">*<\/span> Connection <span class=\"c\">#0 to host localhost left intact<\/span>\r\n<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Mono!\"<\/span><span class=\"o\">}<\/span>\r\n<\/code><\/pre>\n<p>\u65e5\u5fd7\u6587\u4ef6<\/p>\n<pre class=\"post-pre\"><code>2023-02-21 19:09:36.821 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>main] org.springframework.boot.web.embedded.netty.NettyWebServer.start:111 - Netty started on port 8080\r\n2023-02-21 19:09:36.829 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>main] org.springframework.boot.StartupInfoLogger.logStarted:61 - Started SpringbootApplication <span class=\"k\">in <\/span>1.095 seconds <span class=\"o\">(<\/span>JVM running <span class=\"k\">for <\/span>1.321<span class=\"o\">)<\/span>\r\n2023-02-21 19:09:44.125 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>parallel-1] com.example.springwebflux.SpringbootApplication.lambda<span class=\"nv\">$0<\/span>:46 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Mono!<span class=\"o\">}<\/span>\r\n<\/code><\/pre>\n<p>\u4ece\u7ebf\u7a0b\u540d\u4e3a &#8220;parallel-1&#8221; \u53ef\u4ee5\u63a8\u65ad\u51fa Spring WebFlux \u5728\u5e76\u884c\u5904\u7406\u7ebf\u7a0b\u4e0a\u5904\u7406 Mono\u3002<\/p>\n<h3>\u5982\u679c\u7528\u666e\u901a\u7684HTTP\u8bf7\u6c42Flux<\/h3>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span>curl <span class=\"nt\">-v<\/span> http:\/\/localhost:8080\/flux\r\n<span class=\"k\">*<\/span>   Trying 127.0.0.1:8080...\r\n<span class=\"k\">*<\/span> Connected to localhost <span class=\"o\">(<\/span>127.0.0.1<span class=\"o\">)<\/span> port 8080 <span class=\"o\">(<\/span><span class=\"c\">#0)<\/span>\r\n<span class=\"o\">&gt;<\/span> GET \/flux HTTP\/1.1\r\n<span class=\"o\">&gt;<\/span> Host: localhost:8080\r\n<span class=\"o\">&gt;<\/span> User-Agent: curl\/7.81.0\r\n<span class=\"o\">&gt;<\/span> Accept: <span class=\"k\">*<\/span>\/<span class=\"k\">*<\/span>\r\n<span class=\"o\">&gt;<\/span>\r\n<span class=\"k\">*<\/span> Mark bundle as not supporting multiuse\r\n&lt; HTTP\/1.1 200 OK\r\n&lt; transfer-encoding: chunked\r\n&lt; Vary: Origin\r\n&lt; Vary: Access-Control-Request-Method\r\n&lt; Vary: Access-Control-Request-Headers\r\n&lt; Content-Type: application\/json\r\n&lt;\r\n<span class=\"k\">*<\/span> Connection <span class=\"c\">#0 to host localhost left intact<\/span>\r\n<span class=\"o\">[{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Flux 1!\"<\/span><span class=\"o\">}<\/span>,<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Flux 2!\"<\/span><span class=\"o\">}<\/span>,<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Flux 3!\"<\/span><span class=\"o\">}<\/span>,<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Flux 4!\"<\/span><span class=\"o\">}<\/span>,<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Flux 5!\"<\/span><span class=\"o\">}]<\/span>\r\n<\/code><\/pre>\n<p>\u65e5\u5fd7\u6587\u4ef6<\/p>\n<pre class=\"post-pre\"><code>2023-02-21 18:57:26.755 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>main] org.springframework.boot.web.embedded.netty.NettyWebServer.start:111 - Netty started on port 8080\r\n2023-02-21 18:57:26.763 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>main] org.springframework.boot.StartupInfoLogger.logStarted:61 - Started SpringbootApplication <span class=\"k\">in <\/span>1.092 seconds <span class=\"o\">(<\/span>JVM running <span class=\"k\">for <\/span>1.314<span class=\"o\">)<\/span>\r\n2023-02-21 18:57:39.522 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>parallel-1] com.example.springwebflux.SpringbootApplication.lambda<span class=\"nv\">$1<\/span>:66 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Flux 1!<span class=\"o\">}<\/span>\r\n2023-02-21 18:57:41.527 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>parallel-2] com.example.springwebflux.SpringbootApplication.lambda<span class=\"nv\">$1<\/span>:66 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Flux 2!<span class=\"o\">}<\/span>\r\n2023-02-21 18:57:43.529 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>parallel-3] com.example.springwebflux.SpringbootApplication.lambda<span class=\"nv\">$1<\/span>:66 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Flux 3!<span class=\"o\">}<\/span>\r\n2023-02-21 18:57:45.531 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>parallel-4] com.example.springwebflux.SpringbootApplication.lambda<span class=\"nv\">$1<\/span>:66 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Flux 4!<span class=\"o\">}<\/span>\r\n2023-02-21 18:57:47.533 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>parallel-5] com.example.springwebflux.SpringbootApplication.lambda<span class=\"nv\">$1<\/span>:66 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Flux 5!<span class=\"o\">}<\/span>\r\n<\/code><\/pre>\n<p>\u4ece\u6807\u9898\u4e3a&#8221;parallel-n&#8221;\u7684\u7ebf\u7a0b\u4e2d\u53ef\u4ee5\u63a8\u6d4b\u51fa\uff0cSpring WebFlux\u4f7f\u7528\u5e76\u884c\u5904\u7406\u7ebf\u7a0b\u4ee5\u6bcf2\u79d2\u5904\u7406\u4e00\u6b21Flux\u3002<br \/>\n\u5728\u5ba2\u6237\u7aef(curl)\u7aef\uff0c\u6570\u636e\u5c06\u5728\u4e00\u6bb5\u65f6\u95f4\u540e\u4e00\u6b21\u6027\u83b7\u53d6\u3002<\/p>\n<h3>\u5982\u679c\u4f7f\u7528 Server-Sent Events \u6307\u5b9a\u7684 HTTP \u8bf7\u6c42 Flux<\/h3>\n<p>\u203b \u6dfb\u52a0&#8221;Accept: text\/event-stream&#8221; \u5934\u90e8\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"nv\">$ <\/span>curl <span class=\"nt\">-v<\/span> http:\/\/localhost:8080\/flux-sse <span class=\"nt\">-H<\/span> <span class=\"s1\">'Accept: text\/event-stream'<\/span>\r\n<span class=\"k\">*<\/span>   Trying 127.0.0.1:8080...\r\n<span class=\"k\">*<\/span> Connected to localhost <span class=\"o\">(<\/span>127.0.0.1<span class=\"o\">)<\/span> port 8080 <span class=\"o\">(<\/span><span class=\"c\">#0)<\/span>\r\n<span class=\"o\">&gt;<\/span> GET \/flux-sse HTTP\/1.1\r\n<span class=\"o\">&gt;<\/span> Host: localhost:8080\r\n<span class=\"o\">&gt;<\/span> User-Agent: curl\/7.81.0\r\n<span class=\"o\">&gt;<\/span> Accept: text\/event-stream\r\n<span class=\"o\">&gt;<\/span>\r\n<span class=\"k\">*<\/span> Mark bundle as not supporting multiuse\r\n&lt; HTTP\/1.1 200 OK\r\n&lt; transfer-encoding: chunked\r\n&lt; Vary: Origin\r\n&lt; Vary: Access-Control-Request-Method\r\n&lt; Vary: Access-Control-Request-Headers\r\n&lt; Content-Type: text\/event-stream<span class=\"p\">;<\/span><span class=\"nv\">charset<\/span><span class=\"o\">=<\/span>UTF-8\r\n&lt;\r\ndata:<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Flux 1!\"<\/span><span class=\"o\">}<\/span>\r\n\r\ndata:<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Flux 2!\"<\/span><span class=\"o\">}<\/span>\r\n\r\ndata:<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Flux 3!\"<\/span><span class=\"o\">}<\/span>\r\n\r\ndata:<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Flux 4!\"<\/span><span class=\"o\">}<\/span>\r\n\r\ndata:<span class=\"o\">{<\/span><span class=\"s2\">\"message\"<\/span>:<span class=\"s2\">\"Hello Flux 5!\"<\/span><span class=\"o\">}<\/span>\r\n\r\nevent:end\r\n\r\n<span class=\"k\">*<\/span> Connection <span class=\"c\">#0 to host localhost left intact<\/span>\r\n<\/code><\/pre>\n<p>\u65e5\u5fd7\u6587\u4ef6<\/p>\n<pre class=\"post-pre\"><code>2023-02-21 19:25:11.977 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>main] org.springframework.boot.web.embedded.netty.NettyWebServer.start:111 - Netty started on port 8080\r\n2023-02-21 19:25:11.985 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>main] org.springframework.boot.StartupInfoLogger.logStarted:61 - Started SpringbootApplication <span class=\"k\">in <\/span>1.092 seconds <span class=\"o\">(<\/span>JVM running <span class=\"k\">for <\/span>1.313<span class=\"o\">)<\/span>\r\n2023-02-21 19:25:18.690 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>parallel-1] com.example.springwebflux.SpringbootApplication.lambda<span class=\"nv\">$4<\/span>:112 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Flux 1!<span class=\"o\">}<\/span>\r\n2023-02-21 19:25:20.708 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>parallel-2] com.example.springwebflux.SpringbootApplication.lambda<span class=\"nv\">$4<\/span>:112 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Flux 2!<span class=\"o\">}<\/span>\r\n2023-02-21 19:25:22.712 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>parallel-3] com.example.springwebflux.SpringbootApplication.lambda<span class=\"nv\">$4<\/span>:112 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Flux 3!<span class=\"o\">}<\/span>\r\n2023-02-21 19:25:24.717 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>parallel-4] com.example.springwebflux.SpringbootApplication.lambda<span class=\"nv\">$4<\/span>:112 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Flux 4!<span class=\"o\">}<\/span>\r\n2023-02-21 19:25:26.722 <span class=\"o\">[<\/span>INFO <span class=\"o\">]<\/span> <span class=\"o\">[<\/span>parallel-5] com.example.springwebflux.SpringbootApplication.lambda<span class=\"nv\">$4<\/span>:112 - Sending message: <span class=\"o\">{<\/span><span class=\"nv\">message<\/span><span class=\"o\">=<\/span>Hello Flux 5!<span class=\"o\">}<\/span>\r\n<\/code><\/pre>\n<p>\u203b Spring WebFlux \u4f7f\u7528\u5e76\u884c\u5904\u7406\u7ebf\u7a0b\u6765\u5904\u7406Flux\uff0c\u6bcf2\u79d2\u5904\u7406\u4e00\u6b21\u3002<br \/>\n\u203b \u5ba2\u6237\u7aef(curl)\u4ee5\u5b9e\u65f6\u65b9\u5f0f\u9010\u4e2a\u83b7\u53d6\u6570\u636e\u3002<\/p>\n<h2>\u6982\u62ec<\/h2>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">Spring WebFlux \u3067 Server-Sent Events \u3092\u5b9f\u88c5\u3059\u308b\u521d\u6b69\u7684\u306aWEB\u30b5\u30fc\u30d3\u30b9\u3092\u5b9f\u88c5\u3059\u308b\u3053\u3068\u304c\u51fa\u6765\u307e\u3057\u305f\u3002<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">\u4eca\u5f8c\u3053\u306e Server-Sent Events \u3092\u4f7f\u7528\u3059\u308b\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u5074\u306e\u30a2\u30d7\u30ea\u3092\u5b9f\u88c5\u3057\u3066\u7406\u89e3\u3092\u6df1\u3088\u3046\u3068\u601d\u3044\u307e\u3057\u305f\u3002<\/ul>\n<h2>\u8bf7\u63d0\u4f9b\u9700\u8981\u4fee\u6539\u7684\u539f\u6587\u3002<\/h2>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">W3C Server-Sent Events<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">HTML Living Standard 9.2 Server-sent events<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">MDN \u30b5\u30fc\u30d0\u30fc\u9001\u4fe1\u30a4\u30d9\u30f3\u30c8<\/ul>\n","protected":false},"excerpt":{"rendered":"<p>\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\uff0c\u4f7f\u7528Server-Sent Events\u3002 \u9054\u6210\u7684\u76ee\u6a19 \u4f7f\u7528Sp [&hellip;]<\/p>\n","protected":false},"author":12,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-40468","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"<!-- This site is optimized with the Yoast SEO Premium plugin v21.5 (Yoast SEO v21.5) - https:\/\/yoast.com\/wordpress\/plugins\/seo\/ -->\n<title>\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6 - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u5728spring-webflux-web\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6\u3002\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6\" \/>\n<meta property=\"og:description\" content=\"\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\uff0c\u4f7f\u7528Server-Sent Events\u3002 \u9054\u6210\u7684\u76ee\u6a19 \u4f7f\u7528Sp [&hellip;]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u5728spring-webflux-web\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6\u3002\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-11-10T23:49:08+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-28T18:31:55+00:00\" \/>\n<meta name=\"author\" content=\"\u9038, \u79d1\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u9038, \u79d1\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"9 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/\",\"name\":\"\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6 - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-11-10T23:49:08+00:00\",\"dateModified\":\"2024-04-28T18:31:55+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/85c1dae56e6ea1e695c73d33c684d487\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/85c1dae56e6ea1e695c73d33c684d487\",\"name\":\"\u9038, \u79d1\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/c94f6d9cbbfbca863fab309840bd690c153c95f8490c290ad2ed54dd693dad16?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/c94f6d9cbbfbca863fab309840bd690c153c95f8490c290ad2ed54dd693dad16?s=96&d=mm&r=g\",\"caption\":\"\u9038, \u79d1\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/keyi\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6 - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u5728spring-webflux-web\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6\u3002\/","og_locale":"zh_CN","og_type":"article","og_title":"\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6","og_description":"\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\uff0c\u4f7f\u7528Server-Sent Events\u3002 \u9054\u6210\u7684\u76ee\u6a19 \u4f7f\u7528Sp [&hellip;]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u5728spring-webflux-web\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6\u3002\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-11-10T23:49:08+00:00","article_modified_time":"2024-04-28T18:31:55+00:00","author":"\u9038, \u79d1","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u9038, \u79d1","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"9 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/","name":"\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6 - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-11-10T23:49:08+00:00","dateModified":"2024-04-28T18:31:55+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/85c1dae56e6ea1e695c73d33c684d487"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u5728Spring WebFlux WEB\u670d\u52a1\u4e2d\u4f7f\u7528\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/85c1dae56e6ea1e695c73d33c684d487","name":"\u9038, \u79d1","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/c94f6d9cbbfbca863fab309840bd690c153c95f8490c290ad2ed54dd693dad16?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/c94f6d9cbbfbca863fab309840bd690c153c95f8490c290ad2ed54dd693dad16?s=96&d=mm&r=g","caption":"\u9038, \u79d1"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/keyi\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8f%91%e9%80%81%e4%ba%8b%e4%bb%b6%e3%80%82\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/40468","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/12"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=40468"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/40468\/revisions"}],"predecessor-version":[{"id":75245,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/40468\/revisions\/75245"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=40468"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=40468"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=40468"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}