个人博客
0%

【RabbitMQ】RabbitMQ入门

发表于 分类于

关于rabbitmq的介绍和安装

1 MQ引言

1.1 MQ介绍

  • MQ（Message Quene）：翻译为消息队列，通过典型的生产者和消费者模型。生成者不断向消息队列中生成消息，消费者不断从队列中获取信息。因为消息的生产和消费都是异步的，而且只关系消息的发送和接收，没有业务逻辑的侵入，轻松实现系统间解耦，通过利用高效可靠的消息传递机制进行平台无关的数据交流，基于数据通信来进行分布式系统的集成

1.2 MQ种类

  • 市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自出开发RockerMQ等

1.3 不同MQ特点

  • 1.ActiveMQ
    • ActiveMQ 是Apache出品，最流行的，能力强劲的开源消息总线，它是一个完全支持JMS规范的消息中间件，丰富的API，多种集群架构模式让ActiveMQ在业界中称为了老牌的消息中间件，在中小型企业颇受欢迎
  • 2.Kafka
    • Kakfa是LinkedIn开源的分布式发布-订阅消息系统，目前归属于Apache顶级项目。Kafka主要特点是基于pull的模式来处理消息消费，追求高吞吐量，一来是的目的就是用于日志收集和传输，0.8版本开始支持复制，不支持事务，对消息的重复，丢失，没有严格要求，适合产生大量数据的互联网服务的数据收集服务
  • 3.RocketMQ
    • RocketMQ是阿里开源的消息中间件，它是纯Java开发，具有高吞吐量，高可用性，适合大规模分布式系统应用的特点。RockerMQ思路起源于Kafka，但并不是Kafka的一个复制品，它对消息的可靠传输及事务性做了优化。目前在阿里集团被广泛应用于交易，充值，流计算，消息推送，日志流式处理，binglong分发等场景
  • 4.RabbitMQ
    • RabbitMQ是使用Erlang语言开发的开源消息队列系统，基于AMQP协议来实现，AMQP的主要特征是面向消息、队列、路由（包括点对点 和 发布/订阅去）、可靠性、安全、AMQP协议更多用在企业系统内对数据一致性，稳定性和可靠性需求很高的场景，对性能和吞吐量的要求还在其次

1.4 MQ使用场景

  • （1）流量消峰
  • 在处理能力能够应付的前提下，用户下单一秒后获得反馈。但下单次数过高，正常情况下就是超出处理上限的订单禁止下单。但使用MQ后，对订单进行缓存，可以把订单分散为一段时间来处理，打破下单1s后反馈，可能10几s后再进行反馈。用户体验比无法下单要强
  • （2）应用解耦
  • 当一个应用程序包含多个系统时，其中一个系统的调用，耦合调用其他系统时。一旦其他系统中出现故障，会立马造成下单异常。但如果用MQ进行缓存，可以进行等待，等故障修复后继续执行，不会产生异常，提高用户体验。
  • （3）异步处理
  • 服务A调用服务B是异步操作，服务B需要很长时间执行，但服务A需要服务B什么时候执行完。不适用MQ，则需服务A定时发送请求服务B，查看是否完成。使用MQ后，服务B完成后发送消息给MQ，MQ再发送消息给服务A

2 RabbitMQ使用

2.1 RabbitMQ

  • RabbitMQ是基于AMOP协议，erlang语言开发，是部署最广泛的开源消息中间件，是最受欢迎的开源消息中间件之一
  • AMOP（advanced message queuing protocol），模型如下：

2.2 RabbitMQ概念

  • （1）生产者
  • 产生数据发送消息的程序
  • （2）交换机
  • 用户接受生成者发送的消息，并将消息推送到队列中。将消息推送到特定队列，或推送到多个队列，或将此消息丢弃，全由交换机负责
  • 一个交换机，可以绑定多个队列
  • （3）队列
  • RabbitMQ内容中使用的一种数据结构，是一个缓冲区，用于存储消息
  • （4）消费者
  • 处理消息的程序

2.3 下载和安装

本次安装使用虚拟机CentOS8.3.2011

  • （2）安装
    1
    2
    3
    4
    5
    6
    7
    8
    # 安装erlang
    rpm -ivh erlang安装包名

    # 安装rabbitMQ依赖
    yum install socat -y

    # 安装rabbitMQ
    rpm -ivh rabbitMQ安装包名
  • （3）报错解决
  • 安装rabbitmq报错
    • 命令vim /usr/lib/tmpfiles.d/rabbitmq-server.conf，将/var/run/rabbitmq改为/run/rabbitmq
  • 启动测试
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    # 服务启动（前台显示）
    rabbitmq-server start

    # 服务启动（后台）
    systemctl start rabbitmq-server
    /sbin/service rabbitmq-server start

    # 服务关闭
    systemctl stop rabbit-server
    /sbin/service rabbitmq-server stop

    # 服务启动查看
    systemctl status rabbitmq-server
    /sbin/service rabbit-server status

2.4 rabbitmq-web管理

  • （1）插件安装
    1
    2
    # web插件安装
    rabbitmq-plugins enable rabbitmq_management
  • （2）登录用户权限
    1
    2
    3
    4
    5
    6
    7
    # 创建rabbitmq配置文件
    vim /ect/rabbitmq/rabbitmq.conf

    # 输入用户权限内容（开放使用）
    loopback_users=none

    # 内容输入完保存退出即可
  • （2）防火墙开放端口
  • rabbitmq的默认端口号为5672
  • rabbitmq的web界面默认端口号为15672
    1
    2
    3
    4
    5
    6
    # 添加开放端口
    firewall-cmd --permanent --add-port=5672/tcp
    firewall-cmd --permanent --add-port=15672/tcp

    # 重启防火墙
    firewall-cmd --reload
  • （3）查看虚拟机ip地址
    1
    ifconfig
  • （4）连接web界面
  • 重启rabbitmq服务
  • 非虚拟机浏览器输入地址：ip地址:15672
  • 默认用户名、密码都为guest