IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> JavaScript知识库 -> fastapi项目内使用socketio -> 正文阅读

[JavaScript知识库]fastapi项目内使用socketio

参考:https://github.com/pyropy/fastapi-socketio

一、app中启用socketio

如下,一般fastapi项目会这样创建一个应用

from fastapi import FastAPI

app = FastAPI()

那么如果在项目中需要用到socketio服务时,可以通过以下方式来实现绑定;当然也可以把socketio的服务单独起一个项目。

    # 初始化socketio
    sio = socketio.AsyncServer(async_mode='asgi')
    # app绑定socketio
    app.mount('/', socketio.ASGIApp(socketio_server=sio))  # 使用默认的socket path
    
    # 默认的socketio_path是socket.io,通过http://localhost/socket.io就可以访问socketio服务,也可以自定义修改,例如改为ws
    # sio中的事件函数可以指定namespace,前端通过路由来进入不同的namespace,例如
    # sio.on('connect', connect, namespace='/chat')
    # 那么前端的调用接口应该是:http://localhost/socket.io/chat

二、简单示例

在fastapi项目中建立一个init_socketio目录,结构如下,chat_room.html和socket.io-client-4.1.2可以在python socketio 实现(极)简单聊天室中拿到

├── __init__.py
├── chat_room.html
└── static
    └── socket.io-client-4.1.2

?__init__.py

import os
import socketio
from urllib import parse
from bidict import bidict
from pydantic import BaseModel, Field
from fastapi.responses import JSONResponse, HTMLResponse
from fastapi import APIRouter
from fastapi.staticfiles import StaticFiles

user_sid = bidict()
pwd_path = os.path.dirname(os.path.abspath(__file__))


class Login(BaseModel):
    user_name: str = Field(..., description='1')


router = APIRouter()


@router.get('/chat_room', summary='聊天室界面')
async def chat_room():
    chat_room = os.path.join(pwd_path, 'chat_room.html')
    with open(chat_room) as f:
        return HTMLResponse(f.read())


@router.post('/login', summary='登录接口')
async def login(item: Login):
    user_name = item.user_name
    JSONResponse.media_type = 'application/json; charset=utf-8'
    if user_sid.get(user_name, None):
        return JSONResponse({'code': 'fail'}, status_code=400)
    else:
        return JSONResponse({'code': 'success'}, status_code=200)


def init_socketio(app):
    # 事件函数
    async def connect(sid, environ):
        query_params = environ['QUERY_STRING'].split('&')
        params = dict()
        for query_param in query_params:
            a, b = query_param.split('=')
            params[a] = parse.unquote(b)
        user_name = params['name']
        user_sid[user_name] = sid
        await sio.emit('reply', f'{user_name}连线成功!', namespace='/chat')

    async def message(sid, data):
        await sio.emit('reply', f"{user_sid.inv[sid]}: {data}", namespace='/chat')

    async def disconnect(sid):
        user_name = user_sid.inv[sid]
        del user_sid[user_name]
        await sio.emit('reply', f'{user_name}退出连线!', namespace='/chat')
    # 静态文件
    app.mount("/static", StaticFiles(directory=f"{pwd_path}/static"), name="static")

    # 初始化socketio
    sio = socketio.AsyncServer(async_mode='asgi')
    # 绑定事件函数
    sio.on('disconnect', disconnect, namespace='/chat')
    sio.on('chat message', message, namespace='/chat')
    sio.on('connect', connect, namespace='/chat')
    # app绑定socketio
    app.mount('/', socketio.ASGIApp(socketio_server=sio))  # 使用默认的socket path

然后在项目的启动文件中添加

from fastapi import FastAPI
from init_socketio import router, init_socketio

app = FastAPI()

async def startup_event():
    """项目初始化"""

    app.include_router(router)
    init_socketio(app)

启动后,打开http://localhost:8080/chat_room即可测试

?

  JavaScript知识库 最新文章
ES6的相关知识点
react 函数式组件 & react其他一些总结
Vue基础超详细
前端JS也可以连点成线(Vue中运用 AntVG6)
Vue事件处理的基本使用
Vue后台项目的记录 (一)
前后端分离vue跨域,devServer配置proxy代理
TypeScript
初识vuex
vue项目安装包指令收集
上一篇文章      下一篇文章      查看所有文章
加:2021-12-26 22:03:48  更:2021-12-26 22:05:29 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 9:29:30-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码