消息队列1

2019-03-18  本文已影响0人  AnneSan

什么是队列系统?

可以把队列和栈还有堆想象成一个容器,

队列其实就是我们通常说的排队,可以想象成一个两端开口的容器,先来后到,先进来的就先出去后进来的就后出去。

栈就不一样了,栈大家可以想象成一端开口的容器 ,比如说杯子,先进去的反而后出来。

而堆就是没有口的一个盆,随便进出。


含义:

消息队列系统就是利用队列的原理,把一个个的消息放到像队列一样的容器里。


特点:

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 同理。

上一篇下一篇

猜你喜欢

热点阅读