Rabbitmq---消息队列

一 . MQ:message queue

  消息队列的作用:   1 通信解耦   2 高峰限流

原理分析:

Rabbitmq---消息队列

一开始,认证系统是强耦合的,A系统传递认证系统消息接收计算结果的过程中

  1 传给认证系统

  2 认证系统计算

  3 返回计算结果

  4 读取A系统逻辑

只要当前计算没有完成,对于认证系统来讲消耗线程资源.并存在强耦合现象

Rabbitmq---消息队列

有了消息队列,每一次连接不管是生成消息还是消费消息,都有各自的逻辑与其他逻辑无关--通信解耦

 

Rabbitmq---消息队列

  通信强耦合的情况下高峰访问拒绝,达到了高峰限流的效果

Rabbitmq---消息队列

二 . Rabbitmq

  1 rabbitmq的结构(组件)

    外部: 生产者和消费者

    生产者:对于消息来讲,生成消息客户端是生产者

    消费者:消费消息执行消费后的逻辑的客户端是消费者

  客户端可以使用各种其他技术或者语言 都不是rabbitmq自身的技术

  2 rabbitmq内部组件

Rabbitmq---消息队列

  connection:基于底层通信逻辑的长连接

  channel:基于长连接创建的;可以在一次长连接的基础上多次频繁的创建和销毁,占用资源非常少

  交换机Exchange   优点:并发能力高 并发稳定

    客户端连接发送消息,多种情况都需要并发的发送,如果从客户端执行并发的发送逻辑,rabbitmq的并发能力就限制在了客户端

    exchange基于erlang语言开发的(并发,可控制线程)

  queue:rabbitmq中的队列,根据不同的情况队列可以完成不同的工作

  使用场景:在项目中,将一些无需即时返回且耗时的操作提取出来,进行了异步处理,而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高了系统的吞吐量。

三 . rabbitmq的五种工作模式

  1 简单模式

  

Rabbitmq---消息队列

  1 )一个生产者将消息交给默认的交换机(AMQP default)

  2 )交换机获取消息后交给绑定的这个生产者的队列(其中关系是通过队列名称完成的)

  3 )监听当前队列的消费者获取消息,执行消费逻辑

    应用场景:短信聊天

  2 工作模式(资源争抢)

  

Rabbitmq---消息队列

  1 )生产者将消息交给交换机

  2 )交换机交给绑定的队列

  3 )队列由多个消费者同时监听,只有其中一个能获取者一条消息,形成了资源的争抢,谁的资源空闲大,争抢到的可能越大

  3 发布订阅(publish/fanout)

Rabbitmq---消息队列

  1 )生产者扔给交换机消息
  2 )交换机根据自身的类型(fanout)将会把所有消息复制同步到所有与其绑定的队列
  3 )每个队列可以有一个消费者,接收消息进行消费逻辑

  4 路由模式(routing/dircet)

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wpppjf.html