Django Channels 学习笔记

时间 2019-11-11

原文原文链接

一.为何要使用Channels

　　在Django中，默认使用的是HTTP通讯，不过这种通讯方式有个很大的缺陷，就是不能很好的支持实时通讯。若是硬是要使用HTTP作实时通讯的话只能在客户端进行轮询了，不过这样作的开销太大了。
　　所以，在1.9版本以后，Django实现了对Channels的支持，他所使用的是WebSocket通讯，解决了实时通讯的问题，并且在使用WebSocket进行通讯的同时依旧可以支持HTTP通讯。javascript

二.建立一个Django Channels样例的完整流程

1. 首先下载相应插件

pip install channels
pip install asgi_redis

2. 建立一个新工程

django-admin.py startproject channels_example

3. 设置settings.py中的参数

这里首先将channels加入到INSTALLED_APPS中，以下：java

INSTALLED_APPS = [ 'django.contrib.admin', 'django.contrib.auth', 'django.contrib.contenttypes', 'django.contrib.sessions', 'django.contrib.messages', 'django.contrib.staticfiles', 'channels', ]

而后，添加新的参数CHANNEL_LAYERS，以下：python

CHANNEL_LAYERS = { "default": { "BACKEND": "asgiref.inmemory.ChannelLayer", "ROUTING": "channels_example.routing.channel_routing", }, }

这里，须要注意的是 ROUTING 参数，他是用来指定WebSocket表单的位置，当有WebSocket请求访问时，就会根据这个路径找到相应表单，调用相应的函数进行处理。
channels_example.routing 就是咱们刚才建好的routing,py文件，里面的channel_routing咱们下面会进行填充。web

4. 填写新的表单——routing.py文件

上一步咱们已经了解到，routing.py文件其实就是个表单，功能和Django原来的urls.py文件同样，不过这里使用的不是URL，而是请求的类型。

redis

from channels.routing import route from channels_example import consumers  #导入处理函数
 channel_routing = [ #route("http.request", consumers.http_consumer), 这个表项比较特殊，他响应的是http.request，也就是说有HTTP请求时就会响应，同时urls.py里面的表单会失效
 route("websocket.connect", consumers.ws_connect),        #当WebSocket请求链接上时调用consumers.ws_connect函数
    route("websocket.receive", consumers.ws_message),        #当WebSocket请求发来消息时。。。
    route("websocket.disconnect", consumers.ws_disconnect),    #当WebSocket请求断开链接时。。。
]

5. 填写新的视图文件——consumers.py

上一步咱们已经了解到，routing.py至关于新的urls.py，而consumers.py就至关于新的view.py。

代码：django

from django.http import HttpResponse from channels.handler import AsgiHandler #message.reply_channel 一个客户端通道的对象 #message.reply_channel.send(chunk) 用来惟一返回这个客户端

#一个管道大概会持续30s

#当链接上时，发回去一个connect字符串
def ws_connect(message): message.reply_channel.send({"connect"}) #将发来的信息原样返回
def ws_message(message): message.reply_channel.send({ "text": message.content['text'], }) #断开链接时发送一个disconnect字符串，固然，他已经收不到了
def ws_disconnect(message): message.reply_channel.send({"disconnect"})

6. asgi.py文件

相似于Django本身生成的wsgi.py文件，内容以下：

浏览器

import os import channels.asgi os.environ.setdefault("DJANGO_SETTINGS_MODULE", "channels_example.settings")    #这里填的是你的配置文件settings.py的位置
channel_layer = channels.asgi.get_channel_layer()

7. 发布运行

python manage.py runserver 0.0.0.0:8000

这是一个测试用的JS代码，可以发送和接收WebSocket请求：websocket

<!DOCTYPE HTML>
<html>
   <head>
   <meta charset="utf-8">
   <title></title>
    
      <script type="text/javascript">
         function WebSocketTest() { if ("WebSocket" in window) { alert("您的浏览器支持 WebSocket!"); socket = new WebSocket("ws://" + "localhost:8000" + "/channels_example/"); socket.onmessage = function(e) { alert(e.data); } socket.onopen = function() { socket.send("hello world"); } // Call onopen directly if socket is already open
                if (socket.readyState == WebSocket.OPEN) socket.onopen(); } else { // 浏览器不支持 WebSocket
 alert("您的浏览器不支持 WebSocket!"); } } </script>
        
   </head>
   <body>
   
      <div id="sse">
         <a href="javascript:WebSocketTest()">运行 WebSocket</a>
      </div>
      
   </body>
</html>

三.进阶 —— Group

四.进阶 —— message详解

五.遇到的问题

1. 后来的请求可能会打断以前请求的执行

好比，我写了下面三个函数响应connect,send和disconnectsession

@channel_session def ws_message(message): #送给全组人
    print message.channel_session['room'] Group("chat-%s" % message.channel_session['room']).send({ "text": message.content['text'], }) @channel_session def ws_connect(message): room = message.content['path'].strip("/") message.channel_session['room'] = room Group("chat-%s" % room).add(message.reply_channel) @channel_session def ws_disconnect(message): print message.channel_session['room'] Group("chat-%s" % message.channel_session['room']).discard(message.reply_channel)

客户端我这样写：

socket.onopen = function() { socket.send("hello world"); }

这样就会产生一个问题，当客户端链接到服务端时，服务端执行ws_connect()函数，而后客户端又send()了数据，服务端就会去调用ws_message()函数，而终止了ws_connect()函数的执行。

此时，个人ws_connect()函数还未对message.channel_session['room']进行赋值，而ws_message()函数就调用了他，因此会报错。

而后我尝试了断开链接，运行正常，这就说明ws_connect()函数最终仍是执行完了，不过是在ws_message()函数执行以后。

综上，当服务端接收到新的请求时，可能会打断上个请求的执行，这点须要特殊注意一下。

1. django channels
2. Django Channels
3. Django channels
4. Django学习笔记
5. django 学习笔记
6. Django 学习笔记
7. Django 中的 channels
8. Django学习笔记5
9. Django学习笔记9
10. Django学习笔记8
更多相关文章...
• 您已经学习了 XML Schema，下一步学习什么呢？ - XML Schema 教程
• 我们已经学习了 SQL，下一步学习什么呢？ - SQL 教程
• Tomcat学习笔记（史上最全tomcat学习笔记）
• 适用于PHP初学者的学习线路和建议