{"id":23286,"date":"2025-04-19T07:21:19","date_gmt":"2025-04-18T23:21:19","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/23286.html"},"modified":"2025-04-19T07:21:19","modified_gmt":"2025-04-18T23:21:19","slug":"%e9%80%9a%e8%bf%87%e6%9c%8d%e5%8a%a1%e5%99%a8%e6%8e%a8%e9%80%81%e6%b6%88%e6%81%afwebsocket%e5%92%8csse%e8%a7%a3%e9%87%8a","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/23286.html","title":{"rendered":"\u901a\u8fc7\u670d\u52a1\u5668\u63a8\u9001\u6d88\u606f:Websocket\u548cSSE\u89e3\u91ca"},"content":{"rendered":"

\u6700\u8fd1\u5728\u770bLLM\u7684\u6d41\u5f0f\u8f93\u51fa\u5982\u4f55\u53cd\u6620\u5230json\u8f93\u51fa\u4e0a,\u73b0\u6709\u7684\u89e3\u51b3\u65b9\u6848\u5305\u62ec WebSocket \u6216 Server-Sent Events (SSE) \u5b9e\u65f6\u901a\u4fe1\u6280\u672f.<\/p>\n

WebSocket<\/h3>\n

WebSocket API \u53ef\u5728\u7528\u6237\u6d4f\u89c8\u5668\u548c\u670d\u52a1\u5668\u4e4b\u95f4\u5f00\u542f\u53cc\u5411\u4ea4\u4e92\u5f0f\u901a\u4fe1\u4f1a\u8bdd\u3002\u5229\u7528\u8be5 API，\u53ef\u4ee5\u5411\u670d\u52a1\u5668\u53d1\u9001\u4fe1\u606f，\u5e76\u63a5\u6536\u4e8b\u4ef6\u9a71\u52a8\u7684\u54cd\u5e94，\u800c\u65e0\u9700\u8f6e\u8be2\u670d\u52a1\u5668\u4ee5\u83b7\u5f97\u56de\u590d\u3002 \"img\"<\/p>\n

（1）\u5efa\u7acb\u5728 TCP \u534f\u8bae\u4e4b\u4e0a，\u670d\u52a1\u5668\u7aef\u7684\u5b9e\u73b0\u6bd4\u8f83\u5bb9\u6613\u3002<\/p>\n

（2）\u4e0e HTTP \u534f\u8bae\u6709\u7740\u826f\u597d\u7684\u517c\u5bb9\u6027\u3002\u9ed8\u8ba4\u7aef\u53e3\u4e5f\u662f80\u548c443，\u5e76\u4e14\u63e1\u624b\u9636\u6bb5\u91c7\u7528 HTTP \u534f\u8bae，\u56e0\u6b64\u63e1\u624b\u65f6\u4e0d\u5bb9\u6613\u5c4f\u853d，\u80fd\u901a\u8fc7\u5404\u79cd HTTP \u4ee3\u7406\u670d\u52a1\u5668\u3002<\/p>\n

（3）\u6570\u636e\u683c\u5f0f\u6bd4\u8f83\u8f7b\u91cf，\u6027\u80fd\u5f00\u9500\u5c0f，\u901a\u4fe1\u9ad8\u6548\u3002<\/p>\n

（4）\u53ef\u4ee5\u53d1\u9001\u6587\u672c，\u4e5f\u53ef\u4ee5\u53d1\u9001\u4e8c\u8fdb\u5236\u6570\u636e\u3002<\/p>\n

（5）\u6ca1\u6709\u540c\u6e90\u9650\u5236，\u5ba2\u6237\u7aef\u53ef\u4ee5\u4e0e\u4efb\u610f\u670d\u52a1\u5668\u901a\u4fe1\u3002<\/p>\n

（6）\u534f\u8bae\u6807\u8bc6\u7b26\u662fws（\u5982\u679c\u52a0\u5bc6，\u5219\u4e3awss），\u670d\u52a1\u5668\u7f51\u5740\u5c31\u662f URL\u3002<\/p>\n

\u5ba2\u6237\u7aef<\/p>\n

let webSocket = new WebSocket(url, protocols);
\nws.onopen = function(evt) {
\n console.log("Connection open …");
\n ws.send("Hello WebSockets!");
\n};<\/p>\n

ws.onmessage = function(evt) {
\n console.log( "Received Message: " + evt.data);
\n ws.close();
\n};<\/p>\n

ws.onclose = function(evt) {
\n console.log("Connection closed.");
\n}; <\/p>\n

\u53d1\u9001JSON<\/p>\n

\/\/ \u670d\u52a1\u5668\u5411\u6240\u6709\u7528\u6237\u53d1\u9001\u6587\u672c<\/span>
\nfunction<\/span> sendText<\/span>(<\/span>)<\/span> {<\/span>
\n \/\/ \u6784\u9020\u4e00\u4e2a msg \u5bf9\u8c61，\u5305\u542b\u4e86\u670d\u52a1\u5668\u5904\u7406\u6240\u9700\u7684\u6570\u636e<\/span>
\n var<\/span> msg =<\/span> {<\/span>
\n type<\/span>:<\/span> "message"<\/span>,<\/span>
\n text<\/span>:<\/span> document.<\/span>getElementById<\/span>(<\/span>"text"<\/span>)<\/span>.<\/span>value,<\/span>
\n id<\/span>:<\/span> clientID,<\/span>
\n date<\/span>:<\/span> Date.<\/span>now<\/span>(<\/span>)<\/span>,<\/span>
\n }<\/span>;<\/span><\/p>\n

\/\/ \u628a msg \u5bf9\u8c61\u4f5c\u4e3a JSON \u683c\u5f0f\u5b57\u7b26\u4e32\u53d1\u9001<\/span>
\n exampleSocket.<\/span>send<\/span>(<\/span>JSON<\/span>.<\/span>stringify<\/span>(<\/span>msg)<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u6e05\u7a7a\u6587\u672c\u8f93\u5165\u5143\u7d20，\u4e3a\u63a5\u6536\u4e0b\u4e00\u6761\u6d88\u606f\u505a\u597d\u51c6\u5907\u3002<\/span>
\n document.<\/span>getElementById<\/span>(<\/span>"text"<\/span>)<\/span>.<\/span>value =<\/span> ""<\/span>;<\/span>
\n}<\/span><\/p>\n

\u670d\u52a1\u7aef<\/p>\n

\u53ef\u4ee5\u4f7f\u7528Socket.IO,<\/p>\n

const<\/span> {<\/span> Server }<\/span> =<\/span> require<\/span>(<\/span>"socket.io"<\/span>)<\/span>;<\/span><\/p>\n

const<\/span> io =<\/span> new<\/span> Server<\/span>(<\/span>{<\/span> \/* options *\/<\/span> }<\/span>)<\/span>;<\/span><\/p>\n

io.<\/span>on<\/span>(<\/span>"connection"<\/span>,<\/span> (<\/span>socket<\/span>)<\/span> =><\/span> {<\/span>
\n \/\/ …<\/span>
\n}<\/span>)<\/span>;<\/span><\/p>\n

io.<\/span>listen<\/span>(<\/span>3000<\/span>)<\/span>;<\/span><\/p>\n

const<\/span> {<\/span> readFileSync }<\/span> =<\/span> require<\/span>(<\/span>"fs"<\/span>)<\/span>;<\/span>
\nconst<\/span> {<\/span> createServer }<\/span> =<\/span> require<\/span>(<\/span>"https"<\/span>)<\/span>;<\/span>
\nconst<\/span> {<\/span> Server }<\/span> =<\/span> require<\/span>(<\/span>"socket.io"<\/span>)<\/span>;<\/span><\/p>\n

const<\/span> httpsServer =<\/span> createServer<\/span>(<\/span>{<\/span>
\n key<\/span>:<\/span> readFileSync<\/span>(<\/span>"\/path\/to\/my\/key.pem"<\/span>)<\/span>,<\/span>
\n cert<\/span>:<\/span> readFileSync<\/span>(<\/span>"\/path\/to\/my\/cert.pem"<\/span>)<\/span>
\n}<\/span>)<\/span>;<\/span><\/p>\n

const<\/span> io =<\/span> new<\/span> Server<\/span>(<\/span>httpsServer,<\/span> {<\/span> \/* options *\/<\/span> }<\/span>)<\/span>;<\/span><\/p>\n

io.<\/span>on<\/span>(<\/span>"connection"<\/span>,<\/span> (<\/span>socket<\/span>)<\/span> =><\/span> {<\/span>
\n \/\/ …<\/span>
\n}<\/span>)<\/span>;<\/span><\/p>\n

httpsServer.<\/span>listen<\/span>(<\/span>3000<\/span>)<\/span>;<\/span><\/p>\n

SSE<\/h3>\n

HTTP \u534f\u8bae\u672c\u8eab\u4e0d\u5141\u8bb8\u670d\u52a1\u5668\u4e3b\u52a8\u7ed9\u5ba2\u6237\u7aef\u53d1\u9001\u4fe1\u606f，\u4f46\u6709\u4e00\u79cd\u65b9\u6cd5\u53ef\u4ee5\u8ba9\u670d\u52a1\u5668\u6301\u7eed\u5411\u5ba2\u6237\u7aef\u53d1\u9001\u6570\u636e\u6d41\u3002\u8fd9\u79cd\u65b9\u6cd5\u4e0d\u662f\u53d1\u9001\u4e00\u6b21\u6027\u6570\u636e\u5305，\u800c\u662f\u4fdd\u6301\u8fde\u63a5\u5f00\u653e，\u50cf\u89c6\u9891\u64ad\u653e\u90a3\u6837\u8fde\u7eed\u53d1\u9001\u6570\u636e\u3002\u8fd9\u79cd\u957f\u65f6\u95f4\u7684\u4e0b\u8f7d\u8fc7\u7a0b\u5b9e\u9645\u4e0a\u662f\u4ee5\u6570\u636e\u6d41\u7684\u5f62\u5f0f\u8fdb\u884c\u7684\u3002<\/p>\n

\u670d\u52a1\u5668\u53d1\u9001\u4e8b\u4ef6（SSE）\u5c31\u662f\u5229\u7528\u4e86\u8fd9\u4e2a\u7279\u6027，\u901a\u8fc7HTTP\u534f\u8bae\u8ba9\u670d\u52a1\u5668\u53ef\u4ee5\u5411\u6d4f\u89c8\u5668\u63a8\u9001\u5b9e\u65f6\u66f4\u65b0\u7684\u4fe1\u606f\u3002\u4f20\u7edf\u4e0a，\u7f51\u9875\u9700\u8981\u5148\u8bf7\u6c42\u670d\u52a1\u5668\u624d\u80fd\u83b7\u53d6\u65b0\u6570\u636e，\u4f46\u662f\u4f7f\u7528SSE，\u670d\u52a1\u5668\u53ef\u4ee5\u5728\u4efb\u4f55\u65f6\u5019\u4e3b\u52a8\u5411\u7f51\u9875\u63a8\u9001\u65b0\u7684\u6570\u636e\u548c\u6d88\u606f，\u8fd9\u4e9b\u6d88\u606f\u53ef\u4ee5\u5728\u7f51\u9875\u5185\u4f5c\u4e3a\u4e8b\u4ef6\u6765\u5904\u7406\u3002<\/p>\n

\u670d\u52a1\u7aef\u63a8\u9001\u7684\u6570\u636e\u662f\u5355\u5411\u7684，\u53ea\u4ece\u670d\u52a1\u5668\u5230\u5ba2\u6237\u7aef\u6d41\u52a8\u3002\u5f53\u4e0d\u9700\u8981\u4ece\u5ba2\u6237\u7aef\u5411\u670d\u52a1\u5668\u53d1\u9001\u4fe1\u606f\u65f6，\u6bd4\u5982\u66f4\u65b0\u793e\u4ea4\u5a92\u4f53\u72b6\u6001\u3001\u65b0\u95fb\u63a8\u9001\u6216\u628a\u6570\u636e\u4f20\u9001\u5230\u5ba2\u6237\u7aef\u5b58\u50a8（\u5982IndexedDB\u6216Web Storage），SSE\u5c31\u975e\u5e38\u9002\u5408\u3002<\/p>\n

\u4e0eSSE\u4e0d\u540c\u7684\u662f，WebSocket\u63d0\u4f9b\u4e86\u4e00\u4e2a\u66f4\u5f3a\u5927\u7684\u53cc\u5411\u901a\u4fe1\u901a\u9053，\u5141\u8bb8\u5ba2\u6237\u7aef\u548c\u670d\u52a1\u5668\u4e4b\u95f4\u4e92\u76f8\u53d1\u9001\u4fe1\u606f\u3002SSE\u5219\u662f\u5355\u5411\u7684，\u4e3b\u8981\u7528\u4e8e\u670d\u52a1\u5668\u5411\u6d4f\u89c8\u5668\u53d1\u9001\u4fe1\u606f\u3002\u5982\u679c\u6d4f\u89c8\u5668\u9700\u8981\u5411\u670d\u52a1\u5668\u53d1\u9001\u4fe1\u606f，\u5b83\u5fc5\u987b\u53d1\u8d77\u4e00\u4e2a\u65b0\u7684HTTP\u8bf7\u6c42\u3002<\/p>\n

\u8fd9\u91cc\u6709\u51e0\u4e2a\u5173\u4e8eSSE\u548cWebSocket\u7684\u533a\u522b：<\/p>\n