websocket断开连接调用失败

c9qzyr3d  于 2021-06-10  发布在  Redis
关注(0)|答案(1)|浏览(488)

我正在跟踪一个turtorial django通道2，我遵循了所有的步骤，我在控制台中有一个失败的连接。我注意到这个问题发生时，我添加通道层设置，当我删除通道层连接成功。如何解决这个问题？
经理

  1. class ThreadManager(models.Manager):
  2. def by_user(self, user):
  3.     qlookup = Q(first=user) | Q(second=user)
  4.     qlookup2 = Q(first=user) & Q(second=user)
  5.     qs = self.get_queryset().filter(qlookup).exclude(qlookup2).distinct()
  6.     return qs
  8. def get_or_new(self, user, other_username): # get_or_create
  9.     username = user.username
  10.     if username == other_username:
  11.         return None
  12.     qlookup1 = Q(first__username=username) & Q(second__username=other_username)
  13.     qlookup2 = Q(first__username=other_username) & Q(second__username=username)
  14.     qs = self.get_queryset().filter(qlookup1 | qlookup2).distinct()
  15.     if qs.count() == 1:
  16.         return qs.first(), False
  17.     elif qs.count() > 1:
  18.         return qs.order_by('timestamp').first(), False
  19.     else:
  20.         Klass = user.__class__
  21.         user2 = Klass.objects.get(username=other_username)
  22.         if user != user2:
  23.             obj = self.model(
  24.                     first=user, 
  25.                     second=user2
  26.                 )
  27.             obj.save()
  28.             return obj, True
  29.         return None, False

型号.py

  1. class Profile(models.Model):
  2.     user = models.OneToOneField(settings.AUTH_USER_MODEL,on_delete=models.CASCADE,blank=True,null=True) 
  3.     profile_pic = models.ImageField(upload_to='ProfilePicture/', default="ProfilePicture/avatar.png", blank=True)
  5. class Thread(models.Model):
  6.     first        = models.ForeignKey(settings.AUTH_USER_MODEL, on_delete=models.CASCADE, related_name='chat_thread_first')
  7.     second       = models.ForeignKey(settings.AUTH_USER_MODEL, on_delete=models.CASCADE, related_name='chat_thread_second')
  8.     updated      = models.DateTimeField(auto_now=True)
  9.     timestamp    = models.DateTimeField(auto_now_add=True)
  11.     objects      = ThreadManager()
  13.     @property
  14.     def room_group_name(self):
  15.         return f'chat_{self.id}'
  17.     def broadcast(self, msg=None):
  18.         if msg is not None:
  19.             broadcast_msg_to_chat(msg, group_name=self.room_group_name, user='admin')
  20.             return True
  21.         return False
  23. class ChatMessage(models.Model):
  24.     thread      = models.ForeignKey(Thread, null=True, blank=True, on_delete=models.SET_NULL)
  25.     user        = models.ForeignKey(settings.AUTH_USER_MODEL, verbose_name='sender', on_delete=models.CASCADE)
  26.     message     = models.TextField()
  27.     timestamp   = models.DateTimeField(auto_now_add=True)

视图.py

  1. class InboxView(LoginRequiredMixin, ListView):
  2.     template_name = 'inbox.html'
  3.     def get_queryset(self):
  4.         return Thread.objects.by_user(self.request.user)
  6. class ThreadView(LoginRequiredMixin, FormMixin, DetailView):
  7.     template_name = 'thread.html'
  8.     form_class = ComposeForm
  9.     success_url = './'
  11.     def get_queryset(self):
  12.         return Thread.objects.by_user(self.request.user)
  14.     def get_object(self):
  15.         other_username  = self.kwargs.get("username")
  16.         obj, created    = Thread.objects.get_or_new(self.request.user, other_username)
  17.         if obj == None:
  18.             raise Http404
  19.         return obj
  21.     def get_context_data(self,**kwargs):
  22.         context = super().get_context_data(**kwargs)
  23.         context['form'] = self.get_form()
  24.         return context
  26.     def post(self, request, *args,**kwargs):
  27.         if not request.user.is_authenticated:
  28.             return HttpResponseForbidden()
  29.         self.object = self.get_object()
  30.         form = self.get_form()
  31.         if form.is_valid():
  32.             return self.form_valid(form)
  33.         else:
  34.             return self.form_invalid(form)
  36.     def form_valid(self, form):
  37.         thread = self.get_object()
  38.         user = self.request.user
  39.         message = form.cleaned_data.get("message")
  40.         ChatMessage.objects.create(user=user, thread=thread, message=message)
  41.         return super().form_valid(form)

