您的位置：首页 > 脚本大全 > > 正文

django对话框（基于django channel实现websocket的聊天室的方法示例）

更多 时间：2021-10-18 11:31:44 类别：脚本大全 浏览量：302

django对话框

基于django channel实现websocket的聊天室的方法示例

websocket

  • 网易聊天室?
  • ​ web微信?
  • ​ 直播?

假如你工作以后,你的老板让你来开发一个内部的微信程序,你需要怎么办?我们先来分析一下里面的技术难点

  • 消息的实时性?
  • 实现群聊

现在有这样一个需求,老板给到你了,关乎你是否能转正?你要怎么做?

我们先说消息的实时性,按照我们目前的想法是我需要用http协议来做,那么http协议怎么来做那?

是不是要一直去访问我们的服务器,问服务器有没有人给我发消息,有没有人给我发消息?那么大家认为我多长时间去访问一次服务比较合适那? 1分钟1次?1分钟60次?那这样是不是有点问题那?咱们都知道http发起一次请求就需要三次握手,四次断开,那么这样是不是对我服务器资源是严重的浪费啊?对我本地的资源是不是也是严重的浪费啊?这种方式咱们是不是一直去服务器问啊?问有没有我的信息?有我就显示?这种方式咱们一般称为轮询

http协议:

​ 一次请求 一次相应 断开

​ 无状态的 - 你曾经来过 session or cookie

​ 在断开的情况下如果有数据只能等下次再访问的时候返回

那么我们先来总结一下,轮询优缺点

轮询02年之前使用的都是这种技术

​ 每分钟访问60次服务器

​ 优点:消息就基本实时

缺点:双资源浪费

长轮询2000-现在一直在使用

客户端发送一个请求- 服务器接受请求-不返回- 阻塞等待客户端-如果有消息了-返回给客户端

然后客户端立即请求服务器

​ 优点:节省了部分资源,数据实时性略差

​ 缺点:断开连接次数过多

那有没有一种方法是:我的服务器知道我的客户端在哪?有客户端的消息的时候我就把数据发给客户端

websocket是一种基于tcp的新网络协议,它实现了浏览器和服务器之间的双全工通信,允许服务端直接向客户端发送数据

websocket 是一个长连接

现在咱们的前端已经支持websocket协议了,可以直接使用websocket

