ITPub博客

首页 > 应用开发 > IT综合 > MQ消息队列_RabbitMQ

MQ消息队列_RabbitMQ

原创 IT综合 作者:mi_zy 时间:2020-02-22 17:08:21 0 删除 编辑

MQ消息队列中间件— Rabbit MQ

消息中间件主要用于组件之间的解耦,消息的发送者无需知道消息使用者的存在,反之亦然。

https://blog.csdn.net/cdefggg/article/details/88375249

1、 Message Quene是应用程序对应用程序的通信方法。异步RPC的主要手段之一。不需要直接调用彼此来通信。

2、Rabbit MQ(开源消息代理)是实现AMQP(应用层开放标准advanced message queuing protocal提供统一消息服务)协议的MQ产品。

3、消息的生产者Producer--->消息队列----->消息的消费者

4、 安装 Rabbit MQ:windows计算机名用英文,关闭安全软件:   

        1)Erlang环境(编程语言): opt_win64_17.3.exe

             http://www.erlang.org/download/otp_win64_17.3.exe

        2)按照RabbitMQ服务: rabbitmq-server-3.4.1.exe

5、安装完测试:打开 rabbitMQ command prompt

    输入rabbitmq-plugins enable rabbitmq_management启动后台服务软件,浏览器输入127.0.0.1:15672 ,用户名/密码:guest/guest

6、overview:显示消息队列,节点,路径,端口( AMQP端口5672,集群端口25672,web管理端口15672

        connections:

        channels:数据通道(持久化的队列在管理页面可以看到有个“D”,durable为true)

        exchanges:交换机,类型,可以添加交换机。

            点击Exchange的Name可进入到Exchange的详情页面,在里面将Exchange与Queue进行Binding

            测试: 点进交换器之后有一栏是Publish message发送成功后切换到Queues查看是否收到消息,点击ls队列进去查看, 展开Get message选项,点击GetMessage(s)就能得到消息了。

            测试: https://blog.csdn.net/qq_41097820/article/details/88793329

        quenes:队列

                    Message

      • Ready: 队列中等待消费的消息
      • Unacked:队列中等待被确认的消息(此时消息已到达消费者,但是未被确认)
      • Total:队列中消息总数

        admin:添加用户等,Tags指角色;添加virtual host(关联到用户access,起隔离作用,每个vhost本质上就是一个mini版的rabbitmq服务器,拥有自己的队列、交换机、绑定和权限机制)。

7、MQ中的最小对象:消息=消息描述符+用户数据,队列定义的长度制约消息的长度。队列:先进先出FIFO,对远程队列的访问需要使用”通道“。包含关系:消息<队列<队列管理器,三者组合唯一确定一个消息。

8、通道:应用在队列管理器与队列管理器之间的,单向的点对点的通信连接:

  •     单一方向;

  •     通常成对使用;

如果要在  队列管理器与队列管理器之间实现消息传输,必须在两个队列管理器上都要定义相应的通道。

9、RabbitMQ中生产者将消息发送到Exchange(交换器),由Exchange将消息路由到一个或多个Queue中(或者丢弃)。RabbitMQ中通过Binding将Exchange与Queue关联起来,这样RabbitMQ就知道如何正确地将消息路由到指定的Queue了。

10、对于rabbitmq来说,一个broker可以看成一个rabbitmq服务节点,,或者服务实例。也可以将一个broker看做一台rabbitmq服务器

11、rabbitmq有一个最大内存阈值,可以通过配置来实现。当接收的消息达到最大阈值时,rabbitmq不会再接收消息,并进入阻塞状态。rabbitmq有一个内存换页阈值,当达到换页阈值时,将当前内存内的消息放入到磁盘内,而此时会区分持久化消息和非持久化消息。持久化消息因为在接收到消息后就已经存入磁盘,所以在换页时不会重复存入磁盘。此时只会将非持久化消息存入到磁盘内。

12、当内存使用超过配置的阈值或者磁盘剩余空间低于配置的阈值时,rabbitmq会出现告警。此时会暂时阻塞客户端连接(显示blocked),并停止接收客户端发来的消息,以避免服务器崩溃,客户端与服务端的心跳检测也会失效。

13、发送可靠性:确保消息成功发送到broker

        At most once:最多一次,消息可能会丢失,但不会重复传输

        At least once:最少一次,消息不会丢失,但可能重复传输

        Exactly once:恰好一次,保证每条消息都被传输到broker且仅传输一次

RabbitMQ支持:At most once和At least once

14、abbitMQ的六种工作模式:

  • 1、Work queues

  • 2、Publish/subscribe

  • 3、Routing

  • 4、Topics

  • 5、Header 模式

  • 6、RPC

15、Exchange Types有 fanout、direct、topic、headers这四种类型:

        fanout类型:广播模式,Exchange路由规则非常简单,它会把所有发送到该Exchange的消息路由到所有与它绑定的Queue中。

        direct类型: Exchange路由规则也很简单,它会把消息路由到那些binding key与routing key完全匹配的Queue中,binding key == routing key。

        topic message类型:binding key like routing key, 其中routing key中可以带 * 和 # 来做模糊匹配, “*”用于匹配一个单词,“#”用于0~N个单词.

        headers类型: Exchange不依赖于routing key与binding key的匹配规则来路由消息,而是根据发送的消息内容中的headers属性进行匹配。




来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/7970627/viewspace-2676779/,如需转载,请注明出处,否则将追究法律责任。

上一篇: Docker
请登录后发表评论 登录
全部评论
空管自动化,传输,对空通信

注册时间:2011-02-02

  • 博文量
    196
  • 访问量
    351739