Django + WebSocket + Redis 在线聊天室题文章

话很少说先上效果图演示

项目：http://112.74.164.107:9990/

一、安装组建

redis: yum install redis/apt install redis

二、建立虚拟化环境并进入

python3/python -m venv venv

source venv\bin\active

三、安装第三方库
pip install -r requirements.txt

四、初始化
python manage.py makemigrations

python manage.py migrate
python manage.py collectstatic

五、启动服务
gunicorn -w 5 -k gevent -b 0.0.0.0:9990 webchat.wsgi

六、访问

浏览器访问http://ip:9990

整个项目中涉及的思路和知识点咱们在这里都一一分解为你们详细解说以下：

Django 基础

Django ：一个可使 Web 开发工做愉快而且高效的 Web 开发框架，可以以最小的代价构建和维护高质量的 Web 应用

框架：软件开发工程师从平常的重复劳动中总结出快速的、模块化的、安全的软件开发模式

Django 是 Python 开发者的最佳 Web 框架

MVC

ORM

Object Relation Mapping (关系对象映射)

• 用来把对象模型表示的对象映射到基于 SQL 的关系模型数据库结构中去
• 在具体的操做实 体对象的时候，就不 须要再去和复杂的 SQL 语句打交道，只 需简单的操做实体对 象的属性和方法
  

Mail (经过邮箱和验证码方式进行用户登陆验证)

开发者可为使用 Django 提供的 send_mail 函数发送邮件

使用方法

配置邮箱(setting.py)

• EMAIL_HOST = 'smtp-mail.outlook.com'
• EMAIL_PORT = 587
• EMAIL_HOST_USER = 'imsilence@outlook.com'
• EMAIL_HOST_PASSWORD = ‘xxxxxx'
• EMAIL_USE_TLS = True
• EMAIL_FROM = EMAIL_HOST_USER

发送

send_mail(subject, message, from_email, recipient_list, fail_silently=False, auth_user=None, auth_password=None, connection=None, html_message=None)

注: django 发送邮件封装 python smtplib 模块，smtplib 使用方 法: https://github.com/imsilence/packages/blob/master/python/mailclient.py

Session & Cookie

实现用户认证机制

• HTTP 协议为无状态
• Session 存储在服务器
• Cookie 存储在客户端
  
  
  

WebSocket 基础(实现服务端消息主动推送客户端)

是什么?

WebSocket 是 HTML5 开始提供的一种在单个 TCP 链接上进行全双工通信的协议

为何须要?

HTTP 协议是一种无状态的、无链接的、单向的应用层协议。它采用了请

求/响应模型。通讯请求只能由客户端发起，服务端对请求作出应答处理

弊端: HTTP 协议没法实现服务器主动向客户端发起消息。

传统模式下， Web 应用程序经过频繁的 ajax 请求实现长轮询( 轮询是在 特定的时间间隔(如每1秒),由浏览器对服务器发出 HTTP 请求，而后由 服务器返回最新的数据给客户端的浏览器)

缺点:轮询的效率低，很是浪费带宽等资源(浏览器须要不断的向服务器

发出请求)

如何工做?

Web 浏览器和服务器都必须实现 WebSockets 协议来创建和维护连 接，因为 WebSockets 链接长期存在，与典型的 HTTP 链接不一样，对 服务器有重要的影响(任何 WebSockets 服务器都须要实现为异步服 务器，基于多线程或多进程的服务器没法适用于 WebSockets，由于 它旨在打开链接，尽量快地处理请求，而后关闭链接)

在 WebSocket 协议中, 浏览器和服务器只须要作一个握手的动做，而后，浏览器和服务器之间就造成了一条快速通道。二者之间就直接能够数据互相传送。

如何使用?

客户端 API (javascript)

一、建立 websocket 对象
var ws = new WebSocket(url, [protocol] );

二、属性

ws.readyState 表示链接状态

可选值:

