{"id":116467,"date":"2026-10-21T14:40:31","date_gmt":"2026-10-21T06:40:31","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/116467.html"},"modified":"2026-10-21T14:40:31","modified_gmt":"2026-10-21T06:40:31","slug":"%e8%bf%94%e5%9b%9e-flux-%e5%8d%b4%e4%b8%8d%e6%98%af%e6%b5%81%e5%bc%8f%ef%bc%9fcollectlist-%e4%b8%8e-flatmap-%e5%af%bc%e8%87%b4%e7%9a%84%e9%9d%99%e9%bb%98%e9%80%80%e5%8c%96","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/116467.html","title":{"rendered":"\u8fd4\u56de Flux \u5374\u4e0d\u662f\u6d41\u5f0f\uff1fcollectList \u4e0e flatMap \u5bfc\u81f4\u7684\u9759\u9ed8\u9000\u5316"},"content":{"rendered":"

\u9879\u76ee\u80cc\u666f：LLM Gateway \u5927\u6a21\u578b\u7edf\u4e00\u63a5\u5165\u7f51\u5173（Java 17 \u00b7 Spring Boot 3.5.5 \u00b7 WebFlux \/ Reactor Netty \u00b7 Redis \u00b7 Lua）\u3002\u5bf9\u5916\u7aef\u70b9 POST \/v1\/chat\/completions \u517c\u5bb9 OpenAI \u534f\u8bae，stream: true \u65f6\u8d70 SSE \u6d41\u5f0f，\u542b [DONE] \u6536\u5c3e；\u5df2\u5b9e\u73b0\u5ba2\u6237\u7aef\u65ad\u5f00\u7ea7\u8054\u53d6\u6d88\u3001\u5757\u95f4\u7a7a\u95f2\u8d85\u65f6（idle 20s），\u5e76\u7531 StreamingContractTest \/ UpstreamStreamingTest \u8986\u76d6 SSE \u5206\u7247\u3001[DONE] \u4e0e\u574f\u5757\u8df3\u8fc7\u3002<\/p>\n

\u672c\u6587\u4ee3\u7801\u662f\u6309\u9879\u76ee\u5206\u5c42\u8fd8\u539f\u7684\u793a\u610f\u5b9e\u73b0，\u7528\u4e8e\u8bf4\u660e\u8bbe\u8ba1\u610f\u56fe，\u4e0d\u4ee3\u8868\u4ed3\u5e93\u9010\u884c\u539f\u6587\u3002<\/p>\n

\n

\u4e00\u3001\u4e1a\u52a1\u573a\u666f：\u4e3a\u4ec0\u4e48\u300c\u6d41\u5f0f\u300d\u662f\u4ea7\u54c1\u6307\u6807，\u4e0d\u662f\u6280\u672f\u70ab\u6280<\/h3>\n

\u5ba2\u670d\u7cfb\u7edf\u63a5\u4e86\u5927\u6a21\u578b\u505a\u5de5\u5355\u6458\u8981\u3002\u4ea7\u54c1\u7ecf\u7406\u63d0\u4e86\u4e00\u4e2a\u9700\u6c42：<\/p>\n

\u7528\u6237\u63d0\u95ee\u540e，3 \u79d2\u5185\u5fc5\u987b\u770b\u5230\u7b2c\u4e00\u4e2a\u5b57\u3002<\/p>\n

\u8fd9\u53e5\u8bdd\u7ffb\u8bd1\u6210\u6280\u672f\u6307\u6807\u5c31\u662f TTFT（Time To First Token，\u9996\u5b57\u8282\u65f6\u95f4）\u3002<\/p>\n

\u5bf9\u6bd4\u4e00\u4e0b\u4e24\u79cd\u5f62\u6001：<\/p>\n\n\u5f62\u6001\u7528\u6237\u611f\u77e5\u9996\u5b57\u8282\u65f6\u95f4\u5b8c\u6574\u54cd\u5e94<\/tr>\n\n\n\n
\u975e\u6d41\u5f0f<\/td>\n\u8f6c\u5708 \u2192 \u7a81\u7136\u51fa\u73b0\u6574\u6bb5\u7b54\u6848<\/td>\n\u7b49\u4e8e\u603b\u8017\u65f6（8～30s）<\/td>\n\u4e00\u6837<\/td>\n<\/tr>\n
\u6d41\u5f0f<\/td>\n\u6587\u5b57\u4e00\u4e2a\u5b57\u4e00\u4e2a\u5b57\u8e66\u51fa\u6765<\/td>\n200ms～2s<\/td>\n\u4e00\u6837<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

\u5b8c\u6574\u54cd\u5e94\u65f6\u95f4\u5176\u5b9e\u6ca1\u53d8，\u7528\u6237\u5374\u89c9\u5f97\u5feb\u4e86\u5341\u500d\u3002\u56e0\u4e3a\u4eba\u7b49\u5f85\u65f6\u7684\u7126\u8651\u611f\u6765\u81ea\u300c\u4e0d\u786e\u5b9a\u6709\u6ca1\u6709\u5728\u5e72\u6d3b\u300d，\u800c\u4e0d\u662f\u7edd\u5bf9\u65f6\u957f\u3002\u770b\u5230\u5b57\u5728\u5f80\u5916\u5192，\u7b49\u5f85\u5c31\u53d8\u6210\u4e86\u9605\u8bfb\u3002<\/p>\n

\u6240\u4ee5\u6d41\u5f0f\u80fd\u529b\u5728\u8fd9\u4e2a\u7f51\u5173\u91cc\u662f\u7b2c\u4e00\u7b49\u516c\u6c11，README \u7684\u6838\u5fc3\u80fd\u529b\u8868\u91cc\u5b83\u548c\u300cOpenAI \u534f\u8bae\u517c\u5bb9\u300d\u300c\u9650\u6d41\u300d\u662f\u5e76\u5217\u7684\u3002<\/p>\n

\u4f46\u8fd9\u91cc\u6709\u4e2a\u9677\u9631：<\/p>\n

\u8fd4\u56de\u503c\u7c7b\u578b\u5199\u7684\u662f Flux，\u4e0d\u4ee3\u8868\u6570\u636e\u771f\u7684\u662f\u6d41\u5f0f\u53d1\u51fa\u53bb\u7684\u3002<\/p>\n

\u8fd9\u4e24\u4ef6\u4e8b\u4e4b\u95f4\u9694\u7740\u65e0\u6570\u79cd\u5199\u9519\u7684\u65b9\u5f0f，\u800c\u4e14\u5927\u90e8\u5206\u5199\u9519\u65b9\u5f0f\u4e0d\u4f1a\u62a5\u9519\u3001\u4e0d\u4f1a\u629b\u5f02\u5e38\u3001\u6d4b\u8bd5\u4e5f\u53ef\u80fd\u5168\u7eff\u3002\u4f60\u53ea\u4f1a\u6536\u5230\u4e00\u6761\u4ea7\u54c1\u53cd\u9988：\u300c\u6d41\u5f0f\u597d\u50cf\u6709\u70b9\u5361\u300d\u3002<\/p>\n

\u8fd9\u5c31\u662f\u672c\u6587\u8981\u8bb2\u7684\u300c\u9759\u9ed8\u9000\u5316\u300d\u3002<\/p>\n

\n

\u4e8c\u3001\u6d41\u5f0f\u5728\u7f51\u5173\u91cc\u7684\u6570\u636e\u6d41<\/h3>\n

\u4e0a\u6e38\u5382\u5546 API<\/p>\n

OpenAiCompatibleProvider<\/p>\n

ChatController<\/p>\n

\u4e1a\u52a1\u65b9 (OpenAI SDK)<\/p>\n

\u4e0a\u6e38\u5382\u5546 API<\/p>\n

OpenAiCompatibleProvider<\/p>\n

ChatController<\/p>\n

\u4e1a\u52a1\u65b9 (OpenAI SDK)<\/p>\n

#mermaid-svg-YgkNEwKfFeEbtNRs{font-family:\\”trebuchet ms\\”,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-YgkNEwKfFeEbtNRs .edge-animation-slow{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 50s linear infinite;stroke-linecap:round;}#mermaid-svg-YgkNEwKfFeEbtNRs .edge-animation-fast{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 20s linear infinite;stroke-linecap:round;}#mermaid-svg-YgkNEwKfFeEbtNRs .error-icon{fill:#552222;}#mermaid-svg-YgkNEwKfFeEbtNRs .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-YgkNEwKfFeEbtNRs .edge-thickness-normal{stroke-width:1px;}#mermaid-svg-YgkNEwKfFeEbtNRs .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-YgkNEwKfFeEbtNRs .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-YgkNEwKfFeEbtNRs .edge-thickness-invisible{stroke-width:0;fill:none;}#mermaid-svg-YgkNEwKfFeEbtNRs .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-YgkNEwKfFeEbtNRs .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-YgkNEwKfFeEbtNRs .marker{fill:#333333;stroke:#333333;}#mermaid-svg-YgkNEwKfFeEbtNRs .marker.cross{stroke:#333333;}#mermaid-svg-YgkNEwKfFeEbtNRs svg{font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-YgkNEwKfFeEbtNRs p{margin:0;}#mermaid-svg-YgkNEwKfFeEbtNRs .actor{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;}#mermaid-svg-YgkNEwKfFeEbtNRs text.actor>tspan{fill:black;stroke:none;}#mermaid-svg-YgkNEwKfFeEbtNRs .actor-line{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);}#mermaid-svg-YgkNEwKfFeEbtNRs .innerArc{stroke-width:1.5;stroke-dasharray:none;}#mermaid-svg-YgkNEwKfFeEbtNRs .messageLine0{stroke-width:1.5;stroke-dasharray:none;stroke:#333;}#mermaid-svg-YgkNEwKfFeEbtNRs .messageLine1{stroke-width:1.5;stroke-dasharray:2,2;stroke:#333;}#mermaid-svg-YgkNEwKfFeEbtNRs #arrowhead path{fill:#333;stroke:#333;}#mermaid-svg-YgkNEwKfFeEbtNRs .sequenceNumber{fill:white;}#mermaid-svg-YgkNEwKfFeEbtNRs #sequencenumber{fill:#333;}#mermaid-svg-YgkNEwKfFeEbtNRs #crosshead path{fill:#333;stroke:#333;}#mermaid-svg-YgkNEwKfFeEbtNRs .messageText{fill:#333;stroke:none;}#mermaid-svg-YgkNEwKfFeEbtNRs .labelBox{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;}#mermaid-svg-YgkNEwKfFeEbtNRs .labelText,#mermaid-svg-YgkNEwKfFeEbtNRs .labelText>tspan{fill:black;stroke:none;}#mermaid-svg-YgkNEwKfFeEbtNRs .loopText,#mermaid-svg-YgkNEwKfFeEbtNRs .loopText>tspan{fill:black;stroke:none;}#mermaid-svg-YgkNEwKfFeEbtNRs .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-YgkNEwKfFeEbtNRs .note{stroke:#aaaa33;fill:#fff5ad;}#mermaid-svg-YgkNEwKfFeEbtNRs .noteText,#mermaid-svg-YgkNEwKfFeEbtNRs .noteText>tspan{fill:black;stroke:none;}#mermaid-svg-YgkNEwKfFeEbtNRs .activation0{fill:#f4f4f4;stroke:#666;}#mermaid-svg-YgkNEwKfFeEbtNRs .activation1{fill:#f4f4f4;stroke:#666;}#mermaid-svg-YgkNEwKfFeEbtNRs .activation2{fill:#f4f4f4;stroke:#666;}#mermaid-svg-YgkNEwKfFeEbtNRs .actorPopupMenu{position:absolute;}#mermaid-svg-YgkNEwKfFeEbtNRs .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-YgkNEwKfFeEbtNRs .actor-man line{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;}#mermaid-svg-YgkNEwKfFeEbtNRs .actor-man circle,#mermaid-svg-YgkNEwKfFeEbtNRs line{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;stroke-width:2px;}#mermaid-svg-YgkNEwKfFeEbtNRs :root{–mermaid-font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;}<\/p>\n

loop<\/p>\n

[\u9010\u5757\u900f\u4f20]<\/p>\n

POST \/v1\/chat\/completions {"stream": true}<\/p>\n

\u6309 stream \u5b57\u6bb5\u5206\u6d41<\/p>\n

WebClient.retrieve().bodyToFlux(…)<\/p>\n

chunk1 \/ chunk2 \/ chunk3 …<\/p>\n

Flux<ServerSentEvent<String>><\/p>\n

\u6bcf\u6536\u5230\u4e00\u4e2a chunk \u7acb\u523b\u6e32\u67d3<\/p>\n

[DONE]<\/p>\n

\u6d41\u7ed3\u675f<\/p>\n

\u53d1\u9001 [DONE] \u6536\u5c3e<\/p>\n

\u5173\u952e\u5728\u4e2d\u95f4\u90a3\u6761\u7ebf：\u4e0a\u6e38\u6765\u4e00\u5757，\u7f51\u5173\u5c31\u8981\u5f80\u4e0b\u6e38\u53d1\u4e00\u5757，\u4e2d\u95f4\u4efb\u4f55\u4e00\u6b65\u300c\u6512\u7740\u300d\u90fd\u4f1a\u9000\u5316\u3002<\/p>\n

\n

\u4e09\u3001\u4e09\u79cd\u9759\u9ed8\u9000\u5316，\u4e00\u4e2a\u6bd4\u4e00\u4e2a\u9690\u853d<\/h3>\n

\u4e0b\u9762\u662f\u4e09\u79cd\u9759\u9ed8\u9000\u5316\u7684\u5168\u666f\u5bf9\u6bd4，\u5148\u5efa\u7acb\u6574\u4f53\u8ba4\u77e5\u518d\u9010\u4e2a\u62c6\u89e3：<\/p>\n

#mermaid-svg-ZAP4F9C5sZMYEq6h{font-family:\\”trebuchet ms\\”,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-ZAP4F9C5sZMYEq6h .edge-animation-slow{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 50s linear infinite;stroke-linecap:round;}#mermaid-svg-ZAP4F9C5sZMYEq6h .edge-animation-fast{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 20s linear infinite;stroke-linecap:round;}#mermaid-svg-ZAP4F9C5sZMYEq6h .error-icon{fill:#552222;}#mermaid-svg-ZAP4F9C5sZMYEq6h .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-ZAP4F9C5sZMYEq6h .edge-thickness-normal{stroke-width:1px;}#mermaid-svg-ZAP4F9C5sZMYEq6h .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-ZAP4F9C5sZMYEq6h .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-ZAP4F9C5sZMYEq6h .edge-thickness-invisible{stroke-width:0;fill:none;}#mermaid-svg-ZAP4F9C5sZMYEq6h .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-ZAP4F9C5sZMYEq6h .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-ZAP4F9C5sZMYEq6h .marker{fill:#333333;stroke:#333333;}#mermaid-svg-ZAP4F9C5sZMYEq6h .marker.cross{stroke:#333333;}#mermaid-svg-ZAP4F9C5sZMYEq6h svg{font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-ZAP4F9C5sZMYEq6h p{margin:0;}#mermaid-svg-ZAP4F9C5sZMYEq6h .label{font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;color:#333;}#mermaid-svg-ZAP4F9C5sZMYEq6h .cluster-label text{fill:#333;}#mermaid-svg-ZAP4F9C5sZMYEq6h .cluster-label span{color:#333;}#mermaid-svg-ZAP4F9C5sZMYEq6h .cluster-label span p{background-color:transparent;}#mermaid-svg-ZAP4F9C5sZMYEq6h .label text,#mermaid-svg-ZAP4F9C5sZMYEq6h span{fill:#333;color:#333;}#mermaid-svg-ZAP4F9C5sZMYEq6h .node rect,#mermaid-svg-ZAP4F9C5sZMYEq6h .node circle,#mermaid-svg-ZAP4F9C5sZMYEq6h .node ellipse,#mermaid-svg-ZAP4F9C5sZMYEq6h .node polygon,#mermaid-svg-ZAP4F9C5sZMYEq6h .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-ZAP4F9C5sZMYEq6h .rough-node .label text,#mermaid-svg-ZAP4F9C5sZMYEq6h .node .label text,#mermaid-svg-ZAP4F9C5sZMYEq6h .image-shape .label,#mermaid-svg-ZAP4F9C5sZMYEq6h .icon-shape .label{text-anchor:middle;}#mermaid-svg-ZAP4F9C5sZMYEq6h .node .katex path{fill:#000;stroke:#000;stroke-width:1px;}#mermaid-svg-ZAP4F9C5sZMYEq6h .rough-node .label,#mermaid-svg-ZAP4F9C5sZMYEq6h .node .label,#mermaid-svg-ZAP4F9C5sZMYEq6h .image-shape .label,#mermaid-svg-ZAP4F9C5sZMYEq6h .icon-shape .label{text-align:center;}#mermaid-svg-ZAP4F9C5sZMYEq6h .node.clickable{cursor:pointer;}#mermaid-svg-ZAP4F9C5sZMYEq6h .root .anchor path{fill:#333333!important;stroke-width:0;stroke:#333333;}#mermaid-svg-ZAP4F9C5sZMYEq6h .arrowheadPath{fill:#333333;}#mermaid-svg-ZAP4F9C5sZMYEq6h .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-ZAP4F9C5sZMYEq6h .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-ZAP4F9C5sZMYEq6h .edgeLabel{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-ZAP4F9C5sZMYEq6h .edgeLabel p{background-color:rgba(232,232,232, 0.8);}#mermaid-svg-ZAP4F9C5sZMYEq6h .edgeLabel rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-ZAP4F9C5sZMYEq6h .labelBkg{background-color:rgba(232, 232, 232, 0.5);}#mermaid-svg-ZAP4F9C5sZMYEq6h .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-ZAP4F9C5sZMYEq6h .cluster text{fill:#333;}#mermaid-svg-ZAP4F9C5sZMYEq6h .cluster span{color:#333;}#mermaid-svg-ZAP4F9C5sZMYEq6h div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:\\”trebuchet ms\\”,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-ZAP4F9C5sZMYEq6h .flowchartTitleText{text-anchor:middle;font-size:18px;fill:#333;}#mermaid-svg-ZAP4F9C5sZMYEq6h rect.text{fill:none;stroke-width:0;}#mermaid-svg-ZAP4F9C5sZMYEq6h .icon-shape,#mermaid-svg-ZAP4F9C5sZMYEq6h .image-shape{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-ZAP4F9C5sZMYEq6h .icon-shape p,#mermaid-svg-ZAP4F9C5sZMYEq6h .image-shape p{background-color:rgba(232,232,232, 0.8);padding:2px;}#mermaid-svg-ZAP4F9C5sZMYEq6h .icon-shape .label rect,#mermaid-svg-ZAP4F9C5sZMYEq6h .image-shape .label rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-ZAP4F9C5sZMYEq6h .label-icon{display:inline-block;height:1em;overflow:visible;vertical-align:-0.125em;}#mermaid-svg-ZAP4F9C5sZMYEq6h .node .label-icon path{fill:currentColor;stroke:revert;stroke-width:revert;}#mermaid-svg-ZAP4F9C5sZMYEq6h :root{–mermaid-font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;}<\/p>\n

<\/span><\/p>\n

<\/span><\/p>\n

<\/span><\/p>\n

<\/p>\n

\u6512\u6ee1\u518d\u5410<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u5e76\u53d1\u4e71\u5e8f<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u7f13\u5b58 + \u80cc\u538b\u5931\u6548<\/p>\n

<\/span><\/p>\n

<\/span><\/p>\n

<\/span><\/p>\n

<\/span><\/p>\n

<\/span><\/p>\n

<\/p>\n

\u6d41\u5f0f\u94fe\u8def<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u9000\u5316\u4e00：collectList()<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u9000\u5316\u4e8c：flatMap \u5f02\u6b65<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u9000\u5316\u4e09：cache()<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u8f6c\u5708 15s \u2192 \u6574\u6bb5\u77ac\u95f4\u51fa\u73b0<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u53e5\u5b50\u987a\u5e8f\u88ab\u6253\u4e71<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u5185\u5b58\u66b4\u6da8 + \u4e0a\u6e38\u8bef\u5224\u6d88\u8d39\u5feb<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u7528\u6237\u611f\u77e5：\u6d41\u5f0f\u597d\u50cf\u6709\u70b9\u5361<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u7ed3\u8bba：Flux \u53ea\u662f\u7c7b\u578b，\u6d41\u5f0f\u662f\u8fd0\u884c\u65f6\u884c\u4e3a<\/p>\n

<\/span><\/p>\n

\u9000\u5316\u4e00：collectList() \u2014\u2014 \u4ece\u300c\u6d41\u5f0f\u300d\u53d8\u6210\u300c\u5206\u6279\u300d\u7684\u7ecf\u5178\u5199\u6cd5<\/h4>\n

\/\/ \u274c \u770b\u8d77\u6765\u53ea\u662f\u300c\u6536\u96c6\u4e00\u4e0b\u300d，\u5b9e\u9645\u4e0a\u628a\u6d41\u5f0f\u5f7b\u5e95\u6740\u6b7b\u4e86<\/span>
\nreturn<\/span> provider.<\/span>stream<\/span>(<\/span>request)<\/span>
\n .<\/span>collectList<\/span>(<\/span>)<\/span> \/\/ \u7b49\u5168\u90e8 chunk \u5230\u9f50，\u624d\u53d1\u51fa\u7b2c\u4e00\u4e2a\u5143\u7d20<\/span>
\n .<\/span>flatMapMany<\/span>(<\/span>Flux<\/span>::<\/span>fromIterable<\/span>)<\/span> \/\/ \u518d\u62c6\u5f00，\u5047\u88c5\u8fd8\u662f\u6d41<\/span>
\n .<\/span>map<\/span>(<\/span>this<\/span>::<\/span>toServerSentEvent<\/span>)<\/span>;<\/span><\/p>\n

\u4ece\u7c7b\u578b\u4e0a\u770b，\u5165\u53c2 Flux，\u51fa\u53c2 Flux，\u7b7e\u540d\u6ca1\u53d8，\u7f16\u8bd1\u901a\u8fc7，\u5355\u6d4b\u5982\u679c\u53ea\u770b\u300c\u6700\u7ec8\u5185\u5bb9\u5bf9\u4e0d\u5bf9\u300d\u4e5f\u5168\u7eff\u3002<\/p>\n

\u4f46\u8fd0\u884c\u65f6\u7684\u884c\u4e3a\u5df2\u7ecf\u53d8\u6210：\u6512\u6ee1 \u2192 \u4e00\u6b21\u6027\u5410\u51fa\u3002<\/p>\n

\u7528\u6237\u770b\u5230\u7684\u662f：\u8f6c\u5708 15 \u79d2，\u7136\u540e\u6574\u6bb5\u7b54\u6848\u77ac\u95f4\u51fa\u73b0\u2014\u2014\u548c\u975e\u6d41\u5f0f\u4e00\u6a21\u4e00\u6837，\u53ea\u662f\u591a\u4e86\u4e00\u5768\u5185\u5b58\u5360\u7528\u3002<\/p>\n

\u4e3a\u4ec0\u4e48\u4f1a\u6709\u4eba\u8fd9\u4e48\u5199？\u901a\u5e38\u662f\u56e0\u4e3a\u4e2d\u95f4\u8981\u505a\u4e00\u4ef6\u4e8b：<\/p>\n

\u300c\u6211\u60f3\u5728\u6240\u6709\u5206\u7247\u90fd\u6536\u5b8c\u4e4b\u540e，\u7edf\u8ba1\u4e00\u4e0b token \u7528\u91cf，\u5199\u4e00\u6761\u65e5\u5fd7\u3002\u300d<\/p>\n

\u4e8e\u662f\u987a\u624b collectList()\u3002\u4e3a\u4e86\u4e00\u4e2a\u526f\u4f5c\u7528，\u727a\u7272\u4e86\u6574\u4e2a\u6d41\u5f0f\u3002<\/p>\n

\u6b63\u786e\u59ff\u52bf\u662f\u7528 doOnComplete \/ doFinally \u8bb0\u8d26，\u6216\u8005\u7528\u4e00\u4e2a\u5e76\u53d1\u5b89\u5168\u7684\u7d2f\u52a0\u5668\u5728 doOnNext \u91cc\u7edf\u8ba1，\u7edd\u4e0d\u6539\u53d8\u6570\u636e\u7684\u4f20\u9012\u5f62\u6001\u3002<\/p>\n

\u9000\u5316\u4e8c：flatMap \u91cc\u7684\u5f02\u6b65\u5904\u7406 \u2014\u2014 \u987a\u5e8f\u88ab\u6253\u4e71<\/h4>\n

\/\/ \u274c \u6bcf\u4e2a\u5206\u7247\u4e22\u5230 boundedElastic \u4e0a\u5904\u7406，\u56de\u6765\u7684\u987a\u5e8f\u4e0d\u4fdd\u8bc1<\/span>
\nreturn<\/span> provider.<\/span>stream<\/span>(<\/span>request)<\/span>
\n .<\/span>flatMap<\/span>(<\/span>chunk -><\/span> Mono<\/span>.<\/span>fromCallable<\/span>(<\/span>(<\/span>)<\/span> -><\/span> enrich<\/span>(<\/span>chunk)<\/span>)<\/span>
\n .<\/span>subscribeOn<\/span>(<\/span>Schedulers<\/span>.<\/span>boundedElastic<\/span>(<\/span>)<\/span>)<\/span>)<\/span>
\n .<\/span>map<\/span>(<\/span>this<\/span>::<\/span>toServerSentEvent<\/span>)<\/span>;<\/span><\/p>\n

flatMap \u7684\u8bbe\u8ba1\u8bed\u4e49\u5c31\u662f\u300c\u5e76\u53d1\u5904\u7406，\u4e0d\u4fdd\u8bc1\u987a\u5e8f\u300d\u3002\u5bf9\u5927\u591a\u6570\u573a\u666f\u8fd9\u662f\u4f18\u70b9，\u5bf9\u6d41\u5f0f\u6587\u672c\u662f\u707e\u96be\u2014\u2014\u7528\u6237\u4f1a\u770b\u5230：<\/p>\n

\u4eca\u5929 \u5929\u6c14 \u5f88 \u597d<\/p>\n

\u53d8\u6210：<\/p>\n

\u5929\u6c14 \u4eca\u5929 \u5f88 \u597d<\/p>\n

\u800c\u4e14\u5b83\u65f6\u5feb\u65f6\u6162，\u538b\u6d4b\u65f6\u5076\u5c14\u80fd\u590d\u73b0，\u672c\u5730\u5f00\u53d1\u51e0\u4e4e\u6c38\u8fdc\u590d\u73b0\u4e0d\u4e86，\u56e0\u4e3a\u672c\u5730\u53ea\u6709\u4e00\u4e2a\u5206\u7247，\u6ca1\u6709\u5e76\u53d1\u3002<\/p>\n

\u4e09\u4e2a\u64cd\u4f5c\u7b26\u7684\u9009\u62e9\u5fc5\u987b\u8bb0\u7262：<\/p>\n\n\u64cd\u4f5c\u7b26\u662f\u5426\u4fdd\u5e8f\u5e76\u53d1\u9002\u7528\u573a\u666f<\/tr>\n\n\n\n\n
flatMap<\/td>\n\u274c \u4e0d\u4fdd\u5e8f<\/td>\n\u2705 \u9ad8\u5e76\u53d1<\/td>\n\u65e0\u5e8f\u7684\u72ec\u7acb\u4efb\u52a1，\u5982\u5e76\u884c\u8c03\u591a\u4e2a\u63a5\u53e3<\/td>\n<\/tr>\n
concatMap<\/td>\n\u2705 \u4e25\u683c\u4fdd\u5e8f<\/td>\n\u274c \u4e32\u884c<\/td>\n\u987a\u5e8f\u654f\u611f\u3001\u6bcf\u5757\u5904\u7406\u5f88\u5feb<\/td>\n<\/tr>\n
flatMapSequential<\/td>\n\u2705 \u4fdd\u5e8f<\/td>\n\u2705 \u5e76\u53d1<\/td>\n\u4fdd\u5e8f + \u5141\u8bb8\u5e76\u53d1，\u4f46\u4f1a\u7f13\u51b2\u4e71\u5e8f\u7ed3\u679c<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

\u6d41\u5f0f\u6587\u672c\u5929\u7136\u987a\u5e8f\u654f\u611f，\u6b63\u786e\u7684\u505a\u6cd5\u662f：\u80fd\u7528\u540c\u6b65\u7684\u5c31\u522b\u7528\u5f02\u6b65\u3002\u4e00\u4e2a chunk \u7684\u89e3\u6790\u548c\u8f6c\u53d1\u662f\u5f88\u8f7b\u7684\u8ba1\u7b97，\u6839\u672c\u4e0d\u9700\u8981\u5207\u7ebf\u7a0b\u3002\u771f\u8981\u5f02\u6b65，\u7528 concatMap\u3002<\/p>\n

\u9000\u5316\u4e09：\u4e3a\u4e86\u300c\u770b\u4e00\u773c\u300d\u800c cache()<\/h4>\n

\/\/ \u274c \u628a\u6574\u6761\u6d41\u7f13\u5b58\u8fdb\u5185\u5b58<\/span>
\nFlux<\/span><<\/span>String<\/span>><\/span><\/span> shared =<\/span> provider.<\/span>stream<\/span>(<\/span>request)<\/span>.<\/span>cache<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

shared.<\/span>subscribe<\/span>(<\/span>chunk -><\/span> log.<\/span>debug<\/span>(<\/span>"\u4e0a\u6e38\u5206\u7247: {}"<\/span>,<\/span> chunk)<\/span>)<\/span>;<\/span> \/\/ \u60f3\u6253\u65e5\u5fd7<\/span>
\nreturn<\/span> shared.<\/span>map<\/span>(<\/span>this<\/span>::<\/span>toServerSentEvent<\/span>)<\/span>;<\/span> \/\/ \u771f\u6b63\u7684\u4e1a\u52a1<\/span><\/p>\n

cache() \u4f1a\u628a\u6240\u6709\u5df2\u7ecf\u53d1\u51fa\u7684\u5143\u7d20\u4fdd\u5b58\u5230\u5185\u5b58\u91cc，\u4ee5\u4fbf\u540e\u7eed\u8ba2\u9605\u8005\u4ece\u5934\u53d1\u9001\u3002\u5bf9\u4e00\u4e2a\u51e0\u767e token \u7684\u56de\u7b54，\u8fd9\u70b9\u5185\u5b58\u65e0\u6240\u8c13；\u4f46\u7f51\u5173\u662f\u8981\u625b\u5e76\u53d1\u7684，1000 \u4e2a\u5e76\u53d1\u6d41\u5f0f\u8bf7\u6c42，\u6bcf\u4e2a\u7f13\u5b58\u51e0\u5341 KB \u5230\u51e0\u767e KB，\u52a0\u4e0a\u5b57\u7b26\u4e32\u5bf9\u8c61\u5934\u5f00\u9500，\u5f88\u5bb9\u6613\u5c31\u662f\u51e0\u767e MB\u3002<\/p>\n

\u800c\u4e14 cache() \u8fd8\u6709\u4e2a\u66f4\u9690\u853d\u7684\u540e\u679c：\u5b83\u4f1a\u8ba9\u4e0a\u6e38\u7684\u80cc\u538b\u4fe1\u53f7\u5931\u6548\u3002\u4e0a\u6e38\u4ee5\u4e3a\u4e0b\u6e38\u6d88\u8d39\u5f88\u5feb（\u56e0\u4e3a cache \u4e00\u76f4\u5728\u6536），\u5b9e\u9645\u4e0a\u7f13\u5b58\u6b63\u5728\u5f80\u4e0a\u6da8\u3002<\/p>\n

\n

\u56db\u3001\u4ee3\u7801\u5b9e\u73b0：\u8ba9\u6d41\u5f0f\u771f\u6b63\u6d41\u8d77\u6765<\/h3>\n

4.1 Controller：\u628a Content-Type \u5b9a\u6b7b<\/h4>\n

@RestController<\/span>
\n@RequiredArgsConstructor<\/span>
\n@Slf4j<\/span>
\npublic<\/span> class<\/span> ChatController<\/span> {<\/span><\/p>\n

private<\/span> final<\/span> ProviderRegistry<\/span> registry;<\/span><\/p>\n

@PostMapping<\/span>(<\/span>
\n value =<\/span> "\/v1\/chat\/completions"<\/span>,<\/span>
\n produces =<\/span> MediaType<\/span>.<\/span>TEXT_EVENT_STREAM_VALUE<\/span>)<\/span> \/\/ \u26a0\ufe0f \u4e0d\u80fd\u7701<\/span>
\n public<\/span> Flux<\/span><<\/span>ServerSentEvent<\/span><<\/span>String<\/span>><\/span>><\/span><\/span> stream<\/span>(<\/span>@RequestBody<\/span> ChatRequest<\/span> request)<\/span> {<\/span>
\n \/\/ \u53ea\u505a HTTP \u5c42\u5224\u65ad：\u8def\u7531\u4ea4\u7ed9\u6ce8\u518c\u8868，\u627e\u4e0d\u5230\u4f1a fail-fast \u629b\u4e1a\u52a1\u5f02\u5e38<\/span>
\n Provider<\/span> provider =<\/span> registry.<\/span>get<\/span>(<\/span>request.<\/span>getProvider<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

return<\/span> provider.<\/span>stream<\/span>(<\/span>request)<\/span>
\n .<\/span>map<\/span>(<\/span>this<\/span>::<\/span>toServerSentEvent<\/span>)<\/span> \/\/ \u7eaf\u540c\u6b65\u8f6c\u6362，\u4e0d\u5207\u7ebf\u7a0b<\/span>
\n .<\/span>concatWith<\/span>(<\/span>Mono<\/span>.<\/span>just<\/span>(<\/span>doneEvent<\/span>(<\/span>)<\/span>)<\/span>)<\/span>;<\/span> \/\/ \u663e\u5f0f\u53d1 [DONE] \u6536\u5c3e<\/span>
\n }<\/span><\/p>\n

private<\/span> ServerSentEvent<\/span><<\/span>String<\/span>><\/span><\/span> toServerSentEvent<\/span>(<\/span>String<\/span> rawChunk)<\/span> {<\/span>
\n return<\/span> ServerSentEvent<\/span>.<\/span><<\/span>String<\/span>><\/span><\/span>builder<\/span>(<\/span>)<\/span>
\n .<\/span>data<\/span>(<\/span>rawChunk)<\/span>
\n .<\/span>build<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

private<\/span> ServerSentEvent<\/span><<\/span>String<\/span>><\/span><\/span> doneEvent<\/span>(<\/span>)<\/span> {<\/span>
\n return<\/span> ServerSentEvent<\/span>.<\/span><<\/span>String<\/span>><\/span><\/span>builder<\/span>(<\/span>)<\/span>.<\/span>data<\/span>(<\/span>"[DONE]"<\/span>)<\/span>.<\/span>build<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u4e24\u4e2a\u7ec6\u8282\u503c\u5f97\u5355\u72ec\u8bf4：<\/p>\n

\u7b2c\u4e00，produces \u5fc5\u987b\u5199\u3002 \u5982\u679c\u53ea\u5199 @PostMapping("\/v1\/chat\/completions")，\u800c\u8bf7\u6c42\u5934\u91cc Accept: text\/event-stream \u53c8\u6070\u597d\u88ab\u67d0\u4e2a\u4e2d\u95f4\u5c42\u6539\u6389\u4e86，WebFlux \u53ef\u80fd\u4f1a\u6309 JSON \u7f16\u7801，\u5ba2\u6237\u7aef\u62ff\u5230\u7684\u662f\u4e00\u4e2a\u88ab\u5305\u88c5\u8fc7\u7684\u5bf9\u8c61\u800c\u4e0d\u662f SSE \u5e27\u3002\u8fd9\u7c7b\u95ee\u9898\u5728\u6d4f\u89c8\u5668\u5f00\u53d1\u8005\u5de5\u5177\u91cc\u8868\u73b0\u4e3a\u300c\u6709\u6570\u636e\u4f46 EventSource \u4e0d\u89e6\u53d1 onmessage\u300d，\u975e\u5e38\u96be\u67e5\u3002<\/p>\n

\u7b2c\u4e8c，[DONE] \u662f OpenAI \u534f\u8bae\u7684\u4e00\u90e8\u5206\u3002 \u5b98\u65b9 SDK \u9760\u5b83\u5224\u65ad\u6d41\u7ed3\u675f\u3002\u5c11\u53d1\u4e00\u4e2a [DONE]，SDK \u4f1a\u4e00\u76f4\u7b49\u5230\u8fde\u63a5\u8d85\u65f6\u624d\u6536\u5c3e，\u7528\u6237\u90a3\u8fb9\u7684\u300c\u505c\u6b62\u751f\u6210\u300d\u6309\u94ae\u4f1a\u4e00\u76f4\u8f6c\u3002\u8fd9\u4e5f\u6b63\u662f\u9879\u76ee\u91cc StreamingContractTest \u4e13\u95e8\u65ad\u8a00\u7684\u4e1c\u897f\u3002<\/p>\n

4.2 Provider：SSE \u5206\u7247\u89e3\u6790，\u574f\u5757\u8df3\u8fc7\u4f46\u4e0d\u4e2d\u65ad<\/h4>\n

\u4e0a\u6e38\u8fd4\u56de\u7684\u662f SSE \u6587\u672c\u5e27，\u7f51\u5173\u8981\u628a\u5b83\u5207\u6210\u4e00\u5757\u5757\u7684\u5904\u7406\u3002\u9879\u76ee README \u7684\u300c\u5173\u952e\u8bbe\u8ba1\u300d\u7b2c 5 \u6761\u5199\u5f97\u5f88\u660e\u786e：<\/p>\n

\u4e0a\u6e38\u5355\u4e2a\u6d41\u5f0f\u5206\u7247\u89e3\u6790\u5931\u8d25 \u2192 \u8df3\u8fc7\u8be5\u5757\u5e76\u544a\u8b66，\u4e0d\u4e2d\u65ad\u6574\u6761\u6d41；\u7f51\u5173\u81ea\u5df1\u7684 DTO \u5e8f\u5217\u5316\u5931\u8d25 \u2192 \u629b\u51fa IllegalStateException，\u5fc5\u987b\u70b8\u3002<\/p>\n

\u8fd9\u4e24\u6761\u770b\u8d77\u6765\u77db\u76fe，\u5176\u5b9e\u662f\u540c\u4e00\u6761\u539f\u5219\u7684\u4e24\u9762：\u522b\u4eba\u7684\u95ee\u9898\u8981\u5bb9\u9519，\u81ea\u5df1\u7684 bug \u8981\u70b8\u3002<\/p>\n

@Override<\/span>
\npublic<\/span> Flux<\/span><<\/span>String<\/span>><\/span><\/span> stream<\/span>(<\/span>ChatRequest<\/span> request)<\/span> {<\/span>
\n return<\/span> webClient.<\/span>post<\/span>(<\/span>)<\/span>
\n .<\/span>uri<\/span>(<\/span>channel.<\/span>getBaseUrl<\/span>(<\/span>)<\/span> +<\/span> "\/chat\/completions"<\/span>)<\/span>
\n .<\/span>header<\/span>(<\/span>HttpHeaders<\/span>.<\/span>AUTHORIZATION<\/span>,<\/span> "Bearer "<\/span> +<\/span> channel.<\/span>getApiKey<\/span>(<\/span>)<\/span>)<\/span>
\n .<\/span>contentType<\/span>(<\/span>MediaType<\/span>.<\/span>APPLICATION_JSON<\/span>)<\/span>
\n .<\/span>bodyValue<\/span>(<\/span>request.<\/span>toUpstreamBody<\/span>(<\/span>channel)<\/span>)<\/span>
\n .<\/span>retrieve<\/span>(<\/span>)<\/span>
\n .<\/span>bodyToFlux<\/span>(<\/span>String<\/span>.<\/span>class<\/span>)<\/span> \/\/ \u9010\u6761\u8f6c，\u7edd\u4e0d\u7528 bodyToMono<\/span>
\n .<\/span>filter<\/span>(<\/span>chunk -><\/span> !<\/span>"[DONE]"<\/span>.<\/span>equals<\/span>(<\/span>chunk)<\/span>)<\/span> \/\/ [DONE] \u7531\u7f51\u5173\u81ea\u5df1\u53d1，\u7edf\u4e00\u53e3\u5f84<\/span>
\n .<\/span>handle<\/span>(<\/span>(<\/span>raw,<\/span> sink)<\/span> -><\/span> {<\/span>
\n try<\/span> {<\/span>
\n \/\/ \u89e3\u6790\u5931\u8d25 = \u4e0a\u6e38\u683c\u5f0f\u6296\u52a8，\u8df3\u8fc7\u8fd9\u4e00\u5757，\u6d41\u7ee7\u7eed<\/span>
\n sink.<\/span>next<\/span>(<\/span>normalize<\/span>(<\/span>raw)<\/span>)<\/span>;<\/span>
\n }<\/span> catch<\/span> (<\/span>JsonProcessingException<\/span> e)<\/span> {<\/span>
\n log.<\/span>warn<\/span>(<\/span>"\u4e0a\u6e38\u5206\u7247\u89e3\u6790\u5931\u8d25，\u5df2\u8df3\u8fc7: {}"<\/span>,<\/span> abbreviate<\/span>(<\/span>raw)<\/span>,<\/span> e)<\/span>;<\/span>
\n }<\/span>
\n }<\/span>)<\/span>
\n \/\/ \u515c\u5e95：\u4efb\u4f55\u975e\u6d3b\u8dc3\u9519\u8bef\u90fd\u4e0d\u80fd\u8ba9\u6574\u6761\u6d41\u65ad\u6389<\/span>
\n .<\/span>onErrorResume<\/span>(<\/span>ex -><\/span> {<\/span>
\n log.<\/span>error<\/span>(<\/span>"\u4e0a\u6e38\u6d41\u5f0f\u8fde\u63a5\u5f02\u5e38，\u63d0\u524d\u7ed3\u675f"<\/span>,<\/span> ex)<\/span>;<\/span>
\n return<\/span> Flux<\/span>.<\/span>empty<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>)<\/span>;<\/span>
\n}<\/span><\/p>\n

\u6ce8\u610f bodyToFlux(String.class) \u548c bodyToMono(String.class) \u7684\u533a\u522b\u2014\u2014\u8fd9\u662f\u6700\u5bb9\u6613\u5199\u9519\u7684\u4e00\u884c\u3002\u5199\u6210 bodyToMono \u518d .flatMapMany(s -> Flux.fromArray(s.split("\\\\n\\\\n")))，\u8868\u9762\u4e0a\u300c\u6211\u7528 split \u62c6\u5f00\u4e86\u5440\u300d，\u4f46 bodyToMono \u90a3\u4e00\u6b65\u5df2\u7ecf\u628a\u6240\u6709\u5185\u5bb9\u6512\u8fdb\u5185\u5b58\u4e86，\u540e\u9762\u7684\u62c6\u5206\u53ea\u662f\u4e8b\u540e\u8865\u6551\u3002\u7c7b\u578b\u662f Flux，\u884c\u4e3a\u65e9\u5c31\u4e0d\u662f\u6d41\u5f0f\u4e86\u3002<\/p>\n

4.3 \u987a\u5e8f\u4fdd\u8bc1：\u60f3\u4fdd\u5e8f\u5c31\u522b\u4e71\u5207\u7ebf\u7a0b<\/h4>\n

\/\/ \u2705 \u5206\u7247\u8f6c\u53d1\u662f\u8f7b\u91cf\u7eaf\u8ba1\u7b97，\u4fdd\u6301\u5728\u540c\u4e00\u7ebf\u7a0b\u4e0a\u6309\u5e8f\u6d41\u52a8<\/span>
\nreturn<\/span> provider.<\/span>stream<\/span>(<\/span>request)<\/span>
\n .<\/span>map<\/span>(<\/span>this<\/span>::<\/span>toSseFrame<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u2705 \u4e07\u4e00\u5fc5\u987b\u505a\u5f02\u6b65\u5904\u7406，\u7528 concatMap \u800c\u4e0d\u662f flatMap<\/span>
\nreturn<\/span> provider.<\/span>stream<\/span>(<\/span>request)<\/span>
\n .<\/span>concatMap<\/span>(<\/span>chunk -><\/span> Mono<\/span>.<\/span>fromCallable<\/span>(<\/span>(<\/span>)<\/span> -><\/span> enrich<\/span>(<\/span>chunk)<\/span>)<\/span>
\n .<\/span>subscribeOn<\/span>(<\/span>Schedulers<\/span>.<\/span>parallel<\/span>(<\/span>)<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

concatMap \u4f1a\u7b49\u4e0a\u4e00\u4e2a\u5185\u5c42 Mono \u5b8c\u6210，\u624d\u8ba2\u9605\u4e0b\u4e00\u4e2a\u3002\u4ee3\u4ef7\u662f\u4e32\u884c，\u4f46\u6d41\u5f0f\u6587\u672c\u6bcf\u5757\u5904\u7406\u7684\u8017\u65f6\u53ea\u6709\u5fae\u79d2\u7ea7，\u8fd9\u4e2a\u4ee3\u4ef7\u5b8c\u5168\u53ef\u4ee5\u63a5\u53d7\u3002\u7528 flatMap \u7701\u4e0b\u7684\u90a3\u4e9b\u5e76\u53d1，\u6362\u6765\u7684\u662f\u7528\u6237\u770b\u5230\u4e71\u5e8f\u7684\u53e5\u5b50\u2014\u2014\u8fd9\u7b14\u4e70\u5356\u4e0d\u5212\u7b97\u3002<\/p>\n

\n

\u4e94\u3001\u6d41\u5df2\u7ecf\u5f00\u59cb\u4e4b\u540e\u51fa\u9519\u4e86，\u600e\u4e48\u529e？<\/h3>\n

\u6d41\u5f0f\u63a5\u53e3\u51fa\u9519\u540e\u7684\u5904\u7406\u8def\u5f84，\u53ef\u4ee5\u7528\u4e00\u5f20\u51b3\u7b56\u56fe\u8bf4\u6e05\u695a：<\/p>\n

#mermaid-svg-fobVXg5axEa4TCrr{font-family:\\”trebuchet ms\\”,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-fobVXg5axEa4TCrr .edge-animation-slow{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 50s linear infinite;stroke-linecap:round;}#mermaid-svg-fobVXg5axEa4TCrr .edge-animation-fast{stroke-dasharray:9,5!important;stroke-dashoffset:900;animation:dash 20s linear infinite;stroke-linecap:round;}#mermaid-svg-fobVXg5axEa4TCrr .error-icon{fill:#552222;}#mermaid-svg-fobVXg5axEa4TCrr .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-fobVXg5axEa4TCrr .edge-thickness-normal{stroke-width:1px;}#mermaid-svg-fobVXg5axEa4TCrr .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-fobVXg5axEa4TCrr .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-fobVXg5axEa4TCrr .edge-thickness-invisible{stroke-width:0;fill:none;}#mermaid-svg-fobVXg5axEa4TCrr .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-fobVXg5axEa4TCrr .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-fobVXg5axEa4TCrr .marker{fill:#333333;stroke:#333333;}#mermaid-svg-fobVXg5axEa4TCrr .marker.cross{stroke:#333333;}#mermaid-svg-fobVXg5axEa4TCrr svg{font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-fobVXg5axEa4TCrr p{margin:0;}#mermaid-svg-fobVXg5axEa4TCrr .label{font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;color:#333;}#mermaid-svg-fobVXg5axEa4TCrr .cluster-label text{fill:#333;}#mermaid-svg-fobVXg5axEa4TCrr .cluster-label span{color:#333;}#mermaid-svg-fobVXg5axEa4TCrr .cluster-label span p{background-color:transparent;}#mermaid-svg-fobVXg5axEa4TCrr .label text,#mermaid-svg-fobVXg5axEa4TCrr span{fill:#333;color:#333;}#mermaid-svg-fobVXg5axEa4TCrr .node rect,#mermaid-svg-fobVXg5axEa4TCrr .node circle,#mermaid-svg-fobVXg5axEa4TCrr .node ellipse,#mermaid-svg-fobVXg5axEa4TCrr .node polygon,#mermaid-svg-fobVXg5axEa4TCrr .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-fobVXg5axEa4TCrr .rough-node .label text,#mermaid-svg-fobVXg5axEa4TCrr .node .label text,#mermaid-svg-fobVXg5axEa4TCrr .image-shape .label,#mermaid-svg-fobVXg5axEa4TCrr .icon-shape .label{text-anchor:middle;}#mermaid-svg-fobVXg5axEa4TCrr .node .katex path{fill:#000;stroke:#000;stroke-width:1px;}#mermaid-svg-fobVXg5axEa4TCrr .rough-node .label,#mermaid-svg-fobVXg5axEa4TCrr .node .label,#mermaid-svg-fobVXg5axEa4TCrr .image-shape .label,#mermaid-svg-fobVXg5axEa4TCrr .icon-shape .label{text-align:center;}#mermaid-svg-fobVXg5axEa4TCrr .node.clickable{cursor:pointer;}#mermaid-svg-fobVXg5axEa4TCrr .root .anchor path{fill:#333333!important;stroke-width:0;stroke:#333333;}#mermaid-svg-fobVXg5axEa4TCrr .arrowheadPath{fill:#333333;}#mermaid-svg-fobVXg5axEa4TCrr .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-fobVXg5axEa4TCrr .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-fobVXg5axEa4TCrr .edgeLabel{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-fobVXg5axEa4TCrr .edgeLabel p{background-color:rgba(232,232,232, 0.8);}#mermaid-svg-fobVXg5axEa4TCrr .edgeLabel rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-fobVXg5axEa4TCrr .labelBkg{background-color:rgba(232, 232, 232, 0.5);}#mermaid-svg-fobVXg5axEa4TCrr .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-fobVXg5axEa4TCrr .cluster text{fill:#333;}#mermaid-svg-fobVXg5axEa4TCrr .cluster span{color:#333;}#mermaid-svg-fobVXg5axEa4TCrr div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:\\”trebuchet ms\\”,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-fobVXg5axEa4TCrr .flowchartTitleText{text-anchor:middle;font-size:18px;fill:#333;}#mermaid-svg-fobVXg5axEa4TCrr rect.text{fill:none;stroke-width:0;}#mermaid-svg-fobVXg5axEa4TCrr .icon-shape,#mermaid-svg-fobVXg5axEa4TCrr .image-shape{background-color:rgba(232,232,232, 0.8);text-align:center;}#mermaid-svg-fobVXg5axEa4TCrr .icon-shape p,#mermaid-svg-fobVXg5axEa4TCrr .image-shape p{background-color:rgba(232,232,232, 0.8);padding:2px;}#mermaid-svg-fobVXg5axEa4TCrr .icon-shape .label rect,#mermaid-svg-fobVXg5axEa4TCrr .image-shape .label rect{opacity:0.5;background-color:rgba(232,232,232, 0.8);fill:rgba(232,232,232, 0.8);}#mermaid-svg-fobVXg5axEa4TCrr .label-icon{display:inline-block;height:1em;overflow:visible;vertical-align:-0.125em;}#mermaid-svg-fobVXg5axEa4TCrr .node .label-icon path{fill:currentColor;stroke:revert;stroke-width:revert;}#mermaid-svg-fobVXg5axEa4TCrr :root{–mermaid-font-family:\\”trebuchet ms\\”,verdana,arial,sans-serif;}<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u662f<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u5426<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u662f<\/p>\n

<\/span><\/p>\n

<\/span><\/p>\n

<\/p>\n

\u5426<\/p>\n

<\/span><\/p>\n

<\/span><\/p>\n

<\/span><\/p>\n

<\/span><\/p>\n

<\/span><\/p>\n

<\/p>\n

\u6d41\u5df2\u5f00\u59cb，\u54cd\u5e94\u5934 200 \u5df2\u53d1\u51fa<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u4e0a\u6e38\u4e2d\u9014\u5931\u8d25？<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u9519\u8bef\u88ab onErrorResume \u6355\u83b7？<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u7ee7\u7eed\u9010\u5757\u8f6c\u53d1\u76f4\u5230 [DONE]<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u53d1\u9001 event: error \u4e8b\u4ef6<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u524d\u7aef\u63d0\u793a：\u56de\u7b54\u4e2d\u65ad，\u53ef\u91cd\u8bd5<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u5f02\u5e38\u7a7f\u900f\u5230\u6846\u67b6\u5c42<\/p>\n

<\/span><\/p>\n

<\/p>\n

IllegalStateException: already committed<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u65e5\u5fd7\u63a9\u76d6\u771f\u5b9e\u539f\u56e0<\/p>\n

<\/span><\/p>\n

<\/p>\n

\u6b62\u635f，\u4e0d\u91cd\u8bd5<\/p>\n

<\/span><\/p>\n

\u8fd9\u662f\u6d41\u5f0f\u63a5\u53e3\u548c\u666e\u901a\u63a5\u53e3\u6700\u5927\u7684\u7ed3\u6784\u6027\u5dee\u5f02，\u9762\u8bd5\u4e5f\u7279\u522b\u7231\u95ee\u3002<\/p>\n

\u666e\u901a REST \u63a5\u53e3\u7684\u6d41\u7a0b\u662f：\u7b97\u51fa\u7ed3\u679c \u2192 \u8bbe\u7f6e\u72b6\u6001\u7801 \u2192 \u5199\u54cd\u5e94\u4f53\u3002\u6240\u4ee5\u51fa\u9519\u65f6\u4f60\u53ef\u4ee5\u8fd4\u56de 500\u3002<\/p>\n

\u6d41\u5f0f\u63a5\u53e3\u7684\u6d41\u7a0b\u662f：\u5148\u5199\u54cd\u5e94\u5934 200 \u2192 \u7136\u540e\u4e00\u5757\u4e00\u5757\u5f80\u5916\u5410\u3002\u7b49\u4f60\u5728\u5410\u5230\u7b2c 5 \u5757\u65f6\u53d1\u73b0\u4e0a\u6e38\u6302\u4e86，HTTP \u54cd\u5e94\u5934\u548c\u4e00\u90e8\u5206 body \u5df2\u7ecf\u53d1\u51fa\u53bb\u4e86，\u72b6\u6001\u7801\u6539\u4e0d\u4e86\u4e86\u3002<\/p>\n

\u8fd9\u65f6\u4f1a\u53d1\u751f\u4e24\u79cd\u60c5\u51b5：<\/p>\n

\u60c5\u51b5\u4e00（\u9519\u8bef\u88ab\u6b63\u786e\u6355\u83b7）：\u4f60\u5728\u670d\u52a1\u7aef\u81ea\u5df1\u5904\u7406\u6389\u4e86，\u5f80\u4e0b\u53d1\u4e00\u4e2a\u300c\u9519\u8bef\u4e8b\u4ef6\u300d\u7136\u540e\u6b63\u5e38\u7ed3\u675f：<\/p>\n

.<\/span>onErrorResume<\/span>(<\/span>ex -><\/span> Flux<\/span>.<\/span>just<\/span>(<\/span>
\n ServerSentEvent<\/span>.<\/span><<\/span>String<\/span>><\/span><\/span>builder<\/span>(<\/span>)<\/span>
\n .<\/span>event<\/span>(<\/span>"error"<\/span>)<\/span>
\n .<\/span>data<\/span>(<\/span>"{\\\\"type\\\\":\\\\"upstream_error\\\\",\\\\"message\\\\":\\\\"\u4e0a\u6e38\u8fde\u63a5\u4e2d\u65ad\\\\"}"<\/span>)<\/span>
\n .<\/span>build<\/span>(<\/span>)<\/span>)<\/span>)<\/span><\/p>\n

\u524d\u7aef\u7ea6\u5b9a\u597d：\u6536\u5230 event: error \u5c31\u63d0\u793a\u300c\u56de\u7b54\u4e2d\u65ad，\u53ef\u91cd\u8bd5\u300d，\u800c\u4e0d\u662f\u5361\u5728\u90a3\u91cc\u8f6c\u5708\u3002<\/p>\n

\u60c5\u51b5\u4e8c（\u9519\u8bef\u6ca1\u88ab\u6355\u83b7）：\u9ed8\u8ba4\u9519\u8bef\u5904\u7406\u5668\u4f1a\u8bd5\u56fe\u8bbe\u7f6e 500，\u4f46\u54cd\u5e94\u5df2\u7ecf committed，\u4e8e\u662f\u629b\u51fa：<\/p>\n

java.lang.IllegalStateException: ServerHttpResponse already committed<\/p>\n

\u8fd9\u6761\u5f02\u5e38\u4f1a\u76d6\u4f4f\u771f\u6b63\u7684\u539f\u56e0，\u65e5\u5fd7\u91cc\u770b\u8d77\u6765\u50cf\u662f\u300c\u54cd\u5e94\u5199\u5931\u8d25\u300d，\u5b9e\u9645\u6839\u56e0\u662f\u4e0a\u6e38\u6302\u4e86\u3002\u6240\u4ee5\u6d41\u5f0f\u63a5\u53e3\u91cc，onErrorResume \u4e0d\u662f\u53ef\u9009\u9879，\u662f\u5fc5\u9009\u9879\u3002<\/p>\n

\u9879\u76ee\u91cc UpstreamStreamingTest \u548c IdleTimeoutTest \u8986\u76d6\u7684\u5c31\u662f\u8fd9\u4e00\u7c7b\u8fb9\u754c：\u4e0a\u6e38\u5361\u4f4f\u4e0d\u5410\u6570\u636e\u65f6，\u5757\u95f4\u7a7a\u95f2\u8d85\u65f6（idle 20s）\u4f1a\u4e3b\u52a8\u65ad\u5f00，\u5426\u5219\u8fde\u63a5\u4f1a\u4e00\u76f4\u6302\u7740，\u76f4\u5230 responseTimeout（30s，\u53ea\u8986\u76d6\u5230\u300c\u8bf7\u6c42\u53d1\u51fa \u2192 \u6536\u5230\u54cd\u5e94\u5934\u300d\u90a3\u4e00\u6bb5）\u2014\u2014\u800c\u6d41\u5f0f\u7684\u54cd\u5e94\u5934\u51e0\u5341\u6beb\u79d2\u5c31\u56de\u6765\u4e86，responseTimeout \u6839\u672c\u7ba1\u4e0d\u5230\u4e2d\u9014\u505c\u6ede，\u8fd9\u5c31\u662f\u5fc5\u987b\u5355\u72ec\u505a idle \u8d85\u65f6\u7684\u539f\u56e0\u3002<\/p>\n

\n

\u516d\u3001\u600e\u4e48\u9a8c\u8bc1\u300c\u771f\u7684\u5728\u6d41\u300d\u2014\u2014\u4e0d\u662f\u9760\u8089\u773c<\/h3>\n

\u5355\u6d4b\u65ad\u8a00\u300c\u6700\u7ec8\u5185\u5bb9\u62fc\u8d77\u6765\u5bf9\u4e0d\u5bf9\u300d，\u662f\u53d1\u73b0\u4e0d\u4e86\u9759\u9ed8\u9000\u5316\u7684\u3002\u8981\u9a8c\u8bc1\u6d41\u5f0f，\u5fc5\u987b\u9a8c\u8bc1\u65f6\u5e8f\u3002<\/p>\n

@Test<\/span>
\nvoid<\/span> \u9996\u4e2a\u5206\u7247\u5fc5\u987b\u5728\u5b8c\u6210\u540e\u624d.<\/span>.<\/span>.<\/span> \/* \u53cd\u8fc7\u6765\u8bf4：\u5b8c\u6210\u4e4b\u524d\u5c31\u5fc5\u987b\u5df2\u7ecf\u62ff\u5230\u5206\u7247 *\/<\/span> {<\/span>
\n \/\/ \u4e0a\u6e38\u6545\u610f\u6162：\u6bcf\u79d2\u5410\u4e00\u5757，\u4e00\u5171 3 \u5757<\/span>
\n Flux<\/span><<\/span>String<\/span>><\/span><\/span> upstream =<\/span> Flux<\/span>.<\/span>interval<\/span>(<\/span>Duration<\/span>.<\/span>ofSeconds<\/span>(<\/span>1<\/span>)<\/span>)<\/span>
\n .<\/span>take<\/span>(<\/span>3<\/span>)<\/span>
\n .<\/span>map<\/span>(<\/span>i -><\/span> "chunk-"<\/span> +<\/span> i)<\/span>;<\/span><\/p>\n

StepVerifier<\/span>.<\/span>create<\/span>(<\/span>provider.<\/span>stream<\/span>(<\/span>upstream)<\/span>)<\/span>
\n \/\/ \u5173\u952e：\u8fd9\u91cc\u5982\u679c\u88ab collectList \u4e86，\u4e0b\u9762\u4e09\u884c\u4f1a\u5728\u7b2c 3 \u79d2\u540e\u4e00\u6b21\u6027\u901a\u8fc7<\/span>
\n \/\/ StepVerifier \u4f1a\u6309\u771f\u5b9e\u65f6\u95f4\u63a8\u8fdb，\u80fd\u533a\u5206\u300c\u9010\u5757\u5230\u300d\u548c\u300c\u4e00\u8d77\u5230\u300d<\/span>
\n .<\/span>expectNext<\/span>(<\/span>"chunk-0"<\/span>)<\/span>
\n .<\/span>expectNext<\/span>(<\/span>"chunk-1"<\/span>)<\/span>
\n .<\/span>expectNext<\/span>(<\/span>"chunk-2"<\/span>)<\/span>
\n .<\/span>verifyComplete<\/span>(<\/span>)<\/span>;<\/span>
\n}<\/span><\/p>\n

\u66f4\u4e25\u683c\u7684\u505a\u6cd5\u662f\u8bb0\u5f55\u6bcf\u4e2a\u5143\u7d20\u5230\u8fbe\u7684\u65f6\u95f4\u6233，\u65ad\u8a00\u76f8\u90bb\u5143\u7d20\u7684\u95f4\u9694 \u2248 \u4e0a\u6e38\u95f4\u9694\u3002\u5982\u679c\u95f4\u9694\u5168\u53d8\u6210 0，\u8bf4\u660e\u88ab\u6512\u6279\u4e86\u3002<\/p>\n

\u7ebf\u4e0a\u9a8c\u8bc1\u6700\u4fbf\u5b9c\u7684\u529e\u6cd5：<\/p>\n

curl<\/span> -N<\/span> http:\/\/localhost:8081\/v1\/chat\/completions \\\\<\/span>
\n -H<\/span> "Content-Type: application\/json"<\/span> \\\\<\/span>
\n -d<\/span> '{"model":"deepseek-chat","stream":true,
\n "messages":[{"role":"user","content":"\u9010\u5b57\u8bb2\u4e00\u4e0b SSE"}]}'<\/span><\/p>\n

-N \u5173\u95ed curl \u7684\u7f13\u51b2\u3002\u4f60\u4f1a\u770b\u5230\u6587\u5b57\u4e00\u5757\u5757\u5192\u51fa\u6765\u2014\u2014\u5982\u679c\u5b83\u505c\u987f\u597d\u51e0\u79d2\u7136\u540e\u5237\u51fa\u4e00\u6574\u5c4f，\u90a3\u5c31\u662f\u65e5\u5fd7\u91cc\u90a3\u6761\u300c\u6d41\u5f0f\u300d\u94fe\u8def\u88ab\u6512\u4f4f\u4e86\u3002<\/p>\n

\n

\u4e03\u3001\u9762\u8bd5 \/ \u7b80\u5386\u4eae\u70b9\u63d0\u70bc<\/h3>\n

\u8fd9\u6bb5\u8e29\u5751\u7ecf\u9a8c\u6bd4\u300c\u6211\u4f1a\u7528 WebFlux\u300d\u503c\u94b1\u5f97\u591a，\u7b80\u5386\u53ef\u4ee5\u8fd9\u6837\u5199：<\/p>\n

LLM Gateway \u7edf\u4e00\u63a5\u5165\u7f51\u5173（Java 17 \/ Spring Boot 3.5 \/ WebFlux）<\/p>\n

    \n
  • \u5b9e\u73b0 OpenAI \u517c\u5bb9\u7684 SSE \u6d41\u5f0f\u8f6c\u53d1，\u4fdd\u6301\u4e0a\u6e38\u5206\u7247\u5230\u5ba2\u6237\u7aef\u7684\u9010\u5757\u900f\u4f20，[DONE] \u6536\u5c3e\u4e0e\u534f\u8bae\u53e3\u5f84\u7edf\u4e00；<\/li>\n
  • \u5904\u7406\u6d41\u5f0f\u63a5\u53e3\u7684\u300c\u54cd\u5e94\u5df2\u63d0\u4ea4\u300d\u8fb9\u754c：\u4e0a\u6e38\u4e2d\u9014\u5931\u8d25\u65f6\u65e0\u6cd5\u4fee\u6539 HTTP \u72b6\u6001\u7801，\u6539\u4e3a\u53d1\u9001 event: error \u4e8b\u4ef6\u5e76\u5b89\u5168\u7ed3\u675f\u6d41；<\/li>\n
  • \u533a\u5206\u300c\u4e0a\u6e38\u574f\u5757\u300d\u4e0e\u300c\u7f51\u5173\u81ea\u8eab\u5f02\u5e38\u300d\u4e24\u7c7b\u9519\u8bef，\u524d\u8005\u8df3\u8fc7\u5e76\u544a\u8b66\u3001\u4e0d\u4e2d\u65ad\u6574\u6761\u6d41，\u540e\u8005 fail-fast，\u907f\u514d\u6545\u969c\u88ab\u8bef\u5224\u4e3a\u4e0a\u6e38\u6296\u52a8；<\/li>\n
  • \u7f16\u5199 StreamingContractTest \/ UpstreamStreamingTest \u8986\u76d6\u5206\u7247\u3001[DONE]\u3001\u574f\u5757\u8df3\u8fc7\u4e0e\u7a7a\u95f2\u8d85\u65f6\u3002<\/li>\n<\/ul>\n

    \u5199\u7b80\u5386\u65f6\u4e0d\u8981\u5199\u300cQPS \u63d0\u5347 X%\u300d\u8fd9\u79cd\u6ca1\u6d4b\u8fc7\u7684\u6570\u5b57\u3002\u53ef\u4ee5\u5199\u7684\u662f\u6d4b\u8bd5\u7c7b\u8986\u76d6\u4e86\u54ea\u4e9b\u771f\u5b9e\u8fb9\u754c\u2014\u2014\u56e0\u4e3a\u8fd9\u662f\u80fd\u5f53\u573a\u7ffb\u4ee3\u7801\u9a8c\u8bc1\u7684\u3002<\/p>\n

    Commit Message \u53c2\u8003：<\/p>\n

    fix(stream): \u79fb\u9664\u6d41\u5f0f\u94fe\u8def\u4e2d\u7684 collectList \u805a\u5408，\u6062\u590d\u9010\u5757\u8f6c\u53d1<\/p>\n

    – ChatController \u6539\u4e3a\u76f4\u63a5\u900f\u4f20 Flux<ServerSentEvent>，\u4e0d\u518d\u805a\u5408\u540e\u91cd\u53d1
    \n– \u5206\u7247\u4e71\u5e8f\u95ee\u9898\u6539\u7528 concatMap \u4fee\u590d（\u539f flatMap \u5728 boundedElastic \u4e0a\u4e0d\u4fdd\u5e8f）
    \n– \u65b0\u589e onErrorResume \u515c\u5e95，\u907f\u514d\u54cd\u5e94\u5df2\u63d0\u4ea4\u540e\u629b IllegalStateException<\/p>\n

    \n

    \u516b\u3001\u516b\u80a1\u6587 \/ \u573a\u666f\u9898\u66b4\u51fb<\/h3>\n

    \u573a\u666f\u9898 1：\u6d41\u5f0f\u63a5\u53e3\u5df2\u7ecf\u8fd4\u56de 200 \u5e76\u4e14\u5410\u4e86\u4e00\u534a，\u4e0a\u6e38\u5382\u5546\u8fd4\u56de 500 \u4e86，\u4f60\u7684\u7f51\u5173\u600e\u4e48\u5904\u7406？<\/h4>\n

    \u6807\u51c6\u7b54\u6cd5\u5206\u4e09\u5c42：<\/p>\n

  • \u534f\u8bae\u5c42：\u72b6\u6001\u7801\u5df2\u7ecf\u6539\u4e0d\u4e86\u3002\u552f\u4e00\u6b63\u786e\u7684\u65b9\u5f0f\u662f\u5728\u6d41\u5185\u53d1\u9001\u4e00\u4e2a\u7ea6\u5b9a\u7684\u9519\u8bef\u4e8b\u4ef6（\u5982 event: error），\u7136\u540e\u5e72\u51c0\u5730\u7ed3\u675f\u6d41（\u53d1 [DONE] \u6216\u76f4\u63a5 complete，\u53d6\u51b3\u4e8e\u5ba2\u6237\u7aef\u7ea6\u5b9a）\u3002\u5343\u4e07\u4e0d\u8981\u8ba9\u5f02\u5e38\u7a7f\u900f\u5230\u6846\u67b6\u5c42，\u5426\u5219\u65e5\u5fd7\u91cc\u4f1a\u51fa\u73b0 ServerHttpResponse already committed，\u63a9\u76d6\u771f\u5b9e\u539f\u56e0\u3002<\/li>\n
  • \u8ba1\u8d39\/\u8ba1\u91cf\u5c42：\u5df2\u7ecf\u6d88\u8017\u7684 token \u8981\u7167\u5e38\u8bb0\u8d26\u3002\u4e0d\u80fd\u56e0\u4e3a\u5931\u8d25\u5c31\u4e22\u5f03\u2014\u2014\u4e0a\u6e38\u662f\u771f\u7684\u7b97\u8fc7\u94b1\u7684\u3002\u8fd9\u4e5f\u662f\u5f53\u524d\u9879\u76ee README \u91cc\u300cToken \u8ba1\u91cf\u672a\u843d\u5730\u300d\u8981\u8865\u7684\u90e8\u5206\u3002<\/li>\n
  • \u5ba2\u6237\u7aef\u4f53\u9a8c\u5c42：\u5982\u679c\u5df2\u7ecf\u5410\u4e86\u90e8\u5206\u5185\u5bb9，\u4e0d\u8981\u6574\u6bb5\u4e22\u5f03\u91cd\u6765，\u524d\u7aef\u5e94\u8be5\u4fdd\u7559\u5df2\u6536\u5230\u7684\u90e8\u5206\u5e76\u63d0\u793a\u300c\u56de\u7b54\u4e2d\u65ad\u300d\u3002\u5168\u91cf\u91cd\u8bd5\u4f1a\u9020\u6210\u91cd\u590d\u5185\u5bb9\u3002<\/li>\n

    \u8ffd\u95ee\u70b9：\u4e3a\u4ec0\u4e48\u4e0d\u80fd\u5728\u7f51\u5173\u5c42\u91cd\u8bd5？ \u56e0\u4e3a\u8bf7\u6c42\u5df2\u7ecf\u53d1\u51fa\u3001token \u5df2\u7ecf\u70e7\u6389\u3001\u54cd\u5e94\u5df2\u7ecf\u90e8\u5206\u4e0b\u53d1，\u91cd\u8bd5\u610f\u5473\u7740\u5ba2\u6237\u7aef\u4f1a\u6536\u5230\u4e24\u4efd\u5185\u5bb9\u3002\u91cd\u8bd5\u53ea\u5bf9\u300c\u5c1a\u672a\u5f00\u59cb\u54cd\u5e94\u300d\u7684\u5931\u8d25\u6709\u610f\u4e49，\u4e00\u65e6\u6d41\u5f00\u59cb，\u5c31\u53ea\u80fd\u6b62\u635f\u4e0d\u80fd\u91cd\u6765\u3002<\/p>\n

    \u573a\u666f\u9898 2：flatMap\u3001concatMap\u3001flatMapSequential \u5728\u6d41\u5f0f\u7f51\u5173\u91cc\u600e\u4e48\u9009？<\/h4>\n
      \n
    • flatMap：\u4e0d\u4fdd\u5e8f\u3001\u5e76\u53d1\u6700\u9ad8\u3002\u9002\u5408\u300c\u5e76\u884c\u8c03\u591a\u4e2a\u4e92\u4e0d\u4f9d\u8d56\u7684\u6e20\u9053\u505a\u7ed3\u679c\u5bf9\u6bd4\u300d，\u7edd\u4e0d\u7528\u4e8e\u5206\u7247\u8f6c\u53d1\u3002<\/li>\n
    • concatMap：\u4e25\u683c\u4fdd\u5e8f\u3001\u4e32\u884c\u3002\u9002\u5408\u987a\u5e8f\u654f\u611f\u4e14\u5355\u5757\u5904\u7406\u6781\u5feb\u7684\u573a\u666f\u2014\u2014\u6d41\u5f0f\u5206\u7247\u89e3\u6790\u5c31\u662f\u8fd9\u4e00\u7c7b，\u51e0\u4e4e\u65e0\u6027\u80fd\u635f\u5931\u3002<\/li>\n
    • flatMapSequential：\u4fdd\u5e8f + \u5e76\u53d1，\u4f46\u4f1a\u5728\u5185\u5b58\u91cc\u7f13\u51b2\u4e71\u5e8f\u5230\u8fbe\u7684\u7ed3\u679c\u3002\u5982\u679c\u4e0a\u6e38\u7a81\u7136\u5feb\u51fa\u4e00\u5927\u622a，\u7f13\u51b2\u533a\u4f1a\u6da8\u3002\u5bf9\u6d41\u5f0f\u7f51\u5173\u8fd9\u79cd\u300c\u672c\u6765\u5c31\u662f\u7528\u5185\u5b58\u6362\u5b9e\u65f6\u6027\u300d\u7684\u7cfb\u7edf，\u591a\u4e00\u4e2a\u6ca1\u6709\u4e0a\u9650\u7684\u7f13\u51b2\u70b9\u662f\u9690\u60a3\u3002<\/li>\n<\/ul>\n

      \u5224\u65ad\u6807\u51c6\u4e00\u53e5\u8bdd：\u5148\u95ee\u300c\u987a\u5e8f\u91cd\u8981\u5417\u300d，\u518d\u95ee\u300c\u5355\u5757\u8017\u65f6\u503c\u4e0d\u503c\u5f97\u5e76\u53d1\u300d\u3002 \u4e24\u4e2a\u90fd\u4e0d\u9700\u8981，\u5c31\u76f4\u63a5 map，\u6700\u7701\u4e8b\u4e5f\u6700\u5b89\u5168\u3002<\/p>\n

      \n

      \u5c0f\u7ed3<\/h3>\n

      Flux \u53ea\u662f\u7c7b\u578b，\u6d41\u5f0f\u662f\u8fd0\u884c\u65f6\u884c\u4e3a\u3002\u8fd9\u4e24\u8005\u4e4b\u95f4\u9694\u7740 collectList\u3001bodyToMono\u3001flatMap\u3001cache()\u3001buffer() \u65e0\u6570\u4e2a\u5751，\u800c\u4e14\u5b83\u4eec\u90fd\u4e0d\u62a5\u9519\u3002<\/p>\n

      \u8bb0\u4f4f\u4e09\u6761\u5224\u636e，\u968f\u65f6\u81ea\u67e5：<\/p>\n

    • \u6709\u6ca1\u6709\u4efb\u4f55\u4e00\u6b65\u5728\u7b49\u300c\u5168\u90e8\u5b8c\u6210\u300d\u624d\u5f80\u4e0b\u8d70？ \u6709\u5c31\u662f\u9000\u5316\u3002<\/li>\n
    • \u6709\u6ca1\u6709\u628a\u5143\u7d20\u642c\u5230\u591a\u7ebf\u7a0b\u4e0a\u5904\u7406？ \u6709\u5c31\u6709\u4e71\u5e8f\u98ce\u9669\u3002<\/li>\n
    • \u6709\u6ca1\u6709\u4e3a\u4e86\u8ba9\u591a\u4e2a\u8ba2\u9605\u8005\u770b\u5230\u540c\u4e00\u4efd\u6570\u636e\u800c\u7f13\u5b58？ \u6709\u5c31\u662f\u5185\u5b58\u9690\u60a3\u3002<\/li>\n

      \u6d41\u5f0f\u7684\u672c\u8d28\u662f\u300c\u900f\u660e\u300d，\u7f51\u5173\u8981\u505a\u7684\u53ea\u662f\u522b\u6321\u8def\u3002<\/p>\n

      \u9879\u76ee\u5730\u5740：https:\/\/github.com\/maixiaowen111\/llm-gateway<\/p>\n

      \u63a8\u8350\u6807\u7b7e：WebFlux\u3001SSE\u3001Reactor\u3001\u6d41\u5f0f\u8f93\u51fa\u3001LLM<\/p>\n","protected":false},"excerpt":{"rendered":"

      \u9879\u76ee\u80cc\u666f：LLM Gateway \u5927\u6a21\u578b\u7edf\u4e00\u63a5\u5165\u7f51\u5173（Java 17 \u00b7 Spring Boot 3.5.5 \u00b7 WebFlux \/ Reactor Netty \u00b7 Redis \u00b7 Lua）\u3002\u5bf9\u5916\u7aef\u70b9 POST \/v1\/chat\/completions \u517c\u5bb9 OpenAI \u534f\u8bae，stream: true \u65f6\u8d70 SSE \u6d41\u5f0f，\u542b [DONE] \u6536\u5c3e；\u5df2\u5b9e\u73b0\u5ba2\u6237\u7aef\u65ad\u5f00\u7ea7\u8054\u53d6\u6d88\u3001\u5757\u95f4\u7a7a\u95f2\u8d85\u65f6&#xf<\/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":[11820,99],"topic":[],"class_list":["post-116467","post","type-post","status-publish","format-standard","hentry","category-server","tag-atomgit","tag-java"],"yoast_head":"\n\u8fd4\u56de Flux \u5374\u4e0d\u662f\u6d41\u5f0f\uff1fcollectList \u4e0e flatMap \u5bfc\u81f4\u7684\u9759\u9ed8\u9000\u5316 - \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\/116467.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u8fd4\u56de Flux \u5374\u4e0d\u662f\u6d41\u5f0f\uff1fcollectList \u4e0e flatMap \u5bfc\u81f4\u7684\u9759\u9ed8\u9000\u5316 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u9879\u76ee\u80cc\u666f：LLM Gateway \u5927\u6a21\u578b\u7edf\u4e00\u63a5\u5165\u7f51\u5173（Java 17 \u00b7 Spring Boot 3.5.5 \u00b7 WebFlux \/ Reactor Netty \u00b7 Redis \u00b7 Lua）\u3002\u5bf9\u5916\u7aef\u70b9 POST \/v1\/chat\/completions \u517c\u5bb9 OpenAI \u534f\u8bae，stream: true \u65f6\u8d70 SSE \u6d41\u5f0f，\u542b [DONE] \u6536\u5c3e；\u5df2\u5b9e\u73b0\u5ba2\u6237\u7aef\u65ad\u5f00\u7ea7\u8054\u53d6\u6d88\u3001\u5757\u95f4\u7a7a\u95f2\u8d85\u65f6&#xf\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/116467.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-10-21T06:40:31+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=\"12 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/116467.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/116467.html\",\"name\":\"\u8fd4\u56de Flux \u5374\u4e0d\u662f\u6d41\u5f0f\uff1fcollectList \u4e0e flatMap \u5bfc\u81f4\u7684\u9759\u9ed8\u9000\u5316 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-10-21T06:40:31+00:00\",\"dateModified\":\"2026-10-21T06:40:31+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/116467.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/116467.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/116467.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u8fd4\u56de Flux \u5374\u4e0d\u662f\u6d41\u5f0f\uff1fcollectList \u4e0e flatMap \u5bfc\u81f4\u7684\u9759\u9ed8\u9000\u5316\"}]},{\"@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":"\u8fd4\u56de Flux \u5374\u4e0d\u662f\u6d41\u5f0f\uff1fcollectList \u4e0e flatMap \u5bfc\u81f4\u7684\u9759\u9ed8\u9000\u5316 - \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\/116467.html","og_locale":"zh_CN","og_type":"article","og_title":"\u8fd4\u56de Flux \u5374\u4e0d\u662f\u6d41\u5f0f\uff1fcollectList \u4e0e flatMap \u5bfc\u81f4\u7684\u9759\u9ed8\u9000\u5316 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u9879\u76ee\u80cc\u666f：LLM Gateway \u5927\u6a21\u578b\u7edf\u4e00\u63a5\u5165\u7f51\u5173（Java 17 \u00b7 Spring Boot 3.5.5 \u00b7 WebFlux \/ Reactor Netty \u00b7 Redis \u00b7 Lua）\u3002\u5bf9\u5916\u7aef\u70b9 POST \/v1\/chat\/completions \u517c\u5bb9 OpenAI \u534f\u8bae，stream: true \u65f6\u8d70 SSE \u6d41\u5f0f，\u542b [DONE] \u6536\u5c3e；\u5df2\u5b9e\u73b0\u5ba2\u6237\u7aef\u65ad\u5f00\u7ea7\u8054\u53d6\u6d88\u3001\u5757\u95f4\u7a7a\u95f2\u8d85\u65f6&#xf","og_url":"https:\/\/www.wsisp.com\/helps\/116467.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-10-21T06:40:31+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"12 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/116467.html","url":"https:\/\/www.wsisp.com\/helps\/116467.html","name":"\u8fd4\u56de Flux \u5374\u4e0d\u662f\u6d41\u5f0f\uff1fcollectList \u4e0e flatMap \u5bfc\u81f4\u7684\u9759\u9ed8\u9000\u5316 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-10-21T06:40:31+00:00","dateModified":"2026-10-21T06:40:31+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/116467.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/116467.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/116467.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u8fd4\u56de Flux \u5374\u4e0d\u662f\u6d41\u5f0f\uff1fcollectList \u4e0e flatMap \u5bfc\u81f4\u7684\u9759\u9ed8\u9000\u5316"}]},{"@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\/116467","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=116467"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/116467\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=116467"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=116467"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=116467"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=116467"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}