本文介绍: MQ(消息队列),存放消息的队列,异步调用中的Broker,先进先出(FIFO)。Kafka每秒吞吐量达百万级;RockertMQ每秒吞吐量达十万级;RabbitMQ每秒吞吐量达十万级左右,但是它消息延迟仅仅是微秒的,可靠性高;考虑大部分情况下公司是达不到每秒吞吐量百万级的,所以选择RabbitMQ。RabbitMQ官网publisher:消息发送者exchange:交换机,负责路由消息queue:队列,存储消息consumer:消息的消费者。

优势:

  • 解耦,拓展性强
  • 无需等待,性能好
  • 故障隔离
  • 缓存消息,流量削峰填谷
    缺点:
  • 实时性差
  • 不确定下游业务是否执行成功
  • 业务安全依赖于Broker(消息代理)的可靠性

三、MQ介绍

MQ(消息队列),存放消息的队列,异步调用中的Broker,先进先出(FIFO)。
在这里插入图片描述
Kafka每秒吞吐量达百万级;
RockertMQ每秒吞吐量达十万级;
RabbitMQ每秒吞吐量达十万级左右,但是它消息延迟仅仅是微秒的,可靠性高;
考虑大部分情况下公司是达不到每秒吞吐量百万级的,所以选择RabbitMQ。
RabbitMQ官网

1.安装RabbitMQ

docker run -d -p 15672:15672  -p  5672:5672  -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin --name rabbitmq --hostname=rabbitmqhostone  rabbitmq

下载rabbitmq并且启动成功之后,可以直接访问http://localhost:15672,用户名密码都是admin
在这里插入图片描述

2.介绍RabbitMQ

RabbitMQ整体架构及核心概念:

  • publisher:消息发送者
  • exchange:交换机,负责路由消息
  • queue:队列,存储消息
  • consumer:消息的消费者
  • virtual-host:虚拟主机,起到数据隔离的作用
    在这里插入图片描述

3.页面简单使用

  1. 登录在这里插入图片描述

  2. 创建用户
    在这里插入图片描述

  3. 创建exchange,我创建的是test在这里插入图片描述

  4. 创建queue在这里插入图片描述

  5. 将exchange和queue关联起来,关联可以在queues中操作,也可以在exchanges中操作
    在这里插入图片描述在这里插入图片描述

  6. 测试发送消息
    在这里插入图片描述

  • 进入exchange搜索我们创建的exchange
    在这里插入图片描述
  • 点击Name,可以进入详情页,查看到绑定的queue,可以发送消息
    在这里插入图片描述
  • 发送消息之后可以看到有发送的记录数据
    在这里插入图片描述
  • 进去queue页面可以看到通过exchange发送消息的队列中有了1条消息
    在这里插入图片描述
  • 点击Name进入详情,可以查看消息内容

原文地址:https://blog.csdn.net/qq_35716085/article/details/135868206

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。

如若转载,请注明出处:http://www.7code.cn/show_63391.html

如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除!

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注