{"id":82232,"date":"2026-07-25T07:18:58","date_gmt":"2026-07-24T23:18:58","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/82232.html"},"modified":"2026-07-25T07:18:58","modified_gmt":"2026-07-24T23:18:58","slug":"sse%e6%9c%8d%e5%8a%a1%e5%99%a8%e6%8e%a8%e9%80%81%e4%ba%8b%e4%bb%b6%e5%8e%9f%e7%90%86%e6%b7%b1%e5%ba%a6%e8%a7%a3%e6%9e%90%e4%b8%8e%e5%ae%9e%e6%88%98%e5%ba%94%e7%94%a8","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/82232.html","title":{"rendered":"SSE\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6\u539f\u7406\u6df1\u5ea6\u89e3\u6790\u4e0e\u5b9e\u6218\u5e94\u7528"},"content":{"rendered":"<h3>\u4e00\u3001\u4ec0\u4e48\u662fSSE<\/h3>\n<p>SSE&#xff08;Server-Sent Events&#xff09; \u662f\u4e00\u79cd\u57fa\u4e8eHTTP\u7684\u670d\u52a1\u5668\u63a8\u9001\u6280\u672f&#xff0c;\u5141\u8bb8\u670d\u52a1\u5668\u5411\u5ba2\u6237\u7aef\u5355\u5411\u53d1\u9001\u4e8b\u4ef6\u6d41\u3002\u5b83\u662fHTML5\u89c4\u8303\u7684\u4e00\u90e8\u5206&#xff0c;\u4e13\u4e3a\u670d\u52a1\u5668\u5230\u5ba2\u6237\u7aef\u7684\u5355\u5411\u5b9e\u65f6\u901a\u4fe1\u800c\u8bbe\u8ba1\u3002<\/p>\n<h4>1.1 SSE\u7684\u6838\u5fc3\u7279\u6027<\/h4>\n<ul>\n<li>\u5355\u5411\u901a\u4fe1&#xff1a;\u4ec5\u652f\u6301\u670d\u52a1\u5668\u5411\u5ba2\u6237\u7aef\u63a8\u9001\u6570\u636e<\/li>\n<li>\u57fa\u4e8eHTTP&#xff1a;\u4f7f\u7528\u6807\u51c6HTTP\u534f\u8bae&#xff0c;\u65e0\u9700\u989d\u5916\u7684\u8fde\u63a5\u5efa\u7acb<\/li>\n<li>\u81ea\u52a8\u91cd\u8fde&#xff1a;\u6d4f\u89c8\u5668\u4f1a\u81ea\u52a8\u5904\u7406\u65ad\u7ebf\u91cd\u8fde<\/li>\n<li>\u6587\u672c\u683c\u5f0f&#xff1a;\u4f20\u8f93\u7684\u6570\u636e\u5fc5\u987b\u662f\u6587\u672c\u683c\u5f0f<\/li>\n<li>\u4e8b\u4ef6\u6a21\u578b&#xff1a;\u652f\u6301\u4e8b\u4ef6\u7c7b\u578b\u548cID&#xff0c;\u4fbf\u4e8e\u5ba2\u6237\u7aef\u5904\u7406<\/li>\n<\/ul>\n<h3>\u4e8c\u3001SSE\u5de5\u4f5c\u539f\u7406<\/h3>\n<h4>2.1 \u8fde\u63a5\u5efa\u7acb\u6d41\u7a0b<\/h4>\n<p>\u670d\u52a1\u5668\u5ba2\u6237\u7aef\u670d\u52a1\u5668\u5ba2\u6237\u7aef#mermaid-svg-XqZ19Gdk79LGThdG{font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;font-size:16px;fill:#333;}@keyframes edge-animation-frame{from{stroke-dashoffset:0;}}@keyframes dash{to{stroke-dashoffset:0;}}#mermaid-svg-XqZ19Gdk79LGThdG .edge-animation-slow{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 50s linear infinite;stroke-linecap:round;}#mermaid-svg-XqZ19Gdk79LGThdG .edge-animation-fast{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 20s linear infinite;stroke-linecap:round;}#mermaid-svg-XqZ19Gdk79LGThdG .error-icon{fill:#552222;}#mermaid-svg-XqZ19Gdk79LGThdG .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-XqZ19Gdk79LGThdG .edge-thickness-normal{stroke-width:1px;}#mermaid-svg-XqZ19Gdk79LGThdG .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-XqZ19Gdk79LGThdG .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-XqZ19Gdk79LGThdG .edge-thickness-invisible{stroke-width:0;fill:none;}#mermaid-svg-XqZ19Gdk79LGThdG .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-XqZ19Gdk79LGThdG .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-XqZ19Gdk79LGThdG .marker{fill:#333333;stroke:#333333;}#mermaid-svg-XqZ19Gdk79LGThdG .marker.cross{stroke:#333333;}#mermaid-svg-XqZ19Gdk79LGThdG svg{font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-XqZ19Gdk79LGThdG p{margin:0;}#mermaid-svg-XqZ19Gdk79LGThdG .actor{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;}#mermaid-svg-XqZ19Gdk79LGThdG text.actor&gt;tspan{fill:black;stroke:none;}#mermaid-svg-XqZ19Gdk79LGThdG .actor-line{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);}#mermaid-svg-XqZ19Gdk79LGThdG .innerArc{stroke-width:1.5;stroke-dasharray:none;}#mermaid-svg-XqZ19Gdk79LGThdG .messageLine0{stroke-width:1.5;stroke-dasharray:none;stroke:#333;}#mermaid-svg-XqZ19Gdk79LGThdG .messageLine1{stroke-width:1.5;stroke-dasharray:2,2;stroke:#333;}#mermaid-svg-XqZ19Gdk79LGThdG #arrowhead path{fill:#333;stroke:#333;}#mermaid-svg-XqZ19Gdk79LGThdG .sequenceNumber{fill:white;}#mermaid-svg-XqZ19Gdk79LGThdG #sequencenumber{fill:#333;}#mermaid-svg-XqZ19Gdk79LGThdG #crosshead path{fill:#333;stroke:#333;}#mermaid-svg-XqZ19Gdk79LGThdG .messageText{fill:#333;stroke:none;}#mermaid-svg-XqZ19Gdk79LGThdG .labelBox{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;}#mermaid-svg-XqZ19Gdk79LGThdG .labelText,#mermaid-svg-XqZ19Gdk79LGThdG .labelText&gt;tspan{fill:black;stroke:none;}#mermaid-svg-XqZ19Gdk79LGThdG .loopText,#mermaid-svg-XqZ19Gdk79LGThdG .loopText&gt;tspan{fill:black;stroke:none;}#mermaid-svg-XqZ19Gdk79LGThdG .loopLine{stroke-width:2px;stroke-dasharray:2,2;stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);}#mermaid-svg-XqZ19Gdk79LGThdG .note{stroke:#aaaa33;fill:#fff5ad;}#mermaid-svg-XqZ19Gdk79LGThdG .noteText,#mermaid-svg-XqZ19Gdk79LGThdG .noteText&gt;tspan{fill:black;stroke:none;}#mermaid-svg-XqZ19Gdk79LGThdG .activation0{fill:#f4f4f4;stroke:#666;}#mermaid-svg-XqZ19Gdk79LGThdG .activation1{fill:#f4f4f4;stroke:#666;}#mermaid-svg-XqZ19Gdk79LGThdG .activation2{fill:#f4f4f4;stroke:#666;}#mermaid-svg-XqZ19Gdk79LGThdG .actorPopupMenu{position:absolute;}#mermaid-svg-XqZ19Gdk79LGThdG .actorPopupMenuPanel{position:absolute;fill:#ECECFF;box-shadow:0px 8px 16px 0px rgba(0,0,0,0.2);filter:drop-shadow(3px 5px 2px rgb(0 0 0 \/ 0.4));}#mermaid-svg-XqZ19Gdk79LGThdG .actor-man line{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;}#mermaid-svg-XqZ19Gdk79LGThdG .actor-man circle,#mermaid-svg-XqZ19Gdk79LGThdG line{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;stroke-width:2px;}#mermaid-svg-XqZ19Gdk79LGThdG :root{&#8211;mermaid-font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;}\u4fdd\u6301\u8fde\u63a5\u5f00\u653e\u6301\u7eed\u4f20\u8f93&#8230;\u53d1\u9001HTTP\u8bf7\u6c42Accept: text\/event-stream\u8fd4\u56de200 OKContent-Type: text\/event-streamdata: \u6d88\u606f1\\\\n\\\\ndata: \u6d88\u606f2\\\\n\\\\ndata: \u6d88\u606f3\\\\n\\\\n\u8fde\u63a5\u65ad\u5f00\u81ea\u52a8\u91cd\u8fde\u8bf7\u6c42Last-Event-ID: xxx\u7ee7\u7eed\u53d1\u9001\u540e\u7eed\u6d88\u606f<\/p>\n<h4>2.2 SSE\u6570\u636e\u683c\u5f0f<\/h4>\n<p>SSE\u7684\u4f20\u8f93\u683c\u5f0f\u975e\u5e38\u7b80\u5355&#xff0c;\u6bcf\u6761\u6d88\u606f\u7531\u4e00\u4e2a\u6216\u591a\u4e2a\u5b57\u6bb5\u7ec4\u6210&#xff0c;\u4ee5\u6362\u884c\u7b26\u5206\u9694&#xff1a;<\/p>\n<p>\u5b57\u6bb5\u540d: \u503c\\\\n<\/p>\n<p>\u5e38\u7528\u5b57\u6bb5&#xff1a;<\/p>\n<ul>\n<li>data: \u6d88\u606f\u5185\u5bb9&#xff08;\u5fc5\u9700&#xff09;<\/li>\n<li>event: \u4e8b\u4ef6\u7c7b\u578b&#xff08;\u53ef\u9009&#xff09;<\/li>\n<li>id: \u4e8b\u4ef6ID&#xff08;\u53ef\u9009&#xff09;<\/li>\n<li>retry: \u91cd\u8fde\u95f4\u9694\u65f6\u95f4&#xff08;\u53ef\u9009&#xff0c;\u5355\u4f4d\u6beb\u79d2&#xff09;<\/li>\n<\/ul>\n<p>\u793a\u4f8b&#xff1a;<\/p>\n<p>id: 1<br \/>\nevent: message<br \/>\ndata: {&#034;content&#034;: &#034;Hello SSE&#034;}<\/p>\n<p>id: 2<br \/>\nevent: notification<br \/>\ndata: {&#034;title&#034;: &#034;\u65b0\u6d88\u606f&#034;, &#034;count&#034;: 5}<\/p>\n<p>data: \u7b80\u5355\u6587\u672c\u6d88\u606f<\/p>\n<p>\u6ce8\u610f&#xff1a; \u6bcf\u6761\u6d88\u606f\u5fc5\u987b\u4ee5\u4e24\u4e2a\u6362\u884c\u7b26 \\\\n\\\\n \u7ed3\u675f\u3002<\/p>\n<h4>2.3 \u6d88\u606f\u7c7b\u578b\u5904\u7406<\/h4>\n<p>#mermaid-svg-HJDL3gbvbU1eetIe{font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;font-size:16px;fill:#333;}@keyframes edge-animation-frame{from{stroke-dashoffset:0;}}@keyframes dash{to{stroke-dashoffset:0;}}#mermaid-svg-HJDL3gbvbU1eetIe .edge-animation-slow{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 50s linear infinite;stroke-linecap:round;}#mermaid-svg-HJDL3gbvbU1eetIe .edge-animation-fast{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 20s linear infinite;stroke-linecap:round;}#mermaid-svg-HJDL3gbvbU1eetIe .error-icon{fill:#552222;}#mermaid-svg-HJDL3gbvbU1eetIe .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-HJDL3gbvbU1eetIe .edge-thickness-normal{stroke-width:1px;}#mermaid-svg-HJDL3gbvbU1eetIe .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-HJDL3gbvbU1eetIe .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-HJDL3gbvbU1eetIe .edge-thickness-invisible{stroke-width:0;fill:none;}#mermaid-svg-HJDL3gbvbU1eetIe .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-HJDL3gbvbU1eetIe .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-HJDL3gbvbU1eetIe .marker{fill:#333333;stroke:#333333;}#mermaid-svg-HJDL3gbvbU1eetIe .marker.cross{stroke:#333333;}#mermaid-svg-HJDL3gbvbU1eetIe svg{font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-HJDL3gbvbU1eetIe p{margin:0;}#mermaid-svg-HJDL3gbvbU1eetIe .label{font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;color:#333;}#mermaid-svg-HJDL3gbvbU1eetIe .cluster-label text{fill:#333;}#mermaid-svg-HJDL3gbvbU1eetIe .cluster-label span{color:#333;}#mermaid-svg-HJDL3gbvbU1eetIe .cluster-label span p{background-color:transparent;}#mermaid-svg-HJDL3gbvbU1eetIe .label text,#mermaid-svg-HJDL3gbvbU1eetIe span{fill:#333;color:#333;}#mermaid-svg-HJDL3gbvbU1eetIe .node rect,#mermaid-svg-HJDL3gbvbU1eetIe .node circle,#mermaid-svg-HJDL3gbvbU1eetIe .node ellipse,#mermaid-svg-HJDL3gbvbU1eetIe .node polygon,#mermaid-svg-HJDL3gbvbU1eetIe .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-HJDL3gbvbU1eetIe .rough-node .label text,#mermaid-svg-HJDL3gbvbU1eetIe .node .label text,#mermaid-svg-HJDL3gbvbU1eetIe .image-shape .label,#mermaid-svg-HJDL3gbvbU1eetIe .icon-shape .label{text-anchor:middle;}#mermaid-svg-HJDL3gbvbU1eetIe .node .katex path{fill:#000;stroke:#000;stroke-width:1px;}#mermaid-svg-HJDL3gbvbU1eetIe .rough-node .label,#mermaid-svg-HJDL3gbvbU1eetIe .node .label,#mermaid-svg-HJDL3gbvbU1eetIe .image-shape .label,#mermaid-svg-HJDL3gbvbU1eetIe .icon-shape .label{text-align:center;}#mermaid-svg-HJDL3gbvbU1eetIe .node.clickable{cursor:pointer;}#mermaid-svg-HJDL3gbvbU1eetIe .root .anchor path{fill:#333333!important;stroke-width:0;stroke:#333333;}#mermaid-svg-HJDL3gbvbU1eetIe .arrowheadPath{fill:#333333;}#mermaid-svg-HJDL3gbvbU1eetIe .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-HJDL3gbvbU1eetIe .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-HJDL3gbvbU1eetIe .edgeLabel{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-HJDL3gbvbU1eetIe .edgeLabel p{background-color:rgba(232,232,232, 0.8);}#mermaid-svg-HJDL3gbvbU1eetIe .edgeLabel rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-HJDL3gbvbU1eetIe .labelBkg{background-color:rgba(232, 232, 232, 0.5);}#mermaid-svg-HJDL3gbvbU1eetIe .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-HJDL3gbvbU1eetIe .cluster text{fill:#333;}#mermaid-svg-HJDL3gbvbU1eetIe .cluster span{color:#333;}#mermaid-svg-HJDL3gbvbU1eetIe div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;font-size:12px;background:hsl(80, 100%, 96.2745098039%);border:1px solid #aaaa33;border-radius:2px;pointer-events:none;z-index:100;}#mermaid-svg-HJDL3gbvbU1eetIe .flowchartTitleText{text-anchor:middle;font-size:18px;fill:#333;}#mermaid-svg-HJDL3gbvbU1eetIe rect.text{fill:none;stroke-width:0;}#mermaid-svg-HJDL3gbvbU1eetIe .icon-shape,#mermaid-svg-HJDL3gbvbU1eetIe .image-shape{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-HJDL3gbvbU1eetIe .icon-shape p,#mermaid-svg-HJDL3gbvbU1eetIe .image-shape p{background-color:rgba(232,232,232, 0.8);padding:2px;}#mermaid-svg-HJDL3gbvbU1eetIe .icon-shape rect,#mermaid-svg-HJDL3gbvbU1eetIe .image-shape rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-HJDL3gbvbU1eetIe .label-icon{display:inline-block;height:1em;overflow:visible;vertical-align:-0.125em;}#mermaid-svg-HJDL3gbvbU1eetIe .node .label-icon path{fill:currentColor;stroke:revert;stroke-width:revert;}#mermaid-svg-HJDL3gbvbU1eetIe :root{&#8211;mermaid-font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;}<span class=\"edgeLabel\"><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u662f<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u5426<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/span><span class=\"edgeLabel\"><\/span><span class=\"edgeLabel\"><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u662f<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u5426<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/span><span class=\"edgeLabel\"><\/span><span class=\"nodeLabel\"><\/p>\n<p>SSE\u6d88\u606f\u5230\u8fbe<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u6709event\u5b57\u6bb5?<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u89e6\u53d1\u5bf9\u5e94\u4e8b\u4ef6\u76d1\u542c\u5668<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u89e6\u53d1\u9ed8\u8ba4message\u4e8b\u4ef6<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u5ba2\u6237\u7aef\u5904\u7406\u7279\u5b9a\u4e8b\u4ef6<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u6709id\u5b57\u6bb5?<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u4fdd\u5b58Last-Event-ID<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u4e0d\u66f4\u65b0ID<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u65ad\u7ebf\u91cd\u8fde\u65f6\u4f7f\u7528\u6b64ID<\/p>\n<p><\/span><\/p>\n<h3>\u4e09\u3001SSE\u4e0eWebSocket\u5bf9\u6bd4<\/h3>\n<table>\n<tr>\u7279\u6027SSEWebSocket<\/tr>\n<tbody>\n<tr>\n<td>\u901a\u4fe1\u65b9\u5411<\/td>\n<td>\u5355\u5411&#xff08;\u670d\u52a1\u5668\u2192\u5ba2\u6237\u7aef&#xff09;<\/td>\n<td>\u53cc\u5411<\/td>\n<\/tr>\n<tr>\n<td>\u534f\u8bae<\/td>\n<td>HTTP<\/td>\n<td>\u72ec\u7acb\u534f\u8bae&#xff08;ws:\/\/\u6216wss:\/\/&#xff09;<\/td>\n<\/tr>\n<tr>\n<td>\u8fde\u63a5\u5efa\u7acb<\/td>\n<td>\u7b80\u5355&#xff08;\u6807\u51c6HTTP\u8bf7\u6c42&#xff09;<\/td>\n<td>\u590d\u6742&#xff08;\u63e1\u624b\u8fc7\u7a0b&#xff09;<\/td>\n<\/tr>\n<tr>\n<td>\u81ea\u52a8\u91cd\u8fde<\/td>\n<td>\u5185\u7f6e\u652f\u6301<\/td>\n<td>\u9700\u624b\u52a8\u5b9e\u73b0<\/td>\n<\/tr>\n<tr>\n<td>\u6570\u636e\u683c\u5f0f<\/td>\n<td>\u4ec5\u6587\u672c<\/td>\n<td>\u652f\u6301\u6587\u672c\u548c\u4e8c\u8fdb\u5236<\/td>\n<\/tr>\n<tr>\n<td>\u6d4f\u89c8\u5668\u652f\u6301<\/td>\n<td>\u5e7f\u6cdb\u652f\u6301<\/td>\n<td>\u5e7f\u6cdb\u652f\u6301<\/td>\n<\/tr>\n<tr>\n<td>\u670d\u52a1\u5668\u8d44\u6e90<\/td>\n<td>\u76f8\u5bf9\u8f83\u4f4e<\/td>\n<td>\u76f8\u5bf9\u8f83\u9ad8<\/td>\n<\/tr>\n<tr>\n<td>\u9002\u7528\u573a\u666f<\/td>\n<td>\u5b9e\u65f6\u901a\u77e5\u3001\u6570\u636e\u63a8\u9001<\/td>\n<td>\u804a\u5929\u3001\u6e38\u620f\u3001\u53cc\u5411\u4ea4\u4e92<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<h4>3.1 \u9009\u62e9\u5efa\u8bae<\/h4>\n<p>\u9009\u62e9SSE\u7684\u573a\u666f&#xff1a;<\/p>\n<ul>\n<li>\u670d\u52a1\u5668\u5355\u5411\u63a8\u9001\u6570\u636e<\/li>\n<li>\u9700\u8981\u81ea\u52a8\u91cd\u8fde\u673a\u5236<\/li>\n<li>\u63a8\u9001\u7684\u662f\u6587\u672c\u6570\u636e<\/li>\n<li>\u5b9e\u65f6\u901a\u77e5\u3001\u6570\u636e\u66f4\u65b0<\/li>\n<\/ul>\n<p>\u9009\u62e9WebSocket\u7684\u573a\u666f&#xff1a;<\/p>\n<ul>\n<li>\u9700\u8981\u53cc\u5411\u901a\u4fe1<\/li>\n<li>\u9700\u8981\u4f20\u8f93\u4e8c\u8fdb\u5236\u6570\u636e<\/li>\n<li>\u4f4e\u5ef6\u8fdf\u8981\u6c42\u6781\u9ad8\u7684\u5b9e\u65f6\u4ea4\u4e92<\/li>\n<li>\u804a\u5929\u3001\u534f\u4f5c\u7f16\u8f91\u3001\u5728\u7ebf\u6e38\u620f<\/li>\n<\/ul>\n<h3>\u56db\u3001SSE\u4e0e\u4f20\u7edf\u8f6e\u8be2\u5bf9\u6bd4<\/h3>\n<p>#mermaid-svg-s64Wp2AR2W2VYNQ3{font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;font-size:16px;fill:#333;}@keyframes edge-animation-frame{from{stroke-dashoffset:0;}}@keyframes dash{to{stroke-dashoffset:0;}}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edge-animation-slow{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 50s linear infinite;stroke-linecap:round;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edge-animation-fast{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 20s linear infinite;stroke-linecap:round;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .error-icon{fill:#552222;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edge-thickness-normal{stroke-width:1px;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edge-thickness-invisible{stroke-width:0;fill:none;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .marker{fill:#333333;stroke:#333333;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .marker.cross{stroke:#333333;}#mermaid-svg-s64Wp2AR2W2VYNQ3 svg{font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-s64Wp2AR2W2VYNQ3 p{margin:0;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .label{font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;color:#333;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .cluster-label text{fill:#333;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .cluster-label span{color:#333;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .cluster-label span p{background-color:transparent;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .label text,#mermaid-svg-s64Wp2AR2W2VYNQ3 span{fill:#333;color:#333;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .node rect,#mermaid-svg-s64Wp2AR2W2VYNQ3 .node circle,#mermaid-svg-s64Wp2AR2W2VYNQ3 .node ellipse,#mermaid-svg-s64Wp2AR2W2VYNQ3 .node polygon,#mermaid-svg-s64Wp2AR2W2VYNQ3 .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .rough-node .label text,#mermaid-svg-s64Wp2AR2W2VYNQ3 .node .label text,#mermaid-svg-s64Wp2AR2W2VYNQ3 .image-shape .label,#mermaid-svg-s64Wp2AR2W2VYNQ3 .icon-shape .label{text-anchor:middle;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .node .katex path{fill:#000;stroke:#000;stroke-width:1px;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .rough-node .label,#mermaid-svg-s64Wp2AR2W2VYNQ3 .node .label,#mermaid-svg-s64Wp2AR2W2VYNQ3 .image-shape .label,#mermaid-svg-s64Wp2AR2W2VYNQ3 .icon-shape .label{text-align:center;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .node.clickable{cursor:pointer;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .root .anchor path{fill:#333333!important;stroke-width:0;stroke:#333333;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .arrowheadPath{fill:#333333;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edgeLabel{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edgeLabel p{background-color:rgba(232,232,232, 0.8);}#mermaid-svg-s64Wp2AR2W2VYNQ3 .edgeLabel rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-s64Wp2AR2W2VYNQ3 .labelBkg{background-color:rgba(232, 232, 232, 0.5);}#mermaid-svg-s64Wp2AR2W2VYNQ3 .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .cluster text{fill:#333;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .cluster span{color:#333;}#mermaid-svg-s64Wp2AR2W2VYNQ3 div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;font-size:12px;background:hsl(80, 100%, 96.2745098039%);border:1px solid #aaaa33;border-radius:2px;pointer-events:none;z-index:100;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .flowchartTitleText{text-anchor:middle;font-size:18px;fill:#333;}#mermaid-svg-s64Wp2AR2W2VYNQ3 rect.text{fill:none;stroke-width:0;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .icon-shape,#mermaid-svg-s64Wp2AR2W2VYNQ3 .image-shape{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .icon-shape p,#mermaid-svg-s64Wp2AR2W2VYNQ3 .image-shape p{background-color:rgba(232,232,232, 0.8);padding:2px;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .icon-shape rect,#mermaid-svg-s64Wp2AR2W2VYNQ3 .image-shape rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-s64Wp2AR2W2VYNQ3 .label-icon{display:inline-block;height:1em;overflow:visible;vertical-align:-0.125em;}#mermaid-svg-s64Wp2AR2W2VYNQ3 .node .label-icon path{fill:currentColor;stroke:revert;stroke-width:revert;}#mermaid-svg-s64Wp2AR2W2VYNQ3 :root{&#8211;mermaid-font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;}<span class=\"nodeLabel\"><\/p>\n<p>SSE<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u4e00\u6b21\u8bf7\u6c42<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u6301\u7eed\u63a8\u9001<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u5ba2\u6237\u7aef<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u670d\u52a1\u5668<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u4f20\u7edf\u8f6e\u8be2<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u5b9a\u65f6\u8bf7\u6c42<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u8fd4\u56de\u6570\u636e<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u5ba2\u6237\u7aef<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u670d\u52a1\u5668<\/p>\n<p><\/span><\/p>\n<p>\u8f6e\u8be2\u7684\u95ee\u9898&#xff1a;<\/p>\n<ul>\n<li>\u9891\u7e41\u8bf7\u6c42\u6d88\u8017\u670d\u52a1\u5668\u8d44\u6e90<\/li>\n<li>\u6570\u636e\u5ef6\u8fdf&#xff08;\u53d6\u51b3\u4e8e\u8f6e\u8be2\u95f4\u9694&#xff09;<\/li>\n<li>\u5927\u91cf\u65e0\u6548\u8bf7\u6c42&#xff08;\u65e0\u65b0\u6570\u636e\u65f6&#xff09;<\/li>\n<\/ul>\n<p>SSE\u7684\u4f18\u52bf&#xff1a;<\/p>\n<ul>\n<li>\u4e00\u6b21\u8fde\u63a5&#xff0c;\u6301\u7eed\u63a8\u9001<\/li>\n<li>\u5b9e\u65f6\u6027\u9ad8<\/li>\n<li>\u8d44\u6e90\u6d88\u8017\u4f4e<\/li>\n<\/ul>\n<h3>\u4e94\u3001Spring Boot\u96c6\u6210SSE<\/h3>\n<h4>5.1 \u57fa\u7840\u5b9e\u73b0<\/h4>\n<p>\u521b\u5efaSSE\u63a7\u5236\u5668&#xff1a;<\/p>\n<p><span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">org<span class=\"token punctuation\">.<\/span>springframework<span class=\"token punctuation\">.<\/span>http<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">MediaType<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">org<span class=\"token punctuation\">.<\/span>springframework<span class=\"token punctuation\">.<\/span>web<span class=\"token punctuation\">.<\/span>bind<span class=\"token punctuation\">.<\/span>annotation<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">GetMapping<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">org<span class=\"token punctuation\">.<\/span>springframework<span class=\"token punctuation\">.<\/span>web<span class=\"token punctuation\">.<\/span>bind<span class=\"token punctuation\">.<\/span>annotation<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">RequestMapping<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">org<span class=\"token punctuation\">.<\/span>springframework<span class=\"token punctuation\">.<\/span>web<span class=\"token punctuation\">.<\/span>bind<span class=\"token punctuation\">.<\/span>annotation<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">RestController<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">org<span class=\"token punctuation\">.<\/span>springframework<span class=\"token punctuation\">.<\/span>web<span class=\"token punctuation\">.<\/span>servlet<span class=\"token punctuation\">.<\/span>mvc<span class=\"token punctuation\">.<\/span>method<span class=\"token punctuation\">.<\/span>annotation<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">SseEmitter<\/span><\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p><span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">java<span class=\"token punctuation\">.<\/span>io<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">IOException<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">java<span class=\"token punctuation\">.<\/span>util<span class=\"token punctuation\">.<\/span>concurrent<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">ExecutorService<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">java<span class=\"token punctuation\">.<\/span>util<span class=\"token punctuation\">.<\/span>concurrent<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">Executors<\/span><\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p><span class=\"token annotation punctuation\">&#064;RestController<\/span><br \/>\n<span class=\"token annotation punctuation\">&#064;RequestMapping<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\/sse&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">SseController<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">final<\/span> <span class=\"token class-name\">ExecutorService<\/span> executor <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">Executors<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">newCachedThreadPool<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;GetMapping<\/span><span class=\"token punctuation\">(<\/span>value <span class=\"token operator\">&#061;<\/span> <span class=\"token string\">&#034;\/stream&#034;<\/span><span class=\"token punctuation\">,<\/span> produces <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">MediaType<\/span><span class=\"token punctuation\">.<\/span><span class=\"token constant\">TEXT_EVENT_STREAM_VALUE<\/span><span class=\"token punctuation\">)<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token class-name\">SseEmitter<\/span> <span class=\"token function\">streamEvents<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">SseEmitter<\/span> emitter <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">60_000L<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span> <span class=\"token comment\">\/\/ \u8d85\u65f6\u65f6\u95f460\u79d2<\/span><\/p>\n<p>        executor<span class=\"token punctuation\">.<\/span><span class=\"token function\">execute<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">try<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                <span class=\"token keyword\">for<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token keyword\">int<\/span> i <span class=\"token operator\">&#061;<\/span> <span class=\"token number\">0<\/span><span class=\"token punctuation\">;<\/span> i <span class=\"token operator\">&lt;<\/span> <span class=\"token number\">10<\/span><span class=\"token punctuation\">;<\/span> i<span class=\"token operator\">&#043;&#043;<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                    <span class=\"token comment\">\/\/ \u6a21\u62df\u4e1a\u52a1\u5904\u7406<\/span><br \/>\n                    <span class=\"token class-name\">Thread<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">sleep<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">1000<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>                    <span class=\"token comment\">\/\/ \u53d1\u9001\u6d88\u606f<\/span><br \/>\n                    emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">send<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">event<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">id<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">valueOf<\/span><span class=\"token punctuation\">(<\/span>i<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">name<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;message&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u6d88\u606f\u5185\u5bb9: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> i<span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">reconnectTime<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">5000L<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span> <span class=\"token comment\">\/\/ \u91cd\u8fde\u95f4\u96945\u79d2<\/span><\/p>\n<p>                    <span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span>out<span class=\"token punctuation\">.<\/span><span class=\"token function\">println<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u53d1\u9001\u6d88\u606f: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> i<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                <span class=\"token punctuation\">}<\/span><\/p>\n<p>                <span class=\"token comment\">\/\/ \u53d1\u9001\u5b8c\u6210\u4e8b\u4ef6<\/span><br \/>\n                emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">complete<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">catch<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token class-name\">IOException<\/span> <span class=\"token operator\">|<\/span> <span class=\"token class-name\">InterruptedException<\/span> e<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">completeWithError<\/span><span class=\"token punctuation\">(<\/span>e<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token keyword\">return<\/span> emitter<span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h4>5.2 \u5b8c\u6574\u7684SSE\u670d\u52a1\u5b9e\u73b0<\/h4>\n<p>SSE\u670d\u52a1\u7c7b&#xff1a;<\/p>\n<p><span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">org<span class=\"token punctuation\">.<\/span>springframework<span class=\"token punctuation\">.<\/span>stereotype<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">Service<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">org<span class=\"token punctuation\">.<\/span>springframework<span class=\"token punctuation\">.<\/span>web<span class=\"token punctuation\">.<\/span>servlet<span class=\"token punctuation\">.<\/span>mvc<span class=\"token punctuation\">.<\/span>method<span class=\"token punctuation\">.<\/span>annotation<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">SseEmitter<\/span><\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p><span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">java<span class=\"token punctuation\">.<\/span>io<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">IOException<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">java<span class=\"token punctuation\">.<\/span>util<span class=\"token punctuation\">.<\/span>concurrent<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">ConcurrentHashMap<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">java<span class=\"token punctuation\">.<\/span>util<span class=\"token punctuation\">.<\/span>concurrent<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">CopyOnWriteArraySet<\/span><\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p><span class=\"token annotation punctuation\">&#064;Service<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">SseService<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token comment\">\/\/ \u5b58\u50a8\u6240\u6709\u6d3b\u8dc3\u7684SSE\u8fde\u63a5<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">final<\/span> <span class=\"token class-name\">ConcurrentHashMap<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">&gt;<\/span><\/span> emitters <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">ConcurrentHashMap<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token punctuation\">&gt;<\/span><\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token comment\">\/\/ \u5b58\u50a8\u7528\u6237ID\u5230\u8fde\u63a5ID\u7684\u6620\u5c04<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">final<\/span> <span class=\"token class-name\">ConcurrentHashMap<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">String<\/span><span class=\"token punctuation\">&gt;<\/span><\/span> userConnections <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">ConcurrentHashMap<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token punctuation\">&gt;<\/span><\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token comment\">\/\/ \u5b58\u50a8\u8ba2\u9605\u5173\u7cfb&#xff08;\u7528\u6237ID -&gt; \u8ba2\u9605\u7684\u9891\u9053&#xff09;<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">final<\/span> <span class=\"token class-name\">ConcurrentHashMap<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">CopyOnWriteArraySet<\/span><span class=\"token punctuation\">&lt;<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">&gt;<\/span><span class=\"token punctuation\">&gt;<\/span><\/span> subscriptions <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">ConcurrentHashMap<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token punctuation\">&gt;<\/span><\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u521b\u5efaSSE\u8fde\u63a5<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token class-name\">SseEmitter<\/span> <span class=\"token function\">createConnection<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">String<\/span> connectionId <span class=\"token operator\">&#061;<\/span> <span class=\"token function\">generateConnectionId<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token comment\">\/\/ \u8bbe\u7f6e\u8d85\u65f6\u65f6\u95f4\u4e3a30\u5206\u949f<\/span><br \/>\n        <span class=\"token class-name\">SseEmitter<\/span> emitter <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">30<\/span> <span class=\"token operator\">*<\/span> <span class=\"token number\">60<\/span> <span class=\"token operator\">*<\/span> <span class=\"token number\">1000L<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token comment\">\/\/ \u8fde\u63a5\u5173\u95ed\u65f6\u7684\u5904\u7406<\/span><br \/>\n        emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">onCompletion<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span>out<span class=\"token punctuation\">.<\/span><span class=\"token function\">println<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u8fde\u63a5\u5b8c\u6210: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token function\">removeConnection<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">onTimeout<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span>out<span class=\"token punctuation\">.<\/span><span class=\"token function\">println<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u8fde\u63a5\u8d85\u65f6: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token function\">removeConnection<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">onError<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span>ex<span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span>err<span class=\"token punctuation\">.<\/span><span class=\"token function\">println<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u8fde\u63a5\u9519\u8bef: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            ex<span class=\"token punctuation\">.<\/span><span class=\"token function\">printStackTrace<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token function\">removeConnection<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token comment\">\/\/ \u5b58\u50a8\u8fde\u63a5<\/span><br \/>\n        emitters<span class=\"token punctuation\">.<\/span><span class=\"token function\">put<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">,<\/span> emitter<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        userConnections<span class=\"token punctuation\">.<\/span><span class=\"token function\">put<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token comment\">\/\/ \u53d1\u9001\u8fde\u63a5\u6210\u529f\u6d88\u606f<\/span><br \/>\n        <span class=\"token keyword\">try<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">send<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">event<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                    <span class=\"token punctuation\">.<\/span><span class=\"token function\">name<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;connected&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                    <span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u8fde\u63a5\u5efa\u7acb\u6210\u529f&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                    <span class=\"token punctuation\">.<\/span><span class=\"token function\">id<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">catch<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token class-name\">IOException<\/span> e<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token function\">removeConnection<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token keyword\">throw<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">RuntimeException<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u5efa\u7acb\u8fde\u63a5\u5931\u8d25&#034;<\/span><span class=\"token punctuation\">,<\/span> e<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><\/p>\n<p>        <span class=\"token keyword\">return<\/span> emitter<span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u5411\u6307\u5b9a\u7528\u6237\u53d1\u9001\u6d88\u606f<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">boolean<\/span> <span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">String<\/span> eventName<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Object<\/span> data<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">String<\/span> connectionId <span class=\"token operator\">&#061;<\/span> userConnections<span class=\"token punctuation\">.<\/span><span class=\"token function\">get<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span>connectionId <span class=\"token operator\">&#061;&#061;<\/span> <span class=\"token keyword\">null<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">return<\/span> <span class=\"token boolean\">false<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><\/p>\n<p>        <span class=\"token keyword\">return<\/span> <span class=\"token function\">sendToConnection<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">,<\/span> eventName<span class=\"token punctuation\">,<\/span> data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u5411\u6307\u5b9a\u8fde\u63a5\u53d1\u9001\u6d88\u606f<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">boolean<\/span> <span class=\"token function\">sendToConnection<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> connectionId<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">String<\/span> eventName<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Object<\/span> data<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">SseEmitter<\/span> emitter <span class=\"token operator\">&#061;<\/span> emitters<span class=\"token punctuation\">.<\/span><span class=\"token function\">get<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span>emitter <span class=\"token operator\">&#061;&#061;<\/span> <span class=\"token keyword\">null<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">return<\/span> <span class=\"token boolean\">false<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><\/p>\n<p>        <span class=\"token keyword\">try<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">send<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">event<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                    <span class=\"token punctuation\">.<\/span><span class=\"token function\">name<\/span><span class=\"token punctuation\">(<\/span>eventName<span class=\"token punctuation\">)<\/span><br \/>\n                    <span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span>data<span class=\"token punctuation\">)<\/span><br \/>\n                    <span class=\"token punctuation\">.<\/span><span class=\"token function\">id<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">valueOf<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">currentTimeMillis<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token keyword\">return<\/span> <span class=\"token boolean\">true<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">catch<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token class-name\">IOException<\/span> e<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span>err<span class=\"token punctuation\">.<\/span><span class=\"token function\">println<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u53d1\u9001\u6d88\u606f\u5931\u8d25: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token function\">removeConnection<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token keyword\">return<\/span> <span class=\"token boolean\">false<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u5411\u6240\u6709\u8fde\u63a5\u5e7f\u64ad\u6d88\u606f<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">broadcast<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> eventName<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Object<\/span> data<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        emitters<span class=\"token punctuation\">.<\/span><span class=\"token function\">forEach<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">,<\/span> emitter<span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">try<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">send<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">event<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">name<\/span><span class=\"token punctuation\">(<\/span>eventName<span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span>data<span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">id<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">valueOf<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">currentTimeMillis<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">catch<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token class-name\">IOException<\/span> e<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                <span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span>err<span class=\"token punctuation\">.<\/span><span class=\"token function\">println<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u5e7f\u64ad\u6d88\u606f\u5931\u8d25: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                <span class=\"token function\">removeConnection<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u79fb\u9664\u8fde\u63a5<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">removeConnection<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> connectionId<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">SseEmitter<\/span> emitter <span class=\"token operator\">&#061;<\/span> emitters<span class=\"token punctuation\">.<\/span><span class=\"token function\">remove<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span>emitter <span class=\"token operator\">!&#061;<\/span> <span class=\"token keyword\">null<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">complete<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><\/p>\n<p>        <span class=\"token comment\">\/\/ \u79fb\u9664\u7528\u6237\u6620\u5c04<\/span><br \/>\n        userConnections<span class=\"token punctuation\">.<\/span><span class=\"token function\">entrySet<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">removeIf<\/span><span class=\"token punctuation\">(<\/span>entry <span class=\"token operator\">-&gt;<\/span> entry<span class=\"token punctuation\">.<\/span><span class=\"token function\">getValue<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">equals<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span>out<span class=\"token punctuation\">.<\/span><span class=\"token function\">println<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u8fde\u63a5\u5df2\u79fb\u9664: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> connectionId <span class=\"token operator\">&#043;<\/span> <span class=\"token string\">&#034;, \u5f53\u524d\u8fde\u63a5\u6570: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> emitters<span class=\"token punctuation\">.<\/span><span class=\"token function\">size<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u83b7\u53d6\u5f53\u524d\u8fde\u63a5\u6570<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">int<\/span> <span class=\"token function\">getConnectionCount<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">return<\/span> emitters<span class=\"token punctuation\">.<\/span><span class=\"token function\">size<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u751f\u6210\u8fde\u63a5ID<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token class-name\">String<\/span> <span class=\"token function\">generateConnectionId<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">return<\/span> java<span class=\"token punctuation\">.<\/span>util<span class=\"token punctuation\">.<\/span><span class=\"token constant\">UUID<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">randomUUID<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">toString<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<p>\u63a7\u5236\u5668\u4f7f\u7528\u670d\u52a1&#xff1a;<\/p>\n<p><span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">org<span class=\"token punctuation\">.<\/span>springframework<span class=\"token punctuation\">.<\/span>beans<span class=\"token punctuation\">.<\/span>factory<span class=\"token punctuation\">.<\/span>annotation<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">Autowired<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">org<span class=\"token punctuation\">.<\/span>springframework<span class=\"token punctuation\">.<\/span>http<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">MediaType<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">org<span class=\"token punctuation\">.<\/span>springframework<span class=\"token punctuation\">.<\/span>web<span class=\"token punctuation\">.<\/span>bind<span class=\"token punctuation\">.<\/span>annotation<span class=\"token punctuation\">.<\/span><\/span><span class=\"token operator\">*<\/span><\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">import<\/span> <span class=\"token import\"><span class=\"token namespace\">org<span class=\"token punctuation\">.<\/span>springframework<span class=\"token punctuation\">.<\/span>web<span class=\"token punctuation\">.<\/span>servlet<span class=\"token punctuation\">.<\/span>mvc<span class=\"token punctuation\">.<\/span>method<span class=\"token punctuation\">.<\/span>annotation<span class=\"token punctuation\">.<\/span><\/span><span class=\"token class-name\">SseEmitter<\/span><\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p><span class=\"token annotation punctuation\">&#064;RestController<\/span><br \/>\n<span class=\"token annotation punctuation\">&#064;RequestMapping<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\/api\/sse&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">SseController<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;Autowired<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token class-name\">SseService<\/span> sseService<span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u5efa\u7acbSSE\u8fde\u63a5<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token annotation punctuation\">&#064;GetMapping<\/span><span class=\"token punctuation\">(<\/span>value <span class=\"token operator\">&#061;<\/span> <span class=\"token string\">&#034;\/connect&#034;<\/span><span class=\"token punctuation\">,<\/span> produces <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">MediaType<\/span><span class=\"token punctuation\">.<\/span><span class=\"token constant\">TEXT_EVENT_STREAM_VALUE<\/span><span class=\"token punctuation\">)<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token class-name\">SseEmitter<\/span> <span class=\"token function\">connect<\/span><span class=\"token punctuation\">(<\/span><span class=\"token annotation punctuation\">&#064;RequestParam<\/span> <span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span>out<span class=\"token punctuation\">.<\/span><span class=\"token function\">println<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u7528\u6237\u8fde\u63a5: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">return<\/span> sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">createConnection<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u5411\u6307\u5b9a\u7528\u6237\u53d1\u9001\u6d88\u606f&#xff08;\u6d4b\u8bd5\u7528&#xff09;<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token annotation punctuation\">&#064;PostMapping<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\/send&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token class-name\">String<\/span> <span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span><br \/>\n            <span class=\"token annotation punctuation\">&#064;RequestParam<\/span> <span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">,<\/span><br \/>\n            <span class=\"token annotation punctuation\">&#064;RequestParam<\/span><span class=\"token punctuation\">(<\/span>defaultValue <span class=\"token operator\">&#061;<\/span> <span class=\"token string\">&#034;message&#034;<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token class-name\">String<\/span> eventName<span class=\"token punctuation\">,<\/span><br \/>\n            <span class=\"token annotation punctuation\">&#064;RequestBody<\/span> <span class=\"token class-name\">Object<\/span> data<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">boolean<\/span> success <span class=\"token operator\">&#061;<\/span> sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> eventName<span class=\"token punctuation\">,<\/span> data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">return<\/span> success <span class=\"token operator\">?<\/span> <span class=\"token string\">&#034;\u53d1\u9001\u6210\u529f&#034;<\/span> <span class=\"token operator\">:<\/span> <span class=\"token string\">&#034;\u53d1\u9001\u5931\u8d25&#xff08;\u7528\u6237\u672a\u8fde\u63a5&#xff09;&#034;<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u5e7f\u64ad\u6d88\u606f&#xff08;\u6d4b\u8bd5\u7528&#xff09;<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token annotation punctuation\">&#064;PostMapping<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\/broadcast&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token class-name\">String<\/span> <span class=\"token function\">broadcast<\/span><span class=\"token punctuation\">(<\/span><br \/>\n            <span class=\"token annotation punctuation\">&#064;RequestParam<\/span><span class=\"token punctuation\">(<\/span>defaultValue <span class=\"token operator\">&#061;<\/span> <span class=\"token string\">&#034;message&#034;<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token class-name\">String<\/span> eventName<span class=\"token punctuation\">,<\/span><br \/>\n            <span class=\"token annotation punctuation\">&#064;RequestBody<\/span> <span class=\"token class-name\">Object<\/span> data<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">broadcast<\/span><span class=\"token punctuation\">(<\/span>eventName<span class=\"token punctuation\">,<\/span> data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">return<\/span> <span class=\"token string\">&#034;\u5e7f\u64ad\u6210\u529f&#034;<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u83b7\u53d6\u5728\u7ebf\u8fde\u63a5\u6570<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token annotation punctuation\">&#064;GetMapping<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\/count&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">int<\/span> <span class=\"token function\">getConnectionCount<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">return<\/span> sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">getConnectionCount<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h4>5.3 \u5ba2\u6237\u7aef\u4ee3\u7801\u793a\u4f8b<\/h4>\n<p>JavaScript\u5ba2\u6237\u7aef&#xff1a;<\/p>\n<p><span class=\"token comment\">\/\/ \u5efa\u7acbSSE\u8fde\u63a5<\/span><br \/>\n<span class=\"token keyword\">const<\/span> userId <span class=\"token operator\">&#061;<\/span> <span class=\"token string\">&#039;user123&#039;<\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token keyword\">const<\/span> eventSource <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">EventSource<\/span><span class=\"token punctuation\">(<\/span><span class=\"token template-string\"><span class=\"token template-punctuation string\">&#096;<\/span><span class=\"token string\">http:\/\/localhost:8080\/api\/sse\/connect?userId&#061;<\/span><span class=\"token interpolation\"><span class=\"token interpolation-punctuation punctuation\">${<\/span>userId<span class=\"token interpolation-punctuation punctuation\">}<\/span><\/span><span class=\"token template-punctuation string\">&#096;<\/span><\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p><span class=\"token comment\">\/\/ \u76d1\u542c\u8fde\u63a5\u6210\u529f\u4e8b\u4ef6<\/span><br \/>\neventSource<span class=\"token punctuation\">.<\/span><span class=\"token function\">addEventListener<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;connected&#039;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token parameter\">event<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#061;&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n    console<span class=\"token punctuation\">.<\/span><span class=\"token function\">log<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;\u8fde\u63a5\u6210\u529f:&#039;<\/span><span class=\"token punctuation\">,<\/span> event<span class=\"token punctuation\">.<\/span>data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    console<span class=\"token punctuation\">.<\/span><span class=\"token function\">log<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;\u8fde\u63a5ID:&#039;<\/span><span class=\"token punctuation\">,<\/span> event<span class=\"token punctuation\">.<\/span>lastEventId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p><span class=\"token comment\">\/\/ \u76d1\u542c\u81ea\u5b9a\u4e49\u6d88\u606f\u4e8b\u4ef6<\/span><br \/>\neventSource<span class=\"token punctuation\">.<\/span><span class=\"token function\">addEventListener<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;message&#039;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token parameter\">event<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#061;&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n    console<span class=\"token punctuation\">.<\/span><span class=\"token function\">log<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;\u6536\u5230\u6d88\u606f:&#039;<\/span><span class=\"token punctuation\">,<\/span> event<span class=\"token punctuation\">.<\/span>data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token keyword\">const<\/span> data <span class=\"token operator\">&#061;<\/span> <span class=\"token constant\">JSON<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">parse<\/span><span class=\"token punctuation\">(<\/span>event<span class=\"token punctuation\">.<\/span>data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token comment\">\/\/ \u5904\u7406\u6d88\u606f&#8230;<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p><span class=\"token comment\">\/\/ \u76d1\u542c\u901a\u77e5\u4e8b\u4ef6<\/span><br \/>\neventSource<span class=\"token punctuation\">.<\/span><span class=\"token function\">addEventListener<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;notification&#039;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token parameter\">event<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#061;&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n    console<span class=\"token punctuation\">.<\/span><span class=\"token function\">log<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;\u6536\u5230\u901a\u77e5:&#039;<\/span><span class=\"token punctuation\">,<\/span> event<span class=\"token punctuation\">.<\/span>data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token keyword\">const<\/span> notification <span class=\"token operator\">&#061;<\/span> <span class=\"token constant\">JSON<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">parse<\/span><span class=\"token punctuation\">(<\/span>event<span class=\"token punctuation\">.<\/span>data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token comment\">\/\/ \u663e\u793a\u901a\u77e5&#8230;<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p><span class=\"token comment\">\/\/ \u76d1\u542c\u9519\u8bef<\/span><br \/>\neventSource<span class=\"token punctuation\">.<\/span><span class=\"token function-variable function\">onerror<\/span> <span class=\"token operator\">&#061;<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token parameter\">error<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#061;&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n    console<span class=\"token punctuation\">.<\/span><span class=\"token function\">error<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;SSE\u8fde\u63a5\u9519\u8bef:&#039;<\/span><span class=\"token punctuation\">,<\/span> error<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token comment\">\/\/ \u6d4f\u89c8\u5668\u4f1a\u81ea\u52a8\u5c1d\u8bd5\u91cd\u8fde<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p><span class=\"token comment\">\/\/ \u5173\u95ed\u8fde\u63a5<\/span><br \/>\n<span class=\"token comment\">\/\/ eventSource.close();<\/span><\/p>\n<p>\u5e26\u91cd\u8bd5\u548c\u5fc3\u8df3\u7684\u5ba2\u6237\u7aef&#xff1a;<\/p>\n<p><span class=\"token keyword\">class<\/span> <span class=\"token class-name\">SseClient<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n    <span class=\"token function\">constructor<\/span><span class=\"token punctuation\">(<\/span><span class=\"token parameter\">url<span class=\"token punctuation\">,<\/span> options <span class=\"token operator\">&#061;<\/span> <span class=\"token punctuation\">{<\/span><span class=\"token punctuation\">}<\/span><\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>url <span class=\"token operator\">&#061;<\/span> url<span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>options <span class=\"token operator\">&#061;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token literal-property property\">reconnectInterval<\/span><span class=\"token operator\">:<\/span> <span class=\"token number\">5000<\/span><span class=\"token punctuation\">,<\/span><br \/>\n            <span class=\"token literal-property property\">maxReconnectAttempts<\/span><span class=\"token operator\">:<\/span> <span class=\"token number\">10<\/span><span class=\"token punctuation\">,<\/span><br \/>\n            <span class=\"token literal-property property\">heartbeatInterval<\/span><span class=\"token operator\">:<\/span> <span class=\"token number\">30000<\/span><span class=\"token punctuation\">,<\/span><br \/>\n            <span class=\"token operator\">&#8230;<\/span>options<br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>reconnectAttempts <span class=\"token operator\">&#061;<\/span> <span class=\"token number\">0<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>eventSource <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">null<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>heartbeatTimer <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">null<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>isConnected <span class=\"token operator\">&#061;<\/span> <span class=\"token boolean\">false<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token function\">connect<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>eventSource <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">EventSource<\/span><span class=\"token punctuation\">(<\/span><span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>url<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>eventSource<span class=\"token punctuation\">.<\/span><span class=\"token function-variable function\">onopen<\/span> <span class=\"token operator\">&#061;<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#061;&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            console<span class=\"token punctuation\">.<\/span><span class=\"token function\">log<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;SSE\u8fde\u63a5\u5df2\u5efa\u7acb&#039;<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>isConnected <span class=\"token operator\">&#061;<\/span> <span class=\"token boolean\">true<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>reconnectAttempts <span class=\"token operator\">&#061;<\/span> <span class=\"token number\">0<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">startHeartbeat<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>eventSource<span class=\"token punctuation\">.<\/span><span class=\"token function-variable function\">onerror<\/span> <span class=\"token operator\">&#061;<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token parameter\">error<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#061;&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            console<span class=\"token punctuation\">.<\/span><span class=\"token function\">error<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;SSE\u8fde\u63a5\u9519\u8bef:&#039;<\/span><span class=\"token punctuation\">,<\/span> error<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>isConnected <span class=\"token operator\">&#061;<\/span> <span class=\"token boolean\">false<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">stopHeartbeat<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>            <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>reconnectAttempts <span class=\"token operator\">&lt;<\/span> <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>options<span class=\"token punctuation\">.<\/span>maxReconnectAttempts<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>reconnectAttempts<span class=\"token operator\">&#043;&#043;<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                console<span class=\"token punctuation\">.<\/span><span class=\"token function\">log<\/span><span class=\"token punctuation\">(<\/span><span class=\"token template-string\"><span class=\"token template-punctuation string\">&#096;<\/span><span class=\"token string\">\u5c1d\u8bd5\u91cd\u8fde (<\/span><span class=\"token interpolation\"><span class=\"token interpolation-punctuation punctuation\">${<\/span><span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>reconnectAttempts<span class=\"token interpolation-punctuation punctuation\">}<\/span><\/span><span class=\"token string\">\/<\/span><span class=\"token interpolation\"><span class=\"token interpolation-punctuation punctuation\">${<\/span><span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>options<span class=\"token punctuation\">.<\/span>maxReconnectAttempts<span class=\"token interpolation-punctuation punctuation\">}<\/span><\/span><span class=\"token string\">)&#8230;<\/span><span class=\"token template-punctuation string\">&#096;<\/span><\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                <span class=\"token function\">setTimeout<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#061;&gt;<\/span> <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">connect<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>options<span class=\"token punctuation\">.<\/span>reconnectInterval<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">else<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                console<span class=\"token punctuation\">.<\/span><span class=\"token function\">error<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;\u8fbe\u5230\u6700\u5927\u91cd\u8fde\u6b21\u6570&#xff0c;\u505c\u6b62\u91cd\u8fde&#039;<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token keyword\">return<\/span> <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>eventSource<span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token function\">addEventListener<\/span><span class=\"token punctuation\">(<\/span><span class=\"token parameter\">event<span class=\"token punctuation\">,<\/span> callback<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>eventSource<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>eventSource<span class=\"token punctuation\">.<\/span><span class=\"token function\">addEventListener<\/span><span class=\"token punctuation\">(<\/span>event<span class=\"token punctuation\">,<\/span> callback<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token function\">startHeartbeat<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>heartbeatTimer <span class=\"token operator\">&#061;<\/span> <span class=\"token function\">setInterval<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#061;&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>isConnected<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                console<span class=\"token punctuation\">.<\/span><span class=\"token function\">log<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;\u5fc3\u8df3\u68c0\u6d4b&#039;<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>options<span class=\"token punctuation\">.<\/span>heartbeatInterval<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token function\">stopHeartbeat<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>heartbeatTimer<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token function\">clearInterval<\/span><span class=\"token punctuation\">(<\/span><span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>heartbeatTimer<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>heartbeatTimer <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">null<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token function\">close<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">stopHeartbeat<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>eventSource<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>eventSource<span class=\"token punctuation\">.<\/span><span class=\"token function\">close<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>eventSource <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">null<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><br \/>\n        <span class=\"token keyword\">this<\/span><span class=\"token punctuation\">.<\/span>isConnected <span class=\"token operator\">&#061;<\/span> <span class=\"token boolean\">false<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<p><span class=\"token comment\">\/\/ \u4f7f\u7528\u793a\u4f8b<\/span><br \/>\n<span class=\"token keyword\">const<\/span> sseClient <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">SseClient<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;http:\/\/localhost:8080\/api\/sse\/connect?userId&#061;user123&#039;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n    <span class=\"token literal-property property\">reconnectInterval<\/span><span class=\"token operator\">:<\/span> <span class=\"token number\">3000<\/span><span class=\"token punctuation\">,<\/span><br \/>\n    <span class=\"token literal-property property\">maxReconnectAttempts<\/span><span class=\"token operator\">:<\/span> <span class=\"token number\">5<\/span><span class=\"token punctuation\">,<\/span><br \/>\n    <span class=\"token literal-property property\">heartbeatInterval<\/span><span class=\"token operator\">:<\/span> <span class=\"token number\">60000<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>sseClient<span class=\"token punctuation\">.<\/span><span class=\"token function\">connect<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>sseClient<span class=\"token punctuation\">.<\/span><span class=\"token function\">addEventListener<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;message&#039;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token parameter\">event<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#061;&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n    console<span class=\"token punctuation\">.<\/span><span class=\"token function\">log<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;\u6536\u5230\u6d88\u606f:&#039;<\/span><span class=\"token punctuation\">,<\/span> event<span class=\"token punctuation\">.<\/span>data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>sseClient<span class=\"token punctuation\">.<\/span><span class=\"token function\">addEventListener<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;notification&#039;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token parameter\">event<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#061;&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n    console<span class=\"token punctuation\">.<\/span><span class=\"token function\">log<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#039;\u6536\u5230\u901a\u77e5:&#039;<\/span><span class=\"token punctuation\">,<\/span> event<span class=\"token punctuation\">.<\/span>data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p><span class=\"token comment\">\/\/ \u5173\u95ed\u8fde\u63a5<\/span><br \/>\n<span class=\"token comment\">\/\/ sseClient.close();<\/span><\/p>\n<h3>\u516d\u3001\u5b9e\u9645\u5e94\u7528\u573a\u666f<\/h3>\n<h4>6.1 \u5b9e\u65f6\u6d88\u606f\u901a\u77e5<\/h4>\n<p>#mermaid-svg-b1TpQYOgGV9xnVI2{font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;font-size:16px;fill:#333;}@keyframes edge-animation-frame{from{stroke-dashoffset:0;}}@keyframes dash{to{stroke-dashoffset:0;}}#mermaid-svg-b1TpQYOgGV9xnVI2 .edge-animation-slow{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 50s linear infinite;stroke-linecap:round;}#mermaid-svg-b1TpQYOgGV9xnVI2 .edge-animation-fast{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 20s linear infinite;stroke-linecap:round;}#mermaid-svg-b1TpQYOgGV9xnVI2 .error-icon{fill:#552222;}#mermaid-svg-b1TpQYOgGV9xnVI2 .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-b1TpQYOgGV9xnVI2 .edge-thickness-normal{stroke-width:1px;}#mermaid-svg-b1TpQYOgGV9xnVI2 .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-b1TpQYOgGV9xnVI2 .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-b1TpQYOgGV9xnVI2 .edge-thickness-invisible{stroke-width:0;fill:none;}#mermaid-svg-b1TpQYOgGV9xnVI2 .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-b1TpQYOgGV9xnVI2 .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-b1TpQYOgGV9xnVI2 .marker{fill:#333333;stroke:#333333;}#mermaid-svg-b1TpQYOgGV9xnVI2 .marker.cross{stroke:#333333;}#mermaid-svg-b1TpQYOgGV9xnVI2 svg{font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-b1TpQYOgGV9xnVI2 p{margin:0;}#mermaid-svg-b1TpQYOgGV9xnVI2 .label{font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;color:#333;}#mermaid-svg-b1TpQYOgGV9xnVI2 .cluster-label text{fill:#333;}#mermaid-svg-b1TpQYOgGV9xnVI2 .cluster-label span{color:#333;}#mermaid-svg-b1TpQYOgGV9xnVI2 .cluster-label span p{background-color:transparent;}#mermaid-svg-b1TpQYOgGV9xnVI2 .label text,#mermaid-svg-b1TpQYOgGV9xnVI2 span{fill:#333;color:#333;}#mermaid-svg-b1TpQYOgGV9xnVI2 .node rect,#mermaid-svg-b1TpQYOgGV9xnVI2 .node circle,#mermaid-svg-b1TpQYOgGV9xnVI2 .node ellipse,#mermaid-svg-b1TpQYOgGV9xnVI2 .node polygon,#mermaid-svg-b1TpQYOgGV9xnVI2 .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-b1TpQYOgGV9xnVI2 .rough-node .label text,#mermaid-svg-b1TpQYOgGV9xnVI2 .node .label text,#mermaid-svg-b1TpQYOgGV9xnVI2 .image-shape .label,#mermaid-svg-b1TpQYOgGV9xnVI2 .icon-shape .label{text-anchor:middle;}#mermaid-svg-b1TpQYOgGV9xnVI2 .node .katex path{fill:#000;stroke:#000;stroke-width:1px;}#mermaid-svg-b1TpQYOgGV9xnVI2 .rough-node .label,#mermaid-svg-b1TpQYOgGV9xnVI2 .node .label,#mermaid-svg-b1TpQYOgGV9xnVI2 .image-shape .label,#mermaid-svg-b1TpQYOgGV9xnVI2 .icon-shape .label{text-align:center;}#mermaid-svg-b1TpQYOgGV9xnVI2 .node.clickable{cursor:pointer;}#mermaid-svg-b1TpQYOgGV9xnVI2 .root .anchor path{fill:#333333!important;stroke-width:0;stroke:#333333;}#mermaid-svg-b1TpQYOgGV9xnVI2 .arrowheadPath{fill:#333333;}#mermaid-svg-b1TpQYOgGV9xnVI2 .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-b1TpQYOgGV9xnVI2 .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-b1TpQYOgGV9xnVI2 .edgeLabel{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-b1TpQYOgGV9xnVI2 .edgeLabel p{background-color:rgba(232,232,232, 0.8);}#mermaid-svg-b1TpQYOgGV9xnVI2 .edgeLabel rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-b1TpQYOgGV9xnVI2 .labelBkg{background-color:rgba(232, 232, 232, 0.5);}#mermaid-svg-b1TpQYOgGV9xnVI2 .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-b1TpQYOgGV9xnVI2 .cluster text{fill:#333;}#mermaid-svg-b1TpQYOgGV9xnVI2 .cluster span{color:#333;}#mermaid-svg-b1TpQYOgGV9xnVI2 div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;font-size:12px;background:hsl(80, 100%, 96.2745098039%);border:1px solid #aaaa33;border-radius:2px;pointer-events:none;z-index:100;}#mermaid-svg-b1TpQYOgGV9xnVI2 .flowchartTitleText{text-anchor:middle;font-size:18px;fill:#333;}#mermaid-svg-b1TpQYOgGV9xnVI2 rect.text{fill:none;stroke-width:0;}#mermaid-svg-b1TpQYOgGV9xnVI2 .icon-shape,#mermaid-svg-b1TpQYOgGV9xnVI2 .image-shape{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-b1TpQYOgGV9xnVI2 .icon-shape p,#mermaid-svg-b1TpQYOgGV9xnVI2 .image-shape p{background-color:rgba(232,232,232, 0.8);padding:2px;}#mermaid-svg-b1TpQYOgGV9xnVI2 .icon-shape rect,#mermaid-svg-b1TpQYOgGV9xnVI2 .image-shape rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-b1TpQYOgGV9xnVI2 .label-icon{display:inline-block;height:1em;overflow:visible;vertical-align:-0.125em;}#mermaid-svg-b1TpQYOgGV9xnVI2 .node .label-icon path{fill:currentColor;stroke:revert;stroke-width:revert;}#mermaid-svg-b1TpQYOgGV9xnVI2 :root{&#8211;mermaid-font-family:\\&#8221;trebuchet ms\\&#8221;,verdana,arial,sans-serif;}<span class=\"edgeLabel\"><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u5efa\u7acbSSE\u8fde\u63a5<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u5b9e\u65f6\u63a8\u9001<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u8ba2\u5355\u72b6\u6001\u53d8\u66f4<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u65b0\u8bc4\u8bba<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u7cfb\u7edf\u901a\u77e5<\/p>\n<p><\/span><span class=\"edgeLabel\"><\/p>\n<p>\u663e\u793a\u901a\u77e5<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u7528\u6237<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u524d\u7aef\u9875\u9762<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u901a\u77e5\u670d\u52a1<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u8ba2\u5355\u670d\u52a1<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u8bc4\u8bba\u670d\u52a1<\/p>\n<p><\/span><span class=\"nodeLabel\"><\/p>\n<p>\u7cfb\u7edf\u670d\u52a1<\/p>\n<p><\/span><\/p>\n<p>\u5b9e\u73b0\u793a\u4f8b&#xff1a;<\/p>\n<p><span class=\"token annotation punctuation\">&#064;Service<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">NotificationService<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;Autowired<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token class-name\">SseService<\/span> sseService<span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u53d1\u9001\u8ba2\u5355\u72b6\u6001\u53d8\u66f4\u901a\u77e5<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">sendOrderNotification<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Order<\/span> order<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">Notification<\/span> notification <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">Notification<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">builder<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">type<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;order&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">title<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u8ba2\u5355\u72b6\u6001\u66f4\u65b0&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">message<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u60a8\u7684\u8ba2\u5355 &#034;<\/span> <span class=\"token operator\">&#043;<\/span> order<span class=\"token punctuation\">.<\/span><span class=\"token function\">getOrderNo<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#043;<\/span> <span class=\"token string\">&#034; \u72b6\u6001\u5df2\u53d8\u66f4\u4e3a: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> order<span class=\"token punctuation\">.<\/span><span class=\"token function\">getStatus<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span>order<span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">timestamp<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">LocalDateTime<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">now<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">build<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;notification&#034;<\/span><span class=\"token punctuation\">,<\/span> notification<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u53d1\u9001\u8bc4\u8bba\u901a\u77e5<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">sendCommentNotification<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Comment<\/span> comment<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">Notification<\/span> notification <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">Notification<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">builder<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">type<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;comment&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">title<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u65b0\u8bc4\u8bba&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">message<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u7528\u6237 &#034;<\/span> <span class=\"token operator\">&#043;<\/span> comment<span class=\"token punctuation\">.<\/span><span class=\"token function\">getAuthor<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&#043;<\/span> <span class=\"token string\">&#034; \u8bc4\u8bba\u4e86\u4f60\u7684\u6587\u7ae0&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span>comment<span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">timestamp<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">LocalDateTime<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">now<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">build<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;notification&#034;<\/span><span class=\"token punctuation\">,<\/span> notification<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h4>6.2 \u5b9e\u65f6\u6570\u636e\u5927\u5c4f<\/h4>\n<p><span class=\"token annotation punctuation\">&#064;RestController<\/span><br \/>\n<span class=\"token annotation punctuation\">&#064;RequestMapping<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\/api\/dashboard&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">DashboardController<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;Autowired<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token class-name\">SseService<\/span> sseService<span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;Autowired<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token class-name\">DataService<\/span> dataService<span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u5b9e\u65f6\u6570\u636e\u63a8\u9001<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token annotation punctuation\">&#064;GetMapping<\/span><span class=\"token punctuation\">(<\/span>value <span class=\"token operator\">&#061;<\/span> <span class=\"token string\">&#034;\/realtime&#034;<\/span><span class=\"token punctuation\">,<\/span> produces <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">MediaType<\/span><span class=\"token punctuation\">.<\/span><span class=\"token constant\">TEXT_EVENT_STREAM_VALUE<\/span><span class=\"token punctuation\">)<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token class-name\">SseEmitter<\/span> <span class=\"token function\">realtimeData<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">String<\/span> userId <span class=\"token operator\">&#061;<\/span> <span class=\"token string\">&#034;dashboard_&#034;<\/span> <span class=\"token operator\">&#043;<\/span> <span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">currentTimeMillis<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token class-name\">SseEmitter<\/span> emitter <span class=\"token operator\">&#061;<\/span> sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">createConnection<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token class-name\">ScheduledExecutorService<\/span> scheduler <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">Executors<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">newSingleThreadScheduledExecutor<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        scheduler<span class=\"token punctuation\">.<\/span><span class=\"token function\">scheduleAtFixedRate<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">try<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                <span class=\"token comment\">\/\/ \u83b7\u53d6\u5b9e\u65f6\u6570\u636e<\/span><br \/>\n                <span class=\"token class-name\">DashboardData<\/span> data <span class=\"token operator\">&#061;<\/span> dataService<span class=\"token punctuation\">.<\/span><span class=\"token function\">getRealtimeData<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>                <span class=\"token comment\">\/\/ \u63a8\u9001\u6570\u636e<\/span><br \/>\n                sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;dashboard&#034;<\/span><span class=\"token punctuation\">,<\/span> data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">catch<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token class-name\">Exception<\/span> e<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                e<span class=\"token punctuation\">.<\/span><span class=\"token function\">printStackTrace<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token number\">0<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token number\">1<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">TimeUnit<\/span><span class=\"token punctuation\">.<\/span><span class=\"token constant\">SECONDS<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span> <span class=\"token comment\">\/\/ \u6bcf\u79d2\u63a8\u9001\u4e00\u6b21<\/span><\/p>\n<p>        emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">onCompletion<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> scheduler<span class=\"token punctuation\">.<\/span><span class=\"token function\">shutdown<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">onTimeout<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> scheduler<span class=\"token punctuation\">.<\/span><span class=\"token function\">shutdown<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token keyword\">return<\/span> emitter<span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h4>6.3 \u5b9e\u65f6\u65e5\u5fd7\u76d1\u63a7<\/h4>\n<p><span class=\"token annotation punctuation\">&#064;Service<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">LogMonitorService<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;Autowired<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token class-name\">SseService<\/span> sseService<span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">final<\/span> <span class=\"token class-name\">CopyOnWriteArraySet<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">&gt;<\/span><\/span> subscribers <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">CopyOnWriteArraySet<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token punctuation\">&gt;<\/span><\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u8ba2\u9605\u65e5\u5fd7<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token class-name\">SseEmitter<\/span> <span class=\"token function\">subscribeLogs<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        subscribers<span class=\"token punctuation\">.<\/span><span class=\"token function\">add<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">return<\/span> sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">createConnection<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u63a8\u9001\u65e5\u5fd7<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">pushLog<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">LogEntry<\/span> logEntry<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token operator\">!<\/span>subscribers<span class=\"token punctuation\">.<\/span><span class=\"token function\">isEmpty<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            subscribers<span class=\"token punctuation\">.<\/span><span class=\"token function\">forEach<\/span><span class=\"token punctuation\">(<\/span>userId <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;log&#034;<\/span><span class=\"token punctuation\">,<\/span> logEntry<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u53d6\u6d88\u8ba2\u9605<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">unsubscribe<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        subscribers<span class=\"token punctuation\">.<\/span><span class=\"token function\">remove<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h4>6.4 \u8fdb\u5ea6\u6761\u63a8\u9001<\/h4>\n<p><span class=\"token annotation punctuation\">&#064;RestController<\/span><br \/>\n<span class=\"token annotation punctuation\">&#064;RequestMapping<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\/api\/task&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">TaskController<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;Autowired<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token class-name\">SseService<\/span> sseService<span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u6267\u884c\u957f\u4efb\u52a1\u5e76\u63a8\u9001\u8fdb\u5ea6<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token annotation punctuation\">&#064;GetMapping<\/span><span class=\"token punctuation\">(<\/span>value <span class=\"token operator\">&#061;<\/span> <span class=\"token string\">&#034;\/execute&#034;<\/span><span class=\"token punctuation\">,<\/span> produces <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">MediaType<\/span><span class=\"token punctuation\">.<\/span><span class=\"token constant\">TEXT_EVENT_STREAM_VALUE<\/span><span class=\"token punctuation\">)<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token class-name\">SseEmitter<\/span> <span class=\"token function\">executeTask<\/span><span class=\"token punctuation\">(<\/span><span class=\"token annotation punctuation\">&#064;RequestParam<\/span> <span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">,<\/span> <span class=\"token annotation punctuation\">&#064;RequestParam<\/span> <span class=\"token class-name\">String<\/span> taskId<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">SseEmitter<\/span> emitter <span class=\"token operator\">&#061;<\/span> sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">createConnection<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token class-name\">ExecutorService<\/span> executor <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">Executors<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">newSingleThreadExecutor<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        executor<span class=\"token punctuation\">.<\/span><span class=\"token function\">execute<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">try<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                <span class=\"token comment\">\/\/ \u63a8\u9001\u4efb\u52a1\u5f00\u59cb<\/span><br \/>\n                sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;progress&#034;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Progress<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">builder<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">taskId<\/span><span class=\"token punctuation\">(<\/span>taskId<span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">stage<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u521d\u59cb\u5316&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">percentage<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">0<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">message<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u4efb\u52a1\u5f00\u59cb&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">build<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>                <span class=\"token comment\">\/\/ \u6a21\u62df\u4efb\u52a1\u6267\u884c<\/span><br \/>\n                <span class=\"token keyword\">for<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token keyword\">int<\/span> i <span class=\"token operator\">&#061;<\/span> <span class=\"token number\">0<\/span><span class=\"token punctuation\">;<\/span> i <span class=\"token operator\">&lt;&#061;<\/span> <span class=\"token number\">100<\/span><span class=\"token punctuation\">;<\/span> i <span class=\"token operator\">&#043;&#061;<\/span> <span class=\"token number\">10<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                    <span class=\"token class-name\">Thread<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">sleep<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">1000<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>                    sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;progress&#034;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Progress<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">builder<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">taskId<\/span><span class=\"token punctuation\">(<\/span>taskId<span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">stage<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u5904\u7406\u4e2d&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">percentage<\/span><span class=\"token punctuation\">(<\/span>i<span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">message<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u6b63\u5728\u5904\u7406&#8230; &#034;<\/span> <span class=\"token operator\">&#043;<\/span> i <span class=\"token operator\">&#043;<\/span> <span class=\"token string\">&#034;%&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">build<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                <span class=\"token punctuation\">}<\/span><\/p>\n<p>                <span class=\"token comment\">\/\/ \u4efb\u52a1\u5b8c\u6210<\/span><br \/>\n                sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;progress&#034;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Progress<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">builder<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">taskId<\/span><span class=\"token punctuation\">(<\/span>taskId<span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">stage<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u5b8c\u6210&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">percentage<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">100<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">message<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u4efb\u52a1\u5b8c\u6210&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">build<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>                sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;complete&#034;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">TaskResult<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">builder<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">taskId<\/span><span class=\"token punctuation\">(<\/span>taskId<span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">success<\/span><span class=\"token punctuation\">(<\/span><span class=\"token boolean\">true<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">message<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u4efb\u52a1\u6267\u884c\u6210\u529f&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">build<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>                emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">complete<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">catch<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token class-name\">Exception<\/span> e<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;error&#034;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">TaskResult<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">builder<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">taskId<\/span><span class=\"token punctuation\">(<\/span>taskId<span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">success<\/span><span class=\"token punctuation\">(<\/span><span class=\"token boolean\">false<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">message<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u4efb\u52a1\u6267\u884c\u5931\u8d25: &#034;<\/span> <span class=\"token operator\">&#043;<\/span> e<span class=\"token punctuation\">.<\/span><span class=\"token function\">getMessage<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                        <span class=\"token punctuation\">.<\/span><span class=\"token function\">build<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">completeWithError<\/span><span class=\"token punctuation\">(<\/span>e<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">finally<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                executor<span class=\"token punctuation\">.<\/span><span class=\"token function\">shutdown<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token keyword\">return<\/span> emitter<span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h3>\u4e03\u3001\u751f\u4ea7\u73af\u5883\u6700\u4f73\u5b9e\u8df5<\/h3>\n<h4>7.1 \u8fde\u63a5\u7ba1\u7406<\/h4>\n<p><span class=\"token annotation punctuation\">&#064;Service<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">SseConnectionManager<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">final<\/span> <span class=\"token class-name\">ConcurrentHashMap<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">&gt;<\/span><\/span> emitters <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">ConcurrentHashMap<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token punctuation\">&gt;<\/span><\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">final<\/span> <span class=\"token class-name\">ScheduledExecutorService<\/span> scheduler <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">Executors<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">newScheduledThreadPool<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">1<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;PostConstruct<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">init<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token comment\">\/\/ \u5b9a\u671f\u6e05\u7406\u8fc7\u671f\u8fde\u63a5<\/span><br \/>\n        scheduler<span class=\"token punctuation\">.<\/span><span class=\"token function\">scheduleAtFixedRate<\/span><span class=\"token punctuation\">(<\/span><span class=\"token keyword\">this<\/span><span class=\"token operator\">::<\/span><span class=\"token function\">cleanExpiredConnections<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token number\">5<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token number\">5<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">TimeUnit<\/span><span class=\"token punctuation\">.<\/span><span class=\"token constant\">MINUTES<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">cleanExpiredConnections<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        emitters<span class=\"token punctuation\">.<\/span><span class=\"token function\">forEach<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span>id<span class=\"token punctuation\">,<\/span> emitter<span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">try<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                <span class=\"token comment\">\/\/ \u53d1\u9001\u5fc3\u8df3\u68c0\u6d4b<\/span><br \/>\n                emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">send<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">event<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">name<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;heartbeat&#034;<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;ping&#034;<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">catch<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token class-name\">IOException<\/span> e<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                <span class=\"token comment\">\/\/ \u53d1\u9001\u5931\u8d25&#xff0c;\u79fb\u9664\u8fde\u63a5<\/span><br \/>\n                <span class=\"token function\">removeConnection<\/span><span class=\"token punctuation\">(<\/span>id<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;PreDestroy<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">destroy<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        scheduler<span class=\"token punctuation\">.<\/span><span class=\"token function\">shutdown<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        emitters<span class=\"token punctuation\">.<\/span><span class=\"token function\">forEach<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span>id<span class=\"token punctuation\">,<\/span> emitter<span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">complete<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        emitters<span class=\"token punctuation\">.<\/span><span class=\"token function\">clear<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h4>7.2 \u6d88\u606f\u961f\u5217\u96c6\u6210<\/h4>\n<p><span class=\"token annotation punctuation\">&#064;Service<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">SseMessageQueueService<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;Autowired<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token class-name\">SseService<\/span> sseService<span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;Autowired<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token class-name\">RabbitTemplate<\/span> rabbitTemplate<span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u53d1\u9001\u6d88\u606f\u5230\u961f\u5217<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">sendMessageToQueue<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">String<\/span> eventName<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Object<\/span> data<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">SseMessage<\/span> message <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">SseMessage<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">builder<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">userId<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">eventName<\/span><span class=\"token punctuation\">(<\/span>eventName<span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span>data<span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">timestamp<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">LocalDateTime<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">now<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">build<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        rabbitTemplate<span class=\"token punctuation\">.<\/span><span class=\"token function\">convertAndSend<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;sse.exchange&#034;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;sse.routing&#034;<\/span><span class=\"token punctuation\">,<\/span> message<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u4ece\u961f\u5217\u6d88\u8d39\u6d88\u606f\u5e76\u63a8\u9001<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token annotation punctuation\">&#064;RabbitListener<\/span><span class=\"token punctuation\">(<\/span>queues <span class=\"token operator\">&#061;<\/span> <span class=\"token string\">&#034;sse.queue&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">handleSseMessage<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">SseMessage<\/span> message<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>message<span class=\"token punctuation\">.<\/span><span class=\"token function\">getUserId<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">,<\/span> message<span class=\"token punctuation\">.<\/span><span class=\"token function\">getEventName<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">,<\/span> message<span class=\"token punctuation\">.<\/span><span class=\"token function\">getData<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h4>7.3 \u5206\u5e03\u5f0f\u73af\u5883\u652f\u6301<\/h4>\n<p><span class=\"token annotation punctuation\">&#064;Service<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">DistributedSseService<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;Autowired<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token class-name\">RedisTemplate<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Object<\/span><span class=\"token punctuation\">&gt;<\/span><\/span> redisTemplate<span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;Autowired<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token class-name\">SseService<\/span> sseService<span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u53d1\u5e03\u6d88\u606f\u5230Redis<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">publishMessage<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> channel<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">String<\/span> eventName<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Object<\/span> data<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">SseMessage<\/span> message <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">SseMessage<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">builder<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">eventName<\/span><span class=\"token punctuation\">(<\/span>eventName<span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span>data<span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">timestamp<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">LocalDateTime<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">now<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">build<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        redisTemplate<span class=\"token punctuation\">.<\/span><span class=\"token function\">convertAndSend<\/span><span class=\"token punctuation\">(<\/span>channel<span class=\"token punctuation\">,<\/span> message<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u8ba2\u9605Redis\u6d88\u606f<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token annotation punctuation\">&#064;PostConstruct<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">subscribeChannels<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        redisTemplate<span class=\"token punctuation\">.<\/span><span class=\"token function\">getConnectionFactory<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">getConnection<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">subscribe<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span>message<span class=\"token punctuation\">,<\/span> pattern<span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                    <span class=\"token keyword\">try<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                        <span class=\"token class-name\">SseMessage<\/span> sseMessage <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">JsonUtils<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">fromJson<\/span><span class=\"token punctuation\">(<\/span><br \/>\n                                <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">String<\/span><span class=\"token punctuation\">(<\/span>message<span class=\"token punctuation\">.<\/span><span class=\"token function\">getBody<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">,<\/span><br \/>\n                                <span class=\"token class-name\">SseMessage<\/span><span class=\"token punctuation\">.<\/span><span class=\"token keyword\">class<\/span><br \/>\n                        <span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>                        <span class=\"token comment\">\/\/ \u5e7f\u64ad\u7ed9\u5f53\u524d\u670d\u52a1\u5668\u7684\u6240\u6709\u8fde\u63a5<\/span><br \/>\n                        sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">broadcast<\/span><span class=\"token punctuation\">(<\/span>sseMessage<span class=\"token punctuation\">.<\/span><span class=\"token function\">getEventName<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">,<\/span> sseMessage<span class=\"token punctuation\">.<\/span><span class=\"token function\">getData<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                    <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">catch<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token class-name\">Exception<\/span> e<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                        e<span class=\"token punctuation\">.<\/span><span class=\"token function\">printStackTrace<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                    <span class=\"token punctuation\">}<\/span><br \/>\n                <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;sse.channel.*&#034;<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h3>\u516b\u3001\u6027\u80fd\u4f18\u5316\u5efa\u8bae<\/h3>\n<h4>8.1 \u8fde\u63a5\u6570\u9650\u5236<\/h4>\n<p><span class=\"token annotation punctuation\">&#064;Configuration<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">SseConfig<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;Bean<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token class-name\">SseService<\/span> <span class=\"token function\">sseService<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token keyword\">return<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">SseService<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">static<\/span> <span class=\"token keyword\">final<\/span> <span class=\"token keyword\">int<\/span> <span class=\"token constant\">MAX_CONNECTIONS<\/span> <span class=\"token operator\">&#061;<\/span> <span class=\"token number\">10000<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">final<\/span> <span class=\"token class-name\">AtomicInteger<\/span> connectionCount <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">AtomicInteger<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">0<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>            <span class=\"token annotation punctuation\">&#064;Override<\/span><br \/>\n            <span class=\"token keyword\">public<\/span> <span class=\"token class-name\">SseEmitter<\/span> <span class=\"token function\">createConnection<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span>connectionCount<span class=\"token punctuation\">.<\/span><span class=\"token function\">get<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&gt;&#061;<\/span> <span class=\"token constant\">MAX_CONNECTIONS<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                    <span class=\"token keyword\">throw<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">RuntimeException<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\u8fde\u63a5\u6570\u5df2\u8fbe\u4e0a\u9650&#034;<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                <span class=\"token punctuation\">}<\/span><br \/>\n                connectionCount<span class=\"token punctuation\">.<\/span><span class=\"token function\">incrementAndGet<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                <span class=\"token keyword\">return<\/span> <span class=\"token keyword\">super<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">createConnection<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span><\/p>\n<p>            <span class=\"token annotation punctuation\">&#064;Override<\/span><br \/>\n            <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">removeConnection<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> connectionId<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                <span class=\"token keyword\">super<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">removeConnection<\/span><span class=\"token punctuation\">(<\/span>connectionId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                connectionCount<span class=\"token punctuation\">.<\/span><span class=\"token function\">decrementAndGet<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h4>8.2 \u6d88\u606f\u538b\u7f29<\/h4>\n<p><span class=\"token annotation punctuation\">&#064;RestController<\/span><br \/>\n<span class=\"token annotation punctuation\">&#064;RequestMapping<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;\/api\/sse&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">CompressedSseController<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token annotation punctuation\">&#064;GetMapping<\/span><span class=\"token punctuation\">(<\/span>value <span class=\"token operator\">&#061;<\/span> <span class=\"token string\">&#034;\/compressed&#034;<\/span><span class=\"token punctuation\">,<\/span> produces <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">MediaType<\/span><span class=\"token punctuation\">.<\/span><span class=\"token constant\">TEXT_EVENT_STREAM_VALUE<\/span><span class=\"token punctuation\">)<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token class-name\">SseEmitter<\/span> <span class=\"token function\">streamCompressedEvents<\/span><span class=\"token punctuation\">(<\/span><span class=\"token annotation punctuation\">&#064;RequestParam<\/span> <span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">SseEmitter<\/span> emitter <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">60_000L<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token class-name\">ExecutorService<\/span> executor <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">Executors<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">newSingleThreadExecutor<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        executor<span class=\"token punctuation\">.<\/span><span class=\"token function\">execute<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            <span class=\"token keyword\">try<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                <span class=\"token keyword\">for<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token keyword\">int<\/span> i <span class=\"token operator\">&#061;<\/span> <span class=\"token number\">0<\/span><span class=\"token punctuation\">;<\/span> i <span class=\"token operator\">&lt;<\/span> <span class=\"token number\">100<\/span><span class=\"token punctuation\">;<\/span> i<span class=\"token operator\">&#043;&#043;<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                    <span class=\"token comment\">\/\/ \u539f\u59cb\u6570\u636e<\/span><br \/>\n                    <span class=\"token class-name\">Map<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Object<\/span><span class=\"token punctuation\">&gt;<\/span><\/span> data <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">HashMap<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token punctuation\">&gt;<\/span><\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                    data<span class=\"token punctuation\">.<\/span><span class=\"token function\">put<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;id&#034;<\/span><span class=\"token punctuation\">,<\/span> i<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                    data<span class=\"token punctuation\">.<\/span><span class=\"token function\">put<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;timestamp&#034;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">System<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">currentTimeMillis<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                    data<span class=\"token punctuation\">.<\/span><span class=\"token function\">put<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;content&#034;<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token string\">&#034;\u8fd9\u662f\u4e00\u6761\u6d4b\u8bd5\u6d88\u606f&#034;<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>                    <span class=\"token comment\">\/\/ \u5e8f\u5217\u5316\u4e3aJSON<\/span><br \/>\n                    <span class=\"token class-name\">String<\/span> json <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">JsonUtils<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">toJson<\/span><span class=\"token punctuation\">(<\/span>data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>                    <span class=\"token comment\">\/\/ \u4f7f\u7528gzip\u538b\u7f29<\/span><br \/>\n                    <span class=\"token class-name\">ByteArrayOutputStream<\/span> bos <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">ByteArrayOutputStream<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                    <span class=\"token keyword\">try<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token class-name\">GZIPOutputStream<\/span> gzip <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">GZIPOutputStream<\/span><span class=\"token punctuation\">(<\/span>bos<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                        gzip<span class=\"token punctuation\">.<\/span><span class=\"token function\">write<\/span><span class=\"token punctuation\">(<\/span>json<span class=\"token punctuation\">.<\/span><span class=\"token function\">getBytes<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">StandardCharsets<\/span><span class=\"token punctuation\">.<\/span><span class=\"token constant\">UTF_8<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                    <span class=\"token punctuation\">}<\/span><\/p>\n<p>                    <span class=\"token comment\">\/\/ \u53d1\u9001\u538b\u7f29\u540e\u7684\u6570\u636e<\/span><br \/>\n                    emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">send<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">event<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">name<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;message&#034;<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">Base64<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">getEncoder<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">encodeToString<\/span><span class=\"token punctuation\">(<\/span>bos<span class=\"token punctuation\">.<\/span><span class=\"token function\">toByteArray<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                            <span class=\"token punctuation\">.<\/span><span class=\"token function\">comment<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;gzip&#034;<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>                    <span class=\"token class-name\">Thread<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">sleep<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">1000<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n                <span class=\"token punctuation\">}<\/span><br \/>\n                emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">complete<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">catch<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token class-name\">Exception<\/span> e<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">completeWithError<\/span><span class=\"token punctuation\">(<\/span>e<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">finally<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n                executor<span class=\"token punctuation\">.<\/span><span class=\"token function\">shutdown<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n            <span class=\"token punctuation\">}<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token keyword\">return<\/span> emitter<span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h3>\u4e5d\u3001\u5e38\u89c1\u95ee\u9898\u4e0e\u89e3\u51b3\u65b9\u6848<\/h3>\n<h4>9.1 \u8fde\u63a5\u8d85\u65f6\u95ee\u9898<\/h4>\n<p>\u95ee\u9898&#xff1a; SSE\u8fde\u63a5\u5728\u4e00\u6bb5\u65f6\u95f4\u540e\u81ea\u52a8\u65ad\u5f00<\/p>\n<p>\u89e3\u51b3\u65b9\u6848&#xff1a;<\/p>\n<p><span class=\"token comment\">\/\/ 1. \u8bbe\u7f6e\u5408\u7406\u7684\u8d85\u65f6\u65f6\u95f4<\/span><br \/>\n<span class=\"token class-name\">SseEmitter<\/span> emitter <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">(<\/span><span class=\"token number\">30<\/span> <span class=\"token operator\">*<\/span> <span class=\"token number\">60<\/span> <span class=\"token operator\">*<\/span> <span class=\"token number\">1000L<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span> <span class=\"token comment\">\/\/ 30\u5206\u949f<\/span><\/p>\n<p><span class=\"token comment\">\/\/ 2. \u5b9a\u671f\u53d1\u9001\u5fc3\u8df3\u4fdd\u6301\u8fde\u63a5<\/span><br \/>\nscheduledExecutor<span class=\"token punctuation\">.<\/span><span class=\"token function\">scheduleAtFixedRate<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">-&gt;<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n    <span class=\"token keyword\">try<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">send<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">SseEmitter<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">event<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">name<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;heartbeat&#034;<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span><span class=\"token string\">&#034;ping&#034;<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span> <span class=\"token keyword\">catch<\/span> <span class=\"token punctuation\">(<\/span><span class=\"token class-name\">IOException<\/span> e<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        emitter<span class=\"token punctuation\">.<\/span><span class=\"token function\">completeWithError<\/span><span class=\"token punctuation\">(<\/span>e<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token number\">0<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token number\">30<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">TimeUnit<\/span><span class=\"token punctuation\">.<\/span><span class=\"token constant\">SECONDS<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span> <span class=\"token comment\">\/\/ \u6bcf30\u79d2\u53d1\u9001\u4e00\u6b21\u5fc3\u8df3<\/span><\/p>\n<h4>9.2 \u6d88\u606f\u4e22\u5931\u95ee\u9898<\/h4>\n<p>\u95ee\u9898&#xff1a; \u5ba2\u6237\u7aef\u65ad\u7ebf\u91cd\u8fde\u540e\u4e22\u5931\u90e8\u5206\u6d88\u606f<\/p>\n<p>\u89e3\u51b3\u65b9\u6848&#xff1a;<\/p>\n<p><span class=\"token annotation punctuation\">&#064;Service<\/span><br \/>\n<span class=\"token keyword\">public<\/span> <span class=\"token keyword\">class<\/span> <span class=\"token class-name\">ReliableSseService<\/span> <span class=\"token punctuation\">{<\/span><\/p>\n<p>    <span class=\"token comment\">\/\/ \u5b58\u50a8\u6d88\u606f\u5386\u53f2<\/span><br \/>\n    <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">final<\/span> <span class=\"token class-name\">ConcurrentHashMap<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token class-name\">String<\/span><span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">LinkedList<\/span><span class=\"token punctuation\">&lt;<\/span><span class=\"token class-name\">SseMessage<\/span><span class=\"token punctuation\">&gt;<\/span><span class=\"token punctuation\">&gt;<\/span><\/span> messageHistory <span class=\"token operator\">&#061;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">ConcurrentHashMap<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token punctuation\">&gt;<\/span><\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token keyword\">private<\/span> <span class=\"token keyword\">static<\/span> <span class=\"token keyword\">final<\/span> <span class=\"token keyword\">int<\/span> <span class=\"token constant\">MAX_HISTORY_SIZE<\/span> <span class=\"token operator\">&#061;<\/span> <span class=\"token number\">100<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u53d1\u9001\u6d88\u606f\u5e76\u4fdd\u5b58\u5386\u53f2<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">sendWithHistory<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">String<\/span> eventName<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">Object<\/span> data<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">SseMessage<\/span> message <span class=\"token operator\">&#061;<\/span> <span class=\"token class-name\">SseMessage<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">builder<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">id<\/span><span class=\"token punctuation\">(<\/span><span class=\"token function\">generateMessageId<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">eventName<\/span><span class=\"token punctuation\">(<\/span>eventName<span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">data<\/span><span class=\"token punctuation\">(<\/span>data<span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">timestamp<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">LocalDateTime<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">now<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">build<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token comment\">\/\/ \u4fdd\u5b58\u5230\u5386\u53f2<\/span><br \/>\n        messageHistory<span class=\"token punctuation\">.<\/span><span class=\"token function\">computeIfAbsent<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> k <span class=\"token operator\">-&gt;<\/span> <span class=\"token keyword\">new<\/span> <span class=\"token class-name\">LinkedList<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token punctuation\">&gt;<\/span><\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                <span class=\"token punctuation\">.<\/span><span class=\"token function\">addLast<\/span><span class=\"token punctuation\">(<\/span>message<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><\/p>\n<p>        <span class=\"token comment\">\/\/ \u9650\u5236\u5386\u53f2\u5927\u5c0f<\/span><br \/>\n        <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span>messageHistory<span class=\"token punctuation\">.<\/span><span class=\"token function\">get<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">size<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&gt;<\/span> <span class=\"token constant\">MAX_HISTORY_SIZE<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            messageHistory<span class=\"token punctuation\">.<\/span><span class=\"token function\">get<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">removeFirst<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><\/p>\n<p>        <span class=\"token comment\">\/\/ \u53d1\u9001\u6d88\u606f<\/span><br \/>\n        sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> eventName<span class=\"token punctuation\">,<\/span> data<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><\/p>\n<p>    <span class=\"token comment\">\/**<br \/>\n     * \u91cd\u8fde\u65f6\u53d1\u9001\u5386\u53f2\u6d88\u606f<br \/>\n     *\/<\/span><br \/>\n    <span class=\"token keyword\">public<\/span> <span class=\"token keyword\">void<\/span> <span class=\"token function\">sendHistoryOnReconnect<\/span><span class=\"token punctuation\">(<\/span><span class=\"token class-name\">String<\/span> userId<span class=\"token punctuation\">,<\/span> <span class=\"token class-name\">String<\/span> lastEventId<span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n        <span class=\"token class-name\">LinkedList<\/span><span class=\"token generics\"><span class=\"token punctuation\">&lt;<\/span><span class=\"token class-name\">SseMessage<\/span><span class=\"token punctuation\">&gt;<\/span><\/span> history <span class=\"token operator\">&#061;<\/span> messageHistory<span class=\"token punctuation\">.<\/span><span class=\"token function\">get<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token keyword\">if<\/span> <span class=\"token punctuation\">(<\/span>history <span class=\"token operator\">!&#061;<\/span> <span class=\"token keyword\">null<\/span><span class=\"token punctuation\">)<\/span> <span class=\"token punctuation\">{<\/span><br \/>\n            history<span class=\"token punctuation\">.<\/span><span class=\"token function\">stream<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                    <span class=\"token punctuation\">.<\/span><span class=\"token function\">filter<\/span><span class=\"token punctuation\">(<\/span>msg <span class=\"token operator\">-&gt;<\/span> msg<span class=\"token punctuation\">.<\/span><span class=\"token function\">getId<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">.<\/span><span class=\"token function\">compareTo<\/span><span class=\"token punctuation\">(<\/span>lastEventId<span class=\"token punctuation\">)<\/span> <span class=\"token operator\">&gt;<\/span> <span class=\"token number\">0<\/span><span class=\"token punctuation\">)<\/span><br \/>\n                    <span class=\"token punctuation\">.<\/span><span class=\"token function\">forEach<\/span><span class=\"token punctuation\">(<\/span>msg <span class=\"token operator\">-&gt;<\/span> sseService<span class=\"token punctuation\">.<\/span><span class=\"token function\">sendToUser<\/span><span class=\"token punctuation\">(<\/span>userId<span class=\"token punctuation\">,<\/span> msg<span class=\"token punctuation\">.<\/span><span class=\"token function\">getEventName<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">,<\/span> msg<span class=\"token punctuation\">.<\/span><span class=\"token function\">getData<\/span><span class=\"token punctuation\">(<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">)<\/span><span class=\"token punctuation\">;<\/span><br \/>\n        <span class=\"token punctuation\">}<\/span><br \/>\n    <span class=\"token punctuation\">}<\/span><br \/>\n<span class=\"token punctuation\">}<\/span><\/p>\n<h4>9.3 Nginx\u4ee3\u7406\u914d\u7f6e<\/h4>\n<p>\u95ee\u9898&#xff1a; \u901a\u8fc7Nginx\u4ee3\u7406\u540eSSE\u8fde\u63a5\u4e0d\u7a33\u5b9a<\/p>\n<p>\u89e3\u51b3\u65b9\u6848&#xff1a;<\/p>\n<p>location \/sse {<br \/>\n    proxy_pass http:\/\/backend;<br \/>\n    proxy_http_version 1.1;<br \/>\n    proxy_set_header Connection &#034;&#034;;<br \/>\n    proxy_set_header X-Accel-Buffering no;  # \u7981\u7528\u7f13\u51b2<br \/>\n    proxy_cache off;  # \u7981\u7528\u7f13\u5b58<br \/>\n    proxy_read_timeout 3600s;  # \u589e\u52a0\u8d85\u65f6\u65f6\u95f4<br \/>\n    proxy_send_timeout 3600s;<br \/>\n    chunked_transfer_encoding on;<br \/>\n}<\/p>\n<h3>\u5341\u3001\u603b\u7ed3<\/h3>\n<p>SSE\u4f5c\u4e3a\u4e00\u79cd\u8f7b\u91cf\u7ea7\u7684\u670d\u52a1\u5668\u63a8\u9001\u6280\u672f&#xff0c;\u5728\u4ee5\u4e0b\u573a\u666f\u4e2d\u5177\u6709\u660e\u663e\u4f18\u52bf&#xff1a;<\/p>\n<p>\u2705 \u9002\u7528\u573a\u666f&#xff1a;<\/p>\n<ul>\n<li>\u5b9e\u65f6\u6d88\u606f\u901a\u77e5<\/li>\n<li>\u6570\u636e\u5927\u5c4f\u5b9e\u65f6\u66f4\u65b0<\/li>\n<li>\u8fdb\u5ea6\u6761\u63a8\u9001<\/li>\n<li>\u65e5\u5fd7\u76d1\u63a7<\/li>\n<li>\u80a1\u7968\/\u4ef7\u683c\u5b9e\u65f6\u66f4\u65b0<\/li>\n<li>\u65b0\u95fb\u63a8\u9001<\/li>\n<\/ul>\n<p>\u274c \u4e0d\u9002\u7528\u573a\u666f&#xff1a;<\/p>\n<ul>\n<li>\u9700\u8981\u53cc\u5411\u901a\u4fe1\u7684\u573a\u666f&#xff08;\u4f7f\u7528WebSocket&#xff09;<\/li>\n<li>\u9700\u8981\u4f20\u8f93\u4e8c\u8fdb\u5236\u6570\u636e\u7684\u573a\u666f&#xff08;\u4f7f\u7528WebSocket&#xff09;<\/li>\n<li>\u9700\u8981\u4f4e\u5ef6\u8fdf\u9ad8\u9891\u4ea4\u4e92\u7684\u573a\u666f&#xff08;\u4f7f\u7528WebSocket&#xff09;<\/li>\n<\/ul>\n<p>\u6838\u5fc3\u4f18\u52bf&#xff1a;<\/p>\n<ul>\n<li>\u5b9e\u73b0\u7b80\u5355&#xff0c;\u57fa\u4e8e\u6807\u51c6HTTP<\/li>\n<li>\u81ea\u52a8\u91cd\u8fde\u673a\u5236<\/li>\n<li>\u670d\u52a1\u5668\u8d44\u6e90\u6d88\u8017\u4f4e<\/li>\n<li>\u6d4f\u89c8\u5668\u539f\u751f\u652f\u6301<\/li>\n<\/ul>\n<p>\u6ce8\u610f\u4e8b\u9879&#xff1a;<\/p>\n<ul>\n<li>\u6ce8\u610f\u8fde\u63a5\u8d85\u65f6\u548c\u5fc3\u8df3\u4fdd\u6301<\/li>\n<li>\u751f\u4ea7\u73af\u5883\u9700\u8981\u8003\u8651\u5206\u5e03\u5f0f\u652f\u6301<\/li>\n<li>\u5408\u7406\u63a7\u5236\u8fde\u63a5\u6570\u548c\u6d88\u606f\u9891\u7387<\/li>\n<li>\u505a\u597d\u9519\u8bef\u5904\u7406\u548c\u91cd\u8fde\u673a\u5236<\/li>\n<\/ul>\n<p>SSE\u662f\u5b9e\u65f6\u901a\u4fe1\u9886\u57df\u7684\u91cd\u8981\u5de5\u5177&#xff0c;\u638c\u63e1\u5176\u539f\u7406\u548c\u5b9e\u73b0\u65b9\u5f0f&#xff0c;\u80fd\u591f\u5e2e\u52a9\u6211\u4eec\u6784\u5efa\u66f4\u52a0\u5b9e\u65f6\u548c\u9ad8\u6548\u7684Web\u5e94\u7528\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"<p>\u4e00\u3001\u4ec0\u4e48\u662fSSE<br \/>\nSSE&#xff08;Server-Sent Events&#xff09; \u662f\u4e00\u79cd\u57fa\u4e8eHTTP\u7684\u670d\u52a1\u5668\u63a8\u9001\u6280\u672f&#xff0c;\u5141\u8bb8\u670d\u52a1\u5668\u5411\u5ba2\u6237\u7aef\u5355\u5411\u53d1\u9001\u4e8b\u4ef6\u6d41\u3002\u5b83\u662fHTML5\u89c4\u8303\u7684\u4e00\u90e8\u5206&#xff0c;\u4e13\u4e3a\u670d\u52a1\u5668\u5230\u5ba2\u6237\u7aef\u7684\u5355\u5411\u5b9e\u65f6\u901a\u4fe1\u800c\u8bbe\u8ba1\u3002<br \/>\n1.1 SSE\u7684\u6838\u5fc3\u7279\u6027<br \/>\n\u5355\u5411\u901a\u4fe1&#xff1a;\u4ec5\u652f\u6301\u670d\u52a1\u5668\u5411\u5ba2\u6237\u7aef\u63a8\u9001\u6570\u636e\u57fa\u4e8eHTTP&#xff1a;\u4f7f\u7528\u6807\u51c6HTTP\u534f\u8bae&#xff0c;\u65e0\u9700\u989d\u5916\u7684\u8fde\u63a5\u5efa\u7acb\u81ea\u52a8\u91cd\u8fde&#xff1a;\u6d4f\u89c8\u5668\u4f1a\u81ea\u52a8\u5904\u7406\u65ad\u7ebf\u91cd\u8fde\u6587\u672c\u683c\u5f0f&amp;<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[99,78],"topic":[],"class_list":["post-82232","post","type-post","status-publish","format-standard","hentry","category-server","tag-java","tag-78"],"yoast_head":"<!-- This site is optimized with the Yoast SEO plugin v20.3 - https:\/\/yoast.com\/wordpress\/plugins\/seo\/ -->\n<title>SSE\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6\u539f\u7406\u6df1\u5ea6\u89e3\u6790\u4e0e\u5b9e\u6218\u5e94\u7528 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/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.wsisp.com\/helps\/82232.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"SSE\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6\u539f\u7406\u6df1\u5ea6\u89e3\u6790\u4e0e\u5b9e\u6218\u5e94\u7528 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u4e00\u3001\u4ec0\u4e48\u662fSSE SSE&#xff08;Server-Sent Events&#xff09; \u662f\u4e00\u79cd\u57fa\u4e8eHTTP\u7684\u670d\u52a1\u5668\u63a8\u9001\u6280\u672f&#xff0c;\u5141\u8bb8\u670d\u52a1\u5668\u5411\u5ba2\u6237\u7aef\u5355\u5411\u53d1\u9001\u4e8b\u4ef6\u6d41\u3002\u5b83\u662fHTML5\u89c4\u8303\u7684\u4e00\u90e8\u5206&#xff0c;\u4e13\u4e3a\u670d\u52a1\u5668\u5230\u5ba2\u6237\u7aef\u7684\u5355\u5411\u5b9e\u65f6\u901a\u4fe1\u800c\u8bbe\u8ba1\u3002 1.1 SSE\u7684\u6838\u5fc3\u7279\u6027 \u5355\u5411\u901a\u4fe1&#xff1a;\u4ec5\u652f\u6301\u670d\u52a1\u5668\u5411\u5ba2\u6237\u7aef\u63a8\u9001\u6570\u636e\u57fa\u4e8eHTTP&#xff1a;\u4f7f\u7528\u6807\u51c6HTTP\u534f\u8bae&#xff0c;\u65e0\u9700\u989d\u5916\u7684\u8fde\u63a5\u5efa\u7acb\u81ea\u52a8\u91cd\u8fde&#xff1a;\u6d4f\u89c8\u5668\u4f1a\u81ea\u52a8\u5904\u7406\u65ad\u7ebf\u91cd\u8fde\u6587\u672c\u683c\u5f0f&amp;\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/82232.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-07-24T23:18:58+00:00\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"19 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/82232.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/82232.html\",\"name\":\"SSE\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6\u539f\u7406\u6df1\u5ea6\u89e3\u6790\u4e0e\u5b9e\u6218\u5e94\u7528 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-07-24T23:18:58+00:00\",\"dateModified\":\"2026-07-24T23:18:58+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/82232.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/82232.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/82232.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"SSE\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6\u539f\u7406\u6df1\u5ea6\u89e3\u6790\u4e0e\u5b9e\u6218\u5e94\u7528\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"SSE\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6\u539f\u7406\u6df1\u5ea6\u89e3\u6790\u4e0e\u5b9e\u6218\u5e94\u7528 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","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.wsisp.com\/helps\/82232.html","og_locale":"zh_CN","og_type":"article","og_title":"SSE\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6\u539f\u7406\u6df1\u5ea6\u89e3\u6790\u4e0e\u5b9e\u6218\u5e94\u7528 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u4e00\u3001\u4ec0\u4e48\u662fSSE SSE&#xff08;Server-Sent Events&#xff09; \u662f\u4e00\u79cd\u57fa\u4e8eHTTP\u7684\u670d\u52a1\u5668\u63a8\u9001\u6280\u672f&#xff0c;\u5141\u8bb8\u670d\u52a1\u5668\u5411\u5ba2\u6237\u7aef\u5355\u5411\u53d1\u9001\u4e8b\u4ef6\u6d41\u3002\u5b83\u662fHTML5\u89c4\u8303\u7684\u4e00\u90e8\u5206&#xff0c;\u4e13\u4e3a\u670d\u52a1\u5668\u5230\u5ba2\u6237\u7aef\u7684\u5355\u5411\u5b9e\u65f6\u901a\u4fe1\u800c\u8bbe\u8ba1\u3002 1.1 SSE\u7684\u6838\u5fc3\u7279\u6027 \u5355\u5411\u901a\u4fe1&#xff1a;\u4ec5\u652f\u6301\u670d\u52a1\u5668\u5411\u5ba2\u6237\u7aef\u63a8\u9001\u6570\u636e\u57fa\u4e8eHTTP&#xff1a;\u4f7f\u7528\u6807\u51c6HTTP\u534f\u8bae&#xff0c;\u65e0\u9700\u989d\u5916\u7684\u8fde\u63a5\u5efa\u7acb\u81ea\u52a8\u91cd\u8fde&#xff1a;\u6d4f\u89c8\u5668\u4f1a\u81ea\u52a8\u5904\u7406\u65ad\u7ebf\u91cd\u8fde\u6587\u672c\u683c\u5f0f&amp;","og_url":"https:\/\/www.wsisp.com\/helps\/82232.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-07-24T23:18:58+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"19 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/82232.html","url":"https:\/\/www.wsisp.com\/helps\/82232.html","name":"SSE\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6\u539f\u7406\u6df1\u5ea6\u89e3\u6790\u4e0e\u5b9e\u6218\u5e94\u7528 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-07-24T23:18:58+00:00","dateModified":"2026-07-24T23:18:58+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/82232.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/82232.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/82232.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"SSE\u670d\u52a1\u5668\u63a8\u9001\u4e8b\u4ef6\u539f\u7406\u6df1\u5ea6\u89e3\u6790\u4e0e\u5b9e\u6218\u5e94\u7528"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/82232","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=82232"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/82232\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=82232"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=82232"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=82232"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=82232"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}