欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Django Channel實時推送與聊天的示例代碼

 更新時間：2020年04月30日 09:22:05   作者：Sunzz  
這篇文章主要介紹了Django Channel實時推送與聊天的示例代碼，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

先來看一下最終的效果吧

開始聊天，輸入消息并點擊發(fā)送消息就可以開始聊天了

點擊 “獲取后端數(shù)據(jù)”開啟實時推送

先來簡單了解一下 Django Channel

Channels是一個采用Django并將其功能擴展到HTTP以外的項目，以處理WebSocket，聊天協(xié)議，IoT協(xié)議等。它基于稱為ASGI的Python規(guī)范構建。

它以Django的核心為基礎，并在其下面分層了一個完全異步的層，以同步模式運行Django本身，但異步處理了連接和套接字，并提供了以兩種方式編寫的選擇，從而實現(xiàn)了這一點。

詳情請參考官方文檔：https://channels.readthedocs.io/en/latest/introduction.html

再簡單說下ASGI是什么東東吧

ASGI 由 Django 團隊提出，為了解決在一個網絡框架里（如 Django）同時處理 HTTP、HTTP2、WebSocket 協(xié)議。為此，Django 團隊開發(fā)了 Django Channels 插件，為 Django 帶來了 ASGI 能力。
在 ASGI 中，將一個網絡請求劃分成三個處理層面，最前面的一層，interface server（協(xié)議處理服務器），負責對請求協(xié)議進行解析，并將不同的協(xié)議分發(fā)到不同的 Channel（頻道）；頻道屬于第二層，通?？梢允且粋€隊列系統(tǒng)。頻道綁定了第三層的 Consumer（消費者）。

詳情請參考官方文檔：https://channels.readthedocs.io/en/latest/asgi.html

下邊來說一下具體的實現(xiàn)步驟

一、安裝channel

pip3 install channels 
pip3 install channels_redis

二、新建Django項目

1.新建項目

django-admin startproject mysite

2.新建應用

python3 manage.py startapp chat

3.編輯mysite/settings.py文件

#注冊應用
INSTALLED_APPS = [
  ....
  'chat.apps.ChatConfig',
  "channels",
]

# 在文件尾部新增如下配置

#將ASGI_APPLICATION設置設置為指向該路由對象作為您的根應用程序：
ASGI_APPLICATION = 'mysite.routing.application'

#配置Redis
CHANNEL_LAYERS = {
  'default': {
    'BACKEND': 'channels_redis.core.RedisChannelLayer',
    'CONFIG': {
      "hosts": [('10.0.6.29', 6379)],
    },
  },
}

三、詳細代碼與配置

1. 添加索引視圖的模板

在chat目錄中創(chuàng)建一個templates目錄。在您剛剛創(chuàng)建的templates目錄中，創(chuàng)建另一個名為的目錄chat，并在其中創(chuàng)建一個名為的文件index.html以保存索引視圖的模板

將以下代碼放入chat/templates/chat/index.html

<!-- 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 = '/chat/' + roomName + '/';
    };
  </script>
</body>
</html>

2.創(chuàng)建聊天與消息推送模板

chat/templates/chat/room.html

<!DOCTYPE html>
<html>
<head>
  <script src="https://cdn.bootcdn.net/ajax/libs/jquery/3.5.0/jquery.min.js" type="text/javascript"></script>
  <link rel="stylesheet"  rel="external nofollow" >
  <script src="https://cdn.jsdelivr.net/npm/bootstrap@3.3.7/dist/js/bootstrap.min.js"></script>
  <meta charset="utf-8"/>
  <title>Chat Room</title>
</head>
<body>
<textarea id="chat-log" cols="150" rows="30" class="text"></textarea><br>
<input id="chat-message-input" type="text" size="150"><br>
<input id="chat-message-submit" type="button" value="發(fā)送消息" class="input-sm">
<button id="get_data" class="btn btn-success">獲取后端數(shù)據(jù)</button>
{{ room_name|json_script:"room-name" }}

