djnago channels 实时在线用户

    INSTALLED_APPS = ['django.contrib.admin','django.contrib.auth','django.contrib.contenttypes','django.contrib.sessions','django.contrib.messages','django.contrib.staticfiles','channels','example',]

CHANNEL_LAYERS = {
      'default': {
      'BACKEND': 'asgi_redis.RedisChannelLayer','CONFIG': {
      'hosts': [('localhost', 6379)],},'ROUTING': 'example_channels.routing.channel_routing',}
}

from channels import Groupdef ws_connect(message):Group('users').add(message.reply_channel)def ws_disconnect(message):Group('users').discard(message.reply_channel)

from channels.routing import route
from example.consumers import ws_connect, ws_disconnectchannel_routing = [route('websocket.connect', ws_connect),route('websocket.disconnect', ws_disconnect),
]

from django.shortcuts import renderdef user_list(request):return render(request, 'example/user_list.html')

from django.conf.urls import url
from example.views import user_listurlpatterns = [url(r'^$', user_list, name='user_list'),
]

from django.conf.urls import include, url
from django.contrib import adminurlpatterns = [url(r'^admin/', admin.site.urls),url(r'^', include('example.urls', namespace='example')),
]

from django.contrib.auth import login, logout
from django.contrib.auth.forms import AuthenticationForm
from django.core.urlresolvers import reverse
from django.shortcuts import render, redirectdef user_list(request):return render(request, 'example/user_list.html')def log_in(request):form = AuthenticationForm()if request.method == 'POST':form = AuthenticationForm(data=request.POST)if form.is_valid():login(request, form.get_user())return redirect(reverse('example:user_list'))else:print(form.errors)return render(request, 'example/log_in.html', {
      'form': form})def log_out(request):logout(request)return redirect(reverse('example:log_in'))

from django.conf.urls import url
from example.views import log_in, log_out, user_listurlpatterns = [url(r'^log_in/$', log_in, name='log_in'),url(r'^log_out/$', log_out, name='log_out'),url(r'^$', user_list, name='user_list')
]

def sign_up(request):form = UserCreationForm()if request.method == 'POST':form = UserCreationForm(data=request.POST)if form.is_valid():form.save()return redirect(reverse('example:log_in'))else:print(form.errors)return render(request, 'example/sign_up.html', {
      'form': form})

from django.contrib.auth.forms import AuthenticationForm, UserCreationForm

from django.conf.urls import url
from example.views import log_in, log_out, sign_up, user_listurlpatterns = [url(r'^log_in/$', log_in, name='log_in'),url(r'^log_out/$', log_out, name='log_out'),url(r'^sign_up/$', sign_up, name='sign_up'),url(r'^$', user_list, name='user_list')
]

import json
from channels import Group
from channels.auth import channel_session_user, channel_session_user_from_http@channel_session_user_from_http
def ws_connect(message):Group('users').add(message.reply_channel)Group('users').send({
      'text': json.dumps({
      'username': message.user.username,'is_logged_in': True})})@channel_session_user
def ws_disconnect(message):Group('users').send({
      'text': json.dumps({
      'username': message.user.username,'is_logged_in': False})})Group('users').discard(message.reply_channel)

from django.conf import settings
from django.db import modelsclass LoggedInUser(models.Model):user = models.OneToOneField(settings.AUTH_USER_MODEL, related_name='logged_in_user')

from django.contrib.auth import get_user_model, login, logout
from django.contrib.auth.decorators import login_required
from django.contrib.auth.forms import AuthenticationForm, UserCreationForm
from django.core.urlresolvers import reverse
from django.shortcuts import render, redirectUser = get_user_model()@login_required(login_url='/log_in/')
def user_list(request):"""NOTE: This is fine for demonstration purposes, but this should berefactored before we deploy this app to production.Imagine how 100,000 users logging in and out of our app would affectthe performance of this code!"""users = User.objects.select_related('logged_in_user')for user in users:user.status = 'Online' if hasattr(user, 'logged_in_user') else 'Offline'return render(request, 'example/user_list.html', {
      'users': users})def log_in(request):form = AuthenticationForm()if request.method == 'POST':form = AuthenticationForm(data=request.POST)if form.is_valid():login(request, form.get_user())return redirect(reverse('example:user_list'))else:print(form.errors)return render(request, 'example/log_in.html', {
      'form': form})@login_required(login_url='/log_in/')
def log_out(request):logout(request)return redirect(reverse('example:log_in'))def sign_up(request):form = UserCreationForm()if request.method == 'POST':form = UserCreationForm(data=request.POST)if form.is_valid():form.save()return redirect(reverse('example:log_in'))else:print(form.errors)return render(request, 'example/sign_up.html', {
      'form': form})

from django.contrib.auth import get_user_model, login, logout
from django.contrib.auth.decorators import login_required

from django.contrib.auth import user_logged_in, user_logged_out
from django.dispatch import receiver
from example.models import LoggedInUser@receiver(user_logged_in)
def on_user_login(sender, **kwargs):LoggedInUser.objects.get_or_create(user=kwargs.get('user'))@receiver(user_logged_out)
def on_user_logout(sender, **kwargs):LoggedInUser.objects.filter(user=kwargs.get('user')).delete()

from django.apps import AppConfigclass ExampleConfig(AppConfig):name = 'example'def ready(self):import example.signals

default_app_config = 'example.apps.ExampleConfig'