在Python FastAPI中使用websockets并行发送/接收
在Python的FastAPI框架中，你可以使用websockets来建立双向通信
首先，确保你已经安装了FastAPI和Uvicorn，以及websockets库。如果没有安装，可以使用以下命令进行安装：
pip install fastapi uvicorn websockets然后，你可以创建一个FastAPI应用，并使用websockets来并行发送/接收消息。以下是一个简单的示例：
from fastapi import FastAPI
from fastapi.responses import HTMLResponse
import asyncio
import websockets
app = FastAPI()
html = """
<!DOCTYPE html>
<html>
<head>
<title>Chat</title>
</head>
<body>
<h1>WebSocket Chat</h1>
<div id="messages"></div>
<input id="message-input" type="text" placeholder="Type a message...">
<button id="send-message">Send</button>
<script>
var ws = new WebSocket("ws://localhost/ws");
ws.onmessage = function(event) {
var messages = document.getElementById("messages");
var message = document.createElement("div");
message.textContent = event.data;
messages.appendChild(message);
};
document.getElementById("send-message").onclick = function() {
var input = document.getElementById("message-input");
ws.send(input.value);
input.value = "";
};
</script>
</div>
</body>
</html>
"""
@app.get("/")
async def get():
return HTMLResponse(html)
connected_clients = set()
async def websocket_handler(websocket: websockets.WebSocketServerProtocol, _: str):
await websocket.accept()
connected_clients.add(websocket)
try:
while True:
message = await websocket.recv()
for client in connected_clients:
if client != websocket:
await client.send(message)
except websockets.exceptions.ConnectionClosed:
connected_clients.remove(websocket)
@app.websocket("/ws")
async def websocket_endpoint(websocket: websockets.WebSocketServerProtocol):
await websocket_handler(websocket, "")
if __name__ == "__main__":
import uvicorn
uvicorn.run(app, host="0.0.0.0", port=8000)在这个示例中，我们创建了一个简单的聊天应用。当用户访问根URL时，会返回一个包含HTML页面的响应，该页面包含用于发送和接收消息的JavaScript代码。
websocket_handler函数处理与客户端的连接、接收消息以及将消息广播给其他已连接的客户端。我们使用connected_clients集合来跟踪所有已连接的客户端。
最后，我们定义了一个WebSocket端点/ws，它将处理传入的WebSocket连接并调用websocket_handler函数。
要运行此示例，请保存代码到一个Python文件（例如main.py），然后在终端中运行以下命令：
uvicorn main:app --reload相关·内容
浏览器通过websocket发送消息，例如： "city": "Chicago",}{ "country": "IN"现在，服务器应该停止更新芝加哥的天气详细信息，并开始更新有关班加罗尔的详细信息，即同时通过w
浏览 134提问于2021-06-12得票数 2
回答已采纳
1回答
异步发送/接收客户端
、、、
我有一个从RabbitMq读取消息并将其发送到服务器的客户端，服务器的IP在消息中指定，我希望发送和接收部分是异步的，因为我将处理多个服务器，并且我不希望代码挂起并等待响应。我所说的异步是指发送和接收并行工作。有什么建议吗？谢谢
浏览 0提问于2018-10-25得票数 0
我在试着和指纹设备通讯。它通过websocket连接发送数据。所以，我想我可以用webscokets和设备通信。这里我使用的是FastAPI，但它只接受JSON数据。问题是我需要处理XML数据，但是，我不知道如何以XML格式发送和接受数据。
浏览 5提问于2022-03-09得票数 1
usr/bin/uvicorn", line 6, in <module> File "/usr/lib/python3pkg_resources/__init__.py", line 3254, in <module> File "/usr/lib&
浏览 22提问于2021-09-21得票数 1
1回答
我使用FastAPI构建了一个简单的演示项目。我想实时地将数据发布到服务器(可能是30fps)。while True:
....
浏览 10提问于2022-04-14得票数 1
我使用FastAPI和@app.websocket来侦听传入的websockets。FastAPI (或者下面的Starlette或Uvicorn )是如何进行乒乓球心跳的？这个可以配置吗？我在文件里根本找不到。from fastapi import FastAPI, WebSocket
def ws(websocket: WebSocket):
浏览 8提问于2020-09-11得票数 7
回答已采纳
1回答
我正在尝试使用starlette构建一个web套接字，它接收消息，在同步函数中运行计算，并返回响应。因此，文本被接收并运行计算，如果我打印数据变量(字典)，我看到它被正确地返回，但当我试图将它发送回客户机时，我得到以下错误： ERROR: Exception in ASGI applicationTraceback (most recent call last):
File "/usr/lib/python3/
浏览 69提问于2020-09-28得票数 1
我正在尝试测试一个API，该API将长期运行的作业发送到由芹菜工人处理的队列中。我使用在Docker容器中运行的RabbitMQ作为消息队列。但是，当向队列发送消息时，我会得到以下错误：Error: [Errno 111] Connection refuseddocker run -d -p 5672:5672 rabbitmqStartbuild -t fastapi .Run容器docker run -it -p 8000:8000 fastapi
D
浏览 4提问于2022-06-15得票数 1
回答已采纳
1回答
我正在尝试从客户端接收一条消息，对其进行处理，然后返回一个JSON响应。，但我似乎无法将响应字典加载到JSON并将其发送回去。/dist-packages/uvicorn/protocols/websockets/websockets_impl.py", line 153, in run_asgi
result = await/dist-packages/fastapi/applications.py&quo
浏览 0提问于2020-09-28得票数 2
所以我一直在尝试在我的flutter应用程序和FastAPI之间建立一个websocket连接。我认为问题出在Flutter上。> Headers([('Date', 'Fri, 09 Apr 2021 11:10:11 GMT'), ('Server', 'Python/3.7 websockets/8.1'), ('Content-Length/主页中调用co
浏览 340提问于2021-04-09得票数 0
回答已采纳
1回答
我有一些Python脚本，它们为我的公司做不同的事情。获取数据，清理数据，基本上就是把我们需要的东西拿出来。然而，目前这是在这些脚本中完成的，而实际使用它们的人在代码等方面还不够。基本上他们想要使用Excel，但是在某种程度上，Excel是不会这么做的-因此这些脚本。，这里使用的数据(x和y)可能来自以下内容：
@app.get("&
浏览 9提问于2022-01-07得票数 -1
我正在开发一个C# Asp.NET核心应用程序，其中客户端将通过JavaScript WebSocket连接到服务器，服务器本身将是唯一可以向连接的客户端发送消息的东西。客户端不会将消息发送回服务器，如果它们通过在任何浏览器控制台中手动向服务器发送消息，服务器将忽略它们。在调用"ReceiveAsync()“之后不调用"SendAsync()”的缺点/后果是什么？我在MS的文档中找不到任何内容，说明在调用"SendAsync()“
浏览 41提问于2021-06-03得票数 1
回答已采纳
not start correctly FastAPI演示main.py import uvicorn &#x
浏览 965提问于2020-12-24得票数 1
我正在尝试在服务器关闭websocket连接到后自动重新启动。如何确保一次只有一个 websocket连接是活动的？使用Python的FastAPI作为服务器的最小示例：<!d
浏览 8提问于2020-09-22得票数 0
回答已采纳
在Python语言中，我对websocket客户端使用了"websockets“库。import asyncio uri = "wss://echo.websocket.org/"async with websockets.connect(uri) as websocket:
name = input("Wh
浏览 80提问于2020-06-30得票数 0
当客户端同时向服务器发送自己的数据流时，我想要从服务器向客户端发送视频流。是否有可能使用Websocket和NodeJS在服务器上实现这种并行(边接收边发送数据)？我们是否需要将两个websockets与两个http服务器和nodejs工作线程或集群用于多线程？
谢谢。
浏览 31提问于2020-02-05得票数 0
1回答
我正在使用Docker映像在AWS上托管一个非常简单的(Hello ) FastAPI。映像在本地运行良好，但是当我在Lambda上运行它时，它会显示端口绑定错误。596d-41f3-a153-51cb9facc7a7 Task timed out after 3.03 secondsFROM python:3.9
WORKD
浏览 0提问于2021-11-01得票数 1
500 Server Error TypeError: TemplateResponse() missing 1 required positional argument: 'context'from fastapi import FastAPIfrom fastapi import Depends, FastAPI
from fastapi importFastAPI, Request
浏览 31提问于2020-08-31得票数 4
我有一个开放的遥测运行一个python FastApi应用程序。痕迹被发送到Jaeger，我可以查看它们。有人能为我指明正确的方向吗？目前，我正在使用禁用并发性来记录跟踪以进行性能调试，但这在生产中行不通。
浏览 2提问于2022-01-19得票数 1
回答已采纳
我正在开发一个API，我将使用Kubernetes进行部署，并希望在本地测试它。pydantic==1.9.1PyYAML==6.0starlette==0.19.1uvicorn==0.17.6websockets==10.3
ma
浏览 1提问于2022-06-13得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
