前言
有时候,我需要把Django视图中产生的数据,通过websocket推送给用户,应该怎么办呢?有一个和Django配套的ASGI框架,用来实现websocket,而官网资料和其他地方都很少有介绍。
1 准备工作
安装Django 和 channels
安装redis作为数据缓存
sudo apt-get install redis-server
在Django的settings配置好redis数据库,看参考channels的官方文档
2 什么是频道层,一个组到底和频道层是什么关系
本人通过亲身实践,悟出上图结构。所谓频道层就像是一根很粗的电线,用来传送信息。而一个用户建立的ws连接(channel1或channel2),就像是电线里的一根细的金属丝(假设金属丝之间,都被绝缘体包裹)。如果只是你和服务器两人的话,一个小通道就够了。但是,
如果很多人都需要共享通信信息,这时候就需要建立一个组了。就是把一根一根的细的金属丝绑在一起插入到组中,实现信息的共享。
3 实践检测
view中
import channels.layers
from asgiref.sync import async_to_sync
channel_layer = channels.layers.get_channel_layer() # 获取频道层
async_to_sync(channel_layer.group_send)(group_name, payload_dict) # 第一个参数写组名,第二个是一个字典
# payload_dict必填项
payload_dict={
'type': 'receive', # 指定consumer(消费者)类接受消息的函数,receive是函数名
'message': '消息'
}
consumer中
from asgiref.sync import async_to_sync
from channels.generic.websocket import WebsocketConsumer
class ResultConsumer(WebsocketConsumer):
def connect(self):
# Join room group
async_to_sync(self.channel_layer.group_add)(
group_name,
self.channel_name
)
self.accept()
def disconnect(self, code):
async_to_sync(self.channel_layer.group_discard)(
group_name,
self.channel_name
)
def receive(self, text_data=None, bytes_data=None):
message = text_data['message']
# 相应的逻辑自己实现吧
4 再见
有任何问题,可以发私信。