0: 表示链接还没有创建。
1: 表示链接已创建，能够进行通讯。
2: 表示链接正在进行关闭。
3: 表示链接已经关闭或者链接不能打开。
ws.bufferedAmount 表示已被 send() 方法放入正在队列中等待传输，可是尚未发 出的 UTF-8 文本字节数

三、事件

• open ws.onopen 创建链接时触发
• message ws.onmessage 客户端接收服务端数据时触发
• error ws.onerror 通讯发生错误时触发
• close ws.onclose 链接关闭时触发

四、方法
send ws.send() 使用链接发送数据

close ws.close() 关闭链接

dwebsocket 使用

dwebsocket 模块为 django 提供了 WebSocket 协议的实现

使用

一、安装
pip install dwebsocket

二、用法

使用 accept_websocket 或 require_websocket 装饰器修饰 view

• accept_websocket: view 既可处理 websocket 协议又可处理普通 http协议
• require_websocket: view 只处理 websocket 协议，拒绝处理普通 http协议
  request.is_websocket 方法用于判断是否为 websocket 协议

获取 websocket 链接对象

• request.websocket 对象

获取数据

• request.websocket.wait 方法, 阻塞性获取客户端数据
• request.websocket.read 方法，非阻塞性获取客户端数据

发送数据

• request.websocket.send(message): 发送消息给 websocket 客户端

其余

• request.websocket.count_messages()
• request.websocket.has_messages()
• request.websocket.iter()

redis 基础

Redis 是一个开源的，基于内存的，可持久化的，K-V 数据库

用途:

• 缓存
• 消息队列
• 发布订阅

发布订阅:是一种消息通讯模式，发送者(pub)发送消息，缩 影订阅者(sub)均可以接收消息并处理

一、在 redis 客户端中使用

• 订阅:subscribe channel
• 发布:publish channel message

二、在 python 中使用

redis 模块

• pip install redis
• cli = redis.StrictRedis()

订阅

• pubsub = cli.pubsub()
• pubsub.subscribe(channel)
• pubsub.get_message()

发布:

• cli.publish(channel, message)
  

代码解读——项目启动

代码结构

app 定义（app.py）

配置（settings.py）

• 配置访问地址
  

• 启用 app
  

• 配置模版路径
  

• 配置时区和国际化
  

• 配置静态资源路径
  

• 配置邮箱
  

• 配置 redis 缓存
  

代码解读——用户认证流程

流程

一、打开登陆页面

• 浏览器中输入 http://ip:9990/login/, 浏览器发送 GET 请求到 login/
• urls.py 处理 url login/ 到视图 login
• login 视图 打开 login.html 模板

二、发送验证码

• 填写邮箱，点击发送验证码按钮，浏览器发送 ajax(GET) 请求到 login_code/
• urls.py 处理 url login_code/ 到视图 login_code
• login 视图调用 models 建立并记录验证码，同时发送邮件给用户，返回 json 数 据

三、登陆

• 填写验证码，点击登录按钮，浏览器发送 ajax(POST) 请求到 login/
• urls.py 处理 url login/ 到视图 login
• login 视图调用 models 验证邮箱和验证码，返回 json 数据，当验证成功同时记录 session 数据

路由（url.py）

视图-view.py

视图-models.py

视图-templates/login.html

代码解读——websocket 处理流程

流程

建立 websocket 链接到 msg/，同时注册 open, error, message 事件

当链接建立，调用 websocket.send 发送上线消息

用户填写消息，点击按钮，调用 websocket.send 方法发送聊天消息

urls.py 处理 url msg/ 到视图 msg

msg 视图接收和处理 websocket 消息，同时监听和处理 redis 订阅的 消息

• 当接收到 websocket 消息，发布消息到 redis 通道
• 当接收到 redis 发布消息，则发送到 websocket 客户端

获取 websocket 链接和发送消息（index.html）

路由处理（view.py）

消息显示处理（index.html）

代码解读——推出登录流程

想要源码的请留言或者私信博主