django 使用 channels 搭建在线客服疑惑

[endpain]

版本: python == 3.8.1 Django 3.0.4
channels 2.4.0
channels-redis 2.4.2
疑问如下，因为百度搜索的答案实在是一言难尽，都是千篇一律的一样，根据我的个人理解，和查看官网，在 channels 里面包括官方教程都是着重再讲多人聊天和群组聊天（ group ），我想实现的是通过 layim 一对一聊天

整体都能跑通，但是不知道为什么，a 用户发给 b 用户的消息，b 是收不到的，这块我实在是不明白以下几个问题，希望有懂的大神可以指点一下

1 、a 用户发给 b 用户，我如何能给 b 用户去进行推送，

            async_to_sync(self.channel_layer.send)(
                to_user_id,
                {
                    'type': 'chat_messages',  # 调用的发送方法
                    'event':data_json

                }
            )

上面的代码貌似没生效，b 用户是没有收到的

2 、channels 如何能获取当前有几个人在连接，他们存储在 redis 的 channel_name 如何获取？

附上我的代码，感谢~

from asgiref.sync import async_to_sync
from channels.layers import get_channel_layer
from channels.generic.websocket import WebsocketConsumer
from channels.exceptions import *
from channels.db import database_sync_to_async
from rest_framework_jwt.authentication import jwt_decode_handler
import json
import redis
import time
from chat import models

pool = redis.ConnectionPool(
    host='localhost',
    port=6379,
    max_connections=10,
    decode_responses=True
)
conn = redis.Redis(connection_pool=pool, decode_responses=True)


class ChatConsumer(WebsocketConsumer):
    chats = {}

    def connect(self):
        try:
            jwt = self.scope['query_string'].decode() #获取 jwt
            if not jwt:
                # 请求存在问题
                raise DenyConnection("jwt 信息错误")
            payload = jwt_decode_handler(jwt)
        except:
            print("jwt 信息错误")

        print(payload)
        self.user_id = str(payload['user_id'])

        async_to_sync(self.channel_layer.group_add)(
            self.user_id,
            self.channel_name
        )
        # ChatConsumer.chats[user_id] = {'self':self,'last_time':int(time.time())}
        self.accept()

    def disconnect(self, close_code):

        async_to_sync(self.channel_layer.group_discard)(
            self.user_id,
            self.channel_name
        )

        ChatConsumer.chats[self.group_name].remove(self)

        self.close()


    def receive(self, text_data):
        data_json = json.loads(text_data)
        type = data_json.get('type') # 类型

        if type == 'chatMessage':
            # 发送消息
            mine_user_id = data_json.get('data').get('mine').get('id') # 发送者 id
            to_user_id = data_json.get('data').get('to').get('id') # 接受者 id
            message = data_json.get('data').get('mine').get('content') #发送内容

            # 接受成功消息，返回结果
            self.send(text_data=json.dumps({
                'server_socket_type': 'MessageReceivedSuccessfully',
                'result': True,
                'time': int(time.time()),
            }))

            async_to_sync(self.channel_layer.send)(
                to_user_id,
                {
                    'type': 'chat_messages',  # 调用的发送方法
                    'event':data_json

                }
            )