<script>

  $("#get_data").click(function () {
    $.ajax({
      url: "{% url 'push' %}",
      type: "GET",
      data: {
        "room": "{{ room_name }}",
        "csrfmiddlewaretoken": "{{ csrf_token }}"
      },
    })
  });

  const roomName = JSON.parse(document.getElementById('room-name').textContent);
  const chatSocket = new WebSocket(
    'ws://' + window.location.host
    + '/ws/chat/'
    + roomName + '/'
  );
  let chatSocketa = new WebSocket(
    "ws://" + window.location.host + "/ws/push/" + roomName
  );
  chatSocket.onmessage = function (e) {
    const data = JSON.parse(e.data);
    // data 為收到后端發(fā)來的數(shù)據(jù)
    //console.log(data);
    document.querySelector('#chat-log').value += (data.message + '\n');
  };
  chatSocketa.onmessage = function (e) {
    let data = JSON.parse(e.data);
    //let message = data["message"];
    document.querySelector("#chat-log").value += (data.message + "\n");
  };


  chatSocket.onclose = function (e) {
    console.error('Chat socket closed unexpectedly');
  };
  chatSocketa.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) {
    const messageInputDom = document.querySelector('#chat-message-input');
    const message = messageInputDom.value;
    chatSocket.send(JSON.stringify({
      'message': message
    }));
    messageInputDom.value = '';
  };
</script>
</body>
</html>

3.創(chuàng)建房間的視圖

將以下代碼放入chat/views.py

# chat/views.py
from django.shortcuts import render
from django.http import JsonResponse
from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync


def index(request):
  return render(request, "chat/index.html")


def room(request, room_name):
  return render(request, "chat/room.html", {"room_name": room_name})


def pushRedis(request):
  room = request.GET.get("room")
  print(room)

  def push(msg):
    channel_layer = get_channel_layer()
    async_to_sync(channel_layer.group_send)(
      room,
      {"type": "push.message", "message": msg, "room_name": room}
    )

  push("推送測試", )
  return JsonResponse({"1": 1})

4. 創(chuàng)建項目二級路由

在chat目錄下創(chuàng)建一個名為的文件urls.py

# mysite/chat/urls.py
from django.urls import path
from . import views

urlpatterns = [
  path('', views.index, name='index'),
　　 path('<str:room_name>/', views.room, name='room'),
]

5. 修改根路由

# mysite/urls.py

from django.contrib import admin
from django.urls import path, include
from chat.views import pushRedis

urlpatterns = [
  path('admin/', admin.site.urls),
  path("chat/", include("chat.urls")),
  path("push", pushRedis, name="push"),
]

6.創(chuàng)建一個消費者

文件chat/consumers.py

當Django接受HTTP請求時，它會查詢根URLconf來查找視圖函數(shù)，然后調用該視圖函數(shù)來處理該請求。同樣，當Channels接受WebSocket連接時，它會查詢根路由配置以查找使用者，然后在使用者上調用各種功能來處理來自連接的事件。

import time
import json
from channels.generic.websocket import WebsocketConsumer, AsyncWebsocketConsumer
from asgiref.sync import async_to_sync
import redis

pool = redis.ConnectionPool(
  host="10.0.6.29",
  port=6379,
  max_connections=10,
  decode_response=True,
)
conn = redis.Redis(connection_pool=pool, decode_responses=True)


class ChatConsumer(AsyncWebsocketConsumer):
  async def connect(self, ):
    self.room_name = self.scope["url_route"]["kwargs"]["room_name"]
    self.room_group_name = "chat_%s" % self.room_name

    await self.channel_layer.group_add(
      self.room_group_name,
      self.channel_name,
    )
    await self.accept()

  async def disconnect(self, close_code):
    print("close_code: ", close_code)
    await self.channel_layer.group_discard(
      self.room_group_name,
      self.channel_name
    )

  async def receive(self, text_data=None, bytes_data=None):
    text_data_json = json.loads(text_data)
    message = text_data_json["message"]
    print("receive_message：", message)
    await self.channel_layer.group_send(
      self.room_group_name,
      {
        "type": "chat_message",
        "message": message
      }
    )

  async def chat_message(self, event):
    receive_message = event["message"]
    response_message = "You message is :" + receive_message
    await self.send(text_data=json.dumps({
      "message": response_message
    }))


class PushMessage(WebsocketConsumer):

  def connect(self):
    self.room_group_name = self.scope["url_route"]["kwargs"]["room_name"]
    async_to_sync(self.channel_layer.group_add)(
      self.room_group_name,
      self.channel_name
    )
    self.accept()

  def disconnect(self, code):
    async_to_sync(self.channel_layer.group_discard)(
      self.room_group_name,
      self.channel_name
    )

  def push_message(self, event):
    """
    主動推送
    :param event:
    :return:
    """
    print(event, type(event))
    while True:
      time.sleep(2)
      msg = time.strftime("%Y-%m-%d %H:%M:%S") + "--- room_name: %s" % event["room_name"]
      self.send(text_data=json.dumps(
        {"message": msg}
      ))

7.為項目添加websocket的路由配置

在chat目錄下創(chuàng)建一個名為的文件routing.py

