RabbitMQ(基础概念, 简单使用)(上)

简介: RabbitMQ(基础概念, 简单使用)

本篇文章学习于 bilibili黑马 的视频 (狗头保命)

同步通讯 & 异步通讯 (RabbitMQ 的前置知识)

  • 同步通讯:类似打电话,只有对方接受了你发起的请求,双方才能进行通讯, 同一时刻你只能跟一个人打视频电话。
  • 异步通讯:类似发信息,不用对方接受,你就可以直接发信息,而且可以多线操作,同时跟多人发信息。

同步调用

发送方直接把消息传递给接收者, 如果中间有很多环节, 有一步出错, 那么所有操作都要回滚


同步调用的缺点:

  1. 拓展性差
  2. 性能下降
  3. 级联失败

异步调用方式其实就是基于消息通知的方式,一般包含三个角色:

消息发送者:投递消息的人,就是原来的调用方

消息Broker:管理、暂存、转发消息,你可以把它理解成微信服务器

消息接收者:接收和处理消息的人,就是原来的服务提供方


异步调用中, 发送方把消息发送给消息broker, 就算完成发送任务.

接收者从消息 breker 那里订阅消息

这样,发送消息的人和接收消息的人就完全解耦了。


此时, 如果发送方发送消息出错, 不需要全部回滚, 只需要将错误信息重新发布给消息代理

如果接受方接受消息过程出现错误, 那么消息代理重传就好, 发送方还是可以正常进行其他操作

异步调用的优势:

  1. 耦合度更低
  2. 性能更好
  3. 业务拓展性强
  4. 故障隔离,避免级联失败


异步通信的缺点:

  1. 完全依赖于Broker的可靠性、安全性和性能
  2. 架构复杂,后期维护和调试麻烦

消息Broker,目前常见的实现方案就是消息队列(MessageQueue),简称为MQ.

RabbitMQ是基于Erlang语言开发的开源消息通信中间件.

开启 RabbitMQ

打开这个目录(我的电脑是)

C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.7.4\sbin

双击这个文件

等待命令框为这个状态

点击跳转官网地址

RabbitMQ


RabbitMQ对应的架构


  • publisher:生产者,也就是发送消息的一方
  • consumer:消费者,也就是消费消息的一方
  • queue:队列,存储消息。生产者投递的消息会暂存在消息队列中,等待消费者处理
  • exchange:交换机,负责消息路由。生产者发送的消息由交换机决定投递到哪个队列。
  • virtual host:虚拟主机,起到数据隔离的作用。每个虚拟主机相互独立,有各自的exchange、queue

简单的收发消息 (exchange & queue)

1. 添加 exchange

2. 添加 queue

3. 绑定 exchange 和 queue

点击之前创建的 exchange

添加绑定信息

4. 发送消息

输入信息, 点击发送

5. 查看接受的消息

点击被绑定的队列

获取消息

数据隔离

基于不同用户,将管理权限分离。

基于不同的 virtual host ,将每个项目的数据隔离。

创建用户

此时用户没有 virtral hosts

退出, 重新登录

创建 virtual hosts

此时用户 zrj 已经拥有 virtual hosts 了

将 virtual hosts 切换到 /zrj 之后, 查看 queue, 会发现之前创建的 test.queue 已经看不见了, 这就是基于 用户和 virtual hosts 的数据隔离效果

RabbitMQ(基础概念, 简单使用)(中):https://developer.aliyun.com/article/1518407


相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
1月前
|
消息中间件 中间件 数据安全/隐私保护
RabbitMQ 的核心概念
RabbitMQ 的核心概念
20 2
|
5天前
|
消息中间件 存储 物联网
RocketMQ基础概念
RocketMQ基础概念
18 1
|
18天前
|
消息中间件 存储 Apache
RocketMQ实战教程之常见概念和模型
Apache RocketMQ 实战教程介绍了其核心概念和模型。消息是基本的数据传输单元,主题是消息的分类容器,支持字节、数字和短划线命名,最长64个字符。消息类型包括普通、顺序、事务和定时/延时消息。消息队列是实际存储和传输消息的容器,是主题的分区。消费者分组是一组行为一致的消费者的逻辑集合,也有命名限制。此外,文档还提到了一些使用约束和建议,如主题和消费者组名的命名规则,消息大小限制,请求超时时间等。RocketMQ 提供了多种消息模型,包括发布/订阅模型,有助于理解和优化消息处理。
|
23天前
|
消息中间件 Java API
RabbitMQ(基础概念, 简单使用)(下)
RabbitMQ(基础概念, 简单使用)
22 0
|
23天前
|
消息中间件 存储 Java
RabbitMQ(基础概念, 简单使用)(中)
RabbitMQ(基础概念, 简单使用)
12 0
|
1月前
|
消息中间件 安全 Java
一文读懂RabbitMQ核心概念及架构
一文读懂RabbitMQ核心概念及架构
|
1月前
|
消息中间件 存储 JSON
从兔子说起:深入理解RabbitMQ基础概念【RabbitMQ 一】
从兔子说起:深入理解RabbitMQ基础概念【RabbitMQ 一】
40 0
|
1月前
|
消息中间件 缓存 运维
java消息队列基础和RabbitMQ相关概念(二)
java消息队列基础和RabbitMQ相关概念
56 0
|
1月前
|
消息中间件 存储 Java
java消息队列基础和RabbitMQ相关概念(一)
java消息队列基础和RabbitMQ相关概念
49 0
|
1月前
|
消息中间件 存储 负载均衡
RocketMQ基本概念
RocketMQ基本概念
42 0