简单应用

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
    		•
  • <body>
  •   <!-- 输入内容-->
  •   <input type="text" id="input">
  •   <!-- 提交数据-->
  •   <button> 提交数据</button>
  •   <!-- 显示内容-->
  •   <li>
  •     <li ></li>
  •   </li>
  •  
  • <script>
  •   var input=document.getelementbyid('input');
  •   var button=document.queryselector('button');
  •   var message=document.queryselector('li');
  •   //websocket在浏览器端如何使用
  •   //现在html已经提供了websocket,我们可以直接使用
  •   var socket= new websocket('ws://echo.websocket.org');
  •   socket.onopen=function () {
  •     message.innerhtml='连接成功了'
  •   };
  •   //socket.addeventlistener('open',function (data) {
  •    //  message.innerhtml='连接成功了'
  •   //});
  •   //点击事件
  •   button.onclick=function () {
  •     request=input.value;
  •     socket.send(request)
  •   }
  •   //获取返回数据
  •   socket.onmessage=function (data) {
  •     message.innerhtml=data.data
  •   };
  •   socket.onclose=function (data) {
  •     message.innerhtml=data.data
  •   }
  •  
  • </script>
  •  
  • </body>
    		•

    优化前端代码

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
    		•
  • button.onclick=function () {
  •     request=input.value;
  •     socket.send(request);
  •     input.value=''
  •   }
  •   //获取返回数据
  •   socket.onmessage = function (data) {
  •     var dv=document.createelement('li');
  •     dv.innerhtml=data.data;
  •     message.appendchild(dv)
  •  
  •   };
    		•

    websocket 事件

    事件 事件处理函数 描述
    open socket.onopen 连接建立是触发
    message socket.onmessage 客户端收到服务端数据是触发
    error socket.error 通信发生错误时触发
    close socket.close 连接关闭时触发

    websocket方法

    方法 描述
    socket.send() 使用连接发送数据
    socket.close() 关闭连接

    websocke treadystate值的状态

    值 描述
    0 (connecting) 正在链接中
    1 (open) 已经链接并且可以通讯
    2 (closing) 连接正在关闭
    3 (closed) 连接已关闭或者没有链接成功

    自建websocket服务端

    准备前端页面

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
    		•
  • <!-- chat/templates/chat/index.html -->
  • <!doctype html>
  • <html>
  • <head>
  •   <meta charset="utf-8"/>
  •   <title>chat rooms</title>
  • </head>
  • <body>
  •   what chat room would you like to enter?<br/>
  •   <input id="room-name-input" type="text" size="100"/><br/>
  •   <input id="room-name-submit" type="button" value="enter"/>
  •  
  •   <script>
  •     document.queryselector('#room-name-input').focus();
  •     document.queryselector('#room-name-input').onkeyup = function(e) {
  •       if (e.keycode === 13) { // enter, return
  •         document.queryselector('#room-name-submit').click();
  •       }
  •     };
  •  
  •     document.queryselector('#room-name-submit').onclick = function(e) {
  •       var roomname = document.queryselector('#room-name-input').value;
  •       window.location.pathname = '/web/' + roomname + '/';
  •     };
  •   </script>
  • </body>
  • </html>
    		•

    编辑django的views，使其返回数据

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
    		•
  • # chat/views.py
  • from django.shortcuts import render
  •  
  • def index(request):
  •   return render(request, 'chat/index.html', {})
    		•

    修改url

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
    		•
  • from django.conf.urls import url
  • from .views import *
  •  
  • urlpatterns = [
  •   url(r'^$', index, name='index'),
  •   ]
    		•

    跟settings同级目录下创建routing.py 文件

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
    		•
  • # mysite/routing.py
  • from channels.routing import protocoltyperouter
  •  
  • application = protocoltyperouter({
  •   # (http->django views is added by default)
  • })
    		•

    编辑settings文件,将channels添加到installed_apps里面

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
    		•
  • installed_apps = [
  •   'channels',
  •   'chat',
  •   'django.contrib.admin',
  •   'django.contrib.auth',
  •   'django.contrib.contenttypes',
  •   'django.contrib.sessions',
  •   'django.contrib.messages',
  •   'django.contrib.staticfiles',
  • ]
    		•

    并添加channel的配置信息

  • ?
  • 1
    		•
  • asgi_application = 'mysite.routing.application'
    		•

    准备聊天室的页面

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
    		•
  • <!-- chat/templates/chat/room.html -->
  • <!doctype html>
  • <html>
  • <head>
  •   <meta charset="utf-8"/>
  •   <title>chat room</title>
  • </head>
  • <body>
  •   <textarea id="chat-log" cols="100" rows="20"></textarea><br/>
  •   <input id="chat-message-input" type="text" size="100"/><br/>
  •   <input id="chat-message-submit" type="button" value="send"/>
  • </body>
  • <script>
  •   var roomname = {{ room_name_json|safe }};
  •  
  •   var chatsocket = new websocket(
  •     'ws://' + window.location.host +
  •     '/ws/chat/' + roomname + '/');
  •  
  •   chatsocket.onmessage = function(e) {
  •     var data = json.parse(e.data);
  •     var message = data['message'];
  •     document.queryselector('#chat-log').value += (message + '\n');
  •   };
  •  
  •   chatsocket.onclose = function(e) {
  •     console.error('chat socket closed unexpectedly');
  •   };
  •  
  •   document.queryselector('#chat-message-input').focus();
  •   document.queryselector('#chat-message-input').onkeyup = function(e) {
  •     if (e.keycode === 13) { // enter, return
  •       document.queryselector('#chat-message-submit').click();
  •     }
  •   };
  •  
  •   document.queryselector('#chat-message-submit').onclick = function(e) {
  •     var messageinputdom = document.queryselector('#chat-message-input');
  •     var message = messageinputdom.value;
  •     chatsocket.send(json.stringify({
  •       'message': message
  •     }));
  •  
  •     messageinputdom.value = '';
  •   };
  • </script>
  • </html>
    		•

    准备views文件，使其返回页面

  • ?
  • 1
  • 2
  • 3
  • 4
    		•
  • def room(request, room_name):
  •   return render(request, 'chat/room.html', {
  •     'room_name_json':json.dumps(room_name)
  •   })
    		•

    修改url

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
    		•
  • from django.conf.urls import url
  •  
  • from . import views
  •  
  • urlpatterns = [
  •   url(r'^$', views.index, name='index'),
  •   url(r'^(?p<room_name>[^/]+)/$', views.room, name='room'),
  • ]
    		•

    实现简单的发送返回

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
    		•
  • from channels.generic.websocket import websocketconsumer
  • import json
  •  
  • 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
  •     }))
    		•

    创建ws的路由

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
    		•
  • # chat/routing.py
  • from django.conf.urls import url
  •  
  • from . import consumers
  •  
  • websocket_urlpatterns = [
  •   
    标签：聊天室 WebSocket channel django
  • 上一篇：dockerip访问限制（docker win ping 不通容器 避坑指南）
  • 下一篇：python 获取ip mac 地址（Python3获取电脑IP、主机名、Mac地址的方法示例）
    • 您可能感兴趣
    首页 编程学习 Web前端 数据库 软件设计
    开心学习 ©2013-2021 保留所有权利