प्रौद्योगिकी साझेदारी

FastAPI शिक्षणमार्ग (44) WebSockets

2024-07-12

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

अस्माकं पूर्वविश्लेषणं सर्वं http अनुरोधानाम् आधारेण आसीत्, अतः यदि websockets तस्य समर्थनं कर्तुं शक्नुवन्ति तर्हि उत्तरं हाँ, कथं कार्यान्वयनीयम् इति अवलोकयामः ।

  1. from fastapi import WebSocket, FastAPI
  2. from fastapi.responses import HTMLResponse
  3.  
  4. app = FastAPI()
  5.  
  6. html = """
  7.  
  8. <!DOCTYPE html>
  9.  
  10. <html>
  11.  
  12.     <head>
  13.  
  14.         <title>Chat</title>
  15.  
  16.     </head>
  17.  
  18.     <body>
  19.  
  20.         <h1>WebSocket 聊天</h1>
  21.  
  22.         <form action="" onsubmit="sendMessage(event)">
  23.  
  24.             <input type="text" id="messageText" autocomplete="off"/>
  25.  
  26.             <button>Send</button>
  27.  
  28.         </form>
  29.  
  30.         <ul id='messages'>
  31.  
  32.         </ul>
  33.  
  34.         <script>
  35.  
  36.             var ws = new WebSocket("ws://localhost:8000/ws");
  37.  
  38.             ws.onmessage = function(event) {
  39.  
  40.                 var messages = document.getElementById('messages')
  41.  
  42.                 var message = document.createElement('li')
  43.  
  44.                 var content = document.createTextNode(event.data)
  45.  
  46.                 message.appendChild(content)
  47.  
  48.                 messages.appendChild(message)
  49.  
  50.             };
  51.  
  52.             function sendMessage(event) {
  53.  
  54.                 var input = document.getElementById("messageText")
  55.  
  56.                 ws.send(input.value)
  57.  
  58.                 input.value = ''
  59.  
  60.                 event.preventDefault()
  61.  
  62.             }
  63. </script>
  64.  
  65.     </body>
  66.  
  67. </html>
  68.  
  69. """
  70.  
  71.  
  72. @app.get("/")
  73. async def get_page():
  74.     return HTMLResponse(html)
  75.  
  76.  
  77. @app.websocket("/ws")
  78. async def websocket_endpoint(websocket: WebSocket):
  79.     await websocket.accept()
  80.     while True:
  81.         data = await websocket.receive_text()
  82.         await websocket.send_text(f"接收到的消息是：{data}")

वस्तुतः अतीव सरलम् अस्ति । वयं प्राप्तं सन्देशं प्रत्यक्षतया अग्रभागं प्रति प्रत्यागच्छामः।

प्रभावं अवलोकयामः : १.

एवं वयं केवलं websocket इत्यस्य कार्यं कार्यान्वयामः । अतः अस्माकं विशिष्टः सन्देशः अस्ति तथा च वयं गपशपं बन्दं कुर्मः, तस्य निवारणं कथं कर्तव्यम्?

  1. # 接收特定的消息后，终止该聊天
  2. @app.websocket("/ws")
  3. async def websocket_endpoint(websocket: WebSocket):
  4.     await websocket.accept()
  5.     while True:
  6.         data = await websocket.receive_text()
  7.         if data == "bye":
  8.             await websocket.send_text(f"请注意：窗口即将关闭")
  9.             await websocket.send_text("窗口已关闭")
  10.             await websocket.close()
  11.             break
  12.         else:
  13.             await websocket.send_text(f"接收到的消息是：{data}")

अग्रभागस्य कोडः परिवर्तितः नास्ति, केवलं पृष्ठभागस्य परिवर्तनं कृतम् अस्ति ।

वस्तुतः अत्र websocket संचारस्य कार्यान्वयनम् अतीव सरलम् अस्ति ।

अवश्यं वयं अनुरोधेषु अपि तस्य उपयोगं कर्तुं शक्नुमः

  • आश्रित्य भवति
  • सुरक्षा
  • कुकी
  • शीर्षकम्
  • पथं
  • उत्प्रेक्षा

सरलस्य पृष्ठभागस्य लेखनस्य निम्नलिखितम् उदाहरणं वयं पश्यितुं शक्नुमः

  1. # 使用多种参数，比如获取cookie等
  2. from typing import Optional
  3. from fastapi import Cookie, Query, status, Depends
  4.  
  5.  
  6. async def get_cookie_or_token(
  7.     websocket: WebSocket,
  8.     session: Optional[str] = Cookie(None),
  9.     token: Optional[str] = Query(None),
  10. ):
  11.     if session is None and token is None:
  12.         await websocket.close(code=status.WS_1008_POLICY_VIOLATION)
  13.     return session or token
  14.  
  15.  
  16. @app.websocket("item/ws")
  17. async def websocket_endpoint(
  18.     websocket: WebSocket,
  19.     q: Optional[int] = None,
  20.     cookie_or_token: str = Depends(get_cookie_or_token),
  21. ):
  22.     await websocket.accept()
  23.     while True:
  24.         data = await websocket.receive_text()
  25.         await websocket.send_text(
  26.             f"Session cookie or query token value is: {cookie_or_token}"
  27.         )
  28.         if q is not None:
  29.             await websocket.send_text(f"parameter q is: {q}")
  30.         await websocket.send_text(f"Message text was: {data}, for : {q}")

यद्यपि वयं केवलं पृष्ठभागं कार्यान्वितवन्तः तथापि fastapi इत्यत्र websocket इत्यस्य उत्तमं समर्थनम् अस्ति इति वयं द्रष्टुं शक्नुमः

व्यक्तिगत प्रोफाइल

सः ३० वर्षाणाम् अनुसरणं प्रौयोगिक क्रमबद्धता युक्तं, आलंकार, जावा, जावास्विस्च, ph, css, सद्भावना संस्कृती, ph, css निर्वहनशील भाषा सुनावंश, ससरोत विद्वान विपक्षी विद्वान विनियोग विनियोग विनियोग विनियोग्य विवेचन विनियोग विनियोग विनियोग विनियोग विनियोग विनियोग विनियोग विनियोग विनियोग विनियोग विनियोग विनियोग

मम सम्पर्कसूचना

मेल