Thanks for your information! I just did all the configurations again following this post( http://masnun.rocks/2016/11/02/deploying-django-channels-using-daphne/). And I think it is extremely useful for me and my website is now running. And you are right, I don't need both uwsgi and daphne. Only daphne is sufficient.
On Tue, Jun 26, 2018 at 10:47 PM, 赖信桃 <[email protected]> wrote: > Again, websocket is different from HTTP, both are built on TCP. So Nginx > preoxy_pass is for HTTP forward, so you can not use it for HTTP for > tanspond. > > Maybe remove location /ws would work. Just use daphne as ws server. > > Spend some time reading the docs: https://channels. > readthedocs.io/en/latest/deploying.html > > <[email protected]>于2018年6月27日周三 上午10:09写道： > >> I think I must have messed the ports up. Here is a summary: >> redis: 6379 >> daphne: 8000 (if running daphne with this command: daphne >> experiment_platform.asgi:channel_layer --port 8000 --bind 0.0.0.0 -v2 &) >> ws (see *nginx.conf*): 8000 [I guess the error message in the browser >> console "WebSocket connection to 'ws://xxxxxxxx/room1/' failed: Error >> during WebSocket handshake: Unexpected response code: 200" means that I >> did make a mistake in this nginx.conf, right?] >> >> Thanks. >> >> It occurs to me that posting the *nginx.conf* might be helpful: >> upstream django { >> server unix://myproject/experiment_platform.sock; >> } >> server{ >> listen 80; >> server_name myproject; >> charset utf-8; >> client_max_body_size 20M; >> >> location /static { >> alias myproject/static; >> } >> >> location / { >> include myproject/uwsgi_params; >> uwsgi_pass unix://myproject/experiment_platform.sock; >> } >> location /ws { >> proxy_pass http://0.0.0.0:8000; >> proxy_http_version 1.1; >> proxy_set_header Upgrade $http_upgrade; >> proxy_set_header Connection "upgrade"; >> proxy_redirect off; >> proxy_set_header Host $host; >> proxy_set_header X-Real-IP $remote_addr; >> proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for; >> proxy_set_header X-Forwarded-Host $server_name; >> } >> } >> >> >> On Sunday, June 24, 2018 at 9:29:25 PM UTC-4, [email protected] >> wrote: >>> >>> Hi I am deploying a website with a live discussion feature. But people >>> cannot send nor receive messages on this discussion page. In the console it >>> shows: "WebSocket connection to 'ws://xxxxxxxx/room1/' failed: Error during >>> WebSocket handshake: Unexpected response code: 200" >>> >>> I don't know where the websocket bug (or bugs from other sources) is. I >>> am attaching some information that I think might be helpful. Could someone >>> help? If you think I miss some information please let me know and I will >>> post! Thanks!!!!!! >>> >>> >>> *Server: ubuntu 14.03* >>> *nginx* >>> *commands to start the website:* >>> uwsgi --socket experiment_platform.sock --module >>> experiment_platform.wsgi --chmod-socket=666 --processes=6 >>> daphne experiment_platform.asgi:channel_layer --port 8000 --bind >>> 0.0.0.0 -v2 & >>> python manage.py runworker -v2 & >>> [redis server is also activated.] >>> >>> *log information of uwsgi (it keeps updating similar things after the >>> discussion page is opened, whether or not I am trying to send messages to >>> test or not. I think it's trying to establish the websocket connection.)* >>> [pid: 29881|app: 0|req: 33/143] 100.15.133.125 () {52 vars in 1094 >>> bytes} [Mon Jun 25 01:23:59 2018] GET /forum/room1/ => generated 4792 bytes >>> in 55 msecs (HTTP/1.1 200) 3 headers in 102 bytes (1 switches on core 0) >>> [pid: 29885|app: 0|req: 29/144] 100.15.133.125 () {52 vars in 1094 bytes} >>> [Mon Jun 25 01:24:29 2018] GET /forum/room1/ => generated 4792 bytes in 57 >>> msecs (HTTP/1.1 200) 3 headers in 102 bytes (1 switches on core 0) >>> >>> *log information of runworker (it doesn't update after opening the >>> discussion page.)* >>> 2018-06-25 00:22:42,827 - INFO - runworker - Running worker against >>> channel layer default (asgi_redis.core.RedisChannelLayer) >>> 2018-06-25 00:22:42,828 - INFO - worker - Listening on channels >>> http.request, websocket.connect, websocket.disconnect, websocket.receive >>> >>> *forum/consumers.py* >>> import re import json import logging from channels import Group from >>> channels.sessions import channel_session from .models import Discussion, >>> Statement, Vote from chat.models import Room from experiment.models import >>> ExpUser,TaskUser, Crowd from channels.auth import http_session, >>> http_session_user, channel_session_user, channel_session_user_from_http log >>> = logging.getLogger(__name__) @channel_session_user_from_http >>> @channel_session def ws_connect(message): # Extract the discussion-label >>> from the message. This expects message.path to be of the # form >>> forum/{label}/, and finds a Discussion if the message path is applicable, # >>> and if the Discussion exists. Otherwise, bails (meaning this is a some >>> othersort # of websocket). So, this is effectively a version of >>> _get_object_or_404. try: log.debug('In the try block of ws_connect')#added >>> by me prefix, label = message['path'].decode('ascii').strip('/').split('/') >>> if prefix != 'forum': log.debug('invalid ws path=%s', message['path']) >>> return if prefix == 'forum': discussion = >>> Discussion.objects.get(label=label) >>> except ValueError: log.debug('invalid ws path=%s', message['path']) return >>> except Discussion.DoesNotExist: log.debug('ws discussion does not exist >>> label=%s', label) return if prefix == 'forum': log.debug('forum connect >>> discussion=%s client=%s:%s', discussion.label, message['client'][0], >>> message['client'][1]) t = >>> TaskUser(user=message.user,crowd=label,time_type='start') >>> t.save() # Need to be explicit about the channel layer so that testability >>> works # This may be a FIXME? Group('forum-'+label, >>> channel_layer=message.channel_layer).add(message.reply_channel) >>> message.channel_session['discussion'] = discussion.label >>> message.reply_channel.send({ 'accept': True }) @channel_session_user >>> @channel_session def ws_receive(message): if 'discussion' in >>> message.channel_session: # Look up the room from the channel session, >>> bailing if it doesn't exist try: label = >>> message.channel_session['discussion'] >>> discussion = Discussion.objects.get(label=label) except KeyError: >>> log.debug('no discussion-forum in channel_session') return except >>> Discussion.DoesNotExist: log.debug('recieved message, buy discussion does >>> not exist label=%s', label) return try: expuser = >>> ExpUser.objects.get(user=message.user) >>> except KeyError: log.debug('problem getting username') return except >>> ExpUser.DoesNotExist: log.debug('recieved message, but user does not exist >>> label=%s', label) return # Parse out a chat message from the content text, >>> bailing if it doesn't # conform to the expected message format. try: data = >>> json.loads(message['text']) except ValueError: log.debug("ws message isn't >>> json text=%s", text) return if data: if data['msg_type'] == 'vote': >>> log.debug('vote handle=%s value=%s', expuser.nickname, data['value']) >>> statement = Statement.objects.get(id=data['id']) m0 = >>> statement.as_dict() log.debug('vote id=%s, score=%s, ups=%s, downs=%s', >>> statement.id,statement.score,statement.ups,statement.downs) ndata = >>> {'user':message.user,'handle':expuser.nickname,'statement': >>> statement,'value':data['value']} vote = None votes = >>> Vote.objects.filter(user=message.user,statement=statement) if not >>> votes: vote = Vote.objects.create(**ndata) else: vote = votes[0] vote.value >>> = data['value'] vote.save() m = statement.update_score() m['msg_type'] = >>> 'vote' log.debug('vote score=%s', m['score']) # See above for the note >>> about Group Group('forum-'+label, >>> channel_layer=message.channel_layer).send({'text': >>> json.dumps(m)}) else: log.debug('chat message handle=%s message=%s', >>> expuser.nickname, data['message']) parent = None >>> log.debug(data['parentid']) if data['parentid']!=0: parent = >>> discussion.statements.get(id=data['parentid']) log.debug(parent.id) >>> data['parent'] = parent data.pop("msg_type",None) data['user'] = >>> message.user data['handle'] = expuser.nickname data['crowd_label'] = >>> discussion.crowd_label data['task_label'] = discussion.task_label m = >>> discussion.statements.create(**data) # NEED TO FIX HERE # See above for >>> the note about Group Group('forum-'+label, >>> channel_layer=message.channel_layer).send({'text': >>> json.dumps(m.as_dict())}) @channel_session_user @channel_session def >>> ws_disconnect(message): if 'discussion' in message.channel_session: try: >>> label = message.channel_session['discussion'] discussion = >>> Discussion.objects.get(label=label) t = >>> TaskUser(user=message.user,crowd=label,time_type='end') >>> t.save() Group('forum-'+label, channel_layer=message.channel_ >>> layer).discard(message.reply_channel) except (KeyError, >>> Discussion.DoesNotExist): pass >>> >>> *settings.py* >>> CHANNEL_LAYERS = { "default": { "BACKEND": "asgi_redis.RedisChannelLayer", >>> "CONFIG": { "hosts": [os.environ.get('REDISTOGO_URL', >>> 'redis://localhost:6379')], }, "ROUTING": >>> "experiment_platform.routing.channel_routing", >>> #"ROUTING": "waiting_room.routing.channel_routing", }, } CACHES = { >>> "default": { "BACKEND": "django_redis.cache.RedisCache", "LOCATION": >>> "redis://localhost:6379/1", "OPTIONS": { "CLIENT_CLASS": >>> "django_redis.client.DefaultClient", } } } >>> >> -- >> You received this message because you are subscribed to the Google Groups >> "Django users" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to [email protected]. >> To post to this group, send email to [email protected]. >> Visit this group at https://groups.google.com/group/django-users. >> To view this discussion on the web visit https://groups.google.com/d/ >> msgid/django-users/954662a1-d71a-4010-8e30-cae18d564367% >> 40googlegroups.com >> <https://groups.google.com/d/msgid/django-users/954662a1-d71a-4010-8e30-cae18d564367%40googlegroups.com?utm_medium=email&utm_source=footer> >> . >> For more options, visit https://groups.google.com/d/optout. >> > -- > You received this message because you are subscribed to a topic in the > Google Groups "Django users" group. > To unsubscribe from this topic, visit https://groups.google.com/d/ > topic/django-users/2ZOQY_rj6KM/unsubscribe. > To unsubscribe from this group and all its topics, send an email to > [email protected]. > To post to this group, send email to [email protected]. > Visit this group at https://groups.google.com/group/django-users. > To view this discussion on the web visit https://groups.google.com/d/ > msgid/django-users/CAMv51WRQ%3D9%3DLSSt2pGAN-% > 3DMoENKtf7Nc8USpnxLym5wkGtf4qw%40mail.gmail.com > <https://groups.google.com/d/msgid/django-users/CAMv51WRQ%3D9%3DLSSt2pGAN-%3DMoENKtf7Nc8USpnxLym5wkGtf4qw%40mail.gmail.com?utm_medium=email&utm_source=footer> > . > > For more options, visit https://groups.google.com/d/optout. > -- You received this message because you are subscribed to the Google Groups "Django users" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/django-users. To view this discussion on the web visit https://groups.google.com/d/msgid/django-users/CAKVPN7B0LxJGw6f34BFnuiDQPig2hZRbsMetX9%3DYkS3fjx6XUg%40mail.gmail.com. For more options, visit https://groups.google.com/d/optout.
