websocket_urlpatterns = [
 url(r'^ws/chat/(?P<group_name>[^/]+)/$', consumers.ChatConsumer),
 url(r'^push/(?P<username>[0-9a-z]+)/$', consumers.PushConsumer),
]

class ChatConsumer(AsyncJsonWebsocketConsumer):
 chats = dict()
 async def connect(self):
 self.group_name = self.scope['url_route']['kwargs']['group_name']
 await self.channel_layer.group_add(self.group_name, self.channel_name)
 # 將用戶(hù)添加至聊天組信息chats中
 try:
  ChatConsumer.chats[self.group_name].add(self)
 except:
  ChatConsumer.chats[self.group_name] = set([self])
 #print(ChatConsumer.chats)
 # 創(chuàng)建連接時(shí)調(diào)用
 await self.accept()
 async def disconnect(self, close_code):
 # 連接關(guān)閉時(shí)調(diào)用
 # 將關(guān)閉的連接從群組中移除
 await self.channel_layer.group_discard(self.group_name, self.channel_name)
 # 將該客戶(hù)端移除聊天組連接信息
 ChatConsumer.chats[self.group_name].remove(self)
 await self.close()

 async def receive_json(self, message, **kwargs):
 # 收到信息時(shí)調(diào)用
 to_user = message.get('to_user')
 # 信息發(fā)送
 length = len(ChatConsumer.chats[self.group_name])
 if length == 2:
  await self.channel_layer.group_send(
  self.group_name,
  {
   "type": "chat.message",
   "message": message.get('message'),
  },
  )
 else:
  await self.channel_layer.group_send(
  to_user,
  {
   "type": "push.message",
   "event": {'message': message.get('message'), 'group': self.group_name}
  },
  )
 async def chat_message(self, event):
 # Handles the "chat.message" event when it's sent to us.
 await self.send_json({
  "message": event["message"],
 })
# 推送consumer
class PushConsumer(AsyncWebsocketConsumer):
 async def connect(self):
 self.group_name = self.scope['url_route']['kwargs']['username']
 await self.channel_layer.group_add(
  self.group_name,
  self.channel_name
 )
 await self.accept()
 async def disconnect(self, close_code):
 await self.channel_layer.group_discard(
  self.group_name,
  self.channel_name
 )
 # print(PushConsumer.chats)
 async def push_message(self, event):
 print(event)
 await self.send(text_data=json.dumps({
  "event": event['event']
 }))

<script>
 export default {
 name : 'test',
 data() {
 return {
 websock: null,
 }
 },
 created() {
 this.initWebSocket();
 },
 destroyed() {
 this.websock.close() //離開(kāi)路由之后斷開(kāi)websocket連接
 },
 methods: {
 initWebSocket(){ //初始化weosocket
 const wsuri = "ws://127.0.0.1:8080";
 this.websock = new WebSocket(wsuri);
 this.websock.onmessage = this.websocketonmessage;
 this.websock.onopen = this.websocketonopen;
 this.websock.onerror = this.websocketonerror;
 this.websock.onclose = this.websocketclose;
 },
 websocketonopen(){ //連接建立之后執(zhí)行send方法發(fā)送數(shù)據(jù)
 let actions = {"test":"12345"};
 this.websocketsend(JSON.stringify(actions));
 },
 websocketonerror(){//連接建立失敗重連
 this.initWebSocket();
 },
 websocketonmessage(e){ //數(shù)據(jù)接收
 const redata = JSON.parse(e.data);
 },
 websocketsend(Data){//數(shù)據(jù)發(fā)送
 this.websock.send(Data);
 },
 websocketclose(e){ //關(guān)閉
 console.log('斷開(kāi)連接',e);
 },
 },
 }
</script>