FastAPI（56）- 使用 Websocket 打造一个迷你聊天室
FastAPI（56）- 使用 Websocket 打造一个迷你聊天室
- 在实际项目中，可能会通过前端框架使用 WebSocket 和后端进行通信
- 这里就来详细讲解下 FastAPI 是如何操作 WebSocket 的
模拟 WebSocket 客户端
#!usr/bin/env python
# -*- coding:utf-8 _*-
"""
# author: 小菠萝测试笔记
# blog: https://www.cnblogs.com/poloyy/
# time: 2021/10/5 5:26 下午
# file: 46_websocket.py
"""
import uvicorn
from fastapi import FastAPI, WebSocket
from fastapi.responses import HTMLResponse
app = FastAPI()
html = """
html>
<html>
<head>
<title>小菠萝聊天室title>
head>
<body>
<h1>小菠萝聊天室h1>
<form action="" onsubmit="sendMessage(event)">
<input type="text" id="messageText" autocomplete="off"/>
<button>Sendbutton>
form>
<ul id='messages'>
ul>
<script>
// 加载页面，自动创建一个 WebSocket 连接
var ws = new WebSocket("ws://localhost:8080/ws");
// 收到消息
ws.onmessage = function(event) {
// 获取输入框的值
var messages = document.getElementById('messages')
// 创建一个 li 元素
var message = document.createElement('li')
// 接收 event 的 data
var content = document.createTextNode(event.data)
message.appendChild(content)
messages.appendChild(message)
};
// 发送消息方法
function sendMessage(event) {
var input = document.getElementById("messageText")
ws.send(input.value)
input.value = ''
event.preventDefault()
}
script>
body>
html>
"""
# 返回一段 HTML 代码给前端
@app.get("/")
async def get():
return HTMLResponse(html)
@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
# 1、ws 连接
await websocket.accept()
while True:
# 2、接收客户端发送的内容
data = await websocket.receive_text()
# 3、服务端发送内容
await websocket.send_text(f"小菠萝收到的消息是: {data}")
if __name__ == '__main__':
uvicorn.run(app="46_websocket:app", reload=True, host="127.0.0.1", port=8080)
启动 uvicorn 服务器，访问 127.0.0.1:8080/
#!usr/bin/env python
# -*- coding:utf-8 _*-
"""
# author: 小菠萝测试笔记
# blog: https://www.cnblogs.com/poloyy/
# time: 2021/10/5 5:26 下午
# file: 46_websocket.py
"""
import uvicorn
from fastapi import FastAPI, WebSocket
from fastapi.responses import HTMLResponse
app = FastAPI()
html = """
html>
<html>
<head>
<title>小菠萝聊天室title>
head>
<body>
<h1>小菠萝聊天室h1>
<form action="" onsubmit="sendMessage(event)">
<input type="text" id="messageText" autocomplete="off"/>
<button>Sendbutton>
form>
<ul id='messages'>
ul>
<script>
// 加载页面，自动创建一个 WebSocket 连接
var ws = new WebSocket("ws://localhost:8080/ws");
// 收到消息
ws.onmessage = function(event) {
// 获取输入框的值
var messages = document.getElementById('messages')
// 创建一个 li 元素
var message = document.createElement('li')
// 接收 event 的 data
var content = document.createTextNode(event.data)
message.appendChild(content)
messages.appendChild(message)
};
// 发送消息方法
function sendMessage(event) {
var input = document.getElementById("messageText")
ws.send(input.value)
input.value = ''
event.preventDefault()
}
script>
body>
html>
"""
# 返回一段 HTML 代码给前端
@app.get("/")
async def get():
return HTMLResponse(html)
@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
# 1、ws 连接
await websocket.accept()
while True:
# 2、接收客户端发送的内容
data = await websocket.receive_text()
# 3、服务端发送内容
await websocket.send_text(f"小菠萝收到的消息是: {data}")
if __name__ == '__main__':
uvicorn.run(app="46_websocket:app", reload=True, host="127.0.0.1", port=8080)
启动 uvicorn 服务器，访问 127.0.0.1:8080/
每发一条消息，均会显示在列表中
可以在其他地方使用 WebSocket
不带查询参数 q
带查询参数 q
当 WebSocket 连接关闭时
关掉其中一个客户端（tab）
- 本文作者： 小菠萝测试笔记
- 本文链接：