Perpustakaan Python WebSocket yang owerful untuk komunikasi masa nyata: Panduan Pakar

Sebagai pengarang yang produktif, saya menjemput anda untuk meneroka koleksi buku saya yang luas di Amazon. Ingatlah untuk mengikuti saya di Sederhana untuk kemas kini biasa dan tunjukkan sokongan anda. Dorongan anda tidak ternilai!

perpustakaan WebSocket yang mantap Python telah mengubah pembangunan aplikasi web masa nyata. Melukis pada tahun pengalaman, saya membentangkan lima perpustakaan yang kuat untuk meningkatkan projek WebSocket anda.

Pertama, pertimbangkan perpustakaan

. Kekuatannya terletak pada kesederhanaan dan kebolehpercayaannya untuk mencipta kedua -dua pelanggan dan pelayan. Ia sesuai untuk pemula yang meneroka pengaturcaraan WebSocket. websockets

Contoh pelayan Asas

: websockets

import asyncio
import websockets

async def echo(websocket, path):
    async for message in websocket:
        await websocket.send(f"Echo: {message}")

async def main():
    server = await websockets.serve(echo, "localhost", 8765)
    await server.wait_closed()

asyncio.run(main())

Pelayan ini mencerminkan mesej masuk.

Menguruskan sambungan serentak dengan cekap. asyncio

Seterusnya,

menawarkan sokongan HTTP dan WebSocket yang komprehensif. Berikut adalah pelayan websocket menggunakan aiohttp: aiohttp

from aiohttp import web
import aiohttp

async def websocket_handler(request):
    ws = web.WebSocketResponse()
    await ws.prepare(request)

    async for msg in ws:
        if msg.type == aiohttp.WSMsgType.TEXT:
            await ws.send_str(f"Echo: {msg.data}")
        elif msg.type == aiohttp.WSMsgType.ERROR:
            print(f'ws connection closed with exception {ws.exception()}')

    return ws

app = web.Application()
app.add_routes([web.get('/ws', websocket_handler)])

if __name__ == '__main__':
    web.run_app(app)

dengan lancar mengintegrasikan pengendalian websocket dalam kerangka webnya, sesuai untuk gabungan aplikasi HTTP dan WebSocket. aiohttp

fastapi, terkenal dengan kelajuan dan keramahan pengguna, juga cemerlang dalam sokongan WebSocket:

from fastapi import FastAPI, WebSocket
from fastapi.websockets import WebSocketDisconnect

app = FastAPI()

@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
    await websocket.accept()
    try:
        while True:
            data = await websocket.receive_text()
            await websocket.send_text(f"Echo: {data}")
    except WebSocketDisconnect:
        print("Client disconnected")

if __name__ == "__main__":
    import uvicorn
    uvicorn.run(app, host="0.0.0.0", port=8000)

Integrasi Server ASGI FastAPI (mis., Uvicorn) memastikan komunikasi WebSocket berprestasi tinggi. Cirinya, termasuk dokumentasi jenis dan dokumentasi automatik, memudahkan pembangunan.

socket.io Menyediakan komunikasi masa nyata, bidirectional, yang didorong oleh peristiwa, menyokong kedua-dua WebSocket dan penurunan panjang:

import socketio

sio = socketio.AsyncServer(async_mode='asgi')
app = socketio.ASGIApp(sio)

@sio.event
async def connect(sid, environ):
    print(f"Client connected: {sid}")

@sio.event
async def message(sid, data):
    await sio.emit('message', f"Echo: {data}", to=sid)

@sio.event
async def disconnect(sid):
    print(f"Client disconnected: {sid}")

if __name__ == '__main__':
    import uvicorn
    uvicorn.run(app, host='localhost', port=8000)

Socket.io's Architecture Streamlines Application Logic, menawarkan sokongan untuk bilik dan ruang nama.

Akhirnya, Autobahn menyokong WebSocket dan WAMP (Protokol Pemesejan Aplikasi Web), memperluaskan WebSocket dengan ciri RPC dan PubSub. Pelayan Autobahn WebSocket yang mudah:

from autobahn.asyncio.websocket import WebSocketServerProtocol, WebSocketServerFactory

class MyServerProtocol(WebSocketServerProtocol):
    def onConnect(self, request):
        print(f"Client connecting: {request.peer}")

    def onOpen(self):
        print("WebSocket connection open.")

    async def onMessage(self, payload, isBinary):
        if isBinary:
            print(f"Binary message received: {len(payload)} bytes")
        else:
            print(f"Text message received: {payload.decode('utf8')}")
        await self.sendMessage(payload, isBinary)

    def onClose(self, wasClean, code, reason):
        print(f"WebSocket connection closed: {reason}")

if __name__ == '__main__':
    import asyncio
    factory = WebSocketServerFactory("ws://127.0.0.1:9000")
    factory.protocol = MyServerProtocol

    loop = asyncio.get_event_loop()
    coro = loop.create_server(factory, '0.0.0.0', 9000)
    server = loop.run_until_complete(coro)

    try:
        loop.run_forever()
    except KeyboardInterrupt:
        pass
    finally:
        server.close()
        loop.close()

fleksibiliti Autobahn memenuhi pelbagai aplikasi, dari pelayan asas ke sistem yang diedarkan kompleks menggunakan WAMP.

Untuk aplikasi trafik tinggi, pertimbangkan pengurusan skalabiliti dan sambungan, yang berpotensi menggunakan REDIS untuk perkongsian negara. Melaksanakan pengesahan yang mantap (mis., Berasaskan token) dan pengendalian penyambungan semula (backoff eksponen). Mengoptimumkan Serialization Mesej menggunakan format yang cekap seperti MessagePack untuk Prestasi.

Ringkasnya, lima perpustakaan ini menawarkan alat serba boleh untuk komunikasi WebSocket yang cekap. Pilih perpustakaan yang paling sesuai dengan keperluan aplikasi anda dan melaksanakan amalan terbaik untuk pengalaman yang mantap dan tepat.

---

101 buku

101 Buku , sebuah rumah penerbitan berkuasa AI yang diasaskan oleh Aarav Joshi, menawarkan buku yang berpatutan dan berkualiti tinggi. Terokai tajuk kami, termasuk "Golang Clean Code," di Amazon. Cari "Aarav Joshi" untuk diskaun khas!

ciptaan kami

Cari projek kami yang pelbagai: Pusat Pelabur (Bahasa Inggeris, Sepanyol, Jerman), Smart Living, Epochs & Echoes, Misteri yang membingungkan, Hindutva, Elite Dev, dan sekolah JS.

---

Kami berada di Medium

ikuti kami di Medium: Tech Koala Insights, Epochs & Echoes World, Medium Central Investor, Medium Misteri, Sains & Epochs Medium, dan Hindutva Moden.

Atas ialah kandungan terperinci Perpustakaan Python WebSocket yang owerful untuk komunikasi masa nyata: Panduan Pakar. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!