Django Channels Group/channel_session 是如何工作的?
How does Django Channels Group/channel_session work?
Group 和 channel_session 似乎可以跨多个消息会话和消费者持续存在。 Channels 如何做到这一点?
@channel_session_user_from_http
def ws_connect(message):
# Add them to the right group
message.channel_session['room'] = 'room name'
Group("chat-%s" % message.user.username[0]).add(message.reply_channel)
@channel_session_user
def ws_disconnect(message):
if 'room' in message.channel_session:
print('room====', message.channel_session['room'])
Group("chat-%s" % message.user.username[0]).discard(message.reply_channel)
我想设置一个长期存在的对象,就像每个消费者都可以访问的全局对象。
您可以使用 @channel_session
(或 @channel_session_user
)装饰器来实现此目的。确保您的对象是可序列化的,然后像这样将它添加到用户的频道会话中:
@channel_session_user_from_http
def ws_connect(message):
message.session.myobject = {'test': True}
@channel_session_user
def ws_connect(message):
print(message.session.myobject) # should output {'test': True}
或者,只需使用您的 DB 或 Redis 来持久化事物,就像您通常在 Django 中所做的那样:
@channel_session_user_from_http
def ws_connect(message):
redis_conn.set('my-persisted-key', "{'test': True}")
@channel_session_user
def ws_connect(message):
print(redis_conn.get('my-persisted-key')) # should output "{'test': True}"
Group 和 channel_session 似乎可以跨多个消息会话和消费者持续存在。 Channels 如何做到这一点?
@channel_session_user_from_http
def ws_connect(message):
# Add them to the right group
message.channel_session['room'] = 'room name'
Group("chat-%s" % message.user.username[0]).add(message.reply_channel)
@channel_session_user
def ws_disconnect(message):
if 'room' in message.channel_session:
print('room====', message.channel_session['room'])
Group("chat-%s" % message.user.username[0]).discard(message.reply_channel)
我想设置一个长期存在的对象,就像每个消费者都可以访问的全局对象。
您可以使用 @channel_session
(或 @channel_session_user
)装饰器来实现此目的。确保您的对象是可序列化的,然后像这样将它添加到用户的频道会话中:
@channel_session_user_from_http
def ws_connect(message):
message.session.myobject = {'test': True}
@channel_session_user
def ws_connect(message):
print(message.session.myobject) # should output {'test': True}
或者,只需使用您的 DB 或 Redis 来持久化事物,就像您通常在 Django 中所做的那样:
@channel_session_user_from_http
def ws_connect(message):
redis_conn.set('my-persisted-key', "{'test': True}")
@channel_session_user
def ws_connect(message):
print(redis_conn.get('my-persisted-key')) # should output "{'test': True}"