# 定义全局变量

CONN_List = []

class LiveConsumer(WebsocketConsumer):

    def websocket_connect(self, message):

        # 将每个连接对象追加到列表

        CONN_List.append(self)

    def receive(self, text_data=None, bytes_data=None):

        # 循环列表，每个连接对象发送消息

        for conn in CONN_List:

            conn.send('消息')

    def websocket_disconnect(self, message):

        CONN_List.remove(self)

        raise StopConsumer