So verwenden Sie WebSocket in FastAPI für die bidirektionale Kommunikation

So verwenden Sie WebSocket für die bidirektionale Kommunikation in FastAPI

Einführung:
WebSocket ist ein Protokoll, das die bidirektionale Kommunikation in Webanwendungen ermöglicht. Im Gegensatz zum herkömmlichen HTTP-Request-Response-Modell ermöglicht WebSocket dem Server, Nachrichten direkt an den Client zu senden, ohne dass der Client explizit eine Anfrage initiiert. In FastAPI können wir WebSocket problemlos verwenden, um eine bidirektionale Kommunikation in Echtzeit zu erreichen. In diesem Artikel wird anhand von Codebeispielen erläutert, wie WebSocket in FastAPI verwendet wird, um eine bidirektionale Kommunikation zu erreichen.

Schritt 1: FastAPI und uvicorn installieren
Zuerst müssen wir sicherstellen, dass Python 3.7 oder höher installiert ist. Dann können wir FastAPI und uvicorn mit pip installieren:

pip install fastapi uvicorn

Schritt 2: Erstellen Sie eine FastAPI-Anwendung
Als nächstes können wir eine FastAPI-Anwendung erstellen. Fügen Sie in einer neuen .py-Datei den folgenden Code hinzu:

from fastapi import FastAPI, WebSocket

app = FastAPI()

@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
    await websocket.accept()
    while True:
        data = await websocket.receive_text()
        await websocket.send_text(f"Message received: {data}")

Der obige Code erstellt eine FastAPI-Anwendung und definiert eine websocket_endpoint-Funktion zur Verarbeitung von WebSocket-Verbindungen. In dieser Funktion rufen wir zunächst await websocket.accept() auf, um die WebSocket-Verbindung zu akzeptieren. Anschließend verwenden wir eine Endlosschleife, um kontinuierlich auf vom Client gesendete Nachrichten zu warten. Sobald die Nachricht empfangen wurde, verwenden wir await websocket.send_text(), um die Antwortnachricht an den Client zurückzusenden. await websocket.accept()来接受WebSocket连接。然后，我们使用一个无限循环来持续监听从客户端发送的消息。一旦接收到消息，我们使用await websocket.send_text()将回复消息发送回客户端。

步骤三：启动应用
我们可以使用uvicorn命令启动FastAPI应用。在终端执行以下命令：

uvicorn main:app --reload

这将启动一个本地服务器，并监听在http://localhost:8000上。

步骤四：测试WebSocket连接
使用任何WebSocket客户端工具（例如浏览器的开发者工具或Postman），我们可以测试WebSocket连接。打开WebSocket客户端工具，并建立到ws://localhost:8000/ws的连接。

一旦连接建立成功，我们可以发送消息到服务器。服务器会将接收到的消息回复给客户端。

代码示例：
下面是一个使用JavaScript的代码示例，通过WebSocket连接发送并接收消息：

const socket = new WebSocket('ws://localhost:8000/ws');

socket.onopen = () => {
  console.log('WebSocket连接已建立');
  socket.send('Hello, server!');
};

socket.onmessage = (event) => {
  console.log('收到服务器的消息:', event.data);
};

socket.onclose = () => {
  console.log('WebSocket连接已关闭');
};

这段代码使用WebSocket的API来建立连接，并监听连接的打开、消息的接收和连接的关闭事件。当连接打开时，发送消息到服务器。当收到服务器的消息时，打印消息内容。当连接关闭时，打印连接关闭的消息。

结论：
通过以上步骤，我们可以在FastAPI中使用WebSocket实现双向通信。我们可以使用FastAPI提供的WebSocket

Das obige ist der detaillierte Inhalt vonSo verwenden Sie WebSocket in FastAPI für die bidirektionale Kommunikation. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!