Pengaturcaraan pelayan Python: Melaksanakan WebSockets menggunakan saluran-django

Dalam pembangunan web hari ini, komunikasi masa nyata adalah salah satu ciri yang sangat diperlukan. Memandangkan protokol HTTP ialah protokol tindak balas permintaan, adalah sangat menyusahkan untuk menggunakan kaedah HTTP tradisional untuk mencapai komunikasi masa nyata. Protokol WebSockets ialah protokol baru muncul yang menyediakan keupayaan komunikasi dua hala masa nyata untuk aplikasi Web dan boleh menghantar dan menerima data pada sambungan yang sama, menjadikannya sangat sesuai untuk aplikasi masa nyata. Dalam pengaturcaraan pelayan Python, WebSockets boleh dilaksanakan dengan mudah menggunakan rangka kerja saluran django.

1. Pasang django-channels

Sebelum anda mula menggunakan django-channels, anda perlu memasangnya terlebih dahulu. Anda boleh menggunakan pip untuk memasang:

pip install channels

2. Buat projek Django

Seterusnya, buat projek Django. Dalam Django 2.x dan ke atas, anda boleh menggunakan alat baris arahan untuk mencipta projek:

django-admin startproject myproject

3. Konfigurasikan saluran-django

Selepas memasang saluran-django, anda perlu Menambahkannya pada projek Django. Buka fail settings.py dan tambah 'saluran' dalam INSTALLED_APPS. Selain itu, beberapa tetapan perlu dikonfigurasikan untuk saluran-django:

# settings.py

# 添加channels到INSTALLED_APPS
INSTALLED_APPS = [
    # ...
    'channels',
]

# 配置channels
ASGI_APPLICATION = 'myproject.routing.application'
CHANNEL_LAYERS = {
    'default': {
        'BACKEND': 'channels.layers.InMemoryChannelLayer',
    },
}

Dalam kod di atas, ASGI_APPLICATION menentukan titik masuk aplikasi ASGI, manakala CHANNEL_LAYERS menentukan jenis dan parameter lapisan saluran lalai. Dalam contoh ini, InMemoryChannelLayer digunakan, iaitu lapisan saluran yang melaksanakan storan memori mudah.

4. Membuat laluan

Sebelum mencipta aplikasi saluran-django, anda perlu mencipta laluan untuk menghalakan permintaan WebSocket yang masuk. Laluan ialah jadual pemetaan yang memetakan laluan URL ke kelas Pengguna tertentu. Dalam Django, laluan biasanya ditakrifkan dalam fail urls.py, tetapi dalam django-channels, kerana ia menggunakan protokol ASGI, laluan ditakrifkan dalam routing.py seperti berikut:

# myproject/routing.py

from channels.routing import ProtocolTypeRouter, URLRouter
from django.urls import path

application = ProtocolTypeRouter({
    # WebSocket使用的协议类型是“websocket”，将它放在第一位
    "websocket": URLRouter([
        path("ws/", MyConsumer.as_asgi()),
    ]),
})

Kod di atas, kami mencipta laluan protokol menggunakan ProtocolTypeRouter dan menyediakan sub-laluan berasaskan WebSocket. Dalam contoh ini, URL yang diminta oleh WebSocket ialah /ws/, dan kelas MyConsumer akan digunakan apabila menyambung.

5. Buat Pengguna

Dalam saluran-django, Pengguna ialah kelas yang mengendalikan permintaan rangkaian. Permintaan boleh dialihkan kepada pengguna dalam laluan, dan kemudian pengguna akan memproses permintaan dan mengembalikan respons. Pengguna biasanya dilaksanakan dengan kaedah async def (iaitu coroutine). Apabila membina Pengguna, anda mesti mewarisi kelas channels.generic.websocket.WebSocketConsumer dan melaksanakan dua kaedah:

• connect(self): django-channels memanggil kaedah ini apabila sambungan WebSocket diwujudkan.
• receive(self, text_data=None, bytes_data=None): Kaedah ini dipanggil oleh django-channels apabila data diterima daripada sambungan WebSocket.

Berikut ialah contoh Pengguna mudah:

# myapp/consumers.py

import asyncio
import json

from channels.generic.websocket import AsyncWebsocketConsumer


class MyConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        """
        WebSocket连接建立时执行。
        """
        await self.accept()

    async def disconnect(self, code):
        """
        WebSocket连接中断时执行。
        """
        pass

    async def receive(self, text_data=None, bytes_data=None):
        """
        当从WebSocket连接接收到数据时执行。
        """
        # 解析WebSocket发送的JSON数据
        data = json.loads(text_data)
        # 从JSON数据中获取请求
        request = data['request']

        # 这里是处理请求的代码
        # ...

        # 发送响应到WebSocket连接
        response = {'status': 'OK', 'data': request}
        await self.send(json.dumps(response))

6. Mulakan pelayan Django

Sekarang, semua tetapan telah selesai dan boleh dimulakan Pelayan Django dan menguji sambungan WebSocket. Masukkan arahan berikut dalam terminal untuk memulakan pelayan Django:

python manage.py runserver

Jika semuanya berjalan lancar, anda sepatutnya dapat menguji sambungan WebSocket melalui http://127.0.0.1:8000/ws/ sambungan berjaya, WebSocket Consumer Kaedah sambung akan dilaksanakan.

Ringkasan:

Menggunakan saluran-django untuk melaksanakan WebSocket adalah sangat mudah dan pada asasnya hanya memerlukan beberapa langkah. Satu perkara yang perlu diambil perhatian ialah dalam aplikasi saluran django, coroutine asyncio sering digunakan, oleh itu, Python 3.5 dan ke atas diperlukan. Selain itu, konfigurasi lapisan saluran juga sangat penting. Jika anda ingin menggunakan storan berterusan, anda boleh menggunakan lapisan saluran lain, seperti RedisChannelLayer.

Atas ialah kandungan terperinci Pengaturcaraan pelayan Python: Melaksanakan WebSockets menggunakan saluran-django. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!