django-admin startprobject ChannelsReady

# routing.py
from channels.routing import ProtocolTypeRouter

application = ProtocolTypeRouter({
 # 暫時(shí)為空
})

INSTALLED_APPS = [
 'channels'
]

ASGI_APPLICATION = "ChannelsReady.routing.application"

python manage.py startapp chats

INSTALLED_APPS = [
 'chats',
 'channels'
]

from channels.generic.websocket import WebsocketConsumer
# 這里除了 WebsocketConsumer 之外還有
# JsonWebsocketConsumer
# AsyncWebsocketConsumer
# AsyncJsonWebsocketConsumer
# WebsocketConsumer 與 JsonWebsocketConsumer 就是多了一個(gè)可以自動(dòng)處理JSON的方法
# AsyncWebsocketConsumer 與 AsyncJsonWebsocketConsumer 也是多了一個(gè)JSON的方法
# AsyncWebsocketConsumer 與 WebsocketConsumer 才是重點(diǎn)
# 看名稱似乎理解并不難 Async 無(wú)非就是異步帶有 async / await
# 是的理解并沒(méi)有錯(cuò),但對(duì)與我們來(lái)說(shuō)他們唯一不一樣的地方,可能就是名字的長(zhǎng)短了,用法是一模一樣的
# 最夸張的是,基類是同一個(gè),而且這個(gè)基類的方法也是Async異步的

class ChatService(WebsocketConsumer):
 # 當(dāng)Websocket創(chuàng)建連接時(shí)
 def connect(self):
 pass
 
 # 當(dāng)Websocket接收到消息時(shí)
 def receive(self, text_data=None, bytes_data=None):
 pass
 
 # 當(dāng)Websocket發(fā)生斷開(kāi)連接時(shí)
 def disconnect(self, code):
 pass

from django.urls import path
from chats.chatService import ChatService
websocket_url = [
 path("ws/",ChatService)
]

from channels.routing import ProtocolTypeRouter,URLRouter
from chats.urls import websocket_url

application = ProtocolTypeRouter({
 "websocket":URLRouter(
 websocket_url
 )
})

<template>
 <div>
 <input type="text" v-model="message">
 <p><input type="button" @click="send" value="發(fā)送"></p>
 <p><input type="button" @click="close_socket" value="關(guān)閉"></p>
 </div>
</template>


<script>
export default {
 name:'websocket1',
 data() {
 return {
  message:'',
  testsocket:''
 }
 },
 methods:{
 send(){
  
 // send 發(fā)送信息
 // close 關(guān)閉連接

  this.testsocket.send(this.message)
  this.testsocket.onmessage = (res) => {
  console.log("WS的返回結(jié)果",res.data);  
  }

 },
 close_socket(){
  this.testsocket.close()
 }

 },
 mounted(){
 this.testsocket = new WebSocket("ws://127.0.0.1:8000/ws/") 


 // onopen 定義打開(kāi)時(shí)的函數(shù)
 // onclose 定義關(guān)閉時(shí)的函數(shù)
 // onmessage 定義接收數(shù)據(jù)時(shí)候的函數(shù)
 // this.testsocket.onopen = function(){
 // console.log("開(kāi)始連接socket")
 // },
 // this.testsocket.onclose = function(){
 // console.log("socket連接已經(jīng)關(guān)閉")
 // }
 }
}
</script>

socket_list = []

class ChatService(WebsocketConsumer):
 # 當(dāng)Websocket創(chuàng)建連接時(shí)
 def connect(self):
 self.accept()
 socket_list.append(self)


 # 當(dāng)Websocket接收到消息時(shí)
 def receive(self, text_data=None, bytes_data=None):
 print(text_data) # 打印收到的數(shù)據(jù)
 for ws in socket_list: # 遍歷所有的WebsocketConsumer對(duì)象
 ws.send(text_data) # 對(duì)每一個(gè)WebsocketConsumer對(duì)象發(fā)送數(shù)據(jù)

<template>
 <div>
 <input type="text" v-model="message">
 <input type="text" v-model="user">

 <p><input type="button" @click="send" value="發(fā)送"></p>
 <p><input type="button" @click="close_socket" value="關(guān)閉"></p>
 </div>
</template>


<script>
export default {
 name:'websocket1',
 data() {
 return {
  message:'',
  testsocket:'',
  user:''
 }
 },
 methods:{
 send(){
  
 // send 發(fā)送信息
 // close 關(guān)閉連接
  var data1 = {"message":this.message,"to_user":this.user}
  
  this.testsocket.send(JSON.stringify(data1))
  this.testsocket.onmessage = (res) => {
  console.log("WS的返回結(jié)果",res.data);  
  }

 },
 close_socket(){
  this.testsocket.close()
 },
 generate_uuid: function() {
  var d = new Date().getTime();
  if (window.performance && typeof window.performance.now === "function") {
  d += performance.now(); //use high-precision timer if available
  }
  var uuid = "xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(
  /[xy]/g,
  function(c) {
  var r = (d + Math.random() * 16) % 16 | 0;
  d = Math.floor(d / 16);
  return (c == "x" ? r : (r & 0x3) | 0x8).toString(16);
  }
  );
  return uuid;
 },

 },
 mounted(){
 var username = this.generate_uuid();
 console.log(username)
 this.testsocket = new WebSocket("ws://127.0.0.1:8000/ws/"+ username +"/") 
 console.log(this.testsocket)

 	this.testsocket.onmessage = (res) => {
  console.log("WS的返回結(jié)果",res.data);  
  }
 	
 // onopen 定義打開(kāi)時(shí)的函數(shù)
 // onclose 定義關(guān)閉時(shí)的函數(shù)
 // onmessage 定義接收數(shù)據(jù)時(shí)候的函數(shù)
 // this.testsocket.onopen = function(){
 // console.log("開(kāi)始連接socket")
 // },
 // this.testsocket.onclose = function(){
 // console.log("socket連接已經(jīng)關(guān)閉")
 // }
 }
}
</script>

from channels.generic.websocket import WebsocketConsumer
user_dict ={}
list = []
import json
class ChatService(WebsocketConsumer):
 # 當(dāng)Websocket創(chuàng)建連接時(shí)
 def connect(self):
 self.accept()
 username = self.scope.get("url_route").get("kwargs").get("username")
 user_dict[username] =self
 print(user_dict)

 # list.append(self)


 # 當(dāng)Websocket接收到消息時(shí)
 def receive(self, text_data=None, bytes_data=None):
 data = json.loads(text_data)
 print(data)
 to_user = data.get("to_user")
 message = data.get("message")

 ws = user_dict.get(to_user)
 print(to_user)
 print(message)
 print(ws)
 ws.send(text_data)


 # 當(dāng)Websocket發(fā)生斷開(kāi)連接時(shí)
 def disconnect(self, code):
 pass