RabbitMQ系列-概念及安装

这篇具有很好参考价值的文章主要介绍了RabbitMQ系列-概念及安装。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

1. 消息队列

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

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

使用消息队列的作用如下

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

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

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

 文章来源地址https://www.toymoban.com/news/detail-457782.html

2. RabbitMQ简介

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

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

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

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

RabbitMQ系列-概念及安装

消息生产者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节点和集群的能力。

管理后台如下图所示

RabbitMQ系列-概念及安装

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

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

 

到了这里,关于RabbitMQ系列-概念及安装的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 消息队列之RabbitMQ的安装配置

    RabbitMQ是由erlang语言开发,基于AMQP(Advanced Message Queue 高级消息队列协议)协议实现的消息队列,它是一种应用程序之间的通信方法,消息队列在分布式系统开发中应用非常广泛。点击跳转RabbitMQ官方地址 简单模式,work模式 ,Publish/Subscribe发布与订阅模式,Routing路由模式,

    2024年04月25日
    浏览(41)
  • (四)RabbitMQ高级特性(消费端限流、利用限流实现不公平分发、消息存活时间、优先级队列

    Lison dreamlison@163.com , v1.0.0 , 2023.06.23 之前我们讲过MQ可以对请求进行“削峰填谷”,即通过消费端限流的方式限制消息的拉取速度,达到保护消费端的目的。 1、 生产者批量发送消息 2、消费端配置限流机制 3、消费者监听队列 在RabbitMQ中,多个消费者监听同一条队列,则队列

    2024年02月15日
    浏览(43)
  • 消息队列RabbitMQ.01.安装部署与基本使用

    目录  RabbitMQ的作用 Message queue 释义  问题思考  存在的问题 优化方案  案例分析  带来的好处  消息队列特点  Email邮件案例分析 Docker安装部署RabbitMQ 1.下拉镜像 2.运行RabbitMQ  3.打开防火墙端口号并重新运行防火墙 4.容器启动后,可以通过 docker logs 容器 查看日志 6.通过刚才

    2024年01月24日
    浏览(48)
  • 利用消息中间件RabbitMQ创建队列以及扇出(Fanout)、订阅(Direct)、主题(Topic)交换机来完成消息的发送和监听接收(完整版)

    目录 一、前期项目环境准备 1.1父项目以及子项目 1.2配置pom.xml 1.3配置application.yml 二、扇出(Fanout) 交换机实现消息的发送和接收 2.1编写子项目consumer(消费者,接收消息)的代码实现扇出(Fanout)交换机接收消息 2.1.1consumer子项目结构 2.1.2FanoutConfig类的实现扇出(Fanout)交

    2024年02月05日
    浏览(61)
  • 【Spring云原生系列】Spring RabbitMQ:异步处理机制的基础--消息队列 原理讲解+使用教程

    🎉🎉 欢迎光临,终于等到你啦 🎉🎉 🏅我是 苏泽 ,一位对技术充满热情的探索者和分享者。🚀🚀 🌟持续更新的专栏 《Spring 狂野之旅:从入门到入魔》 🚀 本专栏带你从Spring入门到入魔   这是苏泽的个人主页可以看到我其他的内容哦👇👇 努力的苏泽 http://suzee.blog.

    2024年03月15日
    浏览(53)
  • [小白学微服务]消息队列RabbitMQ 的安装和基础使用

      前言 我们为什么要用消息队列技术? 有些复杂的业务系统,一次用户请求可能会同步调用N个系统的接口,需要等待所有的接口都返回了,才能真正的获取执行结果。 这样就导致了: 1.系统之间耦合性太高,如果调用的任何一个子系统出现异常,整个请求都会异常,对系统

    2024年03月15日
    浏览(94)
  • 消息队列中间件 - Docker安装RabbitMQ、AMQP协议、和主要角色

    不管是微服务还是分布式的系统架构中,消息队列中间件都是不可缺少的一个重要环节,主流的消息队列中间件有RabbitMQ、RocketMQ等等,从这篇开始详细介绍以RabbitMQ为代表的消息队列中间件。 AMQP协议 AMQP协议是一个提供统一消息服务的应用层标准协议,基于此协议的客户端与

    2024年02月03日
    浏览(61)
  • RabbitMQ系列(10)--RabbitMQ发布确认模式的概念及实现

    概念:虽然我们可以设置队列和队列中的消息持久化,但任然存在消息在持久化的过程中,即在写入磁盘的过程中,消息未完全写入,然后服务器宕机导致消息丢失的情况,发布确认就是为了解决这种情况的概念,在消息完全写入磁盘后才确认消息完全持久化了 1、发布确认

    2024年02月13日
    浏览(39)
  • RabbitMQ实现延迟消息,RabbitMQ使用死信队列实现延迟消息,RabbitMQ延时队列插件

    假设有一个业务场景:超过30分钟未付款的订单自动关闭,这个功能应该怎么实现? RabbitMQ使用死信队列,可以实现消息的延迟接收。 队列有一个消息过期属性。就像丰巢超过24小时就收费一样,通过设置这个属性,超过了指定事件的消息将会被丢弃。 这个属性交:x-message

    2024年02月13日
    浏览(79)
  • RabbitMq消息模型-队列消息

    基本模型(SimpleQueue)、工作模型(WorkQueue) 队列消息特点: 消息不会丢失 并且 有先进先出的顺序。 消息接收是有顺序的,不是随机的,仅有一个消费者能拿到数据,而且不同消费者拿不到同一份数据。 基本模型: SimpleQueue 在上图的模型中,有以下几个概念: P:为生产

    2024年02月09日
    浏览(49)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包