# mysite/chat/routing.py

from django.urls import re_path, path
from . import consumers

websocket_urlpatterns = [
  re_path(r"ws/chat/(?P<room_name>\w+)/$", consumers.ChatConsumer),
  path("ws/push/<room_name>", consumers.PushMessage),
]

8.配置websocket根路由

與setting同級目錄新建ws根路由文件 routing.py

from channels.routing import ProtocolTypeRouter, URLRouter
from channels.auth import AuthMiddlewareStack
import chat.routing

application = ProtocolTypeRouter({
  "websocket": AuthMiddlewareStack(
    URLRouter(
      chat.routing.websocket_urlpatterns
    )
  ),
})

9.最終的文件關系如下圖

10.啟動服務

python3 manage.py runserver 10.0.6.2:80

注意看，這和django是不一樣的

還有另一種更穩(wěn)健的啟動方式

和setting同級新增文件 asgi.py

import os
import django
from channels.routing import get_default_application

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "mysite.settings")
django.setup()
application = get_default_application()

啟動方式為：

daphne -b 10.0.6.2 -p 80 mysite.asgi:application

daphne 在安裝channel時已經自動安裝好了

參考：

　　https://channels.readthedocs.io/en/latest/tutorial/index.html

　　https://blog.ernest.me/post/asgi-demonstration-realtime-blogging

到此這篇關于Django Channel實時推送與聊天的示例代碼的文章就介紹到這了,更多相關Django Channel實時推送與聊天內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

相關文章

  • 全面了解Python的getattr(),setattr(),delattr(),hasattr()

    全面了解Python的getattr(),setattr(),delattr(),hasattr()

    下面小編就為大家?guī)硪黄媪私釶ython的getattr(),setattr(),delattr(),hasattr()。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2016-06-06
  • python提取包含關鍵字的整行數(shù)據(jù)方法

    python提取包含關鍵字的整行數(shù)據(jù)方法

    今天小編就為大家分享一篇python提取包含關鍵字的整行數(shù)據(jù)方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
    2018-12-12
  • 如何用Python制作微信好友個性簽名詞云圖

    如何用Python制作微信好友個性簽名詞云圖

    這篇文章主要介紹了如何用Python制作微信好友個性簽名詞云圖,上次查看了微信好友的位置信息，想了想，還是不過癮，于是就琢磨起了把微信好友的個性簽名拿到，然后分詞，接著分析詞頻，最后弄出詞云圖來,需要的朋友可以參考下
    2019-06-06
  • Python數(shù)值方法及數(shù)據(jù)可視化

    Python數(shù)值方法及數(shù)據(jù)可視化

    這篇文章主要介紹了Python數(shù)值方法及數(shù)據(jù)可視化，文章圍繞主題展開詳細的內容介紹，具有一定的參考價值，需要的小伙伴可以參考一下
    2022-09-09
  • 基于PyQt5制作一個截圖翻譯工具

    基于PyQt5制作一個截圖翻譯工具

    這篇文章主要為大家介紹了如何利用PyQt5制作一個簡單的截圖翻譯工具，具有截圖功能、翻譯功能和文字識別OCR，需要的可以參考一下
    2022-05-05
  • python實現(xiàn)二維碼掃碼自動登錄淘寶

    python實現(xiàn)二維碼掃碼自動登錄淘寶

    最近做項目，需要用到自動登錄淘寶，正好在學習python,整網絡爬蟲,所以就嘗試著寫一個腳本,自動解決。有相同需求的小伙伴可以參考下
    2016-12-12
  • python_mask_array的用法

    python_mask_array的用法

    今天小編就為大家分享一篇python_mask_array的用法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-02-02
  • windows 下python+numpy安裝實用教程

    windows 下python+numpy安裝實用教程

    這篇文章主要介紹了windows 下python+numpy安裝實用教程，具有一定借鑒價值，需要的朋友可以參考下。
    2017-12-12
  • Python中Django 后臺自定義表單控件

    Python中Django 后臺自定義表單控件

    本篇文章主要介紹了Python中Django 后臺自定義表單控件，其實 django 已經為我們提供了一些可用的表單控件，比如：多選框、單選按鈕等，有興趣的開業(yè)了解一下。
    2017-03-03
  • Python?turtle.right與turtle.setheading的區(qū)別講述

    Python?turtle.right與turtle.setheading的區(qū)別講述

    這篇文章主要介紹了Python?turtle.right與turtle.setheading的區(qū)別,本文以turtle.right為例給大家詳細介紹，需要的朋友可以參考下
    2022-03-03

最新評論