脚本宝典收集整理的这篇文章主要介绍了django channels 模型图,脚本宝典觉得挺不错的,现在分享给大家,也给大家做个参考。
https://channels.readthedocs.io/en/stable/tutorial/part_2.html
浏览器请求, channels给响应。
receive回调接受消息,
send接口发送响应消息
# chat/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 }))
https://channels.readthedocs.io/en/stable/tutorial/part_2.html#enable-a-channel-layer
# chat/consumers.py import json from asgiref.sync import async_to_sync from channels.generic.websocket import WebsocketConsumer class ChatConsumer(WebsocketConsumer): def connect(self): self.room_name = self.scope['url_route']['kwargs']['room_name'] self.room_group_name = 'chat_%s' % self.room_name # Join room group async_to_sync(self.channel_layer.group_add)( self.room_group_name, self.channel_name ) self.accept() def disconnect(self, close_code): # Leave room group async_to_sync(self.channel_layer.group_discard)( self.room_group_name, self.channel_name ) # Receive message from WebSocket def receive(self, text_data): text_data_json = json.loads(text_data) message = text_data_json['message'] # Send message to room group async_to_sync(self.channel_layer.group_send)( self.room_group_name, { 'type': 'chat_message', 'message': message } ) # Receive message from room group def chat_message(self, event): message = event['message'] # Send message to WebSocket self.send(text_data=json.dumps({ 'message': message }))
每个加入聊天室的连接, 都会订阅一份 room_group_name 主题的 redis channel, 一旦room_group_name 主题有消息更新, 各个连接会执行回调 chat_message , 将新消息返回到 客户端。
以上是脚本宝典为你收集整理的django channels 模型图全部内容,希望文章能够帮你解决django channels 模型图所遇到的问题。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。