网址.py

  1. from django.urls import path
  3. from pixmate.views import (
  4.     InboxView,
  5.     ThreadView,
  6. )
  7. app_name = 'pixmate'
  9. urlpatterns = [
  10.     path("inbox", InboxView.as_view(), name='inbox'),
  11.     path('messages/<username>/', ThreadView.as_view(), name='messages'),
  12. ]

asgi.py公司

  1. import os
  2. import django
  3. from channels.routing import get_default_application
  5. os.environ.setdefault("DJANGO_SETTINGS_MODULE", "pixmateDjango.settings")
  6. django.setup()
  7. application = get_default_application()

消费者.py

  1. import asyncio
  2. import json
  3. from django.contrib.auth import get_user_model
  4. from channels.consumer import AsyncConsumer
  5. from channels.db import database_sync_to_async
  6. from pixmate.models import Thread, ChatMessage
  7. from django.db.models import Q
  9. class ChatConsumer(AsyncConsumer):
  10.     async def websocket_connect(self, event):
  11.         print('connected', event)
  13.         other_user = self.scope['url_route']['kwargs']['username']
  14.         me         = self.scope['user']
  15.         thread_obj = await self.get_thread(me, other_user)
  16.         self.thread_obj = thread_obj
  17.         chat_room = f"thread_{thread_obj.id}"
  18.         self.chat_room = chat_room
  19.         await self.channel_layer.group_add(
  20.             chat_room,
  21.             self.channel_name
  22.         )
  23.         await self.send({
  24.             "type": "websocket.accept"
  25.         })
  27.     async def websocket_receive(self, event):
  28.         # when a message is recieved from the websocket
  29.         print("receive", event)
  30.         front_text = event.get('text', None)
  31.         if front_text is not None:
  32.             loaded_dict_data = json.loads(front_text)
  33.             msg = loaded_dict_data.get('message')
  34.             user = self.scope['user']
  35.             username = 'default'
  36.             if user.is_authenticated:
  37.                 username = user.username
  38.             myResponse = {
  39.                 'message': msg,
  40.                 'username': username
  41.             }
  42.             await self.create_chat_message(user, msg)
  43.             # broadcasts the message event to be sent, the group send layer
  44.             # triggers the chat_message function for all of the group (chat_room)
  45.             await self.channel_layer.group_send(
  46.                 self.chat_room,
  47.                 {
  48.                     "type": "chat_message",
  49.                     "text": json.dumps(myResponse)
  50.                 }
  51.             )
  53.     # chat_method is a custom method name that we made
  54.     async def chat_message(self, event):
  55.         #sends the actual message
  56.         await self.send({
  57.             "type": "websocket.send",
  58.             "text": event['text']
  59.         })
  61.     async def websocket_disconnect(self, event):
  62.         # when the socket disconnects
  63.         print('disconnected', event)
  65.     @database_sync_to_async
  66.     def get_thread(self, user, other_username):
  67.         return Thread.objects.get_or_new(user, other_username)[0]
  69.     @database_sync_to_async
  70.     def create_chat_message(self, me, msg):
  71.         thread_obj = self.thread_obj
  72.         return ChatMessage.objects.create(thread=thread_obj, user=me, message=msg)

路由.py

  1. from django.urls import path
  2. from channels.routing import ProtocolTypeRouter, URLRouter
  3. from channels.auth import AuthMiddlewareStack
  4. from channels.security.websocket import AllowedHostsOriginValidator, OriginValidator
  6. from pixmate.consumers import ChatConsumer
  8. application = ProtocolTypeRouter({
  9.     # Empty for now (http->django views is added by default)
  10.     'websocket': AllowedHostsOriginValidator(
  11.         AuthMiddlewareStack(
  12.             URLRouter(
  13.                 [
  14.                     path('messages/<username>/', ChatConsumer),
  15.                 ]
  16.             )
  17.         )
  18.     )
  19. })

设置.py

  1. ASGI_APPLICATION = "pixmateDjango.routing.application"
  3. CHANNEL_LAYERS = {
  4.     "default": {
  5.         "BACKEND": "channels_redis.core.RedisChannelLayer",
  6.         "CONFIG": {
  7.             "hosts": [("localhost", 6379)],
  8.         },
  9.     },
  10. }

线程.html

  1. <div class="px-4 py-3 chat-box bg-white" id='chat-items' style="height:435px;">
  2.     {% for chat in object.chatmessage_set.all %}
  3.      {% if request.user != chat.user %}
  4.     <!-- Sender Message-->
  5.     <div class="media w-50 mb-3">  
  6.       <img src="{{ chat.user.profile.profile_pic.url }}" id="avatarImg" width="30" height="30" class="rounded-circle mt-1">         
  7.       <div class="media-body ml-2">
  8.         <div class="bg-light rounded py-2 px-3 mb-2">
  9.           <p class="text-small mb-0 text-black">{{ chat.message|emoticons }}</p>
  10.         </div>
  11.         <p class="small text-muted">
  12.         {{ chat.timestamp|date:'M j, Y,  g:i a' }}
  13.         <i class="fa fa-ellipsis-h float-right"></i>
  14.         </p>
  15.       </div>
  16.     </div>
  17.     {% endif %}
  18.     {% endfor %}
  20. <form id='form' method='POST' action="." class="chatbox-form">
  21.     {% csrf_token %}
  22.     {{ form }}
  23.     <input = "submit" value="send">
  24. </form>
  26. <!-- Channels Reconnecting Websocket -->
  27. <script src='https://cdnjs.cloudflare.com/ajax/libs/reconnecting-websocket/1.0.0/reconnecting-websocket.js'></script> 
  29. <script>
  30.   // websocket scripts - client side*
  31.   var loc = window.location
  32.   var formData = $("#form")
  33.   var msgInput = $("#id_message")
  34.   var chatHolder = $('#chat-items')
  35.   var me = $('#myUsername').val()
  37.   var wsStart = 'ws://'
  38.   if (loc.protocol == 'https:') {
  39.     wsStart = 'wss://'
  40.   }
  41.   var endpoint = wsStart + loc.host + loc.pathname
  42.   var socket = new ReconnectingWebSocket(endpoint)
  44.   // below is the message I am receiving
  45.   socket.onmessage = function(e) {
  46.     console.log("message", e)
  47.     var chatDataMsg = JSON.parse(e.data)
  49.     var profile_pic = $('#avatarImg').attr("src");
  50.     console.log(profile_pic);
  52.     //alert(e.data)
  53.    if(chatDataMsg.username == me) {
  54.     chatHolder.append("<div class='media w-50 ml-auto mb-3'>" + "<div class='media-body'>" + "<div class='bg-primary rounded py-2 px-3 mb-2'>" + "<p class='text-small mb-0 text-white'>" + chatDataMsg.message + "</p>" + "</div>" + "<p class='small text-muted'>" + newMonth  +  newDate + "<i class='fa fa-ellipsis-h float-right'></i>" + "</p>" + "</div>" + "</div>")
  55.    }
  56.    else{
  57.     chatHolder.append("<div class='media w-50 mb-3'>" + "<img src=" + profile_pic + " width='30' height='30' class='rounded-circle mt-1'/>" + "<div class='media-body ml-2'>" + "<div class='bg-light rounded py-2 px-3 mb-2'>" + "<p class='text-small mb-0 text-black'>" + chatDataMsg.message + "</p>" + "</div>" + "<p class='small text-muted'>" + newMonth  +  newDate + "<i class='fa fa-ellipsis-h float-right'></i>" + "</p>" + "</div>" + "</div>")
  58.    }
  59.       }
  60.   // below is the message I am sending
  61.   socket.onopen = function(e) {
  62.     console.log("open", e)
  63.     formData.submit(function(event){
  64.         event.preventDefault()
  65.         var msgText = msgInput.val()
  66.         //chatHolder.append("<li>" + msgText + " via " + me + "</li>")
  67.         var finalData = {
  68.         'message': msgText
  69.         }
  70.         socket.send(JSON.stringify(finalData))
  71.         formData[0].reset()
  72.     })
  73.   }
  74.   socket.onerror = function(e) {
  75.     console.log("error", e)
  76.   }
  77.   socket.onclose = function(e) {
  78.     console.log("close", e)
  79.   }
  80. </script>
  82. {% endblock %}
redispythondjangowebsocketdjango-channels

1条答案

按热度按时间
uklbhaso

uklbhaso1#

我找到了解决问题的方法：redis在windows中不支持，所以我安装了memurai，它工作了。

赞(0）分享  回复(0）举报  2021-06-10
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com