{"id":40397,"date":"2023-06-16T03:46:53","date_gmt":"2023-07-13T04:55:42","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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%e3%80%82\/"},"modified":"2024-04-30T09:05:36","modified_gmt":"2024-04-30T01:05:36","slug":"%e5%9c%a8spring-webflux-web%e6%9c%8d%e5%8a%a1%e4%b8%ad%e4%bd%bf%e7%94%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%e3%80%82\/","title":{"rendered":"\u5728Spring WebFlux Web\u670d\u52a1\u4e2d\u4f7f\u7528Server-Sent Events\u6765\u5b9e\u73b0Hello World"},"content":{"rendered":"

\u5728Spring WebFlux Web\u670d\u52a1\u4e2d\u4f7f\u7528Server-Sent Events\u5b9e\u73b0”Hello World”\u3002<\/h1>\n
\"spring-boot_on_ubuntu.png\"<\/div>\n

\u8fd9\u4e2a\u95ee\u9898\u7684\u76ee\u6807\u662f\u4ec0\u4e48\uff1f<\/h2>\n

\u6211\u5c06\u4f7f\u7528 Windows 11 \u4e0a\u7684 Linux \u8fdb\u884c\u4e91\u5f00\u53d1\u3002<\/p>\n

\u60a8\u53ef\u4ee5\u5728\u8fd9\u91cc\u67e5\u770b\u6587\u7ae0\u7684\u5217\u8868\u3002<\/p>\n

 <\/p>\n

\u5b9e\u73b0<\/h2>\n

\u5728Ubuntu\u64cd\u4f5c\u7cfb\u7edf\u4e0a\uff0c\u9a8c\u8bc1Spring WebFlux\u5e94\u7528\u7a0b\u5e8f\u7684Server-Sent Events\u529f\u80fd\u3002<\/p>\n

\u6280\u672f\u4e3b\u9898<\/h2>\n

\u4ec0\u4e48\u662fSpring WebFlux\uff1f<\/h3>\n
\u60a8\u53ef\u4ee5\u5c55\u5f00\u67e5\u770b\u8fd9\u91cc\u3002Spring WebFlux<\/p>\n

\u8fd9\u662fSpring Framework\u7684\u4e00\u4e2a\u6a21\u5757\uff0c\u7528\u4e8e\u5f00\u53d1\u5f02\u6b65\u548c\u54cd\u5e94\u5f0f\u7684Web\u5e94\u7528\u7a0b\u5e8f\u3002<\/p>\n

\u5173\u952e\u8bcd
\n\u5185\u5bb9<\/p>\n

\u5f02\u6b65\u548c\u54cd\u5e94\u5f0f\u7684\u8bf7\u6c42\u5904\u7406
\nSpring WebFlux\u53ef\u4ee5\u4f7f\u7528\u79f0\u4e3a\u54cd\u5e94\u5f0f\u6d41\u7684\u673a\u5236\u6765\u5f02\u6b65\u5904\u7406\u8bf7\u6c42\u3002\u8fd9\u6837\u53ef\u4ee5\u5728\u8d44\u6e90\u8f83\u5c11\u7684\u60c5\u51b5\u4e0b\u5b9e\u73b0\u9ad8\u541e\u5410\u91cf\u3002<\/p>\n

WebFlux\u670d\u52a1\u5668
\nSpring WebFlux\u5305\u542b\u57fa\u4e8eNetty\u7684WebFlux\u670d\u52a1\u5668\u3002\u8be5\u670d\u52a1\u5668\u53ef\u4ee5\u5b9e\u73b0\u9ad8\u541e\u5410\u91cf\u548c\u4f4e\u5ef6\u8fdf\u3002<\/p>\n

\u652f\u6301Reactive Streams API
\nSpring WebFlux\u7b26\u5408Reactive Streams API\u89c4\u8303\uff0c\u53ef\u4ee5\u4e0e\u5176\u4ed6\u4f7f\u7528Reactive Streams API\u7684\u5e93\u8fdb\u884c\u96c6\u6210\u3002\u8fd9\u6837\u53ef\u4ee5\u5f00\u53d1\u51fa\u66f4\u7075\u6d3b\u548c\u53ef\u6269\u5c55\u7684\u5e94\u7528\u7a0b\u5e8f\u3002<\/p>\n<\/details>\n

\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6 (Server-Sent Events, SSE) \u662f\u4ec0\u4e48\uff1f<\/h3>\n
\u53ef\u4ee5\u5c55\u5f00\u5e76\u67e5\u770b\u6b64\u5904\u3002\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6<\/p>\n

\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
\nSSE\u9002\u7528\u4e8e\u9700\u8981\u5b9e\u65f6\u4fe1\u606f\u4f20\u9012\u7684Web\u5e94\u7528\u7a0b\u5e8f\u3002\u4f8b\u5982\uff0c\u4e0b\u9762\u662f\u4e00\u4e9b\u53ef\u80fd\u4f7f\u7528SSE\u7684\u60c5\u51b5\u7684\u5173\u952e\u8bcd\u4e0e\u5185\u5bb9\u3002<\/p>\n

\u5173\u952e\u8bcd \u5185\u5bb9<\/p>\n

\u793e\u4ea4\u5a92\u4f53\u7684\u5b9e\u65f6\u66f4\u65b0 \u50cf\u793e\u4ea4\u5a92\u4f53\u8fd9\u6837\u7684Web\u5e94\u7528\u7a0b\u5e8f\u9700\u8981\u5b9e\u65f6\u66f4\u65b0\u7528\u6237\u53d1\u5e03\u7684\u65b0\u4fe1\u606f\u3001\u5173\u6ce8\u4eba\u7684\u6d3b\u52a8\u60c5\u51b5\u7b49\u3002\u901a\u8fc7\u4f7f\u7528SSE\uff0c\u670d\u52a1\u5668\u53ef\u4ee5\u5728\u6536\u5230\u65b0\u4fe1\u606f\u65f6\u63a8\u9001\u7ed9\u5ba2\u6237\u7aef\u3002<\/p>\n

\u80a1\u7968\u4fe1\u606f\u7684\u5b9e\u65f6\u66f4\u65b0 \u5728\u50cf\u80a1\u7968\u5e02\u573a\u8fd9\u6837\u7684\u884c\u4e1a\u4e2d\uff0c\u9700\u8981\u5b9e\u65f6\u83b7\u53d6\u80a1\u7968\u4ef7\u683c\u7684\u53d8\u52a8\u7b49\u4fe1\u606f\u3002\u901a\u8fc7\u4f7f\u7528SSE\uff0c\u53ef\u4ee5\u5b9e\u65f6\u63a8\u9001\u80a1\u4ef7\u548c\u4ea4\u6613\u66f4\u65b0\u4fe1\u606f\u3002<\/p>\n

\u5728\u7ebf\u6e38\u620f\u7684\u5b9e\u65f6\u66f4\u65b0 \u5728\u7ebf\u6e38\u620f\u9700\u8981\u5b9e\u65f6\u4f20\u9012\u73a9\u5bb6\u7684\u52a8\u4f5c\u548c\u5176\u4ed6\u73a9\u5bb6\u7684\u884c\u4e3a\u7b49\u5b9e\u65f6\u4fe1\u606f\u3002\u901a\u8fc7\u4f7f\u7528SSE\uff0c\u53ef\u4ee5\u5411\u73a9\u5bb6\u5b9e\u65f6\u4f20\u9012\u4fe1\u606f\u3002<\/p>\n

\u8fd9\u4e9b\u53ea\u662f\u4e00\u4e9b\u4f8b\u5b50\uff0c\u5404\u79cd\u9700\u8981\u5b9e\u65f6\u4fe1\u606f\u4f20\u9012\u7684Web\u5e94\u7528\u7a0b\u5e8f\u4e2d\u90fd\u53ef\u80fd\u4f1a\u4f7f\u7528SSE\u3002<\/p>\n<\/details>\n

\u5f00\u53d1\u73af\u5883<\/h2>\n
    Windows 11 Home 22H2 \u3092\u4f7f\u7528\u3057\u3066\u3044\u307e\u3059\u3002<\/ul>\n
    \u53ef\u4ee5\u53c2\u8003 macOS \u7684\u64cd\u4f5c\u65b9\u5f0f\uff0c\u56e0\u4e3a\u6211\u4f1a\u64cd\u4f5c WSL \u4e2d\u7684 Ubuntu\u3002<\/div>\n
    WSL\uff08Microsoft Store\u5e94\u7528\u7248\uff09\u203b\u60a8\u53ef\u4ee5\u5728\u76f8\u5173\u6587\u7ae0\u4e2d\u67e5\u627e\u5b89\u88c5\u65b9\u6cd5\uff1a
    \n> wsl –version
    \nWSL\u7248\u672c\uff1a1.0.3.0
    \n\u5185\u6838\u7248\u672c\uff1a5.15.79.1
    \nWSLg\u7248\u672c\uff1a1.0.47Ubuntu \u203b\u60a8\u53ef\u4ee5\u5728\u76f8\u5173\u6587\u7ae0\u4e2d\u67e5\u627e\u5b89\u88c5\u65b9\u6cd5\uff1a
    \n$ lsb_release -a
    \n\u6ca1\u6709\u53ef\u7528\u7684LSB\u6a21\u5757\u3002
    \n\u53d1\u884c\u5546ID\uff1aUbuntu
    \n\u63cf\u8ff0\uff1aUbuntu 22.04.1 LTS
    \n\u53d1\u884c\u7248\u672c\uff1a22.04<\/p>\n

    Java JDK \u203b\u60a8\u53ef\u4ee5\u5728\u76f8\u5173\u6587\u7ae0\u4e2d\u67e5\u627e\u5b89\u88c5\u65b9\u6cd5\uff1a
    \n$ java -version
    \nopenjdk version “17.0.6” 2023-01-17
    \nOpenJDK Runtime Environment GraalVM CE 22.3.1\uff08build 17.0.6+10-jvmci-22.3-b13\uff09
    \nOpenJDK 64\u4f4d\u670d\u52a1\u5668VM GraalVM CE 22.3.1\uff08build 17.0.6+10-jvmci-22.3-b13\uff0c\u6df7\u5408\u6a21\u5f0f\uff0c\u5171\u4eab\uff09<\/p>\n

    Maven \u203b\u60a8\u53ef\u4ee5\u5728\u76f8\u5173\u6587\u7ae0\u4e2d\u67e5\u627e\u5b89\u88c5\u65b9\u6cd5\uff1a
    \n$ mvn -version
    \nApache Maven 3.6.3
    \nMaven\u4e3b\u76ee\u5f55\uff1a\/usr\/share\/maven
    \nJava\u7248\u672c\uff1a11.0.18\uff0c\u4f9b\u5e94\u5546\uff1aUbuntu\uff0c\u8fd0\u884c\u65f6\uff1a\/usr\/lib\/jvm\/java-11-openjdk-amd64<\/p>\n<\/details>\n

    \u5728\u9019\u7bc7\u6587\u7ae0\u4e2d\uff0c\u6211\u5011\u57fa\u672c\u4e0a\u662f\u5728 Ubuntu \u7d42\u7aef\u6a5f\u4e2d\u9032\u884c\u64cd\u4f5c\u3002\u70ba\u4e86\u8b93\u521d\u5b78\u8005\u5b78\u7fd2\u4f7f\u7528 Vim \u9032\u884c\u8907\u88fd\u8cbc\u4e0a\uff0c\u6211\u5011\u5728\u4e0b\u9762\u7684\u6587\u7ae0\u4e2d\u4ecb\u7d39\u4e86\u76f8\u95dc\u6b65\u9a5f\u3002\u8acb\u52c7\u65bc\u5617\u8a66\u3002<\/div>\n

     <\/p>\n

    \u521b\u5efaWeb\u5e94\u7528\u7a0b\u5e8f\u7684\u89c4\u683c<\/h2>\n
    \n
    No\u30d5\u30ec\u30fc\u30e0\u30ef\u30fc\u30af\u30a8\u30f3\u30c9\u30dd\u30a4\u30f3\u30c8HTTP\u30e1\u30bd\u30c3\u30c9MIME \u30bf\u30a4\u30d71Spring MVC\/oneGETapplication\/json2Spring MVC\/listGETapplication\/json3Spring WebFlux\/monoGETapplication\/json4Spring WebFlux\/fluxGETapplication\/json5Spring WebFlux\/flux-sseGETtext\/event-stream<\/div>\n<\/div>\n

    \u5e76\u884c\u5904\u7406<\/h2>\n

    \u521b\u5efaSpring MVC Web\u670d\u52a1<\/h3>\n
    \u8fd9\u5c06\u4f7f\u7528Spring Boot\u521b\u5efa\u3002\u5982\u679c\u4e0d\u9700\u8981\u7279\u522b\u6ce8\u610f\uff0c\u53ef\u4ee5\u8df3\u8fc7\u9605\u8bfb\uff0c\u56e0\u4e3a\u6b64\u9879\u76ee\u662f\u4e3a\u4e86\u6bd4\u8f83\u540c\u6b65\u548c\u5f02\u6b65\u5904\u7406\u800c\u521b\u5efa\u7684\u3002<\/div>\n
    \u53ef\u4ee5\u5c55\u5f00\u8fd9\u91cc\u67e5\u770b\u3002\u521b\u5efa\u9879\u76ee\u6587\u4ef6\u5939
    \n\u521b\u5efa\u9879\u76ee\u6587\u4ef6\u5939\u3002
    \n\u203b\u5c06~\/tmp\/sync-spring-mvc\u8bbe\u7f6e\u4e3a\u9879\u76ee\u6587\u4ef6\u5939\u3002
    \n$ mkdir -p ~\/tmp\/sync-spring-mvc
    \n$ cd ~\/tmp\/sync-spring-mvc<\/p>\n

    \u521b\u5efa\u5e94\u7528\u7a0b\u5e8f\u7c7b
    \n\u521b\u5efa\u5e94\u7528\u7a0b\u5e8f\u7c7b\u3002<\/p>\n

    \u4e3a\u4e86\u7b80\u5316\u9879\u76ee\u7ed3\u6784\uff0c\u5c06\u6240\u6709\u5143\u7d20\u90fd\u5199\u5165Application\u7c7b\u3002<\/p>\n

    $ mkdir -p src\/main\/java\/com\/example\/springmvc
    \n$ vim src\/main\/java\/com\/example\/springmvc\/Application.java<\/p>\n

    \u6587\u4ef6\u5185\u5bb9<\/p>\n

    Application.java
    \npackage com.example.springmvc;<\/p>\n

    import java.util.List;
    \nimport java.util.Map;
    \nimport java.util.concurrent.TimeUnit;<\/p>\n

    import lombok.extern.slf4j.Slf4j;
    \nimport org.springframework.boot.SpringApplication;
    \nimport org.springframework.boot.autoconfigure.SpringBootApplication;
    \nimport org.springframework.web.bind.annotation.GetMapping;
    \nimport org.springframework.web.bind.annotation.RestController;<\/p>\n

    @Slf4j
    \n@RestController
    \n@SpringBootApplication
    \npublic class Application {<\/p>\n

    public static void main(String[] args) {
    \nSpringApplication.run(Application.class, args);
    \n}<\/p>\n

    @GetMapping(“\/one”)
    \npublic Map<String, String> getOne() throws InterruptedException {
    \nMap<String, String> map = Map.of(“message”, “Hello Object!”);
    \nTimeUnit.SECONDS.sleep(2);
    \nlog.info(“Sending message: {}”, map);
    \nreturn map;
    \n}<\/p>\n

    @GetMapping(“\/list”)
    \npublic List<Map<String, String>> getList() throws InterruptedException {
    \nList<Map<String, String>> list = List.of(
    \nMap.of(“message”, “Hello List 1!”),
    \nMap.of(“message”, “Hello List 2!”),
    \nMap.of(“message”, “Hello List 3!”),
    \nMap.of(“message”, “Hello List 4!”),
    \nMap.of(“message”, “Hello List 5!”));
    \nlist.forEach(map -> {
    \ntry {
    \nTimeUnit.SECONDS.sleep(2);
    \n} catch (InterruptedException e) {
    \nlog.error(e.getMessage());
    \nthrow new RuntimeException(e);
    \n}
    \nlog.info(“Sending message: {}”, map);
    \n});
    \nreturn list;
    \n}
    \n}<\/p>\n

    \u6bcf\u4e2a\u5904\u7406\u90fd\u8bbe\u7f6e\u4e862\u79d2\u7684\u5ef6\u8fdf\u3002<\/p>\n

    \u521b\u5efapom.xml
    \n\u521b\u5efapom.xml\u6587\u4ef6\u3002
    \n$ vim pom.xml<\/p>\n

    \u6587\u4ef6\u5185\u5bb9<\/p>\n

    pom.xml
    \n
    \n4.0.0
    \norg.springframework.boot
    \nspring-boot-starter-parent
    \n2.7.8
    \n
    \ncom.example
    \nsync-spring-mvc
    \n1.0
    \nsync-spring-mvc<\/p>\n

    11
    \nUTF-8<\/p>\n

    org.springframework.boot
    \nspring-boot-starter-web<\/p>\n

    <\/p>\n

    org.projectlombok
    \nlombok
    \n1.18.26
    \nprovided<\/p>\n

    app
    \norg.springframework.boot
    \nspring-boot-maven-plugin<\/p>\n

    \u914d\u7f6e\u8f93\u51fa\u65e5\u5fd7\u6587\u4ef6<\/p>\n

    application.properties
    \nlogback-spring.xml<\/p>\n

    \u60a8\u53ef\u4ee5\u5728\u4ee5\u4e0b\u76f8\u5173\u6587\u7ae0\u4e2d\u67e5\u770b\u8be6\u7ec6\u6b65\u9aa4\u3002
    \nhttps:\/\/qiita.com\/fsdg-adachi_h\/items\/ffbcb6ac9179852b2816<\/p>\n

    \u6784\u5efa\u5e94\u7528\u7a0b\u5e8f
    \n\u6784\u5efaJava\u5e94\u7528\u7a0b\u5e8f\u3002
    \n\u203b\u5c06\u521b\u5efatarget\/app.jar\u3002
    \n$ mvn clean install<\/p>\n

    \u542f\u52a8\u5e94\u7528\u7a0b\u5e8f
    \n\u542f\u52a8\u5e94\u7528\u7a0b\u5e8f\u3002
    \n\u203b\u6309Ctrl + C\u505c\u6b62\u5e94\u7528\u7a0b\u5e8f\u3002
    \n$ rm -rf log
    \n$ mvn spring-boot:run<\/p>\n<\/details>\n

    \u5e94\u7528\u7a0b\u5e8f\u7684\u529f\u80fd\u9a8c\u8bc1<\/h3>\n

    \u6211\u5011\u53ef\u4ee5\u5f9e\u53e6\u4e00\u500b\u7d42\u7aef\u7a97\u53e3\u4f7f\u7528curl\u547d\u4ee4\u4f86\u9032\u884c\u78ba\u8a8d\u3002<\/p>\n

    \u5982\u679c\u83b7\u53d6\u5230\u4e00\u4e2a\u5bf9\u8c61(Map)\u7684\u60c5\u51b5\u4e0b\u3002<\/h4>\n
    $ <\/span>curl -v<\/span> http:\/\/localhost:8080\/one -w<\/span> '\\n'<\/span>\r\n*<\/span>   Trying 127.0.0.1:8080...\r\n*<\/span> Connected to localhost (<\/span>127.0.0.1)<\/span> port 8080 (<\/span>#0)<\/span>\r\n><\/span> GET \/one HTTP\/1.1\r\n><\/span> Host: localhost:8080\r\n><\/span> User-Agent: curl\/7.81.0\r\n><\/span> Accept: *<\/span>\/*<\/span>\r\n><\/span>\r\n*<\/span> Mark bundle as not supporting multiuse\r\n< HTTP\/1.1 200\r\n< Content-Type: application\/json\r\n< Transfer-Encoding: chunked\r\n< Date: Mon, 20 Mar 2023 03:53:45 GMT\r\n<\r\n*<\/span> Connection #0 to host localhost left intact<\/span>\r\n{<\/span>\"message\"<\/span>:\"Hello Object!\"<\/span>}<\/span>\r\n<\/code><\/pre>\n
    \u6211\u4f1a\u4ece\u4e0d\u540c\u7684\u7ec8\u7aef\u67e5\u770b\u65e5\u5fd7\u6587\u4ef6\u3002\u203b \u8fd9\u91cc\u53ea\u6458\u5f55\u4e86\u5fc5\u8981\u7684\u90e8\u5206\u3002<\/p>\n
    $ <\/span>cd<\/span> ~\/tmp\/sync-spring-mvc\/log\r\n$ <\/span>cat <\/span>app.log\r\n2023-03-20 13:05:32.679 [<\/span>INFO ]<\/span> [<\/span>main] org.springframework.boot.web.embedded.tomcat.TomcatWebServer.start:220 - Tomcat started on port(<\/span>s)<\/span>: 8080 (<\/span>http)<\/span> with context path ''<\/span>\r\n2023-03-20 13:05:32.686 [<\/span>INFO ]<\/span> [<\/span>main] org.springframework.boot.StartupInfoLogger.logStarted:61 - Started Application in <\/span>0.954 seconds (<\/span>JVM running for <\/span>1.11)<\/span>\r\n2023-03-20 13:05:45.910 [<\/span>INFO ]<\/span> [<\/span>http-nio-8080-exec-1] org.springframework.web.servlet.FrameworkServlet.initServletBean:525 - Initializing Servlet 'dispatcherServlet'<\/span>\r\n2023-03-20 13:05:45.913 [<\/span>INFO ]<\/span> [<\/span>http-nio-8080-exec-1] org.springframework.web.servlet.FrameworkServlet.initServletBean:547 - Completed initialization in <\/span>1 ms\r\n2023-03-20 13:05:47.930 [<\/span>INFO ]<\/span> [<\/span>http-nio-8080-exec-1] com.example.springmvc.Application.getOne:26 - Sending message: {<\/span>message<\/span>=<\/span>Hello Object!}<\/span>\r\n<\/code><\/pre>\n
    \u6839\u636e\u7ebf\u7a0b\u540d\u79f0 http-nio-8080-exec-1\uff0c\u53ef\u4ee5\u63a8\u65ad\u51fa\u8be5\u7ebf\u7a0b\u662f\u7531 Spring MVC \u7684 Tomcat \u8fdb\u884c\u5904\u7406\u3002<\/div>\n
    \u5982\u679c\u83b7\u53d6\u5217\u8868<\/h4>\n
    \u6211\u5011\u5c07\u4f7f\u7528curl\u547d\u4ee4\u5f9e\u53e6\u4e00\u500b\u7d42\u7aef\u7a97\u53e3\u9032\u884c\u9a57\u8b49\u3002<\/p>\n
    $ <\/span>curl -v<\/span> http:\/\/localhost:8080\/list -w<\/span> '\\n'<\/span>\r\n*<\/span>   Trying 127.0.0.1:8080...\r\n*<\/span> Connected to localhost (<\/span>127.0.0.1)<\/span> port 8080 (<\/span>#0)<\/span>\r\n><\/span> GET \/list HTTP\/1.1\r\n><\/span> Host: localhost:8080\r\n><\/span> User-Agent: curl\/7.81.0\r\n><\/span> Accept: *<\/span>\/*<\/span>\r\n><\/span>\r\n*<\/span> Mark bundle as not supporting multiuse\r\n< HTTP\/1.1 200\r\n< Content-Type: application\/json\r\n< Transfer-Encoding: chunked\r\n< Date: Mon, 20 Mar 2023 03:56:19 GMT\r\n<\r\n*<\/span> Connection #0 to host localhost left intact<\/span>\r\n[{<\/span>\"message\"<\/span>:\"Hello List 1!\"<\/span>}<\/span>,{<\/span>\"message\"<\/span>:\"Hello List 2!\"<\/span>}<\/span>,{<\/span>\"message\"<\/span>:\"Hello List 3!\"<\/span>}<\/span>,{<\/span>\"message\"<\/span>:\"Hello List 4!\"<\/span>}<\/span>,{<\/span>\"message\"<\/span>:\"Hello List 5!\"<\/span>}]<\/span>\r\n<\/code><\/pre>\n
    \u6211\u4f1a\u4ece\u53e6\u4e00\u4e2a\u7ec8\u7aef\u68c0\u67e5\u65e5\u5fd7\u6587\u4ef6\u3002\u203b\u4ec5\u63d0\u53d6\u5fc5\u8981\u7684\u90e8\u5206\u3002<\/p>\n
    $ <\/span>cd<\/span> ~\/tmp\/sync-spring-mvc\/log\r\n$ <\/span>cat <\/span>app.log\r\n2023-03-20 13:06:34.424 [<\/span>INFO ]<\/span> [<\/span>main] org.springframework.boot.web.embedded.tomcat.TomcatWebServer.start:220 - Tomcat started on port(<\/span>s)<\/span>: 8080 (<\/span>http)<\/span> with context path ''<\/span>\r\n2023-03-20 13:06:34.430 [<\/span>INFO ]<\/span> [<\/span>main] org.springframework.boot.StartupInfoLogger.logStarted:61 - Started Application in <\/span>0.947 seconds (<\/span>JVM running for <\/span>1.102)<\/span>\r\n2023-03-20 13:06:38.337 [<\/span>INFO ]<\/span> [<\/span>http-nio-8080-exec-1] org.springframework.web.servlet.FrameworkServlet.initServletBean:525 - Initializing Servlet 'dispatcherServlet'<\/span>\r\n2023-03-20 13:06:38.340 [<\/span>INFO ]<\/span> [<\/span>http-nio-8080-exec-1] org.springframework.web.servlet.FrameworkServlet.initServletBean:547 - Completed initialization in <\/span>1 ms\r\n2023-03-20 13:06:40.522 [<\/span>INFO ]<\/span> [<\/span>http-nio-8080-exec-1] com.example.springmvc.Application.lambda$getList$0<\/span>:45 - Sending message: {<\/span>message<\/span>=<\/span>Hello List 1!}<\/span>\r\n2023-03-20 13:06:42.691 [<\/span>INFO ]<\/span> [<\/span>http-nio-8080-exec-1] com.example.springmvc.Application.lambda$getList$0<\/span>:45 - Sending message: {<\/span>message<\/span>=<\/span>Hello List 2!}<\/span>\r\n2023-03-20 13:06:44.721 [<\/span>INFO ]<\/span> [<\/span>http-nio-8080-exec-1] com.example.springmvc.Application.lambda$getList$0<\/span>:45 - Sending message: {<\/span>message<\/span>=<\/span>Hello List 3!}<\/span>\r\n2023-03-20 13:06:46.740 [<\/span>INFO ]<\/span> [<\/span>http-nio-8080-exec-1] com.example.springmvc.Application.lambda$getList$0<\/span>:45 - Sending message: {<\/span>message<\/span>=<\/span>Hello List 4!}<\/span>\r\n2023-03-20 13:06:48.748 [<\/span>INFO ]<\/span> [<\/span>http-nio-8080-exec-1] com.example.springmvc.Application.lambda$getList$0<\/span>:45 - Sending message: {<\/span>message<\/span>=<\/span>Hello List 5!}<\/span>\r\n<\/code><\/pre>\n
    \u53ef\u4ee5\u63a8\u6d4b\u51fa\u6839\u636e\u7ebf\u7a0b\u540d\u79f0\u4e3a http-nio-8080-exec-1\uff0c\u8be5\u7ebf\u7a0b\u662f\u7531 Spring MVC \u7684 Tomcat \u8fdb\u884c\u5904\u7406\u7684\u3002\u6570\u636e\u4f1a\u5728\u4e00\u6bb5\u65f6\u95f4\u540e\u4e00\u6b21\u6027\u5730\u4ece\u5ba2\u6237\u7aef\uff08\u4f7f\u7528 curl\uff09\u83b7\u53d6\u3002<\/div>\n
    \u603b\u7ed3\u5230\u8fd9\u91cc<\/h3>\n
    \u5728Spring MVC\u4e2d\uff0c\u6211\u4eec\u4f7f\u7528Tomcat\u4f5c\u4e3a\u5185\u7f6e\u7684Web\u670d\u52a1\u5668\u3002List\u5bf9\u8c61\u6b63\u5728\u540c\u6b65\u5904\u7406\u3002<\/div>\n
    \u5f02\u6b65\u5904\u7406<\/h2>\n
    \u521b\u5efaSpring WebFlux Web\u670d\u52a1<\/h3>\n
    \u7528Spring Boot\u8fdb\u884c\u521b\u5efa\u3002<\/div>\n
    \u521b\u5efa\u9879\u76ee\u6587\u4ef6\u5939<\/h3>\n
    \u521b\u5efa\u9879\u76ee\u6587\u4ef6\u5939\u3002
    \n\u203b \u5c06~\/tmp\/async-spring-webflux\u8bbe\u4e3a\u9879\u76ee\u6587\u4ef6\u5939\u3002<\/p>\n
    $ <\/span>mkdir<\/span> -p<\/span> ~\/tmp\/async-spring-webflux\r\n$ <\/span>cd<\/span> ~\/tmp\/async-spring-webflux\r\n<\/code><\/pre>\n
    \u521b\u5efa\u5e94\u7528\u7a0b\u5e8f\u7c7b<\/h3>\n
    \u521b\u5efa\u4e00\u4e2a\u5e94\u7528\u7a0b\u5e8f\u7c7b\u3002<\/p>\n
    \u4e3a\u4e86\u7b80\u5316\u9879\u76ee\u7ed3\u6784\uff0c\u6211\u4eec\u5c06\u6240\u6709\u5143\u7d20\u90fd\u5199\u5728\u4e86Application\u7c7b\u4e2d\u3002<\/div>\n
    $ <\/span>mkdir<\/span> -p<\/span> src\/main\/java\/com\/example\/springwebflux\r\n$ <\/span>vim src\/main\/java\/com\/example\/springwebflux\/Application.java\r\n<\/code><\/pre>\n
    \u6587\u4ef6\u7684\u5185\u5bb9 de<\/p>\n
    package<\/span> com.example.springwebflux<\/span>;<\/span>\r\n\r\nimport<\/span> java.time.Duration<\/span>;<\/span>\r\nimport<\/span> java.util.Map<\/span>;<\/span>\r\n\r\nimport<\/span> reactor.core.publisher.Flux<\/span>;<\/span>\r\nimport<\/span> reactor.core.publisher.Mono<\/span>;<\/span>\r\n\r\nimport<\/span> lombok.extern.slf4j.Slf4j<\/span>;<\/span>\r\nimport<\/span> org.springframework.boot.SpringApplication<\/span>;<\/span>\r\nimport<\/span> org.springframework.boot.autoconfigure.SpringBootApplication<\/span>;<\/span>\r\nimport<\/span> org.springframework.http.codec.ServerSentEvent<\/span>;<\/span>\r\nimport<\/span> org.springframework.web.bind.annotation.CrossOrigin<\/span>;<\/span>\r\nimport<\/span> org.springframework.web.bind.annotation.GetMapping<\/span>;<\/span>\r\nimport<\/span> org.springframework.web.bind.annotation.RestController<\/span>;<\/span>\r\n\r\n@Slf4j<\/span>\r\n@CrossOrigin<\/span>(<\/span>origins<\/span> =<\/span> \"*\"<\/span>,<\/span> allowedHeaders<\/span> =<\/span> \"*\"<\/span>)<\/span>\r\n@RestController<\/span>\r\n@SpringBootApplication<\/span>\r\npublic<\/span> class<\/span> Application<\/span> {<\/span>\r\n\r\n    public<\/span> static<\/span> void<\/span> main<\/span>(<\/span>String<\/span>[]<\/span> args<\/span>)<\/span> {<\/span>\r\n        SpringApplication<\/span>.<\/span>run<\/span>(<\/span>Application<\/span>.<\/span>class<\/span>,<\/span> args<\/span>);<\/span>\r\n    }<\/span>\r\n\r\n    @GetMapping<\/span>(<\/span>\"\/mono\"<\/span>)<\/span>\r\n    public<\/span> Mono<\/span><<\/span>Map<\/span><<\/span>String<\/span>,<\/span> String<\/span>>><\/span> getMono<\/span>()<\/span> {<\/span>\r\n        return<\/span> Mono<\/span>.<\/span>just<\/span>(<\/span>\r\n            Map<\/span>.<\/span>of<\/span>(<\/span>\"message\"<\/span>,<\/span> \"Hello Mono!\"<\/span>))<\/span>\r\n            .<\/span>delayElement<\/span>(<\/span>Duration<\/span>.<\/span>ofSeconds<\/span>(<\/span>2<\/span>))<\/span>\r\n            .<\/span>doOnNext<\/span>(<\/span>map<\/span> -><\/span> log<\/span>.<\/span>info<\/span>(<\/span>\"Sending message: {}\"<\/span>,<\/span> map<\/span>));<\/span>\r\n    }<\/span>\r\n\r\n    @GetMapping<\/span>(<\/span>\"\/flux\"<\/span>)<\/span>\r\n    public<\/span> Flux<\/span><<\/span>Map<\/span><<\/span>String<\/span>,<\/span> String<\/span>>><\/span> getFlux<\/span>()<\/span> {<\/span>\r\n        return<\/span> Flux<\/span>.<\/span>range<\/span>(<\/span>1<\/span>,<\/span> 5<\/span>)<\/span>\r\n            .<\/span>map<\/span>(<\/span>idx<\/span> -><\/span> Map<\/span>.<\/span>of<\/span>(<\/span>\"message\"<\/span>,<\/span> \"Hello Flux \"<\/span> +<\/span> idx<\/span> +<\/span> \"!\"<\/span>))<\/span>\r\n            .<\/span>delayElements<\/span>(<\/span>Duration<\/span>.<\/span>ofSeconds<\/span>(<\/span>2<\/span>))<\/span>\r\n            .<\/span>doOnNext<\/span>(<\/span>map<\/span> -><\/span> log<\/span>.<\/span>info<\/span>(<\/span>\"Sending message: {}\"<\/span>,<\/span> map<\/span>));<\/span>\r\n    }<\/span>\r\n\r\n    @GetMapping<\/span>(<\/span>\"\/flux-sse\"<\/span>)<\/span>\r\n    public<\/span> Flux<\/span><<\/span>ServerSentEvent<\/span><<\/span>Map<\/span><<\/span>String<\/span>,<\/span> String<\/span>>>><\/span> getFluxWithSSE<\/span>()<\/span> {<\/span>\r\n        return<\/span> Flux<\/span>.<\/span>range<\/span>(<\/span>1<\/span>,<\/span> 5<\/span>)<\/span>\r\n            .<\/span>map<\/span>(<\/span>idx<\/span> -><\/span> Map<\/span>.<\/span>of<\/span>(<\/span>\"message\"<\/span>,<\/span> \"Hello Flux \"<\/span> +<\/span> idx<\/span> +<\/span> \"!\"<\/span>))<\/span>\r\n            .<\/span>delayElements<\/span>(<\/span>Duration<\/span>.<\/span>ofSeconds<\/span>(<\/span>2<\/span>))<\/span>\r\n            .<\/span>doOnNext<\/span>(<\/span>map<\/span> -><\/span> log<\/span>.<\/span>info<\/span>(<\/span>\"Sending message: {}\"<\/span>,<\/span> map<\/span>))<\/span>\r\n            .<\/span>map<\/span>(<\/span>map<\/span> -><\/span> ServerSentEvent<\/span>.<\/span>builder<\/span>(<\/span>map<\/span>).<\/span>build<\/span>())<\/span>\r\n            .<\/span>concatWith<\/span>(<\/span>Mono<\/span>.<\/span>just<\/span>(<\/span>ServerSentEvent<\/span>.<<\/span>Map<\/span><<\/span>String<\/span>,<\/span> String<\/span>>><\/span>builder<\/span>().<\/span>event<\/span>(<\/span>\"end\"<\/span>).<\/span>build<\/span>()));<\/span>\r\n    }<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n
    \u6bcf\u4e2a\u5904\u7406\u6b65\u9aa4\u90fd\u8bbe\u7f6e\u4e862\u79d2\u7684\u5ef6\u8fdf\u65f6\u95f4\u3002<\/div>\n
    \u5728\u4f7f\u7528Spring WebFlux\u5b9e\u73b0\u670d\u52a1\u5668\u7aef\u7684SSE\u65f6\uff0c\u63a5\u6536\u65b9\u7684\u5ba2\u6237\u7aef\u9700\u8981\u660e\u786e\u5730\u53d1\u9001\u4e8b\u4ef6:end\u3002<\/div>\n
    \u958b\u555f\u8aaa\u660e\u3002\u8fd4\u56de\u7d66\u5ba2\u6236\u7aef\u975e\u540c\u6b65\u7684\u55ae\u4e00\u503c\u56de\u61c9\u7684\u7aef\u9ede
    \n@GetMapping(“\/mono”)
    \npublic Mono<Map<String, String>> getMono() {
    \nreturn Mono.just(
    \nMap.of(“message”, “Hello Mono!”))
    \n.delayElement(Duration.ofSeconds(2))
    \n.doOnNext(map -> log.info(“Sending message: {}”, map));
    \n}<\/p>\n
    \u5167\u5bb9<\/p>\n
    @GetMapping(“\/mono”)\u8a3b\u91cb\u6703\u5c07HTTP GET\u8acb\u6c42\u6620\u5c04\u5230”\/mono”\u7aef\u9ede\u3002<\/p>\n
    Mono<Map<String, String>> \u662f\u4e00\u500b\u8868\u793a\u55ae\u4e00\u975e\u540c\u6b65\u503c\u7684Reactive Streams\u985e\u578b\u3002\u5728\u9019\u7a2e\u60c5\u6cc1\u4e0b\uff0c\u5b83\u8868\u793a\u55ae\u4e00\u500bMap\u5c0d\u8c61\u3002<\/p>\n
    Mono.just(Map.of(“message”, “Hello Mono!”)) \u5275\u5efa\u4e00\u500b\u5305\u542b”message”\u9375\u548c\u5176\u503c\u7684Map\u5c0d\u8c61\uff0c\u4e26\u5c07\u5176\u5305\u88dd\u5230Mono\u4e2d\u8fd4\u56de\u3002<\/p>\n
    .delayElement(Duration.ofSeconds(2)) \u662f\u8f49\u63dbMono\u4ee5\u4f7f\u56de\u61c9\u5ef6\u90722\u79d2\u7684\u904b\u7b97\u7b26\u3002<\/p>\n
    .doOnNext(map -> log.info(“Sending message: {}”, map)) \u662f\u70ba\u4e86\u5c07\u6bcf\u500b\u503c\u901a\u77e5\u5230log\u5c0d\u8c61\u4e26\u8f38\u51fa\u6d88\u606f\u800c\u6dfb\u52a0\u7684\u526f\u4f5c\u7528\u904b\u7b97\u7b26\u3002<\/p>\n
    \u63db\u53e5\u8a71\u8aaa\uff0c\u9019\u500b\u7aef\u9ede\u5c07\u5728\u7b49\u5f852\u79d2\u5f8c\u8fd4\u56de\u5305\u542b”Hello Mono!”\u6d88\u606f\u7684Map\u5c0d\u8c61\u3002\u540c\u6642\uff0c\u65e5\u8a8c\u5c07\u8f38\u51fa”Sending message: {message=Hello Mono!}”\u7684\u6d88\u606f\u7576\u503c\u88ab\u901a\u77e5\u6642\u3002<\/p>\n
    \u8fd4\u56de\u7d66\u5ba2\u6236\u7aef\u975e\u540c\u6b65\u7684\u591a\u500b\u503c\u56de\u61c9\u7684\u7aef\u9ede
    \n@GetMapping(“\/flux”)
    \npublic Flux<Map<String, String>> getFlux() {
    \nreturn Flux.range(1, 5)
    \n.map(idx -> Map.of(“message”, “Hello Flux ” + idx + “!”))
    \n.delayElements(Duration.ofSeconds(2))
    \n.doOnNext(map -> log.info(“Sending message: {}”, map));
    \n}<\/p>\n
    \u5167\u5bb9<\/p>\n
    @GetMapping(“\/flux”)\u8a3b\u91cb\u5c07HTTP GET\u8acb\u6c42\u6620\u5c04\u5230”\/flux”\u7aef\u9ede\u3002<\/p>\n
    Flux<Map<String, String>> \u662f\u4e00\u500b\u4f7f\u7528Reactive Streams\u985e\u578b\u8868\u793a\u591a\u500b\u975e\u540c\u6b65\u503c\u7684\u7aef\u9ede\u3002\u5728\u9019\u7a2e\u60c5\u6cc1\u4e0b\uff0c\u5b83\u8868\u793a\u591a\u500bMap\u5c0d\u8c61\u3002<\/p>\n
    Flux.range(1, 5) \u7522\u751f\u5f9e1\u52305\u7684\u6574\u6578\u7684Flux\u3002<\/p>\n
    .map(idx -> Map.of(“message”, “Hello Flux ” + idx + “!”)) \u662f\u7528\u65bc\u5275\u5efa\u6bcf\u500b\u5143\u7d20\u7684\u5305\u542b”message”\u9375\u548c\u5176\u503c\u7684Map\u5c0d\u8c61\u7684\u904b\u7b97\u7b26\u3002<\/p>\n
    .delayElements(Duration.ofSeconds(2)) \u662f\u5ef6\u9072\u6bcf\u500b\u5143\u7d202\u79d2\u7684\u904b\u7b97\u7b26\u3002<\/p>\n
    .doOnNext(map -> log.info(“Sending message: {}”, map)) \u662f\u70ba\u4e86\u5c07\u6bcf\u500b\u5143\u7d20\u901a\u77e5\u5230log\u5c0d\u8c61\u4e26\u8f38\u51fa\u6d88\u606f\u800c\u6dfb\u52a0\u7684\u526f\u4f5c\u7528\u904b\u7b97\u7b26\u3002<\/p>\n
    \u63db\u53e5\u8a71\u8aaa\uff0c\u9019\u500b\u7aef\u9ede\u5c07\u8fd4\u56de\u5305\u542b\u57282\u79d2\u9593\u9694\u901a\u77e5\u7684\u6bcf\u500b\u5143\u7d20\u4e2d\u7684”Hello Flux {index}!”\u6d88\u606f\u7684Map\u5c0d\u8c61\u3002\u540c\u6642\uff0c\u65e5\u8a8c\u5c07\u5728\u6bcf\u500b\u503c\u88ab\u901a\u77e5\u6642\u8f38\u51fa”Sending message: {message=Hello Flux {index}!}”\u7684\u6d88\u606f\u3002<\/p>\n
    \u8fd4\u56de\u4f7f\u7528Server-Sent Events\uff08SSE\uff09\u5354\u8b70\u975e\u540c\u6b65\u767c\u9001\u6578\u64da\u7d66\u5ba2\u6236\u7aef\u7684\u7aef\u9ede
    \n@GetMapping(“\/flux-sse”)
    \npublic Flux<ServerSentEvent<Map<String, String>>> getFluxWithSSE() {
    \nreturn Flux.range(1, 5)
    \n.map(idx -> Map.of(“message”, “Hello Flux ” + idx + “!”))
    \n.delayElements(Duration.ofSeconds(2))
    \n.doOnNext(map -> log.info(“Sending message: {}”, map))
    \n.map(map -> ServerSentEvent.builder(map).build())
    \n.concatWith(Mono.just(ServerSentEvent.<Map<String, String>>builder().event(“end”).build()));
    \n}<\/p>\n
    \u5167\u5bb9<\/p>\n
    @GetMapping(“\/flux-sse”) \u8a3b\u91cb\u5c07HTTP GET\u8acb\u6c42\u6620\u5c04\u5230”\/flux-sse”\u7aef\u9ede\u3002<\/p>\n
    Flux<ServerSentEvent<Map<String, String>>> \u662f\u4e00\u500b\u4f7f\u7528Server-Sent Events\u8868\u793a\u591a\u500b\u975e\u540c\u6b65\u503c\u7684Reactive Streams\u985e\u578b\u3002\u5728\u9019\u7a2e\u60c5\u6cc1\u4e0b\uff0c\u5b83\u8868\u793a\u591a\u500bMap\u5c0d\u8c61\u3002<\/p>\n
    Flux.range(1, 5) \u7522\u751f\u5f9e1\u52305\u7684\u6574\u6578\u7684Flux\u3002<\/p>\n
    .map(idx -> Map.of(“message”, “Hello Flux ” + idx + “!”)) \u662f\u7528\u65bc\u5275\u5efa\u6bcf\u500b\u5143\u7d20\u7684\u5305\u542b”message”\u9375\u548c\u5176\u503c\u7684Map\u5c0d\u8c61\u7684\u904b\u7b97\u7b26\u3002<\/p>\n
    .delayElements(Duration.ofSeconds(2)) \u662f\u5ef6\u9072\u6bcf\u500b\u5143\u7d202\u79d2\u7684\u904b\u7b97\u7b26\u3002<\/p>\n
    .doOnNext(map -> log.info(“Sending message: {}”, map)) \u662f\u70ba\u4e86\u5c07\u6bcf\u500b\u5143\u7d20\u901a\u77e5\u5230log\u5c0d\u8c61\u4e26\u8f38\u51fa\u6d88\u606f\u800c\u6dfb\u52a0\u7684\u526f\u4f5c\u7528\u904b\u7b97\u7b26\u3002<\/p>\n
    .map(map -> ServerSentEvent.builder(map).build()) \u662f\u5c07\u6bcf\u500bMap\u5c0d\u8c61\u8f49\u63db\u70baServerSentEvent\u5c0d\u8c61\u7684\u904b\u7b97\u7b26\u3002<\/p>\n
    .concatWith(Mono.just(ServerSentEvent.<Map<String, String>>builder().event(“end”).build())) \u662f\u7528\u65bc\u5728\u6d41\u7684\u672b\u5c3e\u6dfb\u52a0ServerSentEvent\u5c0d\u8c61\u7684\u904b\u7b97\u7b26\u3002\u9019\u6a23\u53ef\u4ee5\u767c\u9001\u8868\u793aSSE\u6d41\u7d50\u675f\u7684event: end\u6a19\u7c64\u3002<\/p>\n
    \u63db\u53e5\u8a71\u8aaa\uff0c\u9019\u500b\u7aef\u9ede\u5c07\u8fd4\u56de\u4f7f\u7528Server-Sent Events\u683c\u5f0f\u5305\u542b”Hello Flux {index}!”\u6d88\u606f\u7684Map\u5c0d\u8c61\u7684\u591a\u500b\u503c\uff0c\u6bcf\u500b\u5143\u7d20\u4e4b\u9593\u9593\u96942\u79d2\u901a\u77e5\u3002\u540c\u6642\uff0c\u65e5\u8a8c\u5c07\u5728\u6bcf\u500b\u503c\u88ab\u901a\u77e5\u6642\u8f38\u51fa”Sending message: {message=Hello Flux {index}!}”\u7684\u6d88\u606f\u3002<\/p>\n<\/details>\n
    \u521b\u5efa pom.xml \u6587\u4ef6<\/h3>\n
    \u521b\u5efa pom.xml \u6587\u4ef6\u3002<\/p>\n
    $ <\/span>vim pom.xml\r\n<\/code><\/pre>\n
    \u6587\u4ef6\u7684\u5185\u5bb9 de<\/p>\n
    <?xml version=\"1.0\" encoding=\"UTF-8\"?><\/span>\r\n<project<\/span> xmlns=<\/span>\"http:\/\/maven.apache.org\/POM\/4.0.0\"<\/span>\r\n    xmlns:xsi=<\/span>\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"<\/span>\r\n    xsi:schemaLocation=<\/span>\"http:\/\/maven.apache.org\/POM\/4.0.0 https:\/\/maven.apache.org\/xsd\/maven-4.0.0.xsd\"<\/span>><\/span>\r\n    <modelVersion><\/span>4.0.0<\/modelVersion><\/span>\r\n    <parent><\/span>\r\n        <groupId><\/span>org.springframework.boot<\/groupId><\/span>\r\n        <artifactId><\/span>spring-boot-starter-parent<\/artifactId><\/span>\r\n        <version><\/span>2.7.8<\/version><\/span>\r\n        <relativePath\/><\/span> <!-- lookup parent from repository --><\/span>\r\n    <\/parent><\/span>\r\n    <groupId><\/span>com.example<\/groupId><\/span>\r\n    <artifactId><\/span>sync-spring-webflux<\/artifactId><\/span>\r\n    <version><\/span>1.0<\/version><\/span>\r\n    <name><\/span>sync-spring-webflux<\/name><\/span>\r\n\r\n    <properties><\/span>\r\n        <java.version><\/span>11<\/java.version><\/span>\r\n        <project.build.sourceEncoding><\/span>UTF-8<\/project.build.sourceEncoding><\/span>\r\n    <\/properties><\/span>\r\n\r\n    <dependencies><\/span>\r\n        <dependency><\/span>\r\n            <groupId><\/span>org.springframework.boot<\/groupId><\/span>\r\n            <artifactId><\/span>spring-boot-starter-webflux<\/artifactId><\/span>\r\n        <\/dependency><\/span>\r\n        <!-- Lombok --><\/span>\r\n        <dependency><\/span>\r\n            <groupId><\/span>org.projectlombok<\/groupId><\/span>\r\n            <artifactId><\/span>lombok<\/artifactId><\/span>\r\n            <version><\/span>1.18.26<\/version><\/span>\r\n            <scope><\/span>provided<\/scope><\/span>\r\n        <\/dependency><\/span>\r\n    <\/dependencies><\/span>\r\n\r\n    <build><\/span>\r\n        <finalName><\/span>app<\/finalName><\/span>\r\n        <plugins><\/span>\r\n            <plugin><\/span>\r\n                <groupId><\/span>org.springframework.boot<\/groupId><\/span>\r\n                <artifactId><\/span>spring-boot-maven-plugin<\/artifactId><\/span>\r\n            <\/plugin><\/span>\r\n        <\/plugins><\/span>\r\n    <\/build><\/span>\r\n<\/project><\/span>\r\n<\/code><\/pre>\n
    \u8f93\u51fa\u65e5\u5fd7\u6587\u4ef6\u7684\u8bbe\u7f6e<\/h3>\n
      \n
    • \n
        application.properties<\/ul>\n<\/li>\n<\/ul>\n
         <\/p>\n
          logback-spring.xml<\/ul>\n
          \u60a8\u53ef\u4ee5\u5728\u8fd9\u7bc7\u76f8\u5173\u6587\u7ae0\u4e2d\u786e\u8ba4\u6b65\u9aa4\u3002<\/p>\n
           <\/p>\n
          \u5e94\u7528\u7a0b\u5e8f\u7684\u6784\u5efa<\/h3>\n
          \u6784\u5efaJava\u5e94\u7528\u7a0b\u5e8f\u3002
          \n\u203b \u5c06\u521b\u5efa\u76ee\u6807\/app.jar\u3002<\/p>\n
          $ <\/span>mvn clean package\r\n<\/code><\/pre>\n
          \u6253\u5f00\u5e94\u7528<\/h3>\n
          \u542f\u52a8\u5e94\u7528\u7a0b\u5e8f\u3002
          \n\u203b \u505c\u6b62\u5e94\u7528\u7a0b\u5e8f\u65f6\u6309\u4e0b ctrl + C\u3002<\/p>\n
          $ <\/span>rm<\/span> -rf<\/span> log\r\n$ <\/span>mvn spring-boot:run\r\n<\/code><\/pre>\n
          \u786e\u8ba4\u5e94\u7528\u7684\u8fd0\u884c\u60c5\u51b5<\/h3>\n
          \u6211\u5011\u53ef\u4ee5\u5f9e\u53e6\u4e00\u500b\u7d42\u7aef\u7a97\u53e3\u4f7f\u7528curl\u547d\u4ee4\u9032\u884c\u78ba\u8a8d\u3002<\/p>\n
          \u5982\u679c\u4ee5\u5e38\u89c4\u65b9\u5f0f\u4f7f\u7528 HTTP \u8bf7\u6c42 Mono \u7684\u60c5\u51b5<\/h4>\n
          $ <\/span>curl -v<\/span> http:\/\/localhost:8080\/mono -w<\/span> '\\n'<\/span>\r\n*<\/span>   Trying 127.0.0.1:8080...\r\n*<\/span> Connected to localhost (<\/span>127.0.0.1)<\/span> port 8080 (<\/span>#0)<\/span>\r\n><\/span> GET \/mono HTTP\/1.1\r\n><\/span> Host: localhost:8080\r\n><\/span> User-Agent: curl\/7.81.0\r\n><\/span> Accept: *<\/span>\/*<\/span>\r\n><\/span>\r\n*<\/span> Mark bundle as not supporting multiuse\r\n< HTTP\/1.1 200 OK\r\n< Vary: Origin\r\n< Vary: Access-Control-Request-Method\r\n< Vary: Access-Control-Request-Headers\r\n< Content-Type: application\/json\r\n< Content-Length: 25\r\n<\r\n*<\/span> Connection #0 to host localhost left intact<\/span>\r\n{<\/span>\"message\"<\/span>:\"Hello Mono!\"<\/span>}<\/span>\r\n<\/code><\/pre>\n
          \u6211\u4f1a\u4ece\u53e6\u4e00\u4e2a\u7ec8\u7aef\u67e5\u770b\u65e5\u5fd7\u6587\u4ef6\u3002\u203b \u53ea\u6458\u5f55\u4e86\u5fc5\u8981\u7684\u90e8\u5206\u3002<\/p>\n
          $ <\/span>cd<\/span> ~\/tmp\/async-spring-webflux\/log\r\n$ <\/span>cat <\/span>app.log\r\n2023-03-20 12:11:59.869 [<\/span>DEBUG] [<\/span>main] org.springframework.boot.StartupInfoLogger.logStarting:56 - Running with Spring Boot v2.7.8, Spring v5.3.25\r\n2023-03-20 12:11:59.870 [<\/span>INFO ]<\/span> [<\/span>main] org.springframework.boot.SpringApplication.logStartupProfileInfo:637 - The following 1 profile is active: \"develop\"<\/span>\r\n2023-03-20 12:12:00.556 [<\/span>INFO ]<\/span> [<\/span>main] org.springframework.boot.web.embedded.netty.NettyWebServer.start:111 - Netty started on port 8080\r\n2023-03-20 12:12:00.562 [<\/span>INFO ]<\/span> [<\/span>main] org.springframework.boot.StartupInfoLogger.logStarted:61 - Started Application in <\/span>0.987 seconds (<\/span>JVM running for <\/span>1.221)<\/span>\r\n2023-03-20 12:15:32.844 [<\/span>INFO ]<\/span> [<\/span>parallel-1] com.example.springwebflux.Application.lambda$getMono$0<\/span>:32 - Sending message: {<\/span>message<\/span>=<\/span>Hello Mono!}<\/span>\r\n<\/code><\/pre>\n
          \u4ece\u7ebf\u7a0b\u540d\u79f0 “parallel-1” \u53ef\u4ee5\u63a8\u65ad\u51fa Spring WebFlux \u5728\u5e76\u884c\u5904\u7406\u7ebf\u7a0b\u4e0a\u5904\u7406 Mono\u3002<\/div>\n
          \u5982\u679c\u4f7f\u7528\u666e\u901a\u7684HTTP\u8bf7\u6c42Flux\u7684\u60c5\u51b5\u4e0b<\/h4>\n
          \u6211\u4f1a\u4ece\u53e6\u4e00\u4e2a\u7ec8\u7aef\u4f7f\u7528curl\u547d\u4ee4\u8fdb\u884c\u786e\u8ba4\u3002<\/p>\n
          $ <\/span>curl -v<\/span> http:\/\/localhost:8080\/flux -w<\/span> '\\n'<\/span>\r\n*<\/span>   Trying 127.0.0.1:8080...\r\n*<\/span> Connected to localhost (<\/span>127.0.0.1)<\/span> port 8080 (<\/span>#0)<\/span>\r\n><\/span> GET \/flux HTTP\/1.1\r\n><\/span> Host: localhost:8080\r\n><\/span> User-Agent: curl\/7.81.0\r\n><\/span> Accept: *<\/span>\/*<\/span>\r\n><\/span>\r\n*<\/span> Mark bundle as not supporting multiuse\r\n< HTTP\/1.1 200 OK\r\n< transfer-encoding: chunked\r\n< Vary: Origin\r\n< Vary: Access-Control-Request-Method\r\n< Vary: Access-Control-Request-Headers\r\n< Content-Type: application\/json\r\n<\r\n*<\/span> Connection #0 to host localhost left intact<\/span>\r\n[{<\/span>\"message\"<\/span>:\"Hello Flux 1!\"<\/span>}<\/span>,{<\/span>\"message\"<\/span>:\"Hello Flux 2!\"<\/span>}<\/span>,{<\/span>\"message\"<\/span>:\"Hello Flux 3!\"<\/span>}<\/span>,{<\/span>\"message\"<\/span>:\"Hello Flux 4!\"<\/span>}<\/span>,{<\/span>\"message\"<\/span>:\"Hello Flux 5!\"<\/span>}]<\/span>\r\n<\/code><\/pre>\n
          \u6211\u4f1a\u4ece\u53e6\u4e00\u4e2a\u7ec8\u7aef\u68c0\u67e5\u65e5\u5fd7\u6587\u4ef6\u3002\u203b \u6211\u63d0\u53d6\u4e86\u5fc5\u8981\u7684\u5185\u5bb9\u3002<\/p>\n
          $ <\/span>cd<\/span> ~\/tmp\/async-spring-webflux\/log\r\n$ <\/span>cat <\/span>app.log\r\n2023-03-20 12:19:28.477 [<\/span>INFO ]<\/span> [<\/span>main] org.springframework.boot.web.embedded.netty.NettyWebServer.start:111 - Netty started on port 8080\r\n2023-03-20 12:19:28.482 [<\/span>INFO ]<\/span> [<\/span>main] org.springframework.boot.StartupInfoLogger.logStarted:61 - Started Application in <\/span>0.95 seconds (<\/span>JVM running for <\/span>1.124)<\/span>\r\n2023-03-20 12:19:42.389 [<\/span>INFO ]<\/span> [<\/span>parallel-1] com.example.springwebflux.Application.lambda$getFlux$2<\/span>:40 - Sending message: {<\/span>message<\/span>=<\/span>Hello Flux 1!}<\/span>\r\n2023-03-20 12:19:44.392 [<\/span>INFO ]<\/span> [<\/span>parallel-2] com.example.springwebflux.Application.lambda$getFlux$2<\/span>:40 - Sending message: {<\/span>message<\/span>=<\/span>Hello Flux 2!}<\/span>\r\n2023-03-20 12:19:46.394 [<\/span>INFO ]<\/span> [<\/span>parallel-3] com.example.springwebflux.Application.lambda$getFlux$2<\/span>:40 - Sending message: {<\/span>message<\/span>=<\/span>Hello Flux 3!}<\/span>\r\n2023-03-20 12:19:48.396 [<\/span>INFO ]<\/span> [<\/span>parallel-4] com.example.springwebflux.Application.lambda$getFlux$2<\/span>:40 - Sending message: {<\/span>message<\/span>=<\/span>Hello Flux 4!}<\/span>\r\n2023-03-20 12:19:50.399 [<\/span>INFO ]<\/span> [<\/span>parallel-5] com.example.springwebflux.Application.lambda$getFlux$2<\/span>:40 - Sending message: {<\/span>message<\/span>=<\/span>Hello Flux 5!}<\/span>\r\n<\/code><\/pre>\n
          \u6839\u636e\u7ebf\u7a0b\u540d\u79f0\u4e3aparallel-n\u7684\u63d0\u793a\uff0c\u53ef\u4ee5\u63a8\u6d4bSpring WebFlux\u4ee5\u5e76\u884c\u5904\u7406\u7ebf\u7a0b\u7684\u65b9\u5f0f\u5904\u7406Flux\u6bcf2\u79d2\u949f\u7684\u6570\u636e\u3002\u5ba2\u6237\u7aef\uff08curl\uff09\u5728\u4e00\u6bb5\u65f6\u95f4\u540e\u4e00\u6b21\u6027\u83b7\u53d6\u6570\u636e\u3002<\/div>\n
          \u5982\u679c\u4f7f\u7528Server-Sent Events\u6307\u5b9a\u7684HTTP\u8bf7\u6c42Flux\u7684\u60c5\u51b5\u4e0b\u3002<\/h4>\n
          \u4ece\u53e6\u4e00\u4e2a\u7ec8\u7aef\u4f7f\u7528curl\u547d\u4ee4\u8fdb\u884c\u786e\u8ba4\u3002<\/p>\n
          \u6dfb\u52a0 Accept: text\/event-stream \u5934\u3002<\/div>\n
          $ <\/span>curl -v<\/span> http:\/\/localhost:8080\/flux-sse -H<\/span> 'Accept: text\/event-stream'<\/span> -w<\/span> '\\n'<\/span>\r\n*<\/span>   Trying 127.0.0.1:8080...\r\n*<\/span> Connected to localhost (<\/span>127.0.0.1)<\/span> port 8080 (<\/span>#0)<\/span>\r\n><\/span> GET \/flux-sse HTTP\/1.1\r\n><\/span> Host: localhost:8080\r\n><\/span> User-Agent: curl\/7.81.0\r\n><\/span> Accept: text\/event-stream\r\n><\/span>\r\n*<\/span> Mark bundle as not supporting multiuse\r\n< HTTP\/1.1 200 OK\r\n< transfer-encoding: chunked\r\n< Vary: Origin\r\n< Vary: Access-Control-Request-Method\r\n< Vary: Access-Control-Request-Headers\r\n< Content-Type: text\/event-stream;<\/span>charset<\/span>=<\/span>UTF-8\r\n<\r\ndata:{<\/span>\"message\"<\/span>:\"Hello Flux 1!\"<\/span>}<\/span>\r\n\r\ndata:{<\/span>\"message\"<\/span>:\"Hello Flux 2!\"<\/span>}<\/span>\r\n\r\ndata:{<\/span>\"message\"<\/span>:\"Hello Flux 3!\"<\/span>}<\/span>\r\n\r\ndata:{<\/span>\"message\"<\/span>:\"Hello Flux 4!\"<\/span>}<\/span>\r\n\r\ndata:{<\/span>\"message\"<\/span>:\"Hello Flux 5!\"<\/span>}<\/span>\r\n\r\nevent:end\r\n\r\n*<\/span> Connection #0 to host localhost left intact<\/span>\r\n<\/code><\/pre>\n
          \u6211\u8981\u4ece\u53e6\u4e00\u4e2a\u7ec8\u7aef\u786e\u8ba4\u65e5\u5fd7\u6587\u4ef6\u3002\u203b\u4ec5\u6458\u5f55\u4e86\u5fc5\u8981\u7684\u90e8\u5206\u3002<\/p>\n
          $ <\/span>cd<\/span> ~\/tmp\/async-spring-webflux\/log\r\n$ <\/span>cat <\/span>app.log\r\ncat <\/span>app.log\r\n2023-03-20 12:22:02.249 [<\/span>INFO ]<\/span> [<\/span>main] org.springframework.boot.web.embedded.netty.NettyWebServer.start:111 - Netty started on port 8080\r\n2023-03-20 12:22:02.256 [<\/span>INFO ]<\/span> [<\/span>main] org.springframework.boot.StartupInfoLogger.logStarted:61 - Started Application in <\/span>1.035 seconds (<\/span>JVM running for <\/span>1.224)<\/span>\r\n2023-03-20 12:22:17.814 [<\/span>INFO ]<\/span> [<\/span>parallel-1] com.example.springwebflux.Application.lambda$getFluxWithSSE$4<\/span>:48 - Sending message: {<\/span>message<\/span>=<\/span>Hello Flux 1!}<\/span>\r\n2023-03-20 12:22:19.827 [<\/span>INFO ]<\/span> [<\/span>parallel-2] com.example.springwebflux.Application.lambda$getFluxWithSSE$4<\/span>:48 - Sending message: {<\/span>message<\/span>=<\/span>Hello Flux 2!}<\/span>\r\n2023-03-20 12:22:21.831 [<\/span>INFO ]<\/span> [<\/span>parallel-3] com.example.springwebflux.Application.lambda$getFluxWithSSE$4<\/span>:48 - Sending message: {<\/span>message<\/span>=<\/span>Hello Flux 3!}<\/span>\r\n2023-03-20 12:22:23.842 [<\/span>INFO ]<\/span> [<\/span>parallel-4] com.example.springwebflux.Application.lambda$getFluxWithSSE$4<\/span>:48 - Sending message: {<\/span>message<\/span>=<\/span>Hello Flux 4!}<\/span>\r\n2023-03-20 12:22:25.854 [<\/span>INFO ]<\/span> [<\/span>parallel-5] com.example.springwebflux.Application.lambda$getFluxWithSSE$4<\/span>:48 - Sending message: {<\/span>message<\/span>=<\/span>Hello Flux 5!}<\/span>\r\n<\/code><\/pre>\n
          \u4ece\u540d\u4e3aparallel-n\u7684\u7ebf\u7a0b\u4e2d\uff0cSpring WebFlux\u6bcf2\u79d2\u5728\u5e76\u884c\u5904\u7406\u7ebf\u7a0b\u4e2d\u5904\u7406Flux\u3002\u5ba2\u6237\u7aef\uff08curl\uff09\u4f1a\u4ee5\u9010\u4e2a\u6570\u636e\u7684\u65b9\u5f0f\u5b9e\u65f6\u83b7\u53d6\u6570\u636e\u3002<\/div>\n
          \u8fd9\u662f\u76ee\u524d\u4e3a\u6b62\u7684\u603b\u7ed3\u3002<\/h3>\n
          \u5728Spring WebFlux\u4e2d\uff0c\u6211\u4eec\u4f7f\u7528Netty\u4f5c\u4e3a\u5185\u7f6e\u7684Web\u670d\u52a1\u5668\u3002 Flux\u5bf9\u8c61\u88ab\u5f02\u6b65\u5904\u7406\u3002<\/div>\n
          \u4ec5\u63d0\u4f9b\u4e00\u79cd\u9009\u9879\uff1a
          \n\u603b\u7ed3<\/h2>\n
          \u6211\u80fd\u591f\u5728\u4f7f\u7528Ubuntu\u642d\u5efa\u7684\u7b80\u5355Java\u5f00\u53d1\u73af\u5883\u4e0b\uff0c\u8fd0\u884c\u5b9e\u73b0\u4e86Server-Sent Events\u7684Spring WebFlux Web\u670d\u52a1\u3002<\/p>\n
          \u4f7f\u7528 Ubuntu \u4f1a\u4f7f\u4f60\u638c\u63e1 Linux \u7684\u77e5\u8bc6\u3002\u521a\u5f00\u59cb\u53ef\u80fd\u4f1a\u611f\u89c9\u56f0\u96be\uff0c\u4f46\u968f\u7740\u9010\u6e10\u7684\u5b66\u4e60\uff0c\u4f60\u4f1a\u9010\u6e10\u6709\u4fe1\u5fc3\u5e76\u80fd\u591f\u81ea\u5982\u5730\u64cd\u4f5c\u3002<\/div>\n
          \u8bf7\u95ee\u611f\u89c9\u600e\u4e48\u6837\uff1f\u5728 WSL Ubuntu \u4e0a\uff0c\u60a8\u53ef\u4ee5\u8f7b\u677e\u8fd0\u884c\u5b9e\u73b0 Server-Sent Events \u7684 Spring Boot Web \u5e94\u7528\u7a0b\u5e8f\u3002\u8bf7\u52a1\u5fc5\u5c1d\u8bd5\u4e00\u4e0b\u3002\u6211\u4eec\u5c06\u7ee7\u7eed\u4ecb\u7ecdJava\u5f00\u53d1\u73af\u5883\u7b49\u5185\u5bb9\uff0c\u8bf7\u656c\u8bf7\u671f\u5f85\u3002<\/p>\n
          \u8bf7\u63d0\u4f9b\u76f8\u5173\u53c2\u8003\u8d44\u6599\u3002<\/h2>\n
          W3C\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6<\/h5>\n
           <\/p>\n
          HTML 9.2\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6\u6d3b\u52a8\u6807\u51c6<\/h5>\n
           <\/p>\n
          MDN \u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6<\/h5>\n
           <\/p>\n","protected":false},"excerpt":{"rendered":"
          \u5728Spring WebFlux Web\u670d\u52a1\u4e2d\u4f7f\u7528Server-Sent Events\u5b9e\u73b0”Hell […]<\/p>\n","protected":false},"author":3,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-40397","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n\u5728Spring WebFlux Web\u670d\u52a1\u4e2d\u4f7f\u7528Server-Sent Events\u6765\u5b9e\u73b0Hello World - 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\u7528server-sent-events\u6765\u5b9e\u73b0hello-world\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\u7528Server-Sent Events\u6765\u5b9e\u73b0Hello World\" \/>\n<meta property=\"og:description\" content=\"\u5728Spring WebFlux Web\u670d\u52a1\u4e2d\u4f7f\u7528Server-Sent Events\u5b9e\u73b0”Hell […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u5728spring-webflux-web\u670d\u52a1\u4e2d\u4f7f\u7528server-sent-events\u6765\u5b9e\u73b0hello-world\u3002\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-07-13T04:55:42+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-30T01:05:36+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d403837434c4406c9122e\/1-0.png\" \/>\n<meta name=\"author\" content=\"\u97f5, \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=\"\u97f5, \u79d1\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"11 \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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%e3%80%82\/\",\"name\":\"\u5728Spring WebFlux Web\u670d\u52a1\u4e2d\u4f7f\u7528Server-Sent Events\u6765\u5b9e\u73b0Hello World - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-07-13T04:55:42+00:00\",\"dateModified\":\"2024-04-30T01:05:36+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e\"},\"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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%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\u7528Server-Sent Events\u6765\u5b9e\u73b0Hello World\"}]},{\"@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\/6530331a63adef3b3443a1fab53a0e6e\",\"name\":\"\u97f5, \u79d1\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"caption\":\"\u97f5, \u79d1\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/\"},{\"@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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%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\u7528Server-Sent Events\u6765\u5b9e\u73b0Hello World - 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\u7528server-sent-events\u6765\u5b9e\u73b0hello-world\u3002\/","og_locale":"zh_CN","og_type":"article","og_title":"\u5728Spring WebFlux Web\u670d\u52a1\u4e2d\u4f7f\u7528Server-Sent Events\u6765\u5b9e\u73b0Hello World","og_description":"\u5728Spring WebFlux Web\u670d\u52a1\u4e2d\u4f7f\u7528Server-Sent Events\u5b9e\u73b0”Hell […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u5728spring-webflux-web\u670d\u52a1\u4e2d\u4f7f\u7528server-sent-events\u6765\u5b9e\u73b0hello-world\u3002\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-07-13T04:55:42+00:00","article_modified_time":"2024-04-30T01:05:36+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d403837434c4406c9122e\/1-0.png"}],"author":"\u97f5, \u79d1","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u97f5, \u79d1","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"11 \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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%e3%80%82\/","name":"\u5728Spring WebFlux Web\u670d\u52a1\u4e2d\u4f7f\u7528Server-Sent Events\u6765\u5b9e\u73b0Hello World - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-07-13T04:55:42+00:00","dateModified":"2024-04-30T01:05:36+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e"},"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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%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\u7528Server-Sent Events\u6765\u5b9e\u73b0Hello World"}]},{"@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\/6530331a63adef3b3443a1fab53a0e6e","name":"\u97f5, \u79d1","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","caption":"\u97f5, \u79d1"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/"},{"@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%a8server-sent-events%e6%9d%a5%e5%ae%9e%e7%8e%b0hello-world%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\/40397","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\/3"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=40397"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/40397\/revisions"}],"predecessor-version":[{"id":90980,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/40397\/revisions\/90980"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=40397"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=40397"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=40397"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}