我正在使用通道2和信号，以便检测何时保存了某种类型的模型并将通知发送给所有客户端。我收到错误：WebSocket与“ ws：/ account / home”的连接失败：WebSocket在建立连接之前已关闭。我看不到我在哪里弄错了。预先非常感谢您的帮助。
在我的项目中：FUNDBOOK_V5 / ROUTING.PY
from channels.auth import AuthMiddlewareStack
from channels.routing import ProtocolTypeRouter, URLRouter
import FundBook_Core.routing
application = ProtocolTypeRouter({
# (http->django views is added by default)
'websocket': AuthMiddlewareStack(
URLRouter(
FundBook_Core.routing.websocket_urlpatterns
)
),
})
在我的应用中：FUNDBOOK_CORE \ ROUTING.PY
from django.urls import re_path
from django.conf.urls import url
from . import consumers
websocket_urlpatterns = [
url(r'^account/home/$', consumers.NotificationConsumer),
url(r'^fund/(?P<fund>[\w-]+)/$', consumers.NotificationConsumer),
]
FUNDBOOK_CORE \ CONSUMERS.PY
import json
import asyncio
from django.contrib.auth import get_user_model
from channels.generic.websocket import AsyncJsonWebsocketConsumer, AsyncConsumer
class NotificationConsumer(AsyncConsumer):
async def websocket_connect(self, event):
await self.channel_layer.group_add("task", self.channel_name)
await self.send({
"type": "websocket.accept"
})
print("Connected!", event)
async def websocket_disconnect(self, event):
await self.channel_layer.group_discard("task", self.channel_name)
print("Disconnected!", event)
async def send_message(self, event):
await self.send({
"type": "websocket.send",
'text': 'Oy, mate!'
})
SIGNALS.PY
from FundBook_Core.models import ThreadTask
from django.db.models.signals import pre_save
from django.dispatch import receiver
from asgiref.sync import async_to_sync
from channels.layers import get_channel_layer
@receiver(pre_save, sender=ThreadTask)
def notify_thread_task_save(sender, **kwargs):
if "instance" in kwargs:
instance = kwargs["instance"]
# check if there is a new notification
channel_layer = get_channel_layer()
async_to_sync(channel_layer.group_send)(
"task", {"type": "send_message",
"event": "New Notification",
"username": instance.username}
)
FUNDBOOK_CORE \ INIT.PY
default_app_config = "FundBook_Core.apps.FundbookCoreConfig"
FUNDBOOK_CORE \ APPS.PY
from django.apps import AppConfig
class FundbookCoreConfig(AppConfig):
name = 'FundBook_Core'
def ready(self):
from . import signals
SETTINGS.PY
ALLOWED_HOSTS = ['*']
ASGI_APPLICATION = 'FundBook_v5.routing.application'
# Channels
CHANNEL_LAYERS = {
"default": {
"BACKEND": "channels_redis.core.RedisChannelLayer",
"CONFIG": {"hosts": [("localhost", 6379)]},
}
}
HOME.HTML：
<script>
var loc = window.location;
var wsStart = "ws://"
if (loc.protocol === 'https:'){
wsStart = 'wss://'
}
var url = wsStart + loc.host + loc.pathname;
console.log(url)
var socket = new ReconnectingWebSocket(url);
socket.onmessage = function(e) {
console.log("message", e)
const data = JSON.parse(e.data);
document.querySelector('#notifylist').value += (data.message + '\n');
}
socket.onopen = function(e) {
console.log("open", e)
}
socket.onerror = function(e) {
console.log("error", e)
console.error('Notification socket closed unexpectedly')
}
socket.onclose = function(e) {
console.log("close", e)
}
</script>
实际上，我有两个问题：第一个：ERR_CONNECTION_RESET问题是在防火墙阻止websocket连接或未配置为处理websocket连接时引起的。第二个错误：错误-服务器-应用程序内部异常：多个异常：[Errno 10061] Connect调用失败（':: 1'，6379），[Errno 10061] Connect调用失败（'127. 0.0.1'，6379）来自redit数据库：请参见Windows Error 10061 - Django Channels
我解决了这些问题后，一切正常。对于那些需要代码的人：
APP。INIT
default_app_config = "your_application.apps.FundbookCoreConfig"
APP.APPS
from django.apps import AppConfig
class your_appConfig(AppConfig):
name = 'your_app'
def ready(self):
from . import signals
项目设置
ASGI_APPLICATION = 'your_project.routing.application'
# Channels
CHANNEL_LAYERS = {
"default": {
"BACKEND": "channels_redis.core.RedisChannelLayer",
"CONFIG": {"hosts": [("localhost", 6379)]},
}
}
APP.SIGNALS
from django.db.models.signals import pre_save
from django.dispatch import receiver
from asgiref.sync import async_to_sync
from channels.layers import get_channel_layer
from.models import ThreadTask
@receiver(pre_save, sender=ThreadTask)
def notify_thread_task_save(sender, **kwargs):
if "instance" in kwargs:
instance = kwargs["instance"]
# check if there is a new notification
channel_layer = get_channel_layer()
async_to_sync(channel_layer.group_send)(
"task", {"type": "user_notification",
"event": "New Notification",
"notification": instance.text}
)
项目路由
from channels.auth import AuthMiddlewareStack
from channels.routing import ProtocolTypeRouter, URLRouter
from channels.security.websocket import AllowedHostsOriginValidator, OriginValidator
import your_app.routing
application = ProtocolTypeRouter({
# (http->django views is added by default)
'websocket': AllowedHostsOriginValidator(
AuthMiddlewareStack(
URLRouter(
FundBook_Core.routing.websocket_urlpatterns
)
)
),
})
APP.ROUTING
from django.conf.urls import url
from . import consumers
websocket_urlpatterns = [
url(r'^account/home', consumers.NotificationConsumer),
url(r'^fund/(?P<fund>[\w-]+)', consumers.NotificationConsumer),
]
APP.CONSUMERS
from channels.generic.websocket import AsyncJsonWebsocketConsumer
class NotificationConsumer(AsyncJsonWebsocketConsumer):
async def connect(self):
await self.accept()
await self.channel_layer.group_add("task", self.channel_name)
print(f"Added {self.channel_name} channel to task")
async def disconnect(self, close_code):
await self.channel_layer.group_discard("task", self.channel_name)
print(f"Removed {self.channel_name} channel to task")
async def user_notification(self, event):
await self.send_json(event)
print(f"Got message {event} at {self.channel_name}")
使用您的html
<!-- Plugin JavaScript -->
<script src="{% static "FundBook_Core/js/reconnecting-websocket.js" %}"></script>
<script>
var loc = window.location;
var wsStart = "ws://"
if (loc.protocol === 'https:'){
wsStart = 'wss://'
}
var url = wsStart + loc.host + loc.pathname;
console.log(url)
var socket = new ReconnectingWebSocket(url);
const tt = document.querySelector('#task_text');
socket.onmessage = function(e) {
console.log("message", e)
const data = JSON.parse(e.data);
console.log("parse", data)
console.log("notification", data.notification)
if(data.event == "New Notification"){
var el = document.createElement("li");
el.innerHTML = data.notification;
tt.appendChild(el);
}
}
socket.onopen = function(e) {
console.log("open", e)
}
socket.onerror = function(e) {
console.log("error", e);
console.error('Notification socket closed unexpectedly')
}
socket.onclose = function(e) {
console.log("close", e)
}
</script>