聊天应用:使用Django和sockjs-tornado和redis

Question

我正在尝试编写聊天应用程序，这里有一些设计思路:
Django为主站服务。
Sockjs-tornado服务聊天和他们之间，我想设置redis。

当sockjs-tornado在聊天中接收到消息时，它会处理并发送给其他连接的客户端，并将其保存在redis中，以便Django可以将此消息保存在持久数据库中。我知道我应该使用redis的pubsub功能。我知道如何在龙卷风(brukva库)中设置它，但我如何在django中订阅redis的频道?所以我可以在django中接收消息并将其保存到数据库?你有什么主意吗?

Answer 1

我不知道sockjs是如何使用的，但是这个例子说明了如何在django模型中保存
#在龙卷风

import brukva  
import tornado.web  
import tornado.websocket
c = brukva.Client()  
c.connect()
class MessagesHandler(tornado.websoket.WebsocketHandler):
    def open(self):
        #....
    def handle_request(self, response):
        pass
    def on_message(self, message):
        #....
        c.publish(self.channel, json.dumps({
            "sender": self.sender_name,
            "text": message,
        }))
        http_client = tornado.httpclient.AsyncHTTPClient()
        request = tornado.httpclient.HTTPRequest(
              '/to/django_project/url/chat_save_base/',
                method="POST",
                body=urllib.urlencode({
                "message": message.encode("utf-8"),
                "sender": self.sender.name,
            })
        http_client.fetch(request, self.handle_request)  

#在django_url

url(r'/to/django_project/url/chat_save_base/','app.my_view')

# my_view

from django.views.decorators.csrf import csrf_exempt  
from messages.models import Message
@csrf_exempt
def my_view(request):  
    message_text = request.POST.get("message")  
    sender = User.objects.get(id=request.POST.get("sender_id"))  
    message = Message()
    message.text = message_text
    message.sender_id = sender_id    
    message.save()

附加信息来源:http://habrahabr.ru/post/160123/