Как получить журнал и результат вызова websocket async_to_sync

У меня есть websocket и я просто отправляю мезасгеты на channel_layer

from channels.layers import get_channel_layer
    channel_layer = get_channel_layer()
    async_to_sync(channel_layer.group_send)(
        '{}'.format(mychannelname),
        {
            "type": "chat_message",
            "message": "send you"
        }
    )

Кажется, что все работает хорошо и сообщения отправляются в браузер клиента, однако я хочу знать, работает ли это хорошо или нет с сервера.

Возможно ли или можно ли получить количество клиентов, подключенных к каналу?

Мой consumers.py делает каналы

import json

from channels.db import database_sync_to_async
from channels.generic.websocket import AsyncWebsocketConsumer


class ChatConsumer(AsyncWebsocketConsumer):
    
    async def connect(self):

        self.room_group_name = self.scope["url_route"]["kwargs"]["room_name"]

        await self.channel_layer.group_add(
            self.room_group_name,
            self.channel_name
        )
        await self.accept()
        await self.send(text_data=json.dumps({
            'channel_name': self.channel_name
        }))
    async def disconnect(self, close_code):
        print("some disconnect")
        await self.channel_layer.group_discard(
            self.room_group_name,
            self.channel_name
        )

    async def receive(self, text_data):
        text_data_json = json.loads(text_data)
        message = text_data_json['message']
        print("receive data",text_data_json)
    
        print("channel_name:",self.channel_name)
        print("group_name:",self.room_group_name)
        if text_data_json['type'] == "register":
            self.user_id = text_data_json['message']
        print("user_id is:",self.user_name)

        #res = await self.save_message_to_db(message)
        await self.channel_layer.group_send(
            self.room_group_name,
            {
                'type': 'chat_message',
                'message': "nicelydone",
            }
        )

    async def chat_message(self, event):
        print("someone call chat_message")
        message = event['message']
        await self.send(text_data=json.dumps({
            'message': message
        }))

Как подтвердить, что сообщения доходят до подключенных клиентов:
Один из способов проверить, получает ли каждый клиент сообщение, - реализовать систему подтверждения. Когда клиент получает сообщение в методе chat_message, вы можете заставить его отправить подтверждающее сообщение обратно на сервер.

Вот пример того, как это можно сделать:

socket.onmessage = function(event) {
    const data = JSON.parse(event.data);
    console.log("Received message:", data.message);

    // Send acknowledgment back to the server
    socket.send(JSON.stringify({
        'type': 'acknowledgment',
        'message': 'Message received'
    }));
};

Затем на сервере вы можете обработать это подтверждение в методе receive для подтверждения доставки:

async def receive(self, text_data):
    text_data_json = json.loads(text_data)
    message_type = text_data_json.get('type')

    if message_type == "acknowledgment":
        print(f"Acknowledgment received from {self.channel_name}")

    # Continue with the rest of your logic here...

Таким образом, каждый раз, когда клиент получает сообщение, он отправляет ответное подтверждение, которое вы можете зарегистрировать или отследить на сервере.

Как получить количество подключенных клиентов в группе каналов:
Django Channels не предоставляет встроенного метода для получения количества клиентов в группе. Однако вы можете отслеживать это вручную, ведя подсчет активных соединений. Например:

  • Увеличивает счетчик, когда вызывается connect.
  • Уменьшение счетчика при вызове disconnect.

Вы можете использовать кэш, например Redis, для хранения и получения этого подсчета, который будет сохраняться в разных рабочих процессах.

Вот как это можно реализовать:

from asgiref.sync import async_to_sync
from django.core.cache import cache

class ChatConsumer(AsyncWebsocketConsumer):

    async def connect(self):
        self.room_group_name = self.scope["url_route"]["kwargs"]["room_name"]

        # Increment connected client count
        await self.update_client_count(1)
        await self.channel_layer.group_add(self.room_group_name, self.channel_name)
        await self.accept()

    async def disconnect(self, close_code):
        # Decrement connected client count
        await self.update_client_count(-1)
        await self.channel_layer.group_discard(self.room_group_name, self.channel_name)

    @database_sync_to_async
    def update_client_count(self, delta):
        current_count = cache.get(self.room_group_name, 0)
        new_count = current_count + delta
        cache.set(self.room_group_name, new_count)
        print(f"Current clients in {self.room_group_name}: {new_count}")

Здесь кэш может быть настроен на использование Redis или Memcached, что позволит вам хранить имя_группы_комнаты в качестве ключа и количество в качестве значения.

Таким образом, update_client_count будет отслеживать текущие активные соединения в вашей группе каналов, и вы сможете получить количество подключенных клиентов, вызвав cache.get(room_group_name) там, где это необходимо.

Вернуться на верх