什么是队列系统?
可以把队列和栈还有堆想象成一个容器,
队列其实就是我们通常说的排队,可以想象成一个两端开口的容器,先来后到,先进来的就先出去后进来的就后出去。
栈就不一样了,栈大家可以想象成一端开口的容器 ,比如说杯子,先进去的反而后出来。
而堆就是没有口的一个盆,随便进出。
含义:
消息队列系统就是利用队列的原理,把一个个的消息放到像队列一样的容器里。
特点:
1、消息队列是有顺序的
2、消息队列系统是可以存放数据的
场景:
1.用户点击按钮发送短信,有没有收到短信系统其实并不知道
答疑: 用户点击了获取短信的按钮,主线程收到指令以后,fork 一个新的线程来去处理发送短信,然后主线程继续执行后续的操作。
2.大家在使用各大第三方系统的时候是不是个回调,如果回调没有调通怎么办
3.秒杀的时候商品只有100个的时候怎么处理
4.需要和第三方数据通讯的时候 对方掉线了怎么办
5.如果我需要给别人发回调 别人没有收到咋办
6.我系统需要大量的记录日志的时候怎么记
考虑:
1.我接下来的操作是不是必须成功
2.我接下来的操作用户有没有必要参与
3.接下来的操作是不是费时
如果是命中这三项其中一项,那么我们就可以把这个操作进行异步处理(PS:注意这里不是多线程,而是多进程。PHP支持多进程也支持多线程)。
其实 php 在这里是可以用多线程来处理异步的问题,为啥不用呢?
1.从语言的角度来说 php的多线程需要依赖第三方库,而且比较弱,会出现子线程阻塞的问题,还有线程回收与释放的问题 不像其它语言那么灵活
2.多线程来处理这类的问题只解决了费时的场景,和用户无需参与的场景,并没有解决保证成功的场景
以上都是 php 基于 sapi 运行的情况,也就是基于 web 服务运行 php 的场景,也就是大家用 apache 或者 nginx 的时候,cli 模式下运行 php是另外的模型了。
为什么多线程不能解决保证成功的场景?
答:如果我用多线程处理这个问题,我请求网络还是失败,这个时候怎么办?
1.子线程继续等待,循环直到成功
2.子线程销毁,继续 fork 新线程直到成功
那么就很容易出现有线程一直阻塞在这里不会被释放的现象吧?
如果这种异常情况多了 大家想一下 你的电脑的内存和 cpu 是不是瞬间就被撑爆了?
那么需要解决刚刚说的那三个场景,就需要一个有存储能力的异步工具,起码失败了你能帮我把失败的东西存起来。
失败了, 我首先做的事情是重试 我不能无限重试,我更需要的是把失败的东西存下来我能找到他,只要消息存下来了,准确的说,消息低成本的存下来了,我就可以重新再尝试,
回到场景一:
用户点击发生短信请求—>系统讲请求放到消息队列系统—>返回给用户成功
另外一个进程去消息队列系统里消息—>拿到消息之后处理—>处理成功把消息删掉—>处理失败把消息放回系统
总结:
队列系统 并不是一个系统 而是一个概念,只要你能满足我说的两个条件的,都可以广义的说是队列系统了。
比如 mysql 可以设计成队列系统,redis 同理。