• RabbitMQ系列-概念及安装


    1. 消息队列

    消息队列是指利用队列这种数据结构进行消息发送、缓存、接收,使得进程间能相互通信,是点对点的通信

    而消息代理是对消息队列的扩展,支持对消息的路由,是发布-订阅模式的通信,消息的发送者并不清楚消息的接收者,消息可以被多个消费者接收。

    使用消息队列的作用如下

    异步:对于一些用户的请求,可能包含一些发送短信,发送邮件等系统处理,此时可以不需要等待短息发送完成或者邮件发送完成,而是通过消息队列通知这些模块即可返回,避免用户长时间等待

    解耦:将数据发送到消息队列,对该数据感兴趣的系统自行订阅该消息即可,这种做法可以降低代码的耦合度。

    消峰填谷:将瞬时高并发请求打到消息队队列上,作为数据库请求的缓冲,避免短时间大量的数据库请求导致数据库奔溃。

     

    2. RabbitMQ简介

    RabbitMQ是一种开源的多协议消息代理软件,它将消息发布者(发布消息的应用程序,也称为生产者)接收消息并将它们路由到消费者(处理消息的应用程序)。

    RabbitMQ支持多种消息传递协议,其中AMQP 0-9-1是核心,并以插件的形式支持STOM,MQTT,AMQP 1.0。

    AMQP,即Advanced Message Queuing Protocol,中文名称是高级消息传递协议。

    AMQP 0-9-1 模型如下图所示

    消息生产者producer和消费者consumer均通过TCP连接消息代理broker,生产者producer将消息投递到交换机exchange,消息代理根据消息队列queue和交换机exchange的绑定关系bind将消息推送到对应的消息队列queue,最后消费者consumer消费感兴趣消息队列中的数据。

     

    2.1 RabbitMQ中的相关概念

    Producer:消息生产者

    Consumer:消息消费者

    Broker:消息代理,这里指即RabbitMQ,通过消息代理可以将消息从生产者投递到消费者

    Virtual host:虚拟主机,使单个消息代理能提供了多个相对隔离的环境,隔离的资源包括交换机、队列等

    Exchange:交换机,作用相当于现实生活的快递公司,生产者的消息实际时先投递到交换机,交换机再根据类型和绑定关系拷贝消息副本到指定队列,交换机的类型有directtopicheaders and fanout

    Queue: 队列,先进先出的优先级队列,充当了一个缓冲区的角色,作用相当于现实生活中的菜鸟驿站等代收点

    Binding:交换机和队列的绑定关系,交换机投递消息到指定队列的规则,作用相当于现实生活中寄快递时填写的地址

    Connection: 消息生产者和消费者通过TCP连接到虚拟主机,确保数据传输到可靠性

    Channel:共享单个TCP连接的轻量级的Connection,不同Channel通过Channel ID隔离开,互不影响,通常一个进程可以只建立一个TCP连接,减少TCP的资源开销

     

    2.2 RabbitMQ特性

    可靠性(Reliablity):使用TCP连接进行数据传输、且提供了消息持久化、队列持久化、生产者发送确认、消费者消费确认等机制保证消息的可靠

    灵活的路由(Flexible Routing):提供了多种类型的交换机Exchange

    消息集群(Clustering):多个RabbitMQ服务器可以组成一个集群,形成一个逻辑消息代理Broker

    高可用(Highly Avaliable Queues):队列可以在集群中的机器上进行镜像,使得在部分节点出问题的情况下队列仍然可用

    多种协议(Multi-protocol):支持多种消息队列协议,核心是AMQP,通过插件形式支持STOMP、MQTT等

    多种语言客户端(Many Clients):几乎支持所有常用语言,比如Java、Python、Golang等

    管理界面(Management UI):提供了易用的用户界面,使得用户可以监控和管理消息Broker的许多方面

    跟踪机制(Tracing):如果消息异常,RabbitMQ提供了消息的跟踪机制,使用者可以找出发生了什么

    插件机制(Plugin System):提供了许多插件,来从多方面进行扩展,也可以编辑自己的插件

     

    3. RabbitMQ安装

    3.1 安装Docker

    参考Install Docker Desktop on Mac安装docker,安装完成后点击Docker图标以启动Docker服务

    这里简单介绍几个常用的docker命令

    docker ps -a可以看到Docker启动过的容器

    $ docker ps -a
    CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
    8918b9e8bae2 rabbitmq:3-management "docker-entrypoint.s…" 2 days ago Up 2 days 4369/tcp, 5671/tcp, 0.0.0.0:5672->5672/tcp, 15671/tcp, 15691-15692/tcp, 25672/tcp, 0.0.0.0:15672->15672/tcp some-rabbit

    docker stop CONTAINER ID停止运行中的容器

    $ docker stop 8918b9e8bae2
    8918b9e8bae2

    docker restart CONTAINER ID重启容器

    $ docker restart 8918b9e8bae2
    8918b9e8bae2

    docker exec -it CONTAINER ID /bin/bash 可以进入运行容器的终端

    $ docker exec -it 8918b9e8bae2 /bin/bash
    root@my-rabbit:/#

     

    3.2 RabbitMQ安装及启动

    打开终端,在终端中输入

    docker run -d --hostname my-rabbit --name some-rabbit -p 15672:15672 -p 5672:5672 rabbitmq:3-management

    通过http://localhost:15672可以访问管理后台,默认账号和密码均是guest

    5672AMQP 0-9-1 使用的端口

     

    4. 管理后台

    管理后台提供了监控和管理RabbitMQ节点和集群的能力。

    管理后台如下图所示

    通过该管理后台,可以查看当前活跃的Connection, Channel, Exchange, Queue等信息,从图片可以看出当前活跃的Exchange共有7个,具体的类型覆盖了directtopicheaders and fanout四种。

    通过这个管理后台也可以创建或者删除Connection, Channel, Exchange, Queue

     

  • 相关阅读:
    20220912深圳市梧桐山桃花源看植物
    buu(ssti模板注入、ssrf服务器请求伪造)
    剑指offer(C++)-JZ29:顺时针打印矩阵(算法-模拟)
    TCP/IP(十三)滑动窗口
    skywalking展示http请求和响应
    vmware官网下载(VMware workstation 下载与安装)
    mysql基础部分第一次复习(1-8章,到聚合函数)
    python学习笔记——集合
    今天的码农女孩学习了关于react子父组件传值的知识,并做了小练习
    iOS“超级签名”绕过App Store作弊解决方案
  • 原文地址:https://www.cnblogs.com/amos01/p/17335001.html