文档章节

队列使用场景:为什么需要队列

旋转木马-千里马
 旋转木马-千里马
发布于 2015/12/29 17:08
字数 957
阅读 127
收藏 1

在web开发中,我们经常会遇到需要处理批量任务的时候,这些批量任务可能是用户提交的,也可能是当系统被某个事件触发时需要进行批量处理的,面对这样的任务,如果是用户提交的批量任务,初级程序员只能让用户触发提交动作后,等待服务器处理完毕,并且将结果返回到浏览器,期间用户不能关掉浏览器窗口,如果数据比较大,或者处理速度比较慢,那用户体验将会因此受到直接影响。

但是当我们使用某讯或者某浪的邮箱时,点击群发邮件之后,只需等待很短的时间,浏览器提示提交成功,正在发送之类的信息时,用户就可以关掉浏览器,稍后,收件地址栏里的邮箱将陆续收到该群发邮件,再比如群发定时邮件,以及当商城系统中有客户下单,客户,客服,仓库等相关人员收到订单邮件信息。诸如此类,队列的应用范围是如此之广。二 :普通工程师的解决方案和架构师的解决方案

方案1:建表存邮件,消息等,用定时程序取出发送。

方案2:抽象到更高一层,开发一套通用异步处理队列适用于任何复杂的业务逻辑 那么,作为架构师,使用队列的做法,将抽象层和业务层分离,可具有良好的扩展性和可维护性。相比较而言就高明了许多,下面就我们介绍一下*定义队列的实现思路和方法。

三 :队列总体设*

    1:需要队列程序,提供加入队列接口和取队列接口等

    2:需要存储队列,文件或者数据库

    3:需要定时程序取出队列并执行

    4:其它扩展功能:优先级,日志,定时等  我们这里的队列实现借助了服务器的*划任务来实现,例如linux中的crontab

这本身是linux系统中的一个程   这里面几个需要注意的地方

     1:往数据库中存取数据时,不要直接使用json_encode或者json_decode,容易造成一些意外问题,在代码中,我们定义了a2s和s2a两个方法,分别是处理数组转为字符串,和从数据库中读取字符串后转为数组。

     2:当任务量比较大,同时服务器负载又没有充分利用的时候,可以使用多进程并发处理, 在并发处理的时候需要考虑一个问题,就是如何避免重复,在这里我们使用了,对队列任务进行标记,每次从数据库中读取一个进程需要处理的一批任务,使用数据库中id与批次标示取余等于0的方法来区分,避免不同批次的队列,重复处理相同任务。


© 著作权归作者所有

共有 人打赏支持
旋转木马-千里马
粉丝 15
博文 83
码字总数 85714
作品 0
海淀
程序员
私信 提问
网站架构中为什么要用到消息队列

很多没有实际项目经验的小伙伴,对消息队列系统非常陌生,看着很多架构的介绍中,都提到消息队列。但是,不知道为什么要用消息队列?什么是消息队列?常见的消息队列产品有哪些? 通过阅读本...

kisshua
2015/12/04
543
0
Python多进程执行Redis优先级队列任务

为什么需要消息队列 系统中引入消息队列机制是对系统一个非常大的改善。例如一个web系统中,用户做了某项操作后需要发送邮件通知到用户邮箱中。你可以使用同步方式让用户等待邮件发送完成后反...

cooffeelis
2017/10/27
0
0
Java并发--- 简单聊聊JDK中的七大阻塞队列

JDK中除了上文提到的各种并发容器,还提供了丰富的阻塞队列。阻塞队列统一实现了BlockingQueue接口,BlockingQueue接口在java.util包Queue接口的基础上提供了put(e)以及take()两个阻塞方法。...

Ala6
2018/10/26
0
0
详细介绍Spring Boot + RabbitMQ实现延迟队列

背景 何为延迟队列? 顾名思义,延迟队列就是进入该队列的消息会被延迟消费的队列。而一般的队列,消息一旦入队了之后就会被消费者马上消费。 延迟队列能做什么? 延迟队列多用于需要延迟工作...

wooyoo
2017/11/21
0
0
(一)Kafka中文教程-初识kafka

之前我介绍过RabbitMQ,RabbitMQ作为企业级的消息队列其实未必能满足所有的需求,RabbitMQ在持久化、可靠性、消息确认机制、任务分发等方面都非常优秀。但也因为这些原因导致RabbitMQ的性能受...

Super_RD
2017/05/23
0
0

没有更多内容

加载失败,请刷新页面

加载更多

MaxCompute安全管理指南-案例篇

通过《MaxCompute安全管理-基础篇》了解到MaxCompute和DataWorks的相关安全模型、两个产品安全方面的关联,以及各种安全操作后,本篇主要给出一些安全管理案例,给安全管理的成员作为参考。 ...

zhaowei121
12分钟前
1
0
B站智能防挡弹幕的一种python实现

某天代码写得老眼昏花,去B站上摸鱼,突然发现奇怪的现象: 哟呵,B站竟然做了视频前景提取,把弹幕藏到画面人物的后面。识别效果还意外地不错呢。 然后又翻了下,发现这是个叫做“智能防挡弹...

crossin
19分钟前
2
0
TortoiseSVN 使用教程

TortoiseSVN 使用教程 TortoiseSVN 是 Subversion 版本控制系统的一个免费开源客户端,可以超越时间的管理文件和目录。 TortoiseSVN 安装 下载地址:https://tortoisesvn.net/downloads.htm...

linjin200
22分钟前
2
0
使用应用程序(Java/Python)访问MaxCompute Lightning进行数据开发

MaxCompute Lightning是MaxCompute产品的交互式查询服务,支持以PostgreSQL协议及语法连接访问Maxcompute项目,让您使用熟悉的工具以标准 SQL查询分析MaxCompute项目中的数据,快速获取查询结...

阿里云云栖社区
23分钟前
1
0
条形码控件TBarCode SDK系列教程十二(网络应用程序问题解答)

TBarCode SDK是一款可以在任意应用程序和打印机下生成和打印所有条码的条码软件组件。TBarCode SDK对于Microsoft Office用户以及软件开发者提供条码打印。使用此款条码软件组件您可以以完美效...

ymy_666666
24分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部