我正在尝试使用 django 上的 channel 项目 (http://channels.readthedocs.org/en/latest/index.html)。
虽然在文档上有一个很好的构建基于组的 websocket 应用程序(聊天)的教程,但我找不到与特定于客户端的简单推送机制相关的内容(因此无需使用组)
假设我想构建一个包含各种新闻提供商的提要聚合器,当用户访问主页并等待所有提要被解析时,我想向他发送有关服务器正在解析哪个提要的信息性消息,在他等待的时候。
我现在得到的是: 消费者.py
from channels import Group, Channel
from .views import sort_articles_by_date
from .soup import ProviderParser
from .models import Provider
# Connected to websocket.connect and websocket.keepalive
def ws_add(message):
Group("news_providers_loading").add(message.reply_channel)
def ws_message(message):
providers = Provider.objects.all()
articles = []
for provider in providers:
Group("news_providers_loading").send({'content': str(provider)})
parser = ProviderParser(provider)
articles.extend(parser.parse_articles())
sort_articles_by_date(articles)
# Connected to websocket.disconnect
def ws_disconnect(message):
Group("news_providers_loading").discard(message.reply_channel)
路由.py
channel_routing = {
"websocket.connect": "news_providers.consumers.ws_add",
"websocket.keepalive": "news_providers.consumers.ws_add",
"websocket.receive": "news_providers.consumers.ws_message",
"websocket.disconnect": "news_providers.consumers.ws_disconnect",
}
虽然它工作正常,但我还是忍不住觉得有点矫枉过正(?) 有没有办法只使用 Channel 构造函数而不是 Group?
谢谢:)
最佳答案
更新:
channel 版本 = 0.9
channel 现在是 0.9,所以客户端需要做一些更改才能从服务器接收消息:
class Content:
def __init__(self, reply_channel):
self.reply_channel = reply_channel
def send(self, json):
self.reply_channel.send({
'reply_channel': str(self.reply_channel),
'text': dumps(json)
})
def ws_message(message):
content = Content(message.reply_channel)
content.send({'hello': 'world'})
routing.py 保持不变...
channel 版本<0.9
呸,这有点棘手,但找到了。
您必须使用消息的 reply_channel 属性。 所以这个:
Group("news_providers_loading").send({'content': str(provider)})
变成这样:
Channel(message.reply_channel).send({'content': str(provider)})
我现在得到的是:
from channels import Channel
from .soup import ProviderParser, sort_articles_by_date
from .models import Provider
from django.template.loader import render_to_string
from json import dumps
class Content:
def __init__(self, reply_channel):
self.reply_channel = reply_channel
def send(self, json):
Channel(self.reply_channel).send({'content': dumps(json)})
def ws_message(message):
providers = Provider.objects.all()
content = Content(message.reply_channel)
content.send({'providers_length': len(providers)})
articles = []
for provider in providers:
content.send({'provider': str(provider)})
parser = ProviderParser(provider)
articles.extend(parser.parse_articles())
sort_articles_by_date(articles)
html = render_to_string('news_providers/article.html', {'articles': articles})
content.send({'html': html})
路由.py
channel_routing = {
"websocket.receive": "news_providers.consumers.ws_message",
}
看起来更轻,尽管您可能希望保持连接、保持事件和断开连接方法(作为简单的 foo 方法)-对此并不完全确定-!
# connect, keepalive and disconnect
def ws_foo(message):
pass
路由.py
channel_routing = {
"websocket.connect": "news_providers.consumers.ws_foo",
"websocket.keepalive": "news_providers.consumers.ws_foo",
"websocket.receive": "news_providers.consumers.ws_message",
"websocket.disconnect": "news_providers.consumers.ws_foo",
}
关于python - 使用 Django channel 时如何使用 Channel 而不是 Group?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35104116/