JiFu's Wiki JiFu's Wiki
首页
  • HTML
  • JavaScript
  • NodeJS
  • Vuejs
  • 微信小程序
  • Python
  • 数据库
  • 中间件
  • 算法
  • 软件工程
  • Wordpress
  • iOS开发
  • Android开发
  • Linux
  • Windows
  • MacOS
  • Docker
  • Vim
  • VSCode
  • Office
  • 其他
  • Photoshop
  • Sketch
  • Mac
  • 游戏
关于
  • 分类
  • 标签
  • 归档
GitHub (opens new window)
首页
  • HTML
  • JavaScript
  • NodeJS
  • Vuejs
  • 微信小程序
  • Python
  • 数据库
  • 中间件
  • 算法
  • 软件工程
  • Wordpress
  • iOS开发
  • Android开发
  • Linux
  • Windows
  • MacOS
  • Docker
  • Vim
  • VSCode
  • Office
  • 其他
  • Photoshop
  • Sketch
  • Mac
  • 游戏
关于
  • 分类
  • 标签
  • 归档
GitHub (opens new window)
  • 数据库

  • Python

  • 中间件

    • Nginx

    • Gogs

    • Sentry

    • Jenkins

    • Shadowsocks

    • Logstash

    • RabbitMQ

      • RabbitMQ介绍
      • RabbitMQ入门
        • 安装erlang
        • 安装rabbitmq
        • 开启web访问
        • 访问测试
        • direct交换器
        • fanout交换器
        • topic交换器
      • RabbitMQ集群高可用原理及实战部署介绍1
    • Gitlab

    • 宝塔

  • 算法

  • 软件工程

  • Wordpress

  • 后端技术
  • 中间件
  • RabbitMQ
JiFu
2023-10-18
目录

RabbitMQ入门

# 前言

刚开始接触RabbitMQ的时候,有些概念那理解起来简直是像风像雨又像雾,晦涩难懂。 这篇文章用尽可能浅显的语言来解释RabbitMQ的入门知识。毕竟是入门课程,并没有对很多概念进行深入说明,如果你想更深入的了解RabbitMQ,可以继续关注本头条号后续发布的文章或者自己从网上搜寻了资料,自己探索研究。

# RabbitMQ是什么

官方定义:RabbitMQ是一种消息中间件,用于处理来自客户端的异步消息。服务端将要发送的消息放入到队列池中。接收端可以根据RabbitMQ配置的转发机制接收服务端发来的消息。RabbitMQ依据指定的转发规则进行消息的转发、缓冲和持久化操作,主要用在多服务器间或单服务器的子系统间进行通信,是分布式系统标准的配置。 趣味定义:兔子行动非常迅速而且繁殖起来也非常疯狂,用Rabbit来命名这个分布式软件,呼应了RabbitMQ的主要任务是处理海量的信息

# 安装

# 安装erlang

下载地址:http://erlang.org/download/otp_win64_21.0.1.exe

# 安装rabbitmq

下载地址:https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.7/rabbitmq-server-3.7.7.exe 如果你要安装其它版本,注意版本对应:https://www.rabbitmq.com/which-erlang.html

# 开启web访问

Windows下:打开CMD 进入rabbitmq的安装目录 执行rabbitmq-plugins enable rabbitmq_management命令. 该命令,仅在首次运行RMQ时使用!!!目的就是加载Web插件!!!

# 访问测试

测试地址 http://localhost:15672/

默认用户名:guest 默认密码:guest

# 核心概念

> https://content.pivotal.io/rabbitmq/understanding-when-to-use-rabbitmq-or-apache-kafka

RabbitMQ broker: 原话是RabbitMQ isn’t a food truck, it’s a delivery service,其实说白了,就是一种传输服务。 Exchange: 接受生产者发送的消息,并根据Binding规则将消息路由给服务器中的队列。ExchangeType决定了Exchange路由消息的行为。在RabbitMQ中,ExchangeType常用的有direct、Fanout和Topic三种,在第三部分会详细介绍。 Message Queue: 消息队列。我们发送给RabbitMQ的消息最后都会到达各种queue,并且存储在其中(如果路由找不到相应的queue则数据会丢失),等待消费者来取。 Binding Key:它表示的是Exchange与Message Queue是通过binding key进行联系的,这个关系是固定的,初始化的时候,我们就会建立该队列。 Routing Key:生产者在将消息发送给Exchange的时候,一般会指定一个routing key,来指定这个消息的路由规则。这个routing key需要与Exchange Type及binding key联合使用才能生,我们的生产者只需要通过指定routing key来决定消息流向哪里。

我的注释:初始化的时候,exchange与各个队列的绑定关系是通过binding key进行绑定的;发送消息的时候,使用的routing key就是binding key的某一个(实质,两者是一个含义,角度不同,名称含义不同) 对于消费端来说,只用知道MQ的virtual host 和queue的名称就可以了。而对于发送端,则需要知道exchange和routing key的名称,相对而言queue的名称就不那么重要了(不过也要依Exchange Type而定)。 以下是RabbitMQ最简单的流程图,相信看到这里的你,对MQ的运作流程应该会有个基本的了解了:

# 三种ExchangeType

> http://www.rabbitmq.com/tutorials/amqp-concepts.html
> 这里介绍三种最主要的类型的exchange:direct、fanout和topic。

# direct交换器

Direct交换器很简单,如果是Direct类型,就会将消息中的RoutingKey与该Exchange关联的所有Binding中的BindingKey进行比较,如果相等,则发送到该Binding对应的Queue中。有一个需要注意的地方:如果找不到指定的exchange,就会报错。但routing key找不到的话,不会报错,这条消息会直接丢失,所以此处要小心。

# fanout交换器

Fanout 扇出,顾名思义,就是像风扇吹面粉一样,吹得到处都是。如果使用fanout类型的exchange,那么routing key就不重要了。因为凡是绑定到这个exchange的queue,都会受到消息。

# topic交换器

  • direct是将消息放到exchange绑定的一个queue里(一对一);
  • fanout是将消息放到exchange绑定的所有queue里(一对所有) 那可不可以把消息放到exchange绑定的一部分queue里,或者多个routing key可以路由到一个queue里呢?
  • topic类型的exchange就可以实现(一对部分)。
  • topic应用场景:打印不同级别的错误日志 例如,我们的系统出错后会根据不同的错误级别生成error_levelX.log日志,我们在后台首先要把所有的error保存在一个总的queue(绑定了一个*.error的路由键)里,然后再按level分别存放在不同的queue。

# routing key绑定

# 参考资料

-RabbitMQ 入门秘籍,三分钟带你快速了解RabbitMQ (opens new window)

上次更新: 2024/08/11, 01:59:03
RabbitMQ介绍
RabbitMQ集群高可用原理及实战部署介绍1

← RabbitMQ介绍 RabbitMQ集群高可用原理及实战部署介绍1→

最近更新
01
Disable notification "to get future google chrome updates you'll need macos 10.13 or later" on mac
05-14
02
MacOS软件推荐
04-30
03
Debian Sway开发机安装手册
03-26
更多文章>
Theme by Vdoing | Copyright © 2019-2025 Ji Fu | MIT License
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式