本文分享自华为云社区《构建实时消息通知系统：Django实战指南》，作者：柠檬味拥抱。
在Web应用步伐中，实现消息通知系统是至关重要的，它可以资助用户实时了解到与其相关的事件或动态。Django提供了信号机制，可以用于实现这样的通知系统。本文将介绍如何使用Django的信号机制来构建一个简单但功能强大的消息通知系统，并提供相应的代码和实例。
1. 安装 Django
起首，确保你已经安装了 Django。你可以通过 pip 安装它：2. 创建 Django 项目和应用
创建一个 Django 项目，并在其中创建一个应用：- django-admin startproject notification_system
- cd notification_system
- python manage.py startapp notifications
在 notifications/models.py 文件中定义一个模型来存储通知信息：- from django.db import models
- from django.contrib.auth.models import User
- class Notification(models.Model):
- user = models.ForeignKey(User, on_delete=models.CASCADE)
- message = models.CharField(max_length=255)
- created_at = models.DateTimeField(auto_now_add=True)
- read = models.BooleanField(default=False)
在 notifications/signals.py 文件中创建信号，该信号将在需要发送通知时触发：- from django.dispatch import Signal
- notification_sent = Signal(providing_args=["user", "message"])
在 notifications/handlers.py 文件中编写信号处理器，处理信号并创建相应的通知：- from django.dispatch import receiver
- from .signals import notification_sent
- from .models import Notification
- @receiver(notification_sent)
- def create_notification(sender, **kwargs):
- user = kwargs['user']
- message = kwargs['message']
- Notification.objects.create(user=user, message=message)
在你的应用步伐中的适当位置，发送信号以触发通知：- from django.contrib.auth.models import User
- from notifications.signals import notification_sent
- # 例如，发送通知给特定用户
- user = User.objects.get(username='username')
- notification_sent.send(sender=None, user=user, message='你有一个新消息')
在你的应用步伐中，可以通过查询通知模型来表现用户的通知：- from notifications.models import Notification
- # 例如，在视图中查询并显示通知
- def notifications_view(request):
- user_notifications = Notification.objects.filter(user=request.user)
- return render(request, 'notifications.html', {'notifications': user_notifications})
当用户查看通知时，你可能需要将它们标志为已读。你可以在视图中实验此操纵：- def mark_as_read(request, notification_id):
- notification = Notification.objects.get(pk=notification_id)
- notification.read = True
- notification.save()
- return redirect('notifications_view')
创建一个 HTML 模板来出现通知信息。在 templates/notifications.html 文件中定义：- <!DOCTYPE html>
- <html lang="en">
- <head>
- <meta charset="UTF-8">
- <meta name="viewport" content="width=device-width, initial-scale=1.0">
- <title>Notifications</title>
- </head>
- <body>
- <h1>Notifications</h1>
- <ul>
- {% for notification in notifications %}
- <li{% if notification.read %} style="color: grey;"{% endif %}>
- {{ notification.message }}
- {% if not notification.read %}
- <a target="_blank" href="https://www.cnblogs.com/{% url 'mark_as_read' notification.id %}">Mark as Read</a>
- {% endif %}
- </li>
- {% endfor %}
- </ul>
- </body>
- </html>
配置 URL 来处理通知相关的哀求。在 notification_system/urls.py 文件中：- from django.urls import path
- from notifications.views import notifications_view, mark_as_read
- urlpatterns = [
- path('notifications/', notifications_view, name='notifications_view'),
- path('notifications/mark_as_read/<int:notification_id>/', mark_as_read, name='mark_as_read'),
- ]
运行 Django 服务器以查看结果：- python manage.py runserver
12. 集成前端框架
为了提升通知页面的用户体验，我们可以使用一些盛行的前端框架来美化页面并添加一些交互功能。这里以Bootstrap为例。
起首，安装Bootstrap：- pip install django-bootstrap4
- INSTALLED_APPS = [
- ...
- 'bootstrap4',
- ...
- ]
- {% load bootstrap4 %}
- <!DOCTYPE html>
- <html lang="en">
- <head>
- <meta charset="UTF-8">
- <meta name="viewport" content="width=device-width, initial-scale=1.0">
- <title>Notifications</title>
- {% bootstrap_css %}
- </head>
- <body>
-
- <h1 class="mt-5">Notifications</h1>
- <ul class="list-group mt-3">
- {% for notification in notifications %}
- <li class="list-group-item{% if notification.read %} list-group-item-light{% endif %}">
- {{ notification.message }}
- {% if not notification.read %}
- <a target="_blank" href="https://www.cnblogs.com/{% url 'mark_as_read' notification.id %}" class="btn btn-sm btn-primary ml-2">Mark as Read</a>
- {% endif %}
- </li>
- {% endfor %}
- </ul>
-
- {% bootstrap_javascript %}
- </body>
- </html>
我们可以使用 Ajax 技能来实现标志通知为已读的功能，这样可以避免刷新整个页面。修改模板文件和视图函数如下：
在模板中，使用 jQuery 来发送 Ajax 哀求：- [/code]修改视图函数 mark_as_read：
- [code]from django.http import JsonResponse
- def mark_as_read(request, notification_id):
- notification = Notification.objects.get(pk=notification_id)
- notification.read = True
- notification.save()
- return JsonResponse({'success': True})
为了让用户可以清晰地知道有多少未读通知，我们可以添加一个通知计数的功能，将未读通知的数量表现在页面上。
起首，在 notifications/views.py 中修改 notifications_view 视图函数：- def notifications_view(request):
- user_notifications = Notification.objects.filter(user=request.user)
- unread_count = user_notifications.filter(read=False).count()
- return render(request, 'notifications.html', {'notifications': user_notifications, 'unread_count': unread_count})
- <h1 class="mt-5">Notifications</h1>
-
- You have {{ unread_count }} unread notification(s).
-
- <ul class="list-group mt-3">
- {% for notification in notifications %}
- <li class="list-group-item{% if notification.read %} list-group-item-light{% endif %}">
- {{ notification.message }}
- {% if not notification.read %}
- <a target="_blank" href="https://www.cnblogs.com/{% url 'mark_as_read' notification.id %}" class="btn btn-sm btn-primary ml-2 mark-as-read">Mark as Read</a>
- {% endif %}
- </li>
- {% endfor %}
- </ul>
为了使通知计数实时更新，我们可以使用 Ajax 技能定期哀求服务器以获取最新的未读通知数量。
在通知模板中添加 JavaScript 代码：- [/code]在 notifications/urls.py 中添加一个新的 URL 路由来处理未读通知数量的哀求：
- [code]from django.urls import path
- from .views import notifications_view, mark_as_read, unread_count
- urlpatterns = [
- path('notifications/', notifications_view, name='notifications_view'),
- path('notifications/mark_as_read/<int:notification_id>/', mark_as_read, name='mark_as_read'),
- path('notifications/unread_count/', unread_count, name='unread_count'),
- ]
- from django.http import JsonResponse
- def unread_count(request):
- user_notifications = Notification.objects.filter(user=request.user, read=False)
- unread_count = user_notifications.count()
- return JsonResponse({'unread_count': unread_count})
除了标志通知为已读之外，有时用户还可能希望能够删除一些通知，特别是一些不再需要的通知。因此，我们可以添加一个删除通知的功能。
起首，在模板中为每个通知添加一个删除按钮：- <ul class="list-group mt-3">
- {% for notification in notifications %}
- <li class="list-group-item{% if notification.read %} list-group-item-light{% endif %}">
- {{ notification.message }}
-
- {% if not notification.read %}
- <a target="_blank" href="https://www.cnblogs.com/{% url 'mark_as_read' notification.id %}" class="btn btn-sm btn-primary mark-as-read">Mark as Read</a>
- {% endif %}
- <a target="_blank" href="https://www.cnblogs.com/{% url 'delete_notification' notification.id %}" class="btn btn-sm btn-danger delete-notification">Delete</a>
-
- </li>
- {% endfor %}
- </ul>
- urlpatterns = [
- ...
- path('notifications/delete/<int:notification_id>/', delete_notification, name='delete_notification'),
- ]
- def delete_notification(request, notification_id):
- notification = Notification.objects.get(pk=notification_id)
- notification.delete()
- return redirect('notifications_view')
- [/code][size=4]17. 添加异步使命处理[/size]
- 在实际应用中，通知系统可能需要处理大量的通知，而生成和发送通知可能是一个耗时的操纵。为了避免阻塞用户哀求，我们可以使用异步使命处理来处理通知的生成和发送。
- [size=3]17.1 安装 Celery[/size]
- 起首，安装 Celery 和 Redis 作为消息署理：
- [code]pip install celery redis
在 Django 项目的根目录下创建一个名为 celery.py 的文件，并添加以下内容：- import os
- from celery import Celery
- os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'notification_system.settings')
- app = Celery('notification_system')
- app.config_from_object('django.conf:settings', namespace='CELERY')
- app.autodiscover_tasks()
- CELERY_BROKER_URL = 'redis://localhost:6379/0'
在 notifications/tasks.py 中定义异步使命来处理通知的生成和发送：- from celery import shared_task
- from .models import Notification
- @shared_task
- def send_notification(user_id, message):
- user = User.objects.get(pk=user_id)
- Notification.objects.create(user=user, message=message)
在你的应用步伐中，当需要发送通知时，使用 Celery 的 delay() 方法触发异步使命：- from notifications.tasks import send_notification
- send_notification.delay(user_id, '你有一个新消息')
本文介绍了如何使用 Django 构建一个功能强大的消息通知系统，其中涵盖了以下主要内容：
- 通过定义模型、创建信号、编写信号处理器，实现了通知系统的基本框架。
- 集成了前端框架 Bootstrap，并使用 Ajax 技能实现了标志通知为已读的功能，以及实时更新未读通知数量的功能，提升了用户体验。
- 添加了通知删除功能，使用户可以更灵活地管理通知。
- 引入了异步使命处理技能 Celery，将通知的生成和发送操纵转换为异步使命，提高了系统的性能和相应速度。
通过这些步调，我们建立了一个功能美满的消息通知系统，用户可以实时了解到与其相关的重要信息，并且可以自由地管理和处理通知，从而增强了应用的交互性、可用性和性能。
点击关注，第一时间了解华为云奇怪技能~
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。 |
