Ing*_*ang 12 python django django-channels
我尝试制作一个聊天应用程序django-channels。django-chanels但是,当我创建新项目并在管理站点中编辑数据时,会发生运行时错误。
我不确定我是否认为错误发生是因为我做了几个django-channels项目。
当我构建第一个项目时,WebSocket 无法工作,因此我使用django-channels. 现在 WebSocket 已连接,但我遇到了 RuntimeError 问题(错误消息:单线程执行器已经是用户,会死锁)
我可以做什么来解决这个问题?
myproject/settings.py
import os
from pathlib import Path
# Build paths inside the project like this: BASE_DIR / 'subdir'.
BASE_DIR = Path(__file__).resolve().parent.parent
# Quick-start development settings - unsuitable for production
# See https://docs.djangoproject.com/en/3.2/howto/deployment/checklist/
# SECURITY WARNING: keep the secret key used in production secret!
SECRET_KEY = "django-insecure-is!$&voe3y058!2sus9egmxh@d!$)=l&o8_vl=m8zz!ap+d#a#"
# SECURITY WARNING: don't run with debug turned on in production!
DEBUG = True
ALLOWED_HOSTS = []
# Application definition
INSTALLED_APPS = [
"django.contrib.admin",
"django.contrib.auth",
"django.contrib.contenttypes",
"django.contrib.sessions",
"django.contrib.messages",
"django.contrib.staticfiles",
"users.apps.UsersConfig",
"channels",
"core.apps.CoreConfig",
"broadcasts.apps.BroadcastsConfig",
]
MIDDLEWARE = [
"django.middleware.security.SecurityMiddleware",
"django.contrib.sessions.middleware.SessionMiddleware",
"django.middleware.common.CommonMiddleware",
"django.middleware.csrf.CsrfViewMiddleware",
"django.contrib.auth.middleware.AuthenticationMiddleware",
"django.contrib.messages.middleware.MessageMiddleware",
"django.middleware.clickjacking.XFrameOptionsMiddleware",
]
ROOT_URLCONF = "busker.urls"
TEMPLATES = [
{
"BACKEND": "django.template.backends.django.DjangoTemplates",
"DIRS": [],
"APP_DIRS": True,
"OPTIONS": {
"context_processors": [
"django.template.context_processors.debug",
"django.template.context_processors.request",
"django.contrib.auth.context_processors.auth",
"django.contrib.messages.context_processors.messages",
],
},
},
]
WSGI_APPLICATION = "busker.wsgi.application"
# Database
# https://docs.djangoproject.com/en/3.2/ref/settings/#databases
DATABASES = {
"default": {
"ENGINE": "django.db.backends.sqlite3",
"NAME": BASE_DIR / "db.sqlite3",
}
}
# Password validation
# https://docs.djangoproject.com/en/3.2/ref/settings/#auth-password-validators
AUTH_PASSWORD_VALIDATORS = [
{
"NAME": "django.contrib.auth.password_validation.UserAttributeSimilarityValidator",
},
{
"NAME": "django.contrib.auth.password_validation.MinimumLengthValidator",
},
{
"NAME": "django.contrib.auth.password_validation.CommonPasswordValidator",
},
{
"NAME": "django.contrib.auth.password_validation.NumericPasswordValidator",
},
]
# Internationalization
# https://docs.djangoproject.com/en/3.2/topics/i18n/
LANGUAGE_CODE = "en-us"
TIME_ZONE = "UTC"
USE_I18N = True
USE_L10N = True
USE_TZ = True
# Static files (CSS, JavaScript, Images)
# https://docs.djangoproject.com/en/3.2/howto/static-files/
STATIC_URL = "/static/"
STATICFILES_DIRS = [os.path.join(BASE_DIR, "static")]
# Default primary key field type
# https://docs.djangoproject.com/en/3.2/ref/settings/#default-auto-field
DEFAULT_AUTO_FIELD = "django.db.models.BigAutoField"
ASGI_APPLICATION = "busker.asgi.application"
CHANNEL_LAYERS = {"default": {"BACKEND": "channels.layers.InMemoryChannelLayer"}}
AUTH_USER_MODEL = "users.User"
Run Code Online (Sandbox Code Playgroud)
myproject/asgi.py
import os
from channels.routing import ProtocolTypeRouter, URLRouter
from django.core.asgi import get_asgi_application
from channels.auth import AuthMiddlewareStack
import broadcasts.routing
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "mysite.settings")
application = ProtocolTypeRouter(
{
"http": get_asgi_application(),
# Just HTTP for now. (We can add other protocols later.)
"websocket": AuthMiddlewareStack(
URLRouter(broadcasts.routing.websocket_urlpatterns)
),
}
)
Run Code Online (Sandbox Code Playgroud)
myapp/consumers.py
import json
from channels.generic.websocket import AsyncWebsocketConsumer
class ChatConsumer(AsyncWebsocketConsumer):
async def connect(self):
self.room_group_name = "Test-Room"
await self.channel_layer.group_add(self.room_group_name, self.channel_name)
await self.accept()
async def disconnect(self, close_code):
await self.channel_layer.group_discard(self.room_group_name, self.channel_name)
print("Disconnected!")
async def receive(self, text_data):
receive_dict = json.loads(text_data)
message = receive_dict["message"]
await self.channel_layer.group_send(
self.room_group_name, {"type": "send.message", "message": message}
)
async def send_message(self, event):
message = event["message"]
await self.send(text_data=json.dumps({"message": message}))
Run Code Online (Sandbox Code Playgroud)
myapp/routing.py
from django.urls import re_path
from . import consumers
websocket_urlpatterns = [
re_path(r"", consumers.ChatConsumer.as_asgi()),
]
Run Code Online (Sandbox Code Playgroud)
Ben*_*els 16
如果pip install 'asgiref==3.3.4'您仍使用channels版本 3,或者升级到channels版本 4(该问题已在 4.0.0 中修复)。
RuntimeError: Single thread executor already being used, would deadlock从 3.3.4 升级asgiref到 3.4.1后,我注意到了类似的情况。
这似乎是由于3.0.4中的一个问题channels造成的,其中 Django 开发服务器上的并发请求间歇性失败。另请参阅Django 中随机发生的运行时错误死锁。
在 3.4.0 中,asgiref引入了额外的死锁检查。这是一件好事,但可能暴露了渠道中的根本问题。从变更日志:
* Calling sync_to_async directly from inside itself (which causes a deadlock
when in the default, thread-sensitive mode) now has deadlock detection.
Run Code Online (Sandbox Code Playgroud)
如果您确实需要安装 asgiref >= 3.4.1,开发中的解决方法是使用python manage.py runserver --noasgi. 这还有一个好处是重新加载速度更快。
| 归档时间: |
|
| 查看次数: |
4737 次 |
| 最近记录: |