栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

RabbitMQ

RabbitMQ

1、特点

        先进先出、先进后出

        消息服务中间件来提升系统异步通信、扩展解耦能力         

2、运用场景

        异步任务

        注册和发发对应的信息做成两步分隔。中间由消息队列连接
        区分线程池的异步。使用消息中间件注册后不需要等待。线程池需要等待所有完成

        应用解耦 

订单系统调用库存的接口参数多。如果参数变化需要更改代码。使用消息队列。把参数写入消息队列。库存系统取消息队列获取参数。这样不需要更改代码。

         流量控制

大并发下。用原先处理流程。会导致系统处理慢,后台系统阻塞,系统资源耗尽,机器宕机。

使用消息队列。请求都进入消息队列。前台先给处理完成。后台慢慢处理。

 3、概述

        消息代理:安装了消息中间件的服务器

        目的地:

                1、队列:点对点消息通信(单体应用一样)

                2、主题:发布(publish)/订阅(subscribe)消息通信

        点对点:

                消息发送者发送消息,消息代理将其放入一个队列中,消息接收者从队列中获 取消息内容,消息读取后被移出队列                 消息只有唯一的发送者和接受者,但并不是说只能有一个接收者         发布订阅式:                 发送者发送消息到主题,多个接受者监听这个主题,那么就会在消息到达时同时收到消息                  JMS JAVA消息服务                 基于JVM消息代理的规范。ActiveMQ、HornetMQ是JMS实现         AMQP (Advanced Message Queuing Protocol)                 高级消息队列协议,也是一个消息代理的规范,兼容JMS                 RabbitMQ是AMQP的实现

4、概念

        Message:

                消息是不具名的,它有消息头和消息体组成。消息体是不透明的(不是显示获取的),而消息头则有一系列的可选属性组成   ,这些属性包括routing-key(路由键)    ,priority(相对于其他消息的优先权)    、delivery-mode(指出改消息可能需要持久性存储)等

        Publisher:

                消息的生产者,是一个想交换器发布小区的客户端应用程序

        Exchange:

                 交换器,用来接受生成着发送的消息并将这些消息路由给服务器中的队列。

                  Exchange有4中类型:direct(默认),fanout,topic,和headers,不同类型的Exchange转发消息的策略有所有区别

        Queue:

                消息队列,用来保存消息知道发送给消费者。它是消息的容器,也是消息的终点,一个消息可投入一个或多个队列。消息一直在队列里面,等待消费者连接到这个队列将其取走

        Binding

                绑定,用户消息队列和交换器之间的关联,一个绑定就是基于路由键将交换器和消息队列连接起来的,所以可以将交换器理解成一个有绑定构成的路由表。

                Exchange和Queue的绑定可以是多对多得关系

        Connection:

                网络连接,一个TCP连接

        Channel:

                信道,多路复用连接中的一条独立的双线数据流通道。信道是建立在真实的TCP连接内的虚拟连接,AMQP命令都是通过信道发出去的。不管是发布消息、订阅队列还是接收消息,这些动作都是通过信道完成。因为对于操作系统来说建立和销毁TCP都是非常昂贵的开销,所以引入了信道的概念,以复用一条TCP连接。

        Consumer:

        消息的消费者,表示一个从消息队列中取得消息的客户端应用程序。

        Broker:        

        表示消息队列服务器实体

        Virtual Host

        虚拟主机,表示一批交互器,消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个vhost本质上就是一个mini版的RabbitMQ服务器。用有自己的队列、交换器、绑定和权限机制。vhost是AMQP概念的基础。必须在连接是指定,RabbitMQ默认的vhost是/

5、Docker安装RabbitMQ

        

docker run -d --name rabbitmq -p 5671:5671 -p 5672:5672 -p 4369:4369 -p 25672:25672 -p 15671:15671 -p 15672:15672 rabbitmq:management

6、RabbitMQ运行机制

        AMQP 中的消息路由: AMQP 中消息的路由过程和 Java 开 发者熟悉的 JMS 存在一些差别, AMQP 中增加了 Exchange 和 Binding 的角色。生产者把消息发布 到 Exchange 上,消息最终到达队列 并被消费者接收,而 Binding 决定交 换器的消息应该发送到那个队列。

  

7、Exchange类型

        Exchange分发消息时根据类型的不同分发策略有区别,目前共四种类型: direct 、 fanout 、 topic 、 headers 。 headers 匹配 AMQP 消息的 header 而不是路由键, headers 交换器和 direct 交换器完全一致,但性能差很多,目前几乎用不到了,所以直接 看另外三种类型:                 Direct (直接的)Exchange: (类 似于sql语句的=查询  select * from Bindings where bingding-key =routing key ) 消息中的路由键( routing key )如果和 Binding 中的 binding key 一致, 交换器 就将消息发到对应的队列中。路由键与队 列名完全匹配,如果一个队列绑定到交换 机要求路由键为“dog” ,则只转发 routing key 标记为“ dog” 的消息,不会转发 “dog.puppy” ,也不会转发“ dog.guard” 等等。它是完全匹配、单播的模式。

  路由键(routing key)为dog 根据绑定关系Bindings完全匹配dog 到指定队列Queues

Fanout (扇出)Exchange (类型于sql语句查询 * select * from Bindings  )

        (发布到所有跟这个交换器绑定的队列里)

        每个发到 fanout 类型交换器的消息都 会分到所有绑定的队列上去。fanout 交 换器不处理路由键,只是简单的将队列 绑定到交换器上,每个发送到交换器的 消息都会被转发到与该交换器绑定的所 有队列上。很像子网广播,每台子网内 的主机都获得了一份复制的消息。 fanout 类型转发消息是最快的。

Topic (主题)Exchange (Exchange 就是对应的库名如mysql库,类似于sql语句的like 模糊查询,Bindings 就是表 ,bingding-key 就是字段列   ,routtiing key 就是参数   select * from Bindings where bingding-key like '%routtiing key %')

        topic 交换器通过模式匹配分配消息的 路由键属性,将路由键和某个模式进行 匹配,此时列需要绑定到一个模式上。 它将路由键和绑定键的字符串切分成单 词,这些单词之间用点隔开 。它同样也 会识别两个通配符:符号“#” 和符号 “* ”。 # 匹配 0 个或多个单词, * 匹配一 个单词。

总结:一个消息的流程

        

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/651689.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号