美文网首页
消息队列1

消息队列1

作者: AnneSan | 来源:发表于2019-03-18 17:46 被阅读0次

    什么是队列系统?

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

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

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

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


    含义:

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


    特点:

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

    相关文章

      网友评论

          本文标题:消息队列1

          本文链接:https://www.haomeiwen.com/subject/lcovmqtx.html