pip install django-websocket-redis

# settings.py
​
INSTALLED_APPS = [
    ...
    'websocket',
]
​
WS4REDIS_EXPIRE = 3600
WS4REDIS_PREFIX = 'websocket'
WS4REDIS_HEARTBEAT = '--heartbeat--'

# handlers.py
​
from ws4redis.publisher import RedisPublisher
from ws4redis.redis_store import RedisMessage
​
def send_message(channel, message):
    redis_publisher = RedisPublisher(facility=channel, broadcast=True)
    redis_publisher.publish_message(RedisMessage(message))

# views.py
​
from django.shortcuts import render
from .handlers import send_message
​
def index(request):
    return render(request, 'index.html')
​
def send_websocket_message(request):
    message = request.GET.get('message', '')
    send_message('chatroom', message)
    return HttpResponse("Message sent successfully!")

<!-- index.html -->
​
<script>
    var ws = new WebSocket("ws://localhost:8000/ws/chatroom/");
​
    ws.onopen = function() {
        console.log("WebSocket connected.");
    };
​
    ws.onmessage = function(event) {
        console.log("Received message: " + event.data);
    };
​
    ws.onclose = function() {
        console.log("WebSocket closed.");
    };
</script>

// index.html
​
<script>
    var ws;
​
    function connectWebSocket() {
        ws = new WebSocket("ws://localhost:8000/ws/chatroom/");
​
        ws.onopen = function() {
            console.log("WebSocket connected.");
        };
​
        ws.onmessage = function(event) {
            console.log("Received message: " + event.data);
        };
​
        ws.onclose = function() {
            console.log("WebSocket closed. Reconnecting...");
            setTimeout(connectWebSocket, 3000); // Попробуйте переподключиться через 3 секунды.
        };
    }
​
    connectWebSocket();
</script>

# handlers.py
​
from django.contrib.auth.models import User
from ws4redis.publisher import RedisPublisher
from ws4redis.redis_store import RedisMessage
​
def authenticate_websocket(request):
    user = request.user
    if user.is_authenticated:
        return True
    else:
        return False
​
def send_message(channel, message):
    redis_publisher = RedisPublisher(facility=channel, broadcast=True)
    redis_publisher.publish_message(RedisMessage(message))

# views.py
​
from django.shortcuts import render
from django.http import HttpResponse
from .handlers import send_message, authenticate_websocket
​
def send_websocket_message(request):
    if not authenticate_websocket(request):
        return HttpResponse("Authentication failed!", status=403)
    
    message = request.GET.get('message', '')
    send_message('chatroom', message)
    return HttpResponse("Message sent successfully!")

# handlers.py

from django.core.cache import cache
from ws4redis.publisher import RedisPublisher
from ws4redis.redis_store import RedisMessage

def send_message(channel, message):
    redis_publisher = RedisPublisher(facility=channel, broadcast=True)
    redis_publisher.publish_message(RedisMessage(message))

def handle_message(message):
    # Прежде чем обрабатывать сообщение, сначала проверьте, существует ли уже такое же сообщение в кеше, чтобы избежать повторной обработки.
    if not cache.get(message):
        # Если сообщение не существует в кеше, обработайте сообщение и сохраните его в кеше.
        # Это всего лишь пример, реальную логику обработки необходимо написать в соответствии с требованиями приложения.
        process_message(message)
        cache.set(message, True, timeout=3600)  # Установите срок действия кэша на 1 час.

def process_message(message):
    # Фактическая логика обработки сообщений
    print("Processing message:", message)

# views.py

from django.http import HttpResponse
from .handlers import send_message, handle_message

def send_websocket_message(request):
    message = request.GET.get('message', '')
    send_message('chatroom', message)
    handle_message(message)  # Обработка сообщений
    return HttpResponse("Message sent successfully!")

# handlers.py

from django.db import transaction

@transaction.atomic
def save_message_to_database(message):
    # Используйте транзакции для обеспечения целостности и согласованности данных при сохранении сообщений в базе данных.
    # Это всего лишь пример, реальную логику сохранения необходимо написать в соответствии с требованиями приложения.
    save_message(message)

def save_message(message):
    # Логика фактического сохранения сообщения в базу данных
    print("Saving message to database:", message)

# views.py

from .handlers import send_message, handle_message, save_message_to_database

def send_websocket_message(request):
    message = request.GET.get('message', '')
    send_message('chatroom', message)
    handle_message(message)  # Обработка сообщений
    save_message_to_database(message)  # Сохранить сообщение в базу данных
    return HttpResponse("Message sent successfully!")

pip install channels

# consumers.py

import json
from channels.generic.websocket import WebsocketConsumer

class ChatConsumer(WebsocketConsumer):
    def connect(self):
        self.accept()

    def disconnect(self, close_code):
        pass

    def receive(self, text_data):
        text_data_json = json.loads(text_data)
        message = text_data_json['message']

        # Обрабатывать полученные сообщения
        self.send(text_data=json.dumps({
            'message': message
        }))

# routing.py

from django.urls import re_path
from . import consumers

websocket_urlpatterns = [
    re_path(r'ws/chatroom/$', consumers.ChatConsumer.as_asgi()),
]

<!-- index.html -->

<script>
    var ws = new WebSocket("ws://localhost:8000/ws/chatroom/");

    ws.onopen = function() {
        console.log("WebSocket connected.");
    };

    ws.onmessage = function(event) {
        console.log("Received message: " + event.data);
    };

    ws.onclose = function() {
        console.log("WebSocket closed.");
    };
</script>