Django中,websocket实时通信设置概要

在原有的Django项目中,增加实时通信的功能,用websocket实现,简单记录一下过程,备忘。

1、安装channels、channels-redis、django-redis。

2、在主应用magic_chat目录下新建rounting.py,配置application值。

3、在应用chat_msg目录下新建rounting.py,配置websocket_urlpatterns。

4、在应用chat_msg目录下新建consumers.py,主要逻辑处理都是在这里,相当于views.py。

5、settings里面设置:APP中加入channels;REDIS_HOST、REDIS_PORT;ASGI_APPLICATION、CHANNEL_LAYERS。

6、在主应用magic_chat目录下新建utils目录,在utils目录下新建token_auth.py,放token鉴权的代码(针对websocket);能生效是因为magic_chat/rounting.py里面配置了application的属性。

7、开始编写consumers.py代码。consumers.py主要就是ChatConsumer类,里面有connectdisconnect eceive等函数。

(1)connect函数,Websocket连接。用到了redis.set_user_status函数(在magic_chat/utils新建redis.py,里面是读写redis数据库的代码)。

(2)disconnect函数,断开Websocket连接。

(3)receive函数,服务端接收到消息后的处理;写入长期数据库,并发送websocket消息,即兼容离线和在线用户的使用;用到了下面写的chat_message函数(发送实时消息)。

(4)chat_message函数,给 group 中的用户发送一次消息。

8、开启服务(runserver),开始测试。

9、需要用chrome浏览器的扩展程序smart web client来测,下载安装此插件。

10、smart web client中输入地址,格式如下:ws://127.0.0.1:8000/ws/chat/?token=bc1190581ede19fb34b84ead5faf1a2452b1e13e

点“connect”连接。

 

11、ws连接不上的原因:

(1)报错:“Failure instance: Traceback: <class 'ValueError'>: dictionary update sequence element #0 has length 1; 2 is required”,

原因:token没给出或错误;

解决办法:拿到正确token,以正确格式输入

(2)报错:“redis.exceptions.ConnectionError:”,

原因:redis服务没启动;

解决办法:a.(貌似很麻烦,而且得在linux下)

<1>装docker,

<2>下镜像https://hub.docker.com/_/redis/,  

<3>起redis服务:

$ docker run --name some-redis -d redis

b. <1>下载并安装Redis-x64-3.0.503.msi,地址:https://github.com/MicrosoftArchive/redis/releases

<2>安装完成后,启动服务(找到安装路径,双击redis-cli.exe文件即可)

 

12、在smart web client发送的字段类似下面(注意必须用双引号):

{"message":"Are you busy today?","to_user_id":"222"}

原文地址:https://www.cnblogs.com/djlbolgs/p/12780527.html