位置: 编程技术 - 正文

Python的Django框架中消息通知的计数器实现教程(python中django框架)

编辑:rootadmin

推荐整理分享Python的Django框架中消息通知的计数器实现教程(python中django框架),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:python的Django框架,python的django框架中间件,python的django框架http请求,python的Django框架,python的django框架http请求,python的django框架教学,python的django框架http请求,python的django框架http请求,内容如对您有帮助,希望把文章链接给更多的朋友!

故事的开始:.count()假设你有一个Notification Model类,保存的主要是所有的站内通知:

理所当然的,刚开始你会通过这样的查询来获取某个用户的未读消息数:

当你的Notification表比较小的时候,这样的方式没有任何的问题,但是慢慢的,随着业务量 的扩大。消息表里面有了 上亿条数据 。很多懒惰的用户的未读消息数都到了上千条。

这时候,你就需要实现一个计数器,让这个计数器来统计每个用户的未读消息数,这样 比起之前的 count() ,我们只需要执行一条简单的主键查询(或者更优)就可以拿到实时的未读消息数了。

更优的方案:建立计数器首先,让我们得建立一个新表来存储每个用户的未读消息数。

我们为每一个注册用户提供了一条对应的 UserNotificationsCount 记录来保存他的未读消息数。 每次获取他的未读消息数的时候,只需要 UserNotificationsCount.objects.get(pk=user_id).unread_count 就可以了。

接下来,问题的重点来了,我们如何知道什么时候应该更新我们的计数器?Django在这方面提供了什么捷径吗?

挑战:实时更新你的计数器

为了让我们的计数器正常的工作,我们必须实时的更新它,这包括:

当有新的未读消息过来的时候,为计数器 +1 当消息被异常删除时,如果关联的消息为未读,为计数器 -1 当阅读完一个新消息的时候,为计数器 -1

让我们一个一个来解决这些情况。

在抛出解决方案之前,我们需要先介绍Django中的一个功能: Signals ,Signals是django提供的一个事件通知机制,它可以让你在监听某些自定义或者 预设的事件,当这些事件发生的时候,调用实现定义好的方法。

比如 django.db.models.signals.pre_save & django.db.models.signals.post_save 表示的是 某个Model调用save方法之前和之后会触发的事件,它和Database提供的触发器在功能上有一点相似。

关于Signals更多的介绍可以参考官方文档,下面让我们来看看Signals能给我们的计数器带来什么好处。

1. 当有新的消息过来的时候,为计数器 +1

这个情况应该是最好处理的,使用Django的Signals,只需要短短几行代码,我们便可以实现这种 情况下的计数器更新:

这样,每当你使用 Notification.create 或者 .save() 之类的方法创建新通知 时,我们的 NotificationController 便会得到通知,为计数器 +1。

但是请注意,因为我们的计数器是基于Django的signals,如果你的代码里面有地方 在使用原始sql,没有通过Django ORM方法来添加新通知的话,我们的计数器是不会得到 通知的,所以,最好规范所有的新通知建立方式,比如使用同一个API。

2. 当消息被异常删除时,如果关联的消息为未读,为计数器 -1

有了第一个的经验,这种情况处理起来也比较简单,只需要监控Notification的post_delete 信号就可以了,下面是一段实例代码:

至此,Notification的删除事件也能正常的更新我们的计数器了。

3. 当阅读一个新消息的时候,为计数器 -1

接下来,当用户阅读某条未读消息的时候,我们也需要更新我们的未读消息计数器。 你可能会说,这有什么难的?我只要在我的阅读消息的方法里面,手动更新我的计数器不就好了?

Python的Django框架中消息通知的计数器实现教程(python中django框架)

比如这样:

通过一些简单的测试,你可以会觉得你的计数器工作的非常好,但是,这样的实现方式有一个 非常致命的问题, 这个方式没有办法正常处理并发的请求 。

打一个比方,你拥有一个id为的未读消息对象,这个时候同时有了两个请求过来,都要标记这个通知为已读:

显而易见的,这两次方法都会成功的标记这条通知为已读,因为在并发的情况下, if notification.has_readed 这样的检查无法正常工作,所以我们的计数器将会被错误的 -1 两次 ,但其实我们只读了一条请求。

那么,这样的问题应该怎么解决呢?

基本上,解决并发请求产生的数据冲突只有一个办法: 加锁 ,介绍两种比较简单的解决方案:

使用 select for update 数据库查询

select ... for update 是数据库层面上专门用来解决并发取数据后再修改的场景的,主流的关系数据库 比如mysql、postgresql都支持这个功能, 新版的Django ORM甚至直接提供了这个功能的shortcut 。 关于它的更多介绍,你可以搜索你使用的数据库的介绍文档。

使用 select for update 后,我们的代码可能会变成这样:

除了使用``select for update``这样的功能,还有一个比较简单的办法来解决这个问题。

使用update来实现原子性修改

其实,更简单的办法,只要把我们的数据库改成单条的update就可以解决并发情况下的问题了:

这样,并发的标记已读操作也可以正确的影响到我们的计数器了。

高性能?我们在之前介绍了如何实现一个能够正确更新的未读消息计数器,我们可能会直接使用UPDATE 语句来修改我们的计数器,就像这样:

但是在生产环境中,这样的处理方式很有可能造成严重的性能问题,因为如果我们的计数器在频繁 更新的话,海量的Update会给数据库造成不小的压力。所以为了实现一个高性能的计数器,我们 需要把改动暂存起来,然后批量写入到数据库。

使用 redis 的 sorted set ,我们可以非常轻松的做到这一点。

使用sorted set来缓存计数器改动

redis是一个非常好用的内存数据库,其中的sorted set是它提供的一种数据类型:有序集合, 使用它,我们可以非常简单的缓存所有的计数器改动,然后批量回写到数据库。

通过以上的代码,我们把计数器的更新缓冲在了redis里面,我们还需要一个脚本来把这个缓冲区 里面的数据定时回写到数据库中。

通过自定义django的command,我们可以非常轻松的做到这一点:

之后,通过 python manage.py notification_update_counter 这样的命令就可以把缓冲区 里面的改动批量回写到数据库了。我们还可以把这个命令配置到crontab中来定义执行。

总结文章到了这里,一个简单的“高性能”未读消息计数器算是实现完了。说了这么多,其实主要的知识点就是这么些:

使用Django的signals来获取Model的新建/删除操作更新使用数据库的select for update来正确处理并发的数据库操作使用redis的sorted set来缓存计数器的修改操作希望能对您有所帮助。 :)

python实现中文转换url编码的方法 本文实例讲述了python实现中文转换url编码的方法。分享给大家供大家参考,具体如下:今天要处理百度贴吧的东西。想要做一个关键词的list,每次需要

Python中列表元素转为数字的方法分析 本文实例讲述了Python中列表元素转为数字的方法。分享给大家供大家参考,具体如下:有一个数字字符的列表:numbers=['1','5','','8']想要把每个元素转换

Python找出list中最常出现元素的方法 本文实例讲述了Python找出list中最常出现元素的方法。分享给大家供大家参考,具体如下:假设一个list中保存着各种元素,需要统计每个元素出现的个数

标签: python中django框架

本文链接地址:https://www.jiuchutong.com/biancheng/387620.html 转载请保留说明!

上一篇:详解Python的Flask框架中的signals信号机制(python+flask)

下一篇:python实现中文转换url编码的方法(python 中文转码)

  • 违约金的专票能抵扣吗
  • 500以下的收据可以入账吗
  • 房屋租赁账务处理程序
  • 有形动产租赁服务计入什么科目
  • 购买自用应税车辆的应自购买之日起
  • 固定资产清理期末可以有余额吗
  • 企业清算未分配利润不分配要交个税吗
  • 冲销主营业务收入后导致发生额变大
  • 股东退股分红怎么拿回
  • 产品管理不足
  • 公司章程上的出资时间2050年
  • 没通过认证的增值税发票是否能够记入成本抵扣
  • 开保函会计分录
  • 箱包类增值税发票多少点
  • 分支机构第要交企业所得税吗?
  • 钢结构制作安装方案
  • 办税员实名认证变更
  • 车船税征税范围包括火车吗
  • 企业的财产清查无论什么情况,均应先通过
  • 工程施工什么时候确认收入
  • 我的初级奋斗经历作文
  • 标准差超过多少不合理
  • 跨地区经营汇总纳税企业所得税
  • 如何设置电脑任务栏显示
  • win11怎么安装CAD2008
  • 新个人所得税的发展现状
  • 购买预付卡如何记账
  • 招标场地费怎么收
  • 发出商品但货款没到账
  • 股权转让定金怎么退回
  • 长期借款科目的期末余额反映尚未偿还的借款本金
  • 奥尔梅克
  • 员工出差机票计入什么科目
  • 残保金怎么计算公式
  • 开票缴纳的1%个税是多少
  • 冲回上月暂估入账的商品会计分录
  • 分公司二季度安全生产分析会内容
  • 前一个月开的发票怎么查
  • 购进固定资产的进项税可以抵扣吗
  • 织梦网站特有标识
  • 固定资产报废的请示
  • 企业注销需要清产核资吗
  • 小微企业缴纳增值税的账务处理
  • 员工自己全额承担社保费用要计提吗
  • 运输公司的车辆如何计提折旧
  • 个税手续费返还增值税申报表怎么填
  • 会计账簿有哪些作用
  • 租赁公司异地经营
  • 汇算清缴补交的所得税怎么记帐
  • 一般纳税人采购分录
  • 无进项发票开具销项发票
  • 应交税费应交增值税已交税金怎么用
  • 允许税前扣除的税金及附加包括哪些
  • 票据包括哪些
  • 营改增后建筑业开票规定
  • sqlserver索引语句
  • 无法启动diagnostic policy service服务
  • windows update client
  • windows 10预览版
  • 在windows上装ubuntu
  • Fedora Core 5(FC-5)正式版下载
  • windows10iot安装
  • 笔记本xp系统怎么升级win7系统
  • macos邮件
  • WIN10系统安装EXCEL打开会报警
  • win10控制面板如何卸载软件
  • linux中nm命令
  • 关于linux中Squid代理服务器的10个实用面试问答
  • javascript数据结构与算法项目计算找零
  • js opendialog
  • Node.js中的包管理工具是什么
  • python os.access
  • Eclipse和PyDev搭建完美Python开发环境教程(Windows篇)
  • 慧算账财务公司简介
  • 沈阳新公司办理社保流程
  • 收购烟叶多少公斤违法
  • 简述纳税人与负税的区别
  • 总公司与分公司签订承包协议
  • 河南税务局发票查询系统
  • 联通前面加什么可以隐藏号码
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设