iam尝试使用渠道但无法在此处使用的是Consumer.py
def ws_connect(message, cat_id):
try:
cat = Categories.objects.get(pk=cat_id)
except Categories.DoesNotExist:
pass
Group('cat-1').add(message.reply_channel)
def ws_diconnect(message, cat_id):
try:
cat = Categories.objects.get(pk=cat_id)
except Categories.DoesNotExist:
pass
Group('cat-1').discard(message.reply_channel)
这是routing.py:
channel_routing = [
route('websocket.receive', ws_connect, path=r'^/liveupdate/(?P<cat_id>\d+)/'),
route("websocket.disconnect", ws_diconnect, path=r'^/liveupdate/(?P<cat_id>\d+)/'),
]
这是signals.py:
@receiver(post_save, sender=Tender)
def send_update(sender, instance, created, raw, using, **kwargs):
print '>>>>>>>>>>>>>>>>>>>>>>>>>>>>', instance, '2', raw, '3', using, '4', kwargs
data = json.dumps(
{'ministry': 'hisham',})
Group('cat-1').send({'tender': data,})
print 'Done'
这是javascript:
<script type="application/javascript">
var ws_scheme = window.location.protocol == "https:" ? "wss" : "ws";
alert(ws_scheme +"://" + window.location.host + "/liveupdate/1/");
var socket = new WebSocket(ws_scheme +"://" + window.location.host + "/liveupdate/1/");
socket.onmessage = function(e) {
alert(e.data);
};
socket.onopen = function() {
console.log("Connected to socket");
};
socket.onclose = function() { console.log("Disconnected to socket"); }
</script>
当我为节省招标信号而努力,但在浏览器中什么也没有时,即没有数据警报,我的代码出了什么问题,什么主意
代替websocket.receive使用websocket.connect。客户端向服务器发送数据时使用接收。
route('websocket.connect', ws_connect, path=r'^/liveupdate/(?P<cat_id>\d+)/'),
在什么时候发送数据而不是招标时,请使用文本作为密钥。
Group('cat-1').send({'text': data,})
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句