{"id":86204,"date":"2026-07-28T09:08:24","date_gmt":"2026-07-28T01:08:24","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/86204.html"},"modified":"2026-07-28T09:08:24","modified_gmt":"2026-07-28T01:08:24","slug":"spring-ai-%e6%b5%81%e5%bc%8f%e5%af%b9%e8%af%9d%e8%b8%a9%e5%9d%91%ef%bc%9asse-%e5%b7%b2%e5%85%b3%e9%97%ad%ef%bc%8c%e4%b8%ba%e4%bb%80%e4%b9%88%e5%a4%a7%e6%a8%a1%e5%9e%8b%e8%bf%98%e5%9c%a8%e7%bb%a7","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/86204.html","title":{"rendered":"Spring AI \u6d41\u5f0f\u5bf9\u8bdd\u8e29\u5751\uff1aSSE \u5df2\u5173\u95ed\uff0c\u4e3a\u4ec0\u4e48\u5927\u6a21\u578b\u8fd8\u5728\u7ee7\u7eed\u751f\u6210\uff1f"},"content":{"rendered":"

\u5927\u6a21\u578b\u5728\u6267\u884c\u8fc7\u7a0b\u4e2d\u505c\u6b62\u7684\u4f01\u4e1a\u5b9e\u6218：\u4ece\u8e29\u5751\u5230\u89e3\u51b3\u65b9\u6848<\/h2>\n
\n

\u6458\u8981<\/h3>\n

\u6700\u8fd1\u5728\u4f01\u4e1a\u9879\u76ee\u91cc\u8e29\u4e86\u4e00\u4e2a\u5927\u5751：\u7528\u6237\u5728AI\u5bf9\u8bdd\u8fc7\u7a0b\u4e2d\u70b9"\u505c\u6b62",\u4f46\u6a21\u578b\u8fd8\u5728\u540e\u53f0\u75af\u72c2\u8f93\u51fa\u3002\u8fd9\u5751\u4e0d\u53ea\u662f\u6d6a\u8d39Token,\u66f4\u4e25\u91cd\u7684\u662f\u2014\u2014\u8d44\u6e90\u6cc4\u6f0f\u3002\u6392\u67e5\u4e86\u4e00\u5708\u6e90\u7801,\u6700\u540e\u53d1\u73b0\u771f\u6b63\u7684\u95ee\u9898\u4e0d\u5728\u524d\u7aef,\u800c\u5728\u67b6\u6784\u8bbe\u8ba1\u3002\u8fd9\u7bc7\u6587\u7ae0\u5206\u4eab\u5b8c\u6574\u7684\u89e3\u51b3\u65b9\u6848,\u5305\u62ecAgent\u67b6\u6784\u8bbe\u8ba1\u3001\u6d41\u5f0f\u8f93\u51fa\u505c\u6b62\u673a\u5236\u3001\u4ee5\u53ca\u4e3a\u4ec0\u4e48\u8981\u8fd9\u6837\u8bbe\u8ba1\u3002\u770b\u5b8c\u4f60\u5c31\u80fd\u660e\u767d:\u4e3a\u4ec0\u4e48\u903b\u8f91\u548c\u67b6\u6784\u6bd4\u4ee3\u7801\u66f4\u91cd\u8981\u3002<\/p>\n

\n

\u4e00\u3001\u4e3a\u4ec0\u4e48\u4f1a\u5199\u8fd9\u7bc7<\/h3>\n

\u6700\u8fd1\u5728\u505a\u4f01\u4e1a\u77e5\u8bc6\u5e93\u9879\u76ee,\u7528\u7684Spring AI Alibaba + ReactAgent\u3002<\/p>\n

\u6709\u4e00\u5929\u5ba2\u6237\u53cd\u9988：<\/p>\n

\u201c\u6211\u70b9\u505c\u6b62\u4e86,AI\u600e\u4e48\u8fd8\u5728\u56de\u7b54?\u201d<\/p>\n

\u4e00\u5f00\u59cb\u6211\u4ee5\u4e3a\u662f\u524d\u7aef\u95ee\u9898,\u8ba9\u524d\u7aef\u540c\u4e8b\u6392\u67e5\u3002<\/p>\n

\u524d\u7aef\u8bf4：<\/p>\n

\u201c\u6309\u94ae\u90fddisabled\u4e86,\u4e8b\u4ef6\u90fd\u89e3\u7ed1\u4e86,\u600e\u4e48\u8fd8\u5728\u8f93\u51fa?\u201d<\/p>\n

\u540e\u6765\u67e5\u65e5\u5fd7\u624d\u53d1\u73b0\u2014\u2014<\/p>\n

SSE\u8fde\u63a5\u786e\u5b9e\u5173\u95ed\u4e86,\u4f46\u5e95\u5c42\u7684\u5927\u6a21\u578bHTTP\u8bf7\u6c42\u8fd8\u5728\u8dd1\u3002<\/p>\n

\u66f4\u5751\u7684\u662f：<\/p>\n

\u7528\u6237\u5237\u65b0\u9875\u9762\u3001\u5173\u6d4f\u89c8\u5668\u3001\u5207\u540e\u53f0\u2026\u2026<\/p>\n

\u670d\u52a1\u7aef\u5b8c\u5168\u6ca1\u611f\u77e5\u3002<\/p>\n

\u4e00\u665a\u4e0a\u4e0b\u6765,\u670d\u52a1\u5668\u5185\u5b58\u98d9\u523090%,\u5168\u662f\u50f5\u5c38\u8fde\u63a5\u3002<\/p>\n

Bug\u6ca1\u89e3\u51b3,CPU\u6e29\u5ea6\u5148\u4e0a\u6765\u4e86\u3002<\/p>\n

\u8fd9\u4e2a\u5751\u6211\u662f\u771f\u7684\u8e29\u8fc7,\u800c\u4e14\u8e29\u5f97\u5f88\u75db\u3002<\/p>\n

\u6240\u4ee5\u5199\u7bc7\u6587\u7ae0,\u628a\u65b9\u6848\u5b8c\u6574\u68b3\u7406\u51fa\u6765\u3002<\/p>\n

\n

\u4e8c\u3001\u95ee\u9898\u590d\u73b0<\/h3>\n

2.1 \u73af\u5883\u4fe1\u606f<\/h4>\n\n\u7ec4\u4ef6\u7248\u672c<\/tr>\n\n\n\n\n\n\n
Spring Boot<\/td>\n3.2.0<\/td>\n<\/tr>\n
Spring AI Alibaba<\/td>\n1.1.2<\/td>\n<\/tr>\n
ReactAgent<\/td>\n\u5b98\u65b9\u7248\u672c<\/td>\n<\/tr>\n
\u5927\u6a21\u578bAPI<\/td>\n\u901a\u4e49\u5343\u95ee \/ OpenAI<\/td>\n<\/tr>\n
\u524d\u7aef<\/td>\nReact + SSE<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

2.2 \u4e1a\u52a1\u573a\u666f<\/h4>\n

\u7528\u6237\u901a\u8fc7SSE\u6d41\u5f0f\u5bf9\u8bdd,\u8c03\u7528\u5927\u6a21\u578b\u3002<\/p>\n

\u6b63\u5e38\u6d41\u7a0b：<\/p>\n

\u7528\u6237\u63d0\u95ee \u2192 \u610f\u56fe\u5206\u6790 \u2192 Agent\u6267\u884c \u2192 SSE\u6d41\u5f0f\u8fd4\u56de<\/p>\n

\u95ee\u9898\u573a\u666f：<\/p>\n

\u7528\u6237\u70b9\u505c\u6b62 \u2192 \u524d\u7aef\u65ad\u5f00\u8fde\u63a5 \u2192 \u540e\u7aef\u8fd8\u5728\u8dd1 \u2192 Token\u7ee7\u7eed\u6263 \u2192 \u8d44\u6e90\u6cc4\u6f0f<\/p>\n

2.3 \u95ee\u9898\u6839\u56e0<\/h4>\n

\u6211\u4eec\u5f53\u65f6\u7684\u4ee3\u7801\u957f\u8fd9\u6837：<\/p>\n

@PostMapping<\/span>(<\/span>"\/stream"<\/span>)<\/span>
\npublic<\/span> SseEmitter<\/span> chatStream<\/span>(<\/span>@RequestBody<\/span> ChatRequest<\/span> request)<\/span> {<\/span>
\n SseEmitter<\/span> emitter =<\/span> new<\/span> SseEmitter<\/span>(<\/span>0L<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u5f02\u6b65\u6267\u884c<\/span>
\n executor.<\/span>execute<\/span>(<\/span>(<\/span>)<\/span> -><\/span> {<\/span>
\n Flux<\/span><<\/span>NodeOutput<\/span>><\/span><\/span> stream =<\/span> agent.<\/span>stream<\/span>(<\/span>request.<\/span>getMessage<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n stream.<\/span>subscribe<\/span>(<\/span>
\n output -><\/span> emitter.<\/span>send<\/span>(<\/span>output)<\/span>,<\/span>
\n error -><\/span> emitter.<\/span>completeWithError<\/span>(<\/span>error)<\/span>,<\/span>
\n (<\/span>)<\/span> -><\/span> emitter.<\/span>complete<\/span>(<\/span>)<\/span>
\n )<\/span>;<\/span>
\n }<\/span>)<\/span>;<\/span><\/p>\n

return<\/span> emitter;<\/span>
\n}<\/span><\/p>\n

\u770b\u4f3c\u6ca1\u95ee\u9898\u3002<\/p>\n

\u80fd\u8dd1\u3002<\/p>\n

\u4f46\u57cb\u4e86\u96f7\u3002<\/p>\n

\u95ee\u9898\u5728\u54ea？<\/p>\n

  • \u6ca1\u6709\u505c\u6b62\u63a5\u53e3：\u524d\u7aef\u70b9\u4e86\u505c\u6b62,\u540e\u7aef\u6839\u672c\u4e0d\u77e5\u9053<\/li>\n
  • \u6ca1\u6709\u4f1a\u8bdd\u7ba1\u7406：sessionId\u5230Flux\u7684\u6620\u5c04\u6ca1\u7ef4\u62a4<\/li>\n
  • \u6d4f\u89c8\u5668\u65ad\u8fde\u65e0\u611f\u77e5：\u7528\u6237\u5173\u6d4f\u89c8\u5668,\u670d\u52a1\u7aef\u65e0\u52a8\u4e8e\u8877<\/li>\n
  • \u6ca1\u6709\u515c\u5e95\u6e05\u7406：\u5f02\u5e38\u573a\u666f\u6ca1\u4eba\u7ba1,\u5168\u6210\u50f5\u5c38\u8fde\u63a5<\/li>\n

    \u66f4\u5173\u952e\u7684\u662f：<\/p>\n

    SseEmitter.complete() \u53ea\u5173\u95ed\u4e86SSE\u8fde\u63a5\u3002<\/p>\n

    \u5e95\u5c42\u7684Flux\u8ba2\u9605\u3001HTTP\u8fde\u63a5\u3001\u5927\u6a21\u578bAPI\u8c03\u7528\u2014\u2014<\/p>\n

    \u5168\u8fd8\u5728\u8dd1\u3002<\/p>\n

    \n

    \u4e09\u3001Agent\u67b6\u6784\u8bbe\u8ba1（\u8ba9\u6d41\u7a0b\u53ef\u89c6\u5316）<\/h3>\n

    \u5728\u8bf4\u89e3\u51b3\u65b9\u6848\u4e4b\u524d,\u5148\u8bf4\u8bf4\u6211\u4eec\u7684Agent\u67b6\u6784\u3002<\/p>\n

    \u4e3a\u4ec0\u4e48？<\/p>\n

    \u56e0\u4e3a\u67b6\u6784\u51b3\u5b9a\u4e86\u505c\u6b62\u65b9\u6848\u7684\u53ef\u5b9e\u73b0\u6027\u3002<\/p>\n

    3.1 \u6574\u4f53\u67b6\u6784\u56fe<\/h4>\n

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

    <\/p>\n

    \u57fa\u7840\u8bbe\u65bd\u5c42<\/p>\n

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

    <\/p>\n

    \u6d41\u4f1a\u8bdd\u7ba1\u7406\u5c42<\/p>\n

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

    <\/p>\n

    Service\u5c42<\/p>\n

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

    <\/p>\n

    \u524d\u7aef\u5c42<\/p>\n

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

    <\/p>\n

    POST \/stream<\/p>\n

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

    <\/p>\n

    POST \/stop<\/p>\n

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

    <\/p>\n

    ConcurrentHashMap<\/p>\n

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

    <\/p>\n

    \u521b\u5efa SseEmitter<\/p>\n

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

    <\/p>\n

    1.\u610f\u56fe\u5206\u6790<\/p>\n

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

    <\/p>\n

    \u67e5\u8be2\u667a\u80fd\u4f53\u914d\u7f6e<\/p>\n

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

    <\/p>\n

    \u6784\u5efa ChatModel<\/p>\n

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

    <\/p>\n

    \u8fd4\u56de IntentType<\/p>\n

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

    <\/p>\n

    2.\u8def\u7531\u5206\u53d1<\/p>\n

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

    <\/p>\n

    CHAT<\/p>\n

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

    <\/p>\n

    WRITE_ARTICLE<\/p>\n

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

    <\/p>\n

    \u6ce8\u518c Disposable<\/p>\n

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

    <\/p>\n

    \u6ce8\u518c Future<\/p>\n

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

    <\/p>\n

    stop sessionId<\/p>\n

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

    <\/p>\n

    doCleanup<\/p>\n

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

    <\/p>\n

    Controller\u5c42<\/p>\n

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

    <\/p>\n

    \u6d4f\u89c8\u5668\/\u5ba2\u6237\u7aef<\/p>\n

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

    <\/p>\n

    AiChatController.chatStream<\/p>\n

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

    <\/p>\n

    AiChatController.stopStream<\/p>\n

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

    <\/p>\n

    AiChatServiceImpl.streamChat<\/p>\n

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

    <\/p>\n

    StreamRegistry<\/p>\n

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

    <\/p>\n

    StreamSession<\/p>\n

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

    <\/p>\n

    MySQL<\/p>\n

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

    <\/p>\n

    ChatModelFactory<\/p>\n

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

    <\/p>\n

    StreamHelper<\/p>\n

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

    <\/p>\n

    IntentAnalyzer.analyze<\/p>\n

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

    <\/p>\n

    AgentHandlerFactory<\/p>\n

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

    <\/p>\n

    ChatAgentHandler<\/p>\n

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

    <\/p>\n

    WritingAgentHandler<\/p>\n

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

    <\/p>\n

    \u53d6\u6d88Flux\u8ba2\u9605\u4e2d\u65ad\u6267\u884c\u7ebf\u7a0b\u5173\u95edSSE\u8fde\u63a5<\/p>\n

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

    3.2 \u6d41\u5f0f\u5bf9\u8bdd\u6d41\u7a0b<\/h4>\n

    SseEmitter<\/p>\n

    \u5927\u6a21\u578b<\/p>\n

    AgentHandler<\/p>\n

    IntentAnalyzer<\/p>\n

    AiChatServiceImpl<\/p>\n

    AiChatController<\/p>\n

    \u524d\u7aef<\/p>\n

    SseEmitter<\/p>\n

    \u5927\u6a21\u578b<\/p>\n

    AgentHandler<\/p>\n

    IntentAnalyzer<\/p>\n

    AiChatServiceImpl<\/p>\n

    AiChatController<\/p>\n

    \u524d\u7aef<\/p>\n

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

    \u521b\u5efa SseEmitter (timeout=0)<\/p>\n

    loop<\/p>\n

    [\u6d41\u5f0f\u4e8b\u4ef6]<\/p>\n

    POST \/api\/ai\/chat\/stream<\/p>\n

    streamChat(request)<\/p>\n

    analyze(request)<\/p>\n

    \u521b\u5efa IntentAnalyzerAgent.call(message)<\/p>\n

    \u8fd4\u56de CHAT\/WRITE_ARTICLE<\/p>\n

    IntentType<\/p>\n

    handle(request, emitter)<\/p>\n

    \u67e5\u8be2\u914d\u7f6e + \u6784\u5efa\u6a21\u578b<\/p>\n

    \u521b\u5efa Agent.stream()<\/p>\n

    Flux<NodeOutput><\/p>\n

    NodeOutput<\/p>\n

    sendOpenAiChunk<\/p>\n

    \u6d41\u5f0f\u54cd\u5e94<\/p>\n

    sendOpenAiDone ([DONE])<\/p>\n

    3.3 \u67b6\u6784\u8bbe\u8ba1\u7684\u6838\u5fc3\u601d\u8def<\/h4>\n

    \u8fd9\u4e2a\u67b6\u6784\u4e0d\u662f\u62cd\u8111\u888b\u60f3\u7684\u3002<\/p>\n

    \u800c\u662f\u8e29\u4e86\u5751\u4e4b\u540e,\u4e00\u70b9\u70b9\u4f18\u5316\u51fa\u6765\u7684\u3002<\/p>\n

    \u7b2c\u4e00\u7248\u67b6\u6784：\u6ca1\u6709\u610f\u56fe\u5206\u6790<\/p>\n

    \u76f4\u63a5\u8c03\u7528ChatModel\u3002<\/p>\n

    \u95ee\u9898：<\/p>\n

    \u7528\u6237\u95ee"\u5e2e\u6211\u5199\u4e00\u7bc7\u5173\u4e8eAI\u7684\u6587\u7ae0"\u548c"\u4eca\u5929\u5929\u6c14\u600e\u4e48\u6837",\u8d70\u7684\u662f\u540c\u4e00\u4e2a\u5904\u7406\u903b\u8f91\u3002<\/p>\n

    \u7ed3\u679c：<\/p>\n

    \u5199\u6587\u7ae0\u7684\u9700\u6c42\u88ab\u5f53\u6210\u666e\u901a\u804a\u5929,\u56de\u7b54\u592a\u77ed\u3002<\/p>\n

    \u7b2c\u4e8c\u7248\u67b6\u6784：\u6709\u4e86\u610f\u56fe\u5206\u6790,\u4f46\u6ca1\u6709\u8def\u7531<\/p>\n

    \u5728Service\u91cc\u5199if-else\u3002<\/p>\n

    \u95ee\u9898：<\/p>\n

    \u4ee3\u7801\u8026\u5408\u4e25\u91cd,\u65b0\u589e\u610f\u56fe\u8981\u6539Service\u3002<\/p>\n

    \u8fdd\u53cd\u5f00\u95ed\u539f\u5219\u3002<\/p>\n

    \u7b2c\u4e09\u7248\u67b6\u6784（\u5f53\u524d）：\u7b56\u7565\u6a21\u5f0f + \u5de5\u5382\u6a21\u5f0f<\/p>\n

    \/\/ \u65b0\u589e\u610f\u56fe,\u53ea\u9700\u4e24\u6b65:<\/span>
    \n\/\/ 1. \u6dfb\u52a0 IntentType \u679a\u4e3e<\/span>
    \n\/\/ 2. \u5b9e\u73b0 AgentHandler \u63a5\u53e3<\/span>
    \n\/\/ \u65e0\u9700\u4fee\u6539\u73b0\u6709\u4ee3\u7801<\/span><\/p>\n

    public<\/span> interface<\/span> AgentHandler<\/span> {<\/span>
    \n void<\/span> handle<\/span>(<\/span>ChatRequest<\/span> request,<\/span> SseEmitter<\/span> emitter)<\/span>;<\/span>
    \n}<\/span><\/p>\n

    \u8bbe\u8ba1\u6a21\u5f0f\u4e0d\u662f\u88c5\u903c\u7528\u7684\u3002<\/p>\n

    \u800c\u662f\u771f\u771f\u5207\u5207\u80fd\u51cf\u5c11Bug\u7684\u3002<\/p>\n

    \n

    \u56db\u3001\u5927\u6a21\u578b\u505c\u6b62\u8f93\u51fa\u7684\u65b9\u6848<\/h3>\n

    4.1 \u4e3a\u4ec0\u4e48\u9700\u8981\u505c\u6b62\u65b9\u6848？<\/h4>\n

    \u4f01\u4e1a\u573a\u666f\u4e0b,\u8fd9\u662f\u521a\u9700：<\/p>\n\n\u573a\u666f\u95ee\u9898\u540e\u679c<\/tr>\n\n\n\n\n\n
    \u7528\u6237\u70b9\u505c\u6b62<\/td>\n\u5927\u6a21\u578b\u8fd8\u5728\u8f93\u51fa<\/td>\n\u6d6a\u8d39Token,\u6210\u672c\u589e\u52a0<\/td>\n<\/tr>\n
    \u7528\u6237\u5173\u95ed\u6d4f\u89c8\u5668<\/td>\n\u670d\u52a1\u7aef\u65e0\u611f\u77e5<\/td>\n\u8d44\u6e90\u6cc4\u6f0f,\u5185\u5b58\u6cc4\u6f0f<\/td>\n<\/tr>\n
    \u7528\u6237\u5237\u65b0\u9875\u9762<\/td>\n\u65e7\u8fde\u63a5\u6ca1\u6e05\u7406<\/td>\n\u5efa\u7acb\u65b0\u8fde\u63a5,\u7d2f\u79ef\u6d88\u8017<\/td>\n<\/tr>\n
    \u957f\u65f6\u95f4\u5bf9\u8bdd<\/td>\n\u8d85\u65f6\u65e0\u515c\u5e95<\/td>\n\u50f5\u5c38\u8fde\u63a5,\u670d\u52a1\u5d29\u6e83<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

    Token\u662f\u771f\u91d1\u767d\u94f6\u3002<\/p>\n

    \u8d44\u6e90\u6cc4\u6f0f\u4f1a\u641e\u57ae\u670d\u52a1\u3002<\/p>\n

    \u6240\u4ee5\u505c\u6b62\u65b9\u6848\u4e0d\u662f\u53ef\u9009,\u800c\u662f\u5fc5\u9009\u3002<\/p>\n

    4.2 \u6838\u5fc3\u6280\u672f\u539f\u7406<\/h4>\n

    \u8fd9\u4e2a\u65b9\u6848\u7684\u7075\u9b42\u5c31\u4e00\u53e5\u8bdd：<\/p>\n

    \u5229\u7528Reactor\u7684\u53d6\u6d88\u4f20\u64ad\u673a\u5236\u3002<\/p>\n

    \u4ec0\u4e48\u610f\u601d？<\/p>\n

    \u770b\u8c03\u7528\u94fe：<\/p>\n

    ReactAgent.stream()
    \n \u2514\u2192 OpenAiChatModel.stream(prompt)
    \n \u2514\u2192 OpenAiApi.chatCompletionStream(request)
    \n \u2514\u2192 webClient.post()
    \n \u2514\u2192 retrieve()
    \n \u2514\u2192 bodyToFlux()<\/p>\n

    \u5173\u952e\u70b9：<\/p>\n

      \n
    • OpenAiApi\u7528WebClient\u53d1\u8d77\u6d41\u5f0fHTTP\u8bf7\u6c42<\/li>\n
    • bodyToFlux() \u8fd4\u56de Flux<ChatCompletionChunk><\/li>\n
    • \u8fd9\u4e2aFlux\u5e95\u5c42\u7ed1\u5b9a\u4e86\u4e00\u4e2aTCP\u8fde\u63a5<\/li>\n<\/ul>\n

      \u53d6\u6d88\u4f20\u64ad\u6d41\u7a0b：<\/p>\n

      Flux.subscribe() \u8fd4\u56de Disposable
      \n \u2193
      \nDisposable.dispose()
      \n \u2193
      \nReactor \u5411 Flux \u94fe\u4e0b\u53d1 cancel \u4fe1\u53f7
      \n \u2193
      \nWebClient \u6355\u83b7\u53d6\u6d88\u4fe1\u53f7
      \n \u2193
      \nReactor Netty \u5173\u95ed TCP \u8fde\u63a5<\/p>\n

      \u6548\u679c：<\/p>\n

    • \u5ba2\u6237\u7aef\u4fa7：Flux\u8ba2\u9605\u53d6\u6d88,TCP\u8fde\u63a5\u5173\u95ed<\/li>\n
    • \u670d\u52a1\u7aef\u4fa7：\u5927\u6a21\u578bAPI\u68c0\u6d4b\u5230\u5ba2\u6237\u7aef\u65ad\u5f00,\u505c\u6b62\u751f\u6210Token<\/li>\n

      \u9a8c\u8bc1\u65b9\u6cd5：<\/p>\n

      \u7528Wireshark\u6293\u5305：<\/p>\n

      # \u8fc7\u6ee4\u5668
      \ntcp.port == 443 && ip.addr == <LLM_API_IP><\/p>\n

      # \u89c2\u5bdf\u5230dispose()\u540e\u51fa\u73b0：
      \n# – TCP RST (\u5ba2\u6237\u7aef\u4e3b\u52a8\u91cd\u7f6e)
      \n# – \u6216 TCP FIN (\u5ba2\u6237\u7aef\u4e3b\u52a8\u5173\u95ed)<\/p>\n

      \u8fd9\u5c31\u662f\u4e3a\u4ec0\u4e48 Disposable.dispose() \u80fd\u771f\u6b63\u505c\u6b62\u6a21\u578b\u8f93\u51fa\u3002<\/p>\n

      \u4e0d\u662f\u7384\u5b66,\u662fReactor\u7684\u8bbe\u8ba1\u3002<\/p>\n

      4.3 \u65b9\u6848\u8bbe\u8ba1：\u4e09\u5c42\u515c\u5e95\u4fdd\u969c<\/h4>\n

      \u65e2\u7136\u53d6\u6d88\u80fd\u4f20\u64ad,\u90a3\u95ee\u9898\u5c31\u53d8\u6210：<\/p>\n

      \u5982\u4f55\u5728\u6b63\u786e\u7684\u65f6\u673a\u8c03\u7528 Disposable.dispose()？<\/p>\n

      \u6211\u4eec\u8bbe\u8ba1\u4e86\u4e09\u5c42\u4fdd\u969c：<\/p>\n

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

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

      <\/p>\n

      \u6d4f\u89c8\u5668\u65ad\u8fde<\/p>\n

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

      <\/p>\n

      \u7528\u6237\u70b9\u505c\u6b62<\/p>\n

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

      <\/p>\n

      \u8fde\u63a5\u8d85\u65f6<\/p>\n

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

      <\/p>\n

      \u4f1a\u8bdd\u8d85\u65f6<\/p>\n

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

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

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

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

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

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

      <\/p>\n

      \u89e6\u53d1\u505c\u6b62<\/p>\n

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

      <\/p>\n

      \u89e6\u53d1\u65b9\u5f0f<\/p>\n

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

      <\/p>\n

      onError\u56de\u8c03\u81ea\u52a8\u89e6\u53d1<\/p>\n

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

      <\/p>\n

      POST \/stop API\u4e3b\u52a8\u89e6\u53d1<\/p>\n

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

      <\/p>\n

      onTimeout\u56de\u8c03\u81ea\u52a8\u89e6\u53d1<\/p>\n

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

      <\/p>\n

      \u5b9a\u65f6\u626b\u63cf\u515c\u5e95\u89e6\u53d1<\/p>\n

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

      <\/p>\n

      StreamRegistry.stop<\/p>\n

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

      <\/p>\n

      doCleanup\u4e09\u91cd\u91ca\u653e<\/p>\n

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

      \u7b2c\u4e00\u5c42：SseEmitter\u751f\u547d\u5468\u671f\u56de\u8c03（\u6700\u5e38\u7528）<\/p>\n

      emitter.<\/span>onCompletion<\/span>(<\/span>(<\/span>)<\/span> -><\/span> streamRegistry.<\/span>remove<\/span>(<\/span>sessionId)<\/span>)<\/span>;<\/span>
      \nemitter.<\/span>onError<\/span>(<\/span>ex -><\/span> streamRegistry.<\/span>stop<\/span>(<\/span>sessionId)<\/span>)<\/span>;<\/span>
      \nemitter.<\/span>onTimeout<\/span>(<\/span>(<\/span>)<\/span> -><\/span> streamRegistry.<\/span>stop<\/span>(<\/span>sessionId)<\/span>)<\/span>;<\/span><\/p>\n

        \n
      • onCompletion：\u6b63\u5e38\u7ed3\u675f,\u53ea\u79fb\u9664\u6620\u5c04<\/li>\n
      • onError：\u6d4f\u89c8\u5668\u65ad\u8fde\/I\/O\u5f02\u5e38,\u9700\u8981\u91ca\u653e\u8d44\u6e90<\/li>\n
      • onTimeout：Tomcat\u8fde\u63a5\u8d85\u65f6,\u9700\u8981\u91ca\u653e\u8d44\u6e90<\/li>\n<\/ul>\n

        \u7b2c\u4e8c\u5c42：\u4e3b\u52a8\u505c\u6b62API<\/p>\n

        @PostMapping<\/span>(<\/span>"\/stop\/{sessionId}"<\/span>)<\/span>
        \npublic<\/span> Result<\/span><<\/span>Void<\/span>><\/span><\/span> stopStream<\/span>(<\/span>@PathVariable<\/span> String<\/span> sessionId)<\/span> {<\/span>
        \n boolean<\/span> stopped =<\/span> streamRegistry.<\/span>stop<\/span>(<\/span>sessionId)<\/span>;<\/span>
        \n if<\/span> (<\/span>stopped)<\/span> {<\/span>
        \n return<\/span> Result<\/span>.<\/span>success<\/span>(<\/span>)<\/span>;<\/span>
        \n }<\/span>
        \n return<\/span> Result<\/span>.<\/span>error<\/span>(<\/span>404<\/span>,<\/span> "\u672a\u627e\u5230\u6d3b\u8dc3\u7684\u6d41\u5f0f\u8f93\u51fa"<\/span>)<\/span>;<\/span>
        \n}<\/span><\/p>\n

        \u524d\u7aef\u70b9\u51fb\u505c\u6b62\u6309\u94ae,\u8c03\u7528\u8fd9\u4e2a\u63a5\u53e3\u3002<\/p>\n

        \u7b2c\u4e09\u5c42：\u5b9a\u65f6\u515c\u5e95\u6e05\u7406<\/p>\n

        @Scheduled<\/span>(<\/span>fixedRateString =<\/span> "#{@streamConfigProperties.cleanup.scanInterval.toMillis()}"<\/span>)<\/span>
        \npublic<\/span> void<\/span> cleanupStaleSessions<\/span>(<\/span>)<\/span> {<\/span>
        \n registry.<\/span>forEachExpired<\/span>(<\/span>Instant<\/span>.<\/span>now<\/span>(<\/span>)<\/span>,<\/span> session -><\/span> {<\/span>
        \n StreamRegistry<\/span>.<\/span>doCleanup<\/span>(<\/span>session,<\/span> "\u515c\u5e95\u6e05\u7406-\u8d85\u65f6"<\/span>)<\/span>;<\/span>
        \n }<\/span>)<\/span>;<\/span>
        \n}<\/span><\/p>\n

        \u6bcf30\u79d2\u626b\u63cf\u4e00\u6b21,\u6e05\u7406\u8d85\u65f6\u6b8b\u7559\u3002<\/p>\n

        \u4e3a\u4ec0\u4e48\u9700\u8981\u4e09\u5c42？<\/p>\n

        \u56e0\u4e3a\u73b0\u5b9e\u4e16\u754c\u5f88\u590d\u6742\u3002<\/p>\n

          \n
        • \u7528\u6237\u53ef\u80fd\u5173\u6d4f\u89c8\u5668（\u7b2c\u4e00\u5c42\u515c\u5e95）<\/li>\n
        • \u7528\u6237\u53ef\u80fd\u70b9\u505c\u6b62（\u7b2c\u4e8c\u5c42\u515c\u5e95）<\/li>\n
        • \u4ee3\u7801\u53ef\u80fd\u629b\u5f02\u5e38（\u7b2c\u4e09\u5c42\u515c\u5e95）<\/li>\n<\/ul>\n

          \u4e09\u5c42\u7f3a\u4e00\u4e0d\u53ef\u3002<\/p>\n

          4.4 \u5173\u952e\u8bbe\u8ba1：SessionId\u524d\u540e\u7aef\u4f20\u9012<\/h4>\n

          \u505c\u6b62\u7684\u524d\u63d0\u662f：\u540e\u7aef\u80fd\u627e\u5230\u90a3\u4e2a\u6b63\u5728\u8fd0\u884c\u7684Flux\u3002<\/p>\n

          \u600e\u4e48\u627e？<\/p>\n

          \u7528sessionId\u4f5c\u4e3a\u552f\u4e00\u6807\u8bc6\u3002<\/p>\n

          SseEmitter<\/p>\n

          StreamRegistry<\/p>\n

          AiChatController<\/p>\n

          \u524d\u7aef<\/p>\n

          SseEmitter<\/p>\n

          StreamRegistry<\/p>\n

          AiChatController<\/p>\n

          \u524d\u7aef<\/p>\n

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

          SSE \u8d77\u59cb\u4e8b\u4ef6\u643a\u5e26 sessionId<\/p>\n

          \u524d\u7aef\u63d0\u53d6\u5e76\u5b58\u50a8 sessionId<\/p>\n

          POST \/stream<\/p>\n

          \u521b\u5efa sessionId<\/p>\n

          sendOpenAiStartChunk(sessionId)<\/p>\n

          {"delta": {"session_id": "xxx"}}<\/p>\n

          POST \/stop\/{sessionId}<\/p>\n

          stop(sessionId)<\/p>\n

          \u4eceMap\u4e2d\u627e\u5230\u4f1a\u8bdd<\/p>\n

          doCleanup\u91ca\u653e\u8d44\u6e90<\/p>\n

          true<\/p>\n

          Result.success()<\/p>\n

          \u5173\u952e\u4ee3\u7801：<\/p>\n

          \u540e\u7aef\u53d1\u9001sessionId：<\/p>\n

          public<\/span> void<\/span> sendOpenAiStartChunk<\/span>(<\/span>SseEmitter<\/span> emitter,<\/span> String<\/span> model,<\/span> long<\/span> created,<\/span> String<\/span> sessionId)<\/span> {<\/span>
          \n Map<\/span><<\/span>String<\/span>,<\/span> Object<\/span>><\/span><\/span> delta =<\/span> new<\/span> ConcurrentHashMap<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span>
          \n delta.<\/span>put<\/span>(<\/span>"role"<\/span>,<\/span> "assistant"<\/span>)<\/span>;<\/span>
          \n if<\/span> (<\/span>sessionId !=<\/span> null<\/span>)<\/span> {<\/span>
          \n delta.<\/span>put<\/span>(<\/span>"session_id"<\/span>,<\/span> sessionId)<\/span>;<\/span>
          \n }<\/span>
          \n \/\/ … \u53d1\u9001SSE\u4e8b\u4ef6<\/span>
          \n}<\/span><\/p>\n

          \u524d\u7aef\u63d0\u53d6sessionId：<\/p>\n

          eventSource.<\/span>onmessage<\/span> =<\/span> (<\/span>event<\/span>)<\/span> =><\/span> {<\/span>
          \n const<\/span> data =<\/span> JSON<\/span>.<\/span>parse<\/span>(<\/span>event.<\/span>data)<\/span>;<\/span>
          \n if<\/span> (<\/span>data.<\/span>choices &&<\/span> data.<\/span>choices[<\/span>0<\/span>]<\/span>.<\/span>delta.<\/span>session_id)<\/span> {<\/span>
          \n this<\/span>.<\/span>sessionId =<\/span> data.<\/span>choices[<\/span>0<\/span>]<\/span>.<\/span>delta.<\/span>session_id;<\/span>
          \n }<\/span>
          \n}<\/span>;<\/span><\/p>\n

          \u524d\u7aef\u505c\u6b62\u8bf7\u6c42：<\/p>\n

          const<\/span> stopStream<\/span> =<\/span> async<\/span> (<\/span>)<\/span> =><\/span> {<\/span>
          \n await<\/span> fetch<\/span>(<\/span>`<\/span>\/api\/ai\/chat\/stop\/<\/span>${<\/span>this<\/span>.<\/span>sessionId}<\/span><\/span>`<\/span><\/span>,<\/span> {<\/span> method<\/span>:<\/span> 'POST'<\/span> }<\/span>)<\/span>;<\/span>
          \n}<\/span>;<\/span><\/p>\n

          SessionId\u662f\u8fde\u63a5\u524d\u540e\u7aef\u7684\u6865\u6881\u3002<\/p>\n

          \u6ca1\u6709\u5b83,\u505c\u6b62\u5c31\u6210\u4e86\u7a7a\u8c08\u3002<\/p>\n

          4.5 \u4e09\u91cd\u91ca\u653e\u7b56\u7565：doCleanup<\/h4>\n

          \u8fd9\u662f\u65b9\u6848\u7684\u6838\u5fc3\u3002<\/p>\n

          static<\/span> void<\/span> doCleanup<\/span>(<\/span>StreamSession<\/span> session,<\/span> String<\/span> reason)<\/span> {<\/span>
          \n String<\/span> sessionId =<\/span> session.<\/span>sessionId<\/span>(<\/span>)<\/span>;<\/span>
          \n log.<\/span>info<\/span>(<\/span>"\u91ca\u653e\u8d44\u6e90 sessionId={}, reason={}"<\/span>,<\/span> sessionId,<\/span> reason)<\/span>;<\/span><\/p>\n

          \/\/ \u2460 \u53d6\u6d88Flux\u8ba2\u9605<\/span>
          \n if<\/span> (<\/span>session.<\/span>disposable<\/span>(<\/span>)<\/span> !=<\/span> null<\/span> &&<\/span> !<\/span>session.<\/span>disposable<\/span>(<\/span>)<\/span>.<\/span>isDisposed<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
          \n session.<\/span>disposable<\/span>(<\/span>)<\/span>.<\/span>dispose<\/span>(<\/span>)<\/span>;<\/span>
          \n }<\/span><\/p>\n

          \/\/ \u2461 \u4e2d\u65ad\u6267\u884c\u7ebf\u7a0b<\/span>
          \n if<\/span> (<\/span>session.<\/span>future<\/span>(<\/span>)<\/span> !=<\/span> null<\/span> &&<\/span> !<\/span>session.<\/span>future<\/span>(<\/span>)<\/span>.<\/span>isDone<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
          \n session.<\/span>future<\/span>(<\/span>)<\/span>.<\/span>cancel<\/span>(<\/span>true<\/span>)<\/span>;<\/span>
          \n }<\/span><\/p>\n

          \/\/ \u2462 \u5173\u95edSSE\u8fde\u63a5<\/span>
          \n if<\/span> (<\/span>session.<\/span>emitter<\/span>(<\/span>)<\/span> !=<\/span> null<\/span>)<\/span> {<\/span>
          \n try<\/span> {<\/span>
          \n session.<\/span>emitter<\/span>(<\/span>)<\/span>.<\/span>complete<\/span>(<\/span>)<\/span>;<\/span>
          \n }<\/span> catch<\/span> (<\/span>Exception<\/span> e)<\/span> {<\/span>
          \n log.<\/span>warn<\/span>(<\/span>"\u5173\u95edSSE\u8fde\u63a5\u5931\u8d25"<\/span>,<\/span> e)<\/span>;<\/span>
          \n }<\/span>
          \n }<\/span>
          \n}<\/span><\/p>\n

          \u4e3a\u4ec0\u4e48\u8981\u4e09\u91cd？<\/p>\n\n\u6b65\u9aa4\u8d44\u6e90\u64cd\u4f5c\u6548\u679c<\/tr>\n\n\n\n\n
          \u2460<\/td>\nDisposable (Flux\u8ba2\u9605)<\/td>\ndispose()<\/td>\n\u53d6\u6d88\u4fe1\u53f7\u4f20\u64ad\u5230WebClient,\u5173\u95ed\u5927\u6a21\u578bHTTP\u8fde\u63a5<\/td>\n<\/tr>\n
          \u2461<\/td>\nFuture (\u6267\u884c\u7ebf\u7a0b)<\/td>\ncancel(true)<\/td>\n\u4e2d\u65adAgent\u5de5\u4f5c\u6d41\u7ebf\u7a0b,\u7ec8\u6b62\u5de5\u5177\u6267\u884c<\/td>\n<\/tr>\n
          \u2462<\/td>\nSseEmitter (SSE\u8fde\u63a5)<\/td>\ncomplete()<\/td>\n\u901a\u77e5\u524d\u7aefSSE\u6d41\u7ed3\u675f<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

          \u5c11\u4e00\u6b65\u90fd\u6709\u95ee\u9898：<\/p>\n

            \n
          • \u53ea\u505a\u2460：\u7ebf\u7a0b\u8fd8\u5728\u8dd1,Agent\u5de5\u4f5c\u6d41\u6ca1\u505c\u6b62<\/li>\n
          • \u53ea\u505a\u2461：HTTP\u8fde\u63a5\u6ca1\u5173,\u5927\u6a21\u578b\u8fd8\u5728\u8f93\u51fa<\/li>\n
          • \u53ea\u505a\u2462：\u5ba2\u6237\u7aef\u4ee5\u4e3a\u7ed3\u675f\u4e86,\u670d\u52a1\u7aef\u8fd8\u5728\u6d88\u8017\u8d44\u6e90<\/li>\n<\/ul>\n

            \u4e09\u91cd\u91ca\u653e,\u786e\u4fdd\u8d44\u6e90100%\u91ca\u653e\u3002<\/p>\n

            \n

            \u4e94\u3001\u5b8c\u6574\u4ee3\u7801\u5b9e\u73b0<\/h3>\n

            5.1 StreamSession（\u4f1a\u8bdd\u8bb0\u5f55）<\/h4>\n

            public<\/span> record<\/span> StreamSession<\/span>(<\/span>
            \n String<\/span> sessionId,<\/span>
            \n SseEmitter<\/span> emitter,<\/span>
            \n Disposable<\/span> disposable,<\/span>
            \n Future<\/span><<\/span>?<\/span>><\/span><\/span> future,<\/span>
            \n Instant<\/span> createdAt,<\/span>
            \n Duration<\/span> timeout
            \n)<\/span> {<\/span>
            \n public<\/span> boolean<\/span> isExpired<\/span>(<\/span>Instant<\/span> now)<\/span> {<\/span>
            \n return<\/span> Duration<\/span>.<\/span>between<\/span>(<\/span>createdAt,<\/span> now)<\/span>.<\/span>compareTo<\/span>(<\/span>timeout)<\/span> ><\/span> 0<\/span>;<\/span>
            \n }<\/span>
            \n}<\/span><\/p>\n

            \u7528Record,\u7b80\u6d01\u3002<\/p>\n

            5.2 StreamRegistry（\u6ce8\u518c\u8868）<\/h4>\n

            @Slf4j<\/span>
            \n@Component<\/span>
            \npublic<\/span> class<\/span> StreamRegistry<\/span> {<\/span><\/p>\n

            private<\/span> final<\/span> ConcurrentHashMap<\/span><<\/span>String<\/span>,<\/span> StreamSession<\/span>><\/span><\/span> activeStreams =<\/span> new<\/span> ConcurrentHashMap<\/span><<\/span>><\/span><\/span>(<\/span>)<\/span>;<\/span><\/p>\n

            \/**
            \n * \u6ce8\u518c\u4f1a\u8bdd（\u5e42\u7b49）
            \n *\/<\/span>
            \n public<\/span> boolean<\/span> register<\/span>(<\/span>String<\/span> sessionId,<\/span> SseEmitter<\/span> emitter,<\/span>
            \n Disposable<\/span> disposable,<\/span> String<\/span> interfaceKey)<\/span> {<\/span>
            \n Duration<\/span> timeout =<\/span> config.<\/span>getTimeout<\/span>(<\/span>)<\/span>.<\/span>getTimeout<\/span>(<\/span>interfaceKey)<\/span>;<\/span>
            \n StreamSession<\/span> session =<\/span> new<\/span> StreamSession<\/span>(<\/span>
            \n sessionId,<\/span> emitter,<\/span> disposable,<\/span> Instant<\/span>.<\/span>now<\/span>(<\/span>)<\/span>,<\/span> timeout)<\/span>;<\/span><\/p>\n

            \/\/ \u5e42\u7b49\u6821\u9a8c：\u9632\u6b62\u91cd\u590d\u6ce8\u518c<\/span>
            \n StreamSession<\/span> existing =<\/span> activeStreams.<\/span>putIfAbsent<\/span>(<\/span>sessionId,<\/span> session)<\/span>;<\/span>
            \n if<\/span> (<\/span>existing !=<\/span> null<\/span> &&<\/span> existing.<\/span>disposable<\/span>(<\/span>)<\/span> !=<\/span> null<\/span> &&<\/span> !<\/span>existing.<\/span>disposable<\/span>(<\/span>)<\/span>.<\/span>isDisposed<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
            \n log.<\/span>warn<\/span>(<\/span>"\u91cd\u590d\u6ce8\u518c\u88ab\u62d2\u7edd sessionId={}"<\/span>,<\/span> sessionId)<\/span>;<\/span>
            \n return<\/span> false<\/span>;<\/span>
            \n }<\/span><\/p>\n

            log.<\/span>info<\/span>(<\/span>"\u4f1a\u8bdd\u5df2\u6ce8\u518c sessionId={}"<\/span>,<\/span> sessionId)<\/span>;<\/span>
            \n return<\/span> true<\/span>;<\/span>
            \n }<\/span><\/p>\n

            \/**
            \n * \u505c\u6b62\u4f1a\u8bdd（\u91ca\u653e\u8d44\u6e90）
            \n *\/<\/span>
            \n public<\/span> boolean<\/span> stop<\/span>(<\/span>String<\/span> sessionId)<\/span> {<\/span>
            \n StreamSession<\/span> session =<\/span> activeStreams.<\/span>remove<\/span>(<\/span>sessionId)<\/span>;<\/span>
            \n if<\/span> (<\/span>session ==<\/span> null<\/span>)<\/span> {<\/span>
            \n return<\/span> false<\/span>;<\/span>
            \n }<\/span>
            \n doCleanup<\/span>(<\/span>session,<\/span> "\u4e3b\u52a8\u505c\u6b62"<\/span>)<\/span>;<\/span>
            \n return<\/span> true<\/span>;<\/span>
            \n }<\/span><\/p>\n

            \/**
            \n * \u79fb\u9664\u4f1a\u8bdd（\u4ec5\u6e05\u7406Map）
            \n *\/<\/span>
            \n public<\/span> void<\/span> remove<\/span>(<\/span>String<\/span> sessionId)<\/span> {<\/span>
            \n activeStreams.<\/span>remove<\/span>(<\/span>sessionId)<\/span>;<\/span>
            \n }<\/span><\/p>\n

            \/**
            \n * \u4e09\u91cd\u91ca\u653e
            \n *\/<\/span>
            \n static<\/span> void<\/span> doCleanup<\/span>(<\/span>StreamSession<\/span> session,<\/span> String<\/span> reason)<\/span> {<\/span>
            \n log.<\/span>info<\/span>(<\/span>"\u91ca\u653e\u8d44\u6e90 sessionId={}, reason={}"<\/span>,<\/span> session.<\/span>sessionId<\/span>(<\/span>)<\/span>,<\/span> reason)<\/span>;<\/span><\/p>\n

            \/\/ \u2460 \u53d6\u6d88Flux\u8ba2\u9605<\/span>
            \n if<\/span> (<\/span>session.<\/span>disposable<\/span>(<\/span>)<\/span> !=<\/span> null<\/span> &&<\/span> !<\/span>session.<\/span>disposable<\/span>(<\/span>)<\/span>.<\/span>isDisposed<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
            \n session.<\/span>disposable<\/span>(<\/span>)<\/span>.<\/span>dispose<\/span>(<\/span>)<\/span>;<\/span>
            \n }<\/span><\/p>\n

            \/\/ \u2461 \u4e2d\u65ad\u6267\u884c\u7ebf\u7a0b<\/span>
            \n if<\/span> (<\/span>session.<\/span>future<\/span>(<\/span>)<\/span> !=<\/span> null<\/span> &&<\/span> !<\/span>session.<\/span>future<\/span>(<\/span>)<\/span>.<\/span>isDone<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
            \n session.<\/span>future<\/span>(<\/span>)<\/span>.<\/span>cancel<\/span>(<\/span>true<\/span>)<\/span>;<\/span>
            \n }<\/span><\/p>\n

            \/\/ \u2462 \u5173\u95edSSE\u8fde\u63a5<\/span>
            \n if<\/span> (<\/span>session.<\/span>emitter<\/span>(<\/span>)<\/span> !=<\/span> null<\/span>)<\/span> {<\/span>
            \n try<\/span> {<\/span>
            \n session.<\/span>emitter<\/span>(<\/span>)<\/span>.<\/span>complete<\/span>(<\/span>)<\/span>;<\/span>
            \n }<\/span> catch<\/span> (<\/span>Exception<\/span> e)<\/span> {<\/span>
            \n log.<\/span>warn<\/span>(<\/span>"\u5173\u95edSSE\u8fde\u63a5\u5931\u8d25"<\/span>,<\/span> e)<\/span>;<\/span>
            \n }<\/span>
            \n }<\/span>
            \n }<\/span>
            \n}<\/span><\/p>\n

            5.3 StreamCleaner（\u5b9a\u65f6\u6e05\u7406）<\/h4>\n

            @Slf4j<\/span>
            \n@Component<\/span>
            \npublic<\/span> class<\/span> StreamCleaner<\/span> {<\/span><\/p>\n

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

            @Scheduled<\/span>(<\/span>fixedRateString =<\/span> "#{@streamConfigProperties.cleanup.scanInterval.toMillis()}"<\/span>)<\/span>
            \n public<\/span> void<\/span> cleanupStaleSessions<\/span>(<\/span>)<\/span> {<\/span>
            \n if<\/span> (<\/span>registry.<\/span>activeCount<\/span>(<\/span>)<\/span> ==<\/span> 0<\/span>)<\/span> {<\/span>
            \n return<\/span>;<\/span>
            \n }<\/span><\/p>\n

            Instant<\/span> now =<\/span> Instant<\/span>.<\/span>now<\/span>(<\/span>)<\/span>;<\/span>
            \n registry.<\/span>forEachExpired<\/span>(<\/span>now,<\/span> session -><\/span> {<\/span>
            \n log.<\/span>warn<\/span>(<\/span>"\u515c\u5e95\u6e05\u7406：\u4f1a\u8bdd\u8d85\u65f6 sessionId={}"<\/span>,<\/span> session.<\/span>sessionId<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
            \n StreamRegistry<\/span>.<\/span>doCleanup<\/span>(<\/span>session,<\/span> "\u515c\u5e95\u6e05\u7406-\u8d85\u65f6"<\/span>)<\/span>;<\/span>
            \n }<\/span>)<\/span>;<\/span>
            \n }<\/span>
            \n}<\/span><\/p>\n

            5.4 Controller\u5c42\u6539\u9020<\/h4>\n

            @PostMapping<\/span>(<\/span>value =<\/span> "\/stream"<\/span>,<\/span> produces =<\/span> MediaType<\/span>.<\/span>TEXT_EVENT_STREAM_VALUE<\/span>)<\/span>
            \npublic<\/span> SseEmitter<\/span> chatStream<\/span>(<\/span>@Validated<\/span> @RequestBody<\/span> ChatRequest<\/span> request)<\/span> {<\/span>
            \n String<\/span> sessionId =<\/span> ensureSessionId<\/span>(<\/span>request)<\/span>;<\/span>
            \n SseEmitter<\/span> emitter =<\/span> new<\/span> SseEmitter<\/span>(<\/span>0L<\/span>)<\/span>;<\/span><\/p>\n

            \/\/ \u5148\u7ed1\u56de\u8c03<\/span>
            \n emitter.<\/span>onCompletion<\/span>(<\/span>(<\/span>)<\/span> -><\/span> streamRegistry.<\/span>remove<\/span>(<\/span>sessionId)<\/span>)<\/span>;<\/span>
            \n emitter.<\/span>onError<\/span>(<\/span>ex -><\/span> streamRegistry.<\/span>stop<\/span>(<\/span>sessionId)<\/span>)<\/span>;<\/span>
            \n emitter.<\/span>onTimeout<\/span>(<\/span>(<\/span>)<\/span> -><\/span> streamRegistry.<\/span>stop<\/span>(<\/span>sessionId)<\/span>)<\/span>;<\/span><\/p>\n

            \/\/ \u518d\u6ce8\u518c<\/span>
            \n streamRegistry.<\/span>register<\/span>(<\/span>sessionId,<\/span> emitter,<\/span> null<\/span>,<\/span> "chat"<\/span>)<\/span>;<\/span><\/p>\n

            \/\/ \u5f02\u6b65\u6267\u884c<\/span>
            \n executor.<\/span>execute<\/span>(<\/span>(<\/span>)<\/span> -><\/span> {<\/span>
            \n Flux<\/span><<\/span>NodeOutput<\/span>><\/span><\/span> stream =<\/span> agent.<\/span>stream<\/span>(<\/span>request.<\/span>getMessage<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
            \n Disposable<\/span> disposable =<\/span> subscriber.<\/span>subscribe<\/span>(<\/span>stream)<\/span>;<\/span><\/p>\n

            \/\/ \u56de\u586bDisposable<\/span>
            \n streamRegistry.<\/span>updateDisposable<\/span>(<\/span>sessionId,<\/span> disposable)<\/span>;<\/span><\/p>\n

            \/\/ \u53d1\u9001sessionId\u5230\u524d\u7aef<\/span>
            \n streamHelper.<\/span>sendOpenAiStartChunk<\/span>(<\/span>emitter,<\/span> modelName,<\/span> created,<\/span> sessionId)<\/span>;<\/span>
            \n }<\/span>)<\/span>;<\/span><\/p>\n

            return<\/span> emitter;<\/span>
            \n}<\/span><\/p>\n

            @PostMapping<\/span>(<\/span>"\/stop\/{sessionId}"<\/span>)<\/span>
            \npublic<\/span> Result<\/span><<\/span>Void<\/span>><\/span><\/span> stopStream<\/span>(<\/span>@PathVariable<\/span> String<\/span> sessionId)<\/span> {<\/span>
            \n boolean<\/span> stopped =<\/span> streamRegistry.<\/span>stop<\/span>(<\/span>sessionId)<\/span>;<\/span>
            \n if<\/span> (<\/span>stopped)<\/span> {<\/span>
            \n return<\/span> Result<\/span>.<\/span>success<\/span>(<\/span>)<\/span>;<\/span>
            \n }<\/span>
            \n return<\/span> Result<\/span>.<\/span>error<\/span>(<\/span>404<\/span>,<\/span> "\u672a\u627e\u5230\u6d3b\u8dc3\u7684\u6d41\u5f0f\u8f93\u51fa"<\/span>)<\/span>;<\/span>
            \n}<\/span><\/p>\n

            \u6ce8\u518c\u987a\u5e8f\u975e\u5e38\u91cd\u8981：<\/p>\n

            \u5148\u7ed1\u56de\u8c03 \u2192 \u518d\u6ce8\u518c \u2192 \u6700\u540e\u8ba2\u9605<\/p>\n

            \u4e3a\u4ec0\u4e48？<\/p>\n

            \u5982\u679c\u5148\u8ba2\u9605,\u8ba2\u9605\u8fc7\u7a0b\u4e2d\u629b\u5f02\u5e38,\u4f46\u56de\u8c03\u8fd8\u6ca1\u7ed1,\u5c31\u6ca1\u4eba\u6e05\u7406\u4e86\u3002<\/p>\n

            \n

            \u516d\u3001\u65b9\u6848\u7684\u4f18\u70b9\u548c\u4e3a\u4ec0\u4e48<\/h3>\n

            6.1 \u6838\u5fc3\u4f18\u70b9<\/h4>\n\n\u4f18\u70b9\u8bf4\u660e\u4e3a\u4ec0\u4e48<\/tr>\n\n\n\n\n\n\n\n\n
            \u8d44\u6e90\u96f6\u6cc4\u6f0f<\/td>\n\u4e09\u91cd\u91ca\u653e\u786e\u4fdd100%\u6e05\u7406<\/td>\n\u6bcf\u4e2a\u8d44\u6e90\u90fd\u6709\u91ca\u653e\u8def\u5f84<\/td>\n<\/tr>\n
            Token\u6210\u672c\u964d\u4f4e<\/td>\n\u7528\u6237\u70b9\u505c\u6b62,\u7acb\u523b\u4e2d\u65ad\u5927\u6a21\u578b<\/td>\nReactor\u53d6\u6d88\u4f20\u64ad\u5230HTTP\u8fde\u63a5<\/td>\n<\/tr>\n
            \u7528\u6237\u4f53\u9a8c\u597d<\/td>\n\u524d\u7aef\u70b9\u505c\u6b62,\u540e\u7aef\u7acb\u523b\u54cd\u5e94<\/td>\nsessionId\u6620\u5c04\u5b9e\u73b0\u7cbe\u51c6\u5b9a\u4f4d<\/td>\n<\/tr>\n
            \u4ee3\u7801\u89e3\u8026<\/td>\nStreamRegistry\u3001StreamCleaner\u804c\u8d23\u5355\u4e00<\/td>\n\u5355\u4e00\u804c\u8d23\u539f\u5219<\/td>\n<\/tr>\n
            \u6269\u5c55\u6027\u5f3a<\/td>\n\u65b0\u589e\u610f\u56fe\u53ea\u9700\u5b9e\u73b0AgentHandler<\/td>\n\u7b56\u7565\u6a21\u5f0f + \u5de5\u5382\u6a21\u5f0f<\/td>\n<\/tr>\n
            \u53ef\u914d\u7f6e<\/td>\n\u8d85\u65f6\u65f6\u95f4\u3001\u626b\u63cf\u95f4\u9694\u5168\u53ef\u914d<\/td>\n@ConfigurationProperties<\/td>\n<\/tr>\n
            \u53ef\u9a8c\u8bc1<\/td>\n\u65e5\u5fd7\u3001Wireshark\u3001\u96c6\u6210\u6d4b\u8bd5\u591a\u7ef4\u5ea6\u9a8c\u8bc1<\/td>\n\u4e0d\u662f\u7384\u5b66,\u662f\u79d1\u5b66<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

            6.2 \u4e3a\u4ec0\u4e48\u8fd9\u6837\u8bbe\u8ba1？<\/h4>\n

            \u95ee\u98981：\u4e3a\u4ec0\u4e48\u4e0d\u7528\u7ebf\u7a0b\u4e2d\u65ad？<\/p>\n

            \u7ebf\u7a0b\u4e2d\u65ad\u662fJava\u5c42\u9762\u7684\u3002<\/p>\n

            \u4f46\u5927\u6a21\u578b\u8c03\u7528\u662fHTTP\u8bf7\u6c42\u3002<\/p>\n

            HTTP\u8bf7\u6c42\u5728Reactor Netty\u7ebf\u7a0b\u6c60\u91cc\u3002<\/p>\n

            \u4e2d\u65adJava\u7ebf\u7a0b,\u4e0d\u7b49\u540c\u4e8e\u5173\u95edHTTP\u8fde\u63a5\u3002<\/p>\n

            \u6240\u4ee5\u8981\u7528Reactor\u7684\u53d6\u6d88\u673a\u5236,\u800c\u4e0d\u662fJava\u7684\u7ebf\u7a0b\u4e2d\u65ad\u3002<\/p>\n

            \u95ee\u98982：\u4e3a\u4ec0\u4e48\u9700\u8981\u4e09\u5c42\u515c\u5e95？<\/p>\n

            \u56e0\u4e3a\u7528\u6237\u884c\u4e3a\u4e0d\u53ef\u63a7\u3002<\/p>\n

              \n
            • \u7528\u6237\u53ef\u80fd\u70b9\u505c\u6b62<\/li>\n
            • \u7528\u6237\u53ef\u80fd\u5173\u6d4f\u89c8\u5668<\/li>\n
            • \u7528\u6237\u53ef\u80fd\u5237\u65b0\u9875\u9762<\/li>\n
            • \u4ee3\u7801\u53ef\u80fd\u629b\u5f02\u5e38<\/li>\n<\/ul>\n

              \u4e00\u5c42\u515c\u4e0d\u4f4f\u6240\u6709\u573a\u666f\u3002<\/p>\n

              \u95ee\u98983：\u4e3a\u4ec0\u4e48\u6ce8\u518c\u987a\u5e8f\u8fd9\u4e48\u91cd\u8981？<\/p>\n

              \u770b\u53cd\u4f8b：<\/p>\n

              \/\/ \u9519\u8bef\u793a\u8303<\/span>
              \nDisposable<\/span> disposable =<\/span> stream.<\/span>subscribe<\/span>(<\/span>.<\/span>.<\/span>.<\/span>)<\/span>;<\/span> \/\/ \u5148\u8ba2\u9605<\/span>
              \nemitter.<\/span>onError<\/span>(<\/span>ex -><\/span> registry.<\/span>stop<\/span>(<\/span>sessionId)<\/span>)<\/span>;<\/span> \/\/ \u540e\u7ed1\u56de\u8c03<\/span>
              \nregistry.<\/span>register<\/span>(<\/span>sessionId,<\/span> emitter,<\/span> disposable)<\/span>;<\/span> \/\/ \u518d\u6ce8\u518c<\/span><\/p>\n

              \/\/ \u95ee\u9898：\u8ba2\u9605\u8fc7\u7a0b\u4e2d\u5982\u679c\u629b\u5f02\u5e38,\u56de\u8c03\u8fd8\u6ca1\u7ed1,\u8d44\u6e90\u6cc4\u6f0f<\/span><\/p>\n

              \u6b63\u786e\u987a\u5e8f：<\/p>\n

              \/\/ \u6b63\u786e\u793a\u8303<\/span>
              \nemitter.<\/span>onError<\/span>(<\/span>ex -><\/span> registry.<\/span>stop<\/span>(<\/span>sessionId)<\/span>)<\/span>;<\/span> \/\/ \u5148\u7ed1\u56de\u8c03<\/span>
              \nregistry.<\/span>register<\/span>(<\/span>sessionId,<\/span> emitter,<\/span> null<\/span>)<\/span>;<\/span> \/\/ \u518d\u6ce8\u518c<\/span>
              \nDisposable<\/span> disposable =<\/span> stream.<\/span>subscribe<\/span>(<\/span>.<\/span>.<\/span>.<\/span>)<\/span>;<\/span> \/\/ \u6700\u540e\u8ba2\u9605<\/span>
              \nregistry.<\/span>updateDisposable<\/span>(<\/span>sessionId,<\/span> disposable)<\/span>;<\/span> \/\/ \u56de\u586b<\/span><\/p>\n

              \u5148\u7ed1\u56de\u8c03,\u518d\u6ce8\u518c,\u6700\u540e\u8ba2\u9605\u3002<\/p>\n

              \u6d88\u9664\u7ade\u6001\u7a97\u53e3\u3002<\/p>\n

              \n

              👇 \u4e09\u8fde\u652f\u6301，\u52a8\u529b\u6e90\u6cc9<\/h3>\n

              \u5982\u679c\u8fd9\u7bc7\u6587\u7ae0\u5e2e\u4f60\u7701\u4e0b\u4e86\u8e29\u5751\u7684\u65f6\u95f4，\u6b22\u8fce：<\/p>\n

              🔹 \u70b9\u8d5e \u2014\u2014 \u8ba9\u66f4\u591a\u4eba\u770b\u5230\u8fd9\u7bc7\u5e72\u8d27 🔹 \u5728\u770b \u2014\u2014 \u4f60\u7684\u8ba4\u53ef\u662f\u6211\u6301\u7eed\u8f93\u51fa\u7684\u52a8\u529b 🔹 \u8f6c\u53d1 \u2014\u2014 \u5206\u4eab\u7ed9\u8eab\u8fb9\u6b63\u5728\u505aAI Agent\u7684\u670b\u53cb<\/p>\n

              \u4f60\u7684\u6bcf\u4e00\u4e2a\u5c0f\u52a8\u4f5c，\u5bf9\u6211\u90fd\u5f88\u91cd\u8981 \u2764\ufe0f<\/p>\n

              \n

              🙏 \u5173\u4e8e\u4f5c\u8005<\/h3>\n

              \u4f60\u597d，\u6211\u662f \u7a7a\u95e8\u6280\u672f\u6808，\u4e00\u4e2a\u5e38\u5e74\u548cBug\u6218\u6597\u3001\u6301\u7eed\u586b\u5751\u7684Java\u5f00\u53d1\u8005\u3002<\/p>\n

              \u4e13\u6ce8\u5206\u4eab：<\/p>\n

                \n
              • \u2705 Java \/ Spring Boot \/ Spring AI Alibaba \u4f01\u4e1a\u7ea7\u5b9e\u6218<\/li>\n
              • \u2705 RAG\u77e5\u8bc6\u5e93\u3001AI Agent\u3001\u591a\u667a\u80fd\u4f53\u534f\u4f5c\u843d\u5730\u7ecf\u9a8c<\/li>\n
              • \u2705 Docker\u90e8\u7f72\u3001\u5fae\u670d\u52a1\u67b6\u6784\u3001\u7ebf\u4e0a\u95ee\u9898\u6392\u67e5<\/li>\n
              • \u2705 \u5076\u5c14\u804a\u804a\u300c\u5982\u4f55\u4fdd\u4f4f\u5934\u53d1\u300d\u8fd9\u7c7b\u7a0b\u5e8f\u5458\u7ec8\u6781\u8bdd\u9898 😂<\/li>\n<\/ul>\n

                \u4e0d\u641e\u6c34\u6587，\u4e0d\u8d29\u5356\u7126\u8651，\u53ea\u5199\u80fd\u8dd1\u901a\u3001\u80fd\u843d\u5730\u3001\u80fd\u5e2e\u4f60\u5c11\u52a0\u73ed\u7684\u5b9e\u6218\u5185\u5bb9\u3002<\/p>\n

                \u5173\u6ce8\u6211，\u54b1\u4eec\u4e00\u8d77\u5c11\u8e29\u5751，\u591a\u5199\u4f18\u96c5\u4ee3\u7801\u3002<\/p>\n

                \n

                📖 \u66f4\u591a\u5e72\u8d27\u63a8\u8350<\/h3>\n
                  \n
                • \u544a\u522b\u624b\u52a8\u590d\u5236\u63a5\u53e3\u6587\u6863！Apifox MCP + AI \u81ea\u52a8\u6d4b\u8bd5\u8ba9\u5f00\u53d1\u6548\u7387\u8d77\u98de<\/li>\n
                • MySQL MCP Server \u4ece\u96f6\u5b89\u88c5\u5230\u4f7f\u7528\u5b9e\u6218，AI \u76f4\u63a5\u67e5\u8be2\u6570\u636e\u5e93<\/li>\n
                • Spring Event \u7528\u4e86\u4e09\u5e74，\u540c\u4e8b\u4e00\u53e5\u8bdd\u628a\u6211\u95ee\u61f5\u4e86<\/li>\n
                • Java \u62bd\u8c61\u7c7b（Abstract Class）\u5f7b\u5e95\u8bb2\u900f：\u4ece\u57fa\u7840\u5230\u591a\u6001\u5b9e\u6218<\/li>\n
                • Spring AI Alibaba \u591a\u667a\u80fd\u4f53（Multi-agent）\u5b9e\u6218：6 \u5927\u534f\u4f5c\u6a21\u5f0f + \u5b8c\u6574\u4ee3\u7801<\/li>\n
                • Spring AI Alibaba \u667a\u80fd\u4f53\u4f5c\u4e3a\u5de5\u5177\u5b9e\u6218：\u522b\u518d\u8ba9\u4e3b Agent \u5f53"\u4eba\u8089\u8def\u7531\u5668"\u4e86<\/li>\n
                • \u4e00\u6587\u641e\u61c2 Spring AI Alibaba Workflow：10 \u4e2a\u5b9e\u6218\u6848\u4f8b\u5e26\u4f60\u5f7b\u5e95\u638c\u63e1 AI \u5de5\u4f5c\u6d41\u7f16\u6392<\/li>\n
                • RAG \u77e5\u8bc6\u5e93\u4e3a\u4ec0\u4e48\u8d8a\u66f4\u65b0\u8d8a\u4e71？\u4e00\u6587\u8bb2\u900f\u751f\u4ea7\u7ea7\u6587\u6863\u66f4\u65b0\u65b9\u6848<\/li>\n
                • Transformers VS vLLM：\u5927\u6a21\u578b\u90e8\u7f72\u5230\u5e95\u8be5\u9009\u8c01？\u4ece\u672c\u5730\u8fd0\u884c\u5230\u751f\u4ea7\u4e0a\u7ebf\u5b8c\u6574\u89e3\u6790<\/li>\n
                • LangChain Agent\u7ec8\u4e8e\u8bb2\u900f\u4e86：\u77ed\u671f\u8bb0\u5fc6\u3001Redis\u6301\u4e45\u5316\u3001Middleware\u4f01\u4e1a\u7ea7\u5b9e\u6218，\u4e00\u7bc7\u5e26\u4f60\u4ece\u5165\u95e8\u5230\u751f\u4ea7<\/li>\n
                • LangChain \u6d41\u5f0f\u8f93\u51fa\u7ec8\u4e8e\u8bb2\u900f\u4e86：6 \u79cd stream_mode \u4e00\u7bc7\u5168\u641e\u61c2<\/li>\n<\/ul>\n
                  \n

                  🤝 \u9879\u76ee\u5408\u4f5c \/ \u6280\u672f\u54a8\u8be2<\/h3>\n

                  \u5e73\u65f6\u5de5\u4f5c\u4e4b\u4f59，\u4e5f\u4f1a\u63a5\u4e00\u4e9b\u6280\u672f\u9879\u76ee\u548c\u54a8\u8be2，\u4e3b\u8981\u65b9\u5411：<\/p>\n

                  \u2694\ufe0f \u4f01\u4e1a\u7ea7\u5f00\u53d1<\/p>\n

                    \n
                  • Java \/ Spring Boot \u9879\u76ee\u5f00\u53d1\u4e0e\u91cd\u6784<\/li>\n
                  • \u5fae\u670d\u52a1\u67b6\u6784\u8bbe\u8ba1\u4e0e\u843d\u5730<\/li>\n
                  • \u7cfb\u7edf\u6027\u80fd\u8c03\u4f18\u3001\u7ebf\u4e0a\u95ee\u9898\u6392\u67e5<\/li>\n<\/ul>\n

                    🤖 AI \u5e94\u7528\u843d\u5730（\u8fd9\u662f\u6211\u6700\u8fd1\u7684\u4e3b\u529b\u65b9\u5411）<\/p>\n

                      \n
                    • Spring AI Alibaba \/ RAG \/ Agent \u5e94\u7528\u5f00\u53d1<\/li>\n
                    • \u4f01\u4e1a\u79c1\u6709\u77e5\u8bc6\u5e93\u642d\u5efa<\/li>\n
                    • AI\u80fd\u529b\u63a5\u5165\u73b0\u6709\u4e1a\u52a1\u7cfb\u7edf<\/li>\n
                    • \u5927\u6a21\u578b\u672c\u5730\u5316\u90e8\u7f72\u4e0e\u8c03\u4f18<\/li>\n<\/ul>\n

                      🛠\ufe0f \u6280\u672f\u987e\u95ee \/ \u7591\u96beBug\u6392\u67e5<\/p>\n

                        \n
                      • \u9879\u76ee\u67b6\u6784\u8bc4\u5ba1\u4e0e\u65b9\u6848\u8bbe\u8ba1<\/li>\n
                      • \u7ebf\u4e0a\u7591\u96be\u95ee\u9898\u5b9a\u4f4d\u89e3\u51b3<\/li>\n
                      • \u6280\u672f\u9009\u578b\u4e0e\u56e2\u961f\u57f9\u8bad<\/li>\n<\/ul>\n

                        \u5982\u679c\u4f60\u6b63\u9047\u5230\u4ee5\u4e0b\u60c5\u51b5，\u6b22\u8fce\u627e\u6211\u804a\u804a：<\/p>\n

                          \n
                        • \u2705 \u60f3\u505aAI\u9879\u76ee，\u4f46\u6280\u672f\u65b9\u6848\u62ff\u4e0d\u51c6<\/li>\n
                        • \u2705 \u9879\u76ee\u5361\u5728\u67d0\u4e2aBug\u4e0a\u5f88\u4e45，\u56e2\u961f\u641e\u4e0d\u5b9a<\/li>\n
                        • \u2705 \u60f3\u628aAI\u63a5\u5165\u73b0\u6709\u4e1a\u52a1，\u4e0d\u77e5\u9053\u4ece\u54ea\u4e0b\u624b<\/li>\n
                        • \u2705 \u9700\u8981\u9760\u8c31\u7684\u5f00\u53d1\u5916\u5305\u6216\u957f\u671f\u6280\u672f\u987e\u95ee<\/li>\n<\/ul>\n

                          📮 \u8054\u7cfb\u6e20\u9053（\u6309\u56de\u590d\u901f\u5ea6\u6392\u5e8f）：<\/p>\n

                        • \u6700\u5feb：\u79c1\u4fe1\u7a7a\u95e8\u6280\u672f\u6808<\/li>\n
                        • \u90ae\u4ef6：2929119150@qq.com（\u8bf7\u6ce8\u660e\u6765\u610f\u548c\u5177\u4f53\u9700\u6c42）<\/li>\n

                          \u4e00\u4e2a\u4eba\u8e29\u5751，\u662f\u4e8b\u6545；\u4e00\u7fa4\u4eba\u8e29\u5751，\u5c31\u662f\u300a\u907f\u5751\u5b9d\u5178\u300b\u3002<\/p>\n

                          \u2014\u2014 IT \u7a7a\u95e8，\u4e0e\u8bf8\u541b\u5171\u4fee\u6280\u672f\u5927\u9053 😎<\/p>\n","protected":false},"excerpt":{"rendered":"

                          \u5927\u6a21\u578b\u5728\u6267\u884c\u8fc7\u7a0b\u4e2d\u505c\u6b62\u7684\u4f01\u4e1a\u5b9e\u6218：\u4ece\u8e29\u5751\u5230\u89e3\u51b3\u65b9\u6848 \u6458\u8981
                          \n\u6700\u8fd1\u5728\u4f01\u4e1a\u9879\u76ee\u91cc\u8e29\u4e86\u4e00\u4e2a\u5927\u5751：\u7528\u6237\u5728AI\u5bf9\u8bdd\u8fc7\u7a0b\u4e2d\u70b9\\”\u505c\u6b62\\”,\u4f46\u6a21\u578b\u8fd8\u5728\u540e\u53f0\u75af\u72c2\u8f93\u51fa\u3002\u8fd9\u5751\u4e0d\u53ea\u662f\u6d6a\u8d39Token,\u66f4\u4e25\u91cd\u7684\u662f\u2014\u2014\u8d44\u6e90\u6cc4\u6f0f\u3002\u6392\u67e5\u4e86\u4e00\u5708\u6e90\u7801,\u6700\u540e\u53d1\u73b0\u771f\u6b63\u7684\u95ee\u9898\u4e0d\u5728\u524d\u7aef,\u800c\u5728\u67b6\u6784\u8bbe\u8ba1\u3002\u8fd9\u7bc7\u6587\u7ae0\u5206\u4eab\u5b8c\u6574\u7684\u89e3\u51b3\u65b9\u6848,\u5305\u62ecAgent\u67b6\u6784\u8bbe\u8ba1\u3001\u6d41\u5f0f\u8f93\u51fa\u505c\u6b62\u673a\u5236\u3001\u4ee5\u53ca\u4e3a\u4ec0\u4e48\u8981\u8fd9\u6837\u8bbe\u8ba1\u3002\u770b\u5b8c\u4f60\u5c31\u80fd\u660e\u767d:\u4e3a\u4ec0\u4e48\u903b\u8f91\u548c\u67b6\u6784\u6bd4\u4ee3\u7801\u66f4\u91cd\u8981\u3002 \u4e00\u3001\u4e3a\u4ec0\u4e48\u4f1a\u5199\u8fd9\u7bc7
                          \n\u6700\u8fd1\u5728\u505a\u4f01\u4e1a\u77e5\u8bc6\u5e93\u9879\u76ee,\u7528\u7684Spri<\/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":[101,50,1654],"topic":[],"class_list":["post-86204","post","type-post","status-publish","format-standard","hentry","category-server","tag-spring","tag-50","tag-1654"],"yoast_head":"\nSpring AI \u6d41\u5f0f\u5bf9\u8bdd\u8e29\u5751\uff1aSSE \u5df2\u5173\u95ed\uff0c\u4e3a\u4ec0\u4e48\u5927\u6a21\u578b\u8fd8\u5728\u7ee7\u7eed\u751f\u6210\uff1f - \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\/86204.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Spring AI \u6d41\u5f0f\u5bf9\u8bdd\u8e29\u5751\uff1aSSE \u5df2\u5173\u95ed\uff0c\u4e3a\u4ec0\u4e48\u5927\u6a21\u578b\u8fd8\u5728\u7ee7\u7eed\u751f\u6210\uff1f - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u5927\u6a21\u578b\u5728\u6267\u884c\u8fc7\u7a0b\u4e2d\u505c\u6b62\u7684\u4f01\u4e1a\u5b9e\u6218：\u4ece\u8e29\u5751\u5230\u89e3\u51b3\u65b9\u6848 \u6458\u8981 \u6700\u8fd1\u5728\u4f01\u4e1a\u9879\u76ee\u91cc\u8e29\u4e86\u4e00\u4e2a\u5927\u5751：\u7528\u6237\u5728AI\u5bf9\u8bdd\u8fc7\u7a0b\u4e2d\u70b9"\u505c\u6b62",\u4f46\u6a21\u578b\u8fd8\u5728\u540e\u53f0\u75af\u72c2\u8f93\u51fa\u3002\u8fd9\u5751\u4e0d\u53ea\u662f\u6d6a\u8d39Token,\u66f4\u4e25\u91cd\u7684\u662f\u2014\u2014\u8d44\u6e90\u6cc4\u6f0f\u3002\u6392\u67e5\u4e86\u4e00\u5708\u6e90\u7801,\u6700\u540e\u53d1\u73b0\u771f\u6b63\u7684\u95ee\u9898\u4e0d\u5728\u524d\u7aef,\u800c\u5728\u67b6\u6784\u8bbe\u8ba1\u3002\u8fd9\u7bc7\u6587\u7ae0\u5206\u4eab\u5b8c\u6574\u7684\u89e3\u51b3\u65b9\u6848,\u5305\u62ecAgent\u67b6\u6784\u8bbe\u8ba1\u3001\u6d41\u5f0f\u8f93\u51fa\u505c\u6b62\u673a\u5236\u3001\u4ee5\u53ca\u4e3a\u4ec0\u4e48\u8981\u8fd9\u6837\u8bbe\u8ba1\u3002\u770b\u5b8c\u4f60\u5c31\u80fd\u660e\u767d:\u4e3a\u4ec0\u4e48\u903b\u8f91\u548c\u67b6\u6784\u6bd4\u4ee3\u7801\u66f4\u91cd\u8981\u3002 \u4e00\u3001\u4e3a\u4ec0\u4e48\u4f1a\u5199\u8fd9\u7bc7 \u6700\u8fd1\u5728\u505a\u4f01\u4e1a\u77e5\u8bc6\u5e93\u9879\u76ee,\u7528\u7684Spri\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/86204.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-28T01:08:24+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=\"13 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/86204.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/86204.html\",\"name\":\"Spring AI \u6d41\u5f0f\u5bf9\u8bdd\u8e29\u5751\uff1aSSE \u5df2\u5173\u95ed\uff0c\u4e3a\u4ec0\u4e48\u5927\u6a21\u578b\u8fd8\u5728\u7ee7\u7eed\u751f\u6210\uff1f - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-07-28T01:08:24+00:00\",\"dateModified\":\"2026-07-28T01:08:24+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/86204.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/86204.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/86204.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Spring AI \u6d41\u5f0f\u5bf9\u8bdd\u8e29\u5751\uff1aSSE \u5df2\u5173\u95ed\uff0c\u4e3a\u4ec0\u4e48\u5927\u6a21\u578b\u8fd8\u5728\u7ee7\u7eed\u751f\u6210\uff1f\"}]},{\"@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":"Spring AI \u6d41\u5f0f\u5bf9\u8bdd\u8e29\u5751\uff1aSSE \u5df2\u5173\u95ed\uff0c\u4e3a\u4ec0\u4e48\u5927\u6a21\u578b\u8fd8\u5728\u7ee7\u7eed\u751f\u6210\uff1f - \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\/86204.html","og_locale":"zh_CN","og_type":"article","og_title":"Spring AI \u6d41\u5f0f\u5bf9\u8bdd\u8e29\u5751\uff1aSSE \u5df2\u5173\u95ed\uff0c\u4e3a\u4ec0\u4e48\u5927\u6a21\u578b\u8fd8\u5728\u7ee7\u7eed\u751f\u6210\uff1f - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u5927\u6a21\u578b\u5728\u6267\u884c\u8fc7\u7a0b\u4e2d\u505c\u6b62\u7684\u4f01\u4e1a\u5b9e\u6218：\u4ece\u8e29\u5751\u5230\u89e3\u51b3\u65b9\u6848 \u6458\u8981 \u6700\u8fd1\u5728\u4f01\u4e1a\u9879\u76ee\u91cc\u8e29\u4e86\u4e00\u4e2a\u5927\u5751：\u7528\u6237\u5728AI\u5bf9\u8bdd\u8fc7\u7a0b\u4e2d\u70b9\"\u505c\u6b62\",\u4f46\u6a21\u578b\u8fd8\u5728\u540e\u53f0\u75af\u72c2\u8f93\u51fa\u3002\u8fd9\u5751\u4e0d\u53ea\u662f\u6d6a\u8d39Token,\u66f4\u4e25\u91cd\u7684\u662f\u2014\u2014\u8d44\u6e90\u6cc4\u6f0f\u3002\u6392\u67e5\u4e86\u4e00\u5708\u6e90\u7801,\u6700\u540e\u53d1\u73b0\u771f\u6b63\u7684\u95ee\u9898\u4e0d\u5728\u524d\u7aef,\u800c\u5728\u67b6\u6784\u8bbe\u8ba1\u3002\u8fd9\u7bc7\u6587\u7ae0\u5206\u4eab\u5b8c\u6574\u7684\u89e3\u51b3\u65b9\u6848,\u5305\u62ecAgent\u67b6\u6784\u8bbe\u8ba1\u3001\u6d41\u5f0f\u8f93\u51fa\u505c\u6b62\u673a\u5236\u3001\u4ee5\u53ca\u4e3a\u4ec0\u4e48\u8981\u8fd9\u6837\u8bbe\u8ba1\u3002\u770b\u5b8c\u4f60\u5c31\u80fd\u660e\u767d:\u4e3a\u4ec0\u4e48\u903b\u8f91\u548c\u67b6\u6784\u6bd4\u4ee3\u7801\u66f4\u91cd\u8981\u3002 \u4e00\u3001\u4e3a\u4ec0\u4e48\u4f1a\u5199\u8fd9\u7bc7 \u6700\u8fd1\u5728\u505a\u4f01\u4e1a\u77e5\u8bc6\u5e93\u9879\u76ee,\u7528\u7684Spri","og_url":"https:\/\/www.wsisp.com\/helps\/86204.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-07-28T01:08:24+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"13 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/86204.html","url":"https:\/\/www.wsisp.com\/helps\/86204.html","name":"Spring AI \u6d41\u5f0f\u5bf9\u8bdd\u8e29\u5751\uff1aSSE \u5df2\u5173\u95ed\uff0c\u4e3a\u4ec0\u4e48\u5927\u6a21\u578b\u8fd8\u5728\u7ee7\u7eed\u751f\u6210\uff1f - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-07-28T01:08:24+00:00","dateModified":"2026-07-28T01:08:24+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/86204.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/86204.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/86204.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"Spring AI \u6d41\u5f0f\u5bf9\u8bdd\u8e29\u5751\uff1aSSE \u5df2\u5173\u95ed\uff0c\u4e3a\u4ec0\u4e48\u5927\u6a21\u578b\u8fd8\u5728\u7ee7\u7eed\u751f\u6210\uff1f"}]},{"@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\/86204","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=86204"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/86204\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=86204"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=86204"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=86204"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=86204"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}