9

我正在关注本教程：最后，实时 Django 来了：开始使用 Django 频道。

我想通过使用 Django User 对象而不是handle变量来扩展应用程序。但是如何从ws_recieve(message)函数中接收到的 WebSocket 数据包中获取当前用户？

我注意到来自网络套接字数据包csrftoken的前十位数字都sessionid与正常的 HTTP 请求相匹配。我可以使用此信息获取当前用户吗？

作为参考，收到的数据包如下所示：

{'channel': <channels.channel.Channel object at 0x110ea3a20>,
 'channel_layer': <channels.asgi.ChannelLayerWrapper object at 0x110c399e8>,
 'channel_session': <django.contrib.sessions.backends.db.SessionStore object at 0x110d52cc0>,
 'content': {'client': ['127.0.0.1', 52472],
             'headers': [[b'connection', b'Upgrade'],
                         [b'origin', b'http://0.0.0.0:8000'],
                         [b'cookie',
                          b'csrftoken=EQLI0lx4SGCpyTWTJrT9UTe1mZV5cbNPpevmVu'
                          b'STjySlk9ZJvxzHj9XFsJPgWCWq; sessionid=kgi57butc3'
                          b'zckszpuqphn0egqh22wqaj'],
                         [b'cache-control', b'no-cache'],
                         [b'sec-websocket-version', b'13'],
                         [b'sec-websocket-extensions',
                          b'x-webkit-deflate-frame'],
                         [b'host', b'0.0.0.0:8000'],
                         [b'upgrade', b'websocket'],
                         [b'sec-websocket-key', b'y2Lmb+Ej+lMYN+BVrSXpXQ=='],
                         [b'user-agent',
                          b'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_11_6) '
                          b'AppleWebKit/602.1.50 (KHTML, like Gecko) Version'
                          b'/10.0 Safari/602.1.50'],
                         [b'pragma', b'no-cache']],
             'order': 0,
             'path': '/chat-message/',
             'query_string': '',
             'reply_channel': 'websocket.send!UZaOWhupBefN',
             'server': ['127.0.0.1', 8000]},
 'reply_channel': <channels.channel.Channel object at 0x110ea3a90>}
4

2 回答 2

8

通过文档在 2018 年更新了答案：

要访问用户，只需在您的消费者代码中使用 self.scope["user"] ：

class ChatConsumer(WebsocketConsumer):

    def connect(self, event):
        self.user = self.scope["user"]

    def receive(self, event):
        username_str = None
        username = self.scope["user"]
        if(username.is_authenticated()):
            username_str = username.username
            print(type(username_str))
            #pdb.set_trace() # optional debugging
于 2018-02-25T15:05:45.283 回答
5

注意：这个问题是特定于Channels 1.x会话Django系统的，如果您在这里Channels 2.x，请阅读下面链接中的文档，他们非常清楚如何做到这一点，Channels 1.x文档让某些人感到困惑（包括我），这就是为什么提出这个问题和其他问题的原因，Channels 2.x文档对如何实现这一点非常清楚：
https ://channels.readthedocs.io/en/latest/topics/authentication.html#django-authentication

频道 1.x：

您可以通过更改装饰器以匹配文档来访问您的 auser和http_session属性：messageconsumers.py

您可以使用 - 访问用户的正常 Django 会话，http_session decorator这为您提供了一个message.http_session行为类似于request.session. 您可以更进一步并使用http_session_user它将提供message.user属性以及会话属性。

因此consumers.py示例中的文件应变为以下内容：

from channels.auth import http_session_user, channel_session_user, channel_session_user_from_http  

@channel_session_user_from_http  
def ws_connect(message):  
    ...  
    ...


@channel_session_user  
def ws_receive(message):  
    # You can check for the user attr like this  
    log.debug('%s', message.user)  
    ...  
    ...  


@channel_session_user  
def ws_disconnect(message):  
    ...  
    ...

注意装饰器的变化。
另外，我建议您不要在该示例上构建任何内容

有关更多详细信息，请参阅：https ://channels.readthedocs.io/en/1.x/getting-started.html#authentication

于 2016-10-12T19:40:41.460 回答