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初學者的學習線路和建議

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。