```html Python WebSocket \u670d\u52a1\u5668\u7684\u9ad8\u5e76\u53d1\u4f18\u5316<\/p>\n
\u968f\u7740\u5b9e\u65f6\u901a\u4fe1\u9700\u6c42\u7684\u589e\u957f，WebSocket \u6280\u672f\u56e0\u5176\u4f4e\u5ef6\u8fdf\u548c\u53cc\u5411\u901a\u4fe1\u80fd\u529b\u800c\u53d7\u5230\u5e7f\u6cdb\u6b22\u8fce\u3002\u5728 Python \u4e2d\u5b9e\u73b0 WebSocket \u670d\u52a1\u5668\u65f6，\u5982\u4f55\u5e94\u5bf9\u9ad8\u5e76\u53d1\u573a\u666f\u662f\u4e00\u4e2a\u91cd\u8981\u7684\u95ee\u9898\u3002\u672c\u6587\u5c06\u4ecb\u7ecd Python WebSocket \u670d\u52a1\u5668\u7684\u57fa\u672c\u539f\u7406，\u5e76\u63a2\u8ba8\u5982\u4f55\u901a\u8fc7\u4f18\u5316\u63d0\u5347\u5176\u6027\u80fd\u3002<\/p>\n
WebSocket \u662f\u4e00\u79cd\u6301\u4e45\u5316\u7684\u534f\u8bae，\u5141\u8bb8\u5ba2\u6237\u7aef\u4e0e\u670d\u52a1\u5668\u4e4b\u95f4\u4fdd\u6301\u957f\u8fde\u63a5\u3002\u4e0e\u4f20\u7edf\u7684 HTTP \u8bf7\u6c42-\u54cd\u5e94\u6a21\u5f0f\u4e0d\u540c，WebSocket \u5141\u8bb8\u6570\u636e\u5728\u53cc\u65b9\u4e4b\u95f4\u53cc\u5411\u4f20\u8f93，\u4e14\u65e0\u9700\u9891\u7e41\u5730\u6253\u5f00\u548c\u5173\u95ed\u8fde\u63a5\u3002\u8fd9\u79cd\u7279\u6027\u4f7f\u5f97 WebSocket \u5728\u5b9e\u65f6\u5e94\u7528（\u5982\u804a\u5929\u5ba4\u3001\u5728\u7ebf\u6e38\u620f\u3001\u80a1\u7968\u884c\u60c5\u7b49）\u4e2d\u8868\u73b0\u4f18\u5f02\u3002<\/p>\n
\u5728 Python \u4e2d，\u5e38\u7528\u7684 WebSocket \u5e93\u5305\u62ec `websockets` \u548c `Tornado`\u3002\u8fd9\u4e9b\u5e93\u63d0\u4f9b\u4e86\u7b80\u5355\u6613\u7528\u7684\u63a5\u53e3\u6765\u521b\u5efa WebSocket \u670d\u52a1\u5668\u3002\u7136\u800c，\u5728\u5904\u7406\u9ad8\u5e76\u53d1\u8bf7\u6c42\u65f6，\u5355\u7ebf\u7a0b\u963b\u585e\u6a21\u578b\u53ef\u80fd\u4f1a\u6210\u4e3a\u74f6\u9888\u3002<\/p>\n
\u5f53 WebSocket \u670d\u52a1\u5668\u9762\u4e34\u5927\u91cf\u5e76\u53d1\u8fde\u63a5\u65f6，\u4ee5\u4e0b\u51e0\u4e2a\u95ee\u9898\u53ef\u80fd\u4f1a\u5f71\u54cd\u6027\u80fd：<\/p>\n
\u4e3a\u4e86\u63d0\u9ad8 WebSocket \u670d\u52a1\u5668\u7684\u9ad8\u5e76\u53d1\u5904\u7406\u80fd\u529b，\u53ef\u4ee5\u91c7\u53d6\u4ee5\u4e0b\u51e0\u79cd\u4f18\u5316\u7b56\u7565：<\/p>\n
\u5f02\u6b65\u7f16\u7a0b\u662f\u89e3\u51b3\u9ad8\u5e76\u53d1\u95ee\u9898\u7684\u6709\u6548\u624b\u6bb5\u4e4b\u4e00\u3002Python \u7684 `asyncio` \u6a21\u5757\u63d0\u4f9b\u4e86\u4e00\u79cd\u9ad8\u6548\u7684\u5f02\u6b65\u7f16\u7a0b\u65b9\u5f0f\u3002\u7ed3\u5408 `websockets` \u6216 `Tornado` \u7b49\u652f\u6301\u5f02\u6b65\u7684\u5e93，\u53ef\u4ee5\u663e\u8457\u63d0\u5347\u670d\u52a1\u5668\u7684\u5e76\u53d1\u5904\u7406\u80fd\u529b\u3002<\/p>\n
\u793a\u4f8b\u4ee3\u7801\u5982\u4e0b：<\/p>\n
import asyncio
\nimport websockets<\/p>\n
async def echo(websocket, path):
\n async for message in websocket:
\n await websocket.send(message)<\/p>\n
start_server = websockets.serve(echo, "localhost", 8765)<\/p>\n
asyncio.get_event_loop().run_until_complete(start_server)
\nasyncio.get_event_loop().run_forever()<\/p>\n
\u4e0a\u8ff0\u4ee3\u7801\u4f7f\u7528\u4e86 `asyncio` \u548c `websockets` \u5b9e\u73b0\u4e86\u4e00\u4e2a\u7b80\u5355\u7684\u5f02\u6b65 WebSocket \u670d\u52a1\u5668\u3002<\/p>\n
\u4e3a\u4e86\u907f\u514d\u670d\u52a1\u5668\u56e0\u8fc7\u591a\u8fde\u63a5\u800c\u5d29\u6e83，\u53ef\u4ee5\u901a\u8fc7\u9650\u5236\u6700\u5927\u8fde\u63a5\u6570\u6765\u4fdd\u62a4\u7cfb\u7edf\u8d44\u6e90\u3002\u4f8b\u5982，\u53ef\u4ee5\u8bbe\u7f6e\u4e00\u4e2a\u961f\u5217\u6765\u7ba1\u7406\u65b0\u8fde\u63a5\u8bf7\u6c42，\u5f53\u8fde\u63a5\u6570\u8fbe\u5230\u4e0a\u9650\u65f6，\u62d2\u7edd\u65b0\u7684\u8fde\u63a5\u3002<\/p>\n
\u793a\u4f8b\u4ee3\u7801\u5982\u4e0b：<\/p>\n
import asyncio
\nimport websockets<\/p>\n
CONNECTION_LIMIT = 100<\/p>\n
connected = set()<\/p>\n
async def handler(websocket, path):
\n if len(connected) >= CONNECTION_LIMIT:
\n await websocket.close(code=1008, reason="Too many connections")
\n return<\/p>\n
connected.add(websocket)
\n try:
\n async for message in websocket:
\n await websocket.send(message)
\n finally:
\n connected.remove(websocket)<\/p>\n
start_server = websockets.serve(handler, "localhost", 8765)<\/p>\n
asyncio.get_event_loop().run_until_complete(start_server)
\nasyncio.get_event_loop().run_forever()<\/p>\n
\u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d，\u6211\u4eec\u8bbe\u7f6e\u4e86\u6700\u5927\u8fde\u63a5\u6570\u4e3a 100，\u5e76\u5728\u8d85\u8fc7\u6b64\u9650\u5236\u65f6\u62d2\u7edd\u65b0\u7684\u8fde\u63a5\u3002<\/p>\n
\u5bf9\u4e8e CPU \u5bc6\u96c6\u578b\u4efb\u52a1，\u53ef\u4ee5\u8003\u8651\u4f7f\u7528\u591a\u8fdb\u7a0b\u6216\u591a\u7ebf\u7a0b\u6765\u5145\u5206\u5229\u7528\u786c\u4ef6\u8d44\u6e90\u3002Python \u7684 `multiprocessing` \u548c `concurrent.futures` \u6a21\u5757\u53ef\u4ee5\u5e2e\u52a9\u6211\u4eec\u8f7b\u677e\u5b9e\u73b0\u8fd9\u4e00\u76ee\u6807\u3002<\/p>\n
\u793a\u4f8b\u4ee3\u7801\u5982\u4e0b：<\/p>\n
from concurrent.futures import ProcessPoolExecutor
\nimport asyncio
\nimport websockets<\/p>\n
async def echo(websocket, path):
\n async for message in websocket:
\n await websocket.send(message)<\/p>\n
def run_server():
\n start_server = websockets.serve(echo, "localhost", 8765)
\n asyncio.get_event_loop().run_until_complete(start_server)
\n asyncio.get_event_loop().run_forever()<\/p>\n
if __name__ == "__main__":
\n executor = ProcessPoolExecutor(4)
\n for _ in range(4):
\n executor.submit(run_server)
\n executor.shutdown(wait=True)<\/p>\n
\u4e0a\u8ff0\u4ee3\u7801\u901a\u8fc7\u591a\u8fdb\u7a0b\u7684\u65b9\u5f0f\u542f\u52a8\u4e86\u56db\u4e2a\u72ec\u7acb\u7684 WebSocket \u670d\u52a1\u5668\u5b9e\u4f8b，\u4ece\u800c\u63d0\u9ad8\u4e86\u7cfb\u7edf\u7684\u5e76\u53d1\u5904\u7406\u80fd\u529b\u3002<\/p>\n
\u5bf9\u4e8e\u67d0\u4e9b\u9ad8\u9891\u6b21\u7684\u64cd\u4f5c，\u53ef\u4ee5\u8003\u8651\u4f7f\u7528\u7f13\u5b58\u673a\u5236\u6765\u51cf\u5c11\u91cd\u590d\u8ba1\u7b97\u3002\u6b64\u5916，\u6279\u91cf\u5904\u7406\u8bf7\u6c42\u4e5f\u53ef\u4ee5\u964d\u4f4e\u7cfb\u7edf\u5f00\u9500\u3002<\/p>\n
\u793a\u4f8b\u4ee3\u7801\u5982\u4e0b：<\/p>\n
import asyncio
\nimport websockets<\/p>\n
cache = {}<\/p>\n
async def handle_request(websocket, path):
\n async for message in websocket:
\n if message in cache:
\n response = cache[message]
\n else:
\n response = process_message(message)
\n cache[message] = response
\n await websocket.send(response)<\/p>\n
def process_message(message):
\n # \u6a21\u62df\u8017\u65f6\u64cd\u4f5c
\n return f"Processed {message}"<\/p>\n
\u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d，\u6211\u4eec\u4f7f\u7528\u4e86\u4e00\u4e2a\u7f13\u5b58\u5b57\u5178\u6765\u5b58\u50a8\u5df2\u7ecf\u5904\u7406\u8fc7\u7684\u6d88\u606f，\u907f\u514d\u91cd\u590d\u8ba1\u7b97\u3002<\/p>\n
\u901a\u8fc7\u4ee5\u4e0a\u4f18\u5316\u7b56\u7565，\u6211\u4eec\u53ef\u4ee5\u663e\u8457\u63d0\u5347 Python WebSocket \u670d\u52a1\u5668\u7684\u9ad8\u5e76\u53d1\u5904\u7406\u80fd\u529b\u3002\u9009\u62e9\u5408\u9002\u7684\u5f02\u6b65\u6846\u67b6\u3001\u5408\u7406\u9650\u5236\u8fde\u63a5\u6570\u3001\u5229\u7528\u591a\u8fdb\u7a0b\u6216\u591a\u7ebf\u7a0b\u4ee5\u53ca\u91c7\u7528\u7f13\u5b58\u548c\u6279\u91cf\u64cd\u4f5c\u90fd\u662f\u6709\u6548\u7684\u4f18\u5316\u624b\u6bb5\u3002\u5e0c\u671b\u672c\u6587\u80fd\u5e2e\u52a9\u4f60\u5728\u5b9e\u9645\u9879\u76ee\u4e2d\u66f4\u597d\u5730\u5e94\u5bf9\u9ad8\u5e76\u53d1\u6311\u6218\u3002<\/p>\n
```<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb811\u6b21\uff0c\u70b9\u8d5e18\u6b21\uff0c\u6536\u85cf18\u6b21\u3002\u901a\u8fc7\u4ee5\u4e0a\u4f18\u5316\u7b56\u7565\uff0c\u6211\u4eec\u53ef\u4ee5\u663e\u8457\u63d0\u5347 Python WebSocket \u670d\u52a1\u5668\u7684\u9ad8\u5e76\u53d1\u5904\u7406\u80fd\u529b\u3002\u9009\u62e9\u5408\u9002\u7684\u5f02\u6b65\u6846\u67b6\u3001\u5408\u7406\u9650\u5236\u8fde\u63a5\u6570\u3001\u5229\u7528\u591a\u8fdb\u7a0b\u6216\u591a\u7ebf\u7a0b\u4ee5\u53ca\u91c7\u7528\u7f13\u5b58\u548c\u6279\u91cf\u64cd\u4f5c\u90fd\u662f\u6709\u6548\u7684\u4f18\u5316\u624b\u6bb5\u3002\u5e0c\u671b\u672c\u6587\u80fd\u5e2e\u52a9\u4f60\u5728\u5b9e\u9645\u9879\u76ee\u4e2d\u66f4\u597d\u5730\u5e94\u5bf9\u9ad8\u5e76\u53d1\u6311\u6218\u3002“`_python\u591a\u8fdb\u7a0bwebsocket<\/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":[81,947,43],"topic":[],"class_list":["post-26333","post","type-post","status-publish","format-standard","hentry","category-server","tag-python","tag-websocket","tag-43"],"yoast_head":"\n