rabbitMQ文档

### rabbitMQ文档 #### MQ（消息队列）概述 **MQ**，即**Message Queue**（消息队列），是一种在分布式系统中实现进程间通信的技术。消息队列本质上是一个先进先出（FIFO）的数据结构，用于存储消息直到被消费。这种技术允许不同组件之间解耦，提高系统的灵活性和可扩展性。 **消息队列的作用**主要包括： 1. **异步处理**：通过将任务放入队列，接收方可以在适当的时候处理这些任务，实现了异步处理，提高了系统的响应速度。 2. **应用解耦**：发送方与接收方不需要直接交互，只需要通过消息队列即可完成数据传输，这使得系统各部分之间的依赖减少，易于维护和扩展。 3. **流量削峰**：当短时间内大量请求涌入时，消息队列可以起到缓冲作用，避免后端系统过载崩溃。 4. **日志处理**：通过消息队列收集、处理来自不同系统的日志信息，便于统一管理。 #### MQ的应用案例 - **电商系统**：在电商系统中，商品下单、支付等操作可以通过消息队列异步处理，从而提高用户体验并减轻服务器压力。 - **钢铁电商平台**：类似于一般的电商平台，钢铁电商平台也可以利用消息队列来处理订单、库存更新等逻辑，确保交易的高效稳定。 - **新浪Kafka日志处理**：Kafka作为一款高性能的消息队列，被广泛应用于日志收集和处理场景中，如新浪的网站日志实时处理。 #### 几种主流的消息队列技术 1. **ActiveMQ**：Apache ActiveMQ 是一个完全支持JMS 1.1和J2EE 1.4规范的、功能全面的消息代理服务，提供多种消息传递模式。 2. **RabbitMQ**：RabbitMQ 是基于AMQP标准的一个消息中间件，具有高可用性和扩展性，支持多种消息传递协议。 3. **RocketMQ**：阿里云开源的一款分布式消息中间件，特别适用于高并发场景下的消息推送和存储需求。 4. **Kafka**：最初由LinkedIn开发，现已成为Apache项目的一部分，Kafka是一个分布式的流处理平台，特别适合大数据量的日志收集和处理。 5. **ZeroMQ**：ZeroMQ是一个高性能的异步消息队列库，适用于构建高性能分布式应用。 6. **OpenMQ**：OpenMQ 是一个开源的消息中间件，提供多种消息传递模型，支持JMS API。 #### RabbitMQ详解 **RabbitMQ**是一款基于AMQP协议的消息中间件，提供了丰富的API接口以及强大的插件机制，能够满足各种复杂的应用场景需求。 ##### 安装RabbitMQ 为了安装RabbitMQ，首先需要安装Erlang环境。下面是具体的步骤： 1. **下载并安装Erlang**： ```bash cd ~ && wget http://erlang.org/download/otp_src_18.3.tar.gz cp otp_src_18.3.tar.gz /usr/local/erlang/ && cd /usr/local/erlang/ tar xzvf otp_src_18.3.tar.gz && cd otp_src_18.3 ./configure --prefix=/usr/local/erlang/18.3 && make && make install cd ../ && rm -rf otp_src_18.3 vi /etc/profile # 添加export PATH=$PATH:/usr/local/erlang/18.3/bin source /etc/profile ``` 2. **下载并安装RabbitMQ Server**： ```bash cd ~ && wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.6/rabbitmq-server-generic-unix-3.6.6.tar.xz cp rabbitmq-server-generic-unix-3.6.6.tar.xz /usr/local/rabbitmq/ cd /usr/local/rabbitmq/ && xz -d rabbitmq-server-generic-unix-3.6.6.tar.xz tar -xvf rabbitmq-server-generic-unix-3.6.6.tar && cd rabbitmq_server-3.6.6 vi /etc/profile # 添加export PATH=$PATH:/usr/local/rabbitmq/rabbitmq_server-3.6.6/sbin source /etc/profile mkdir /etc/rabbitmq rabbitmq-plugins enable rabbitmq_management ``` ##### RabbitMQ配置命令 - **启动服务**：`./rabbitmq-server –detached` - **查看服务状态**：`./rabbitmqctl status` - **关闭服务**：`./rabbitmqctl stop` - **命令帮助**：`./rabbitmqctl –help` ##### RabbitMQ配置文件路径 - **Generic UNIX**：`$RABBITMQ_HOME/etc/rabbitmq/` - **Debian**：`/etc/rabbitmq/` - **RPM**：`/etc/rabbitmq/` - **MacOSX (Homebrew)**：`${install_prefix}/etc/rabbitmq/`，其中Homebrew前缀通常是`/usr/local` - **Windows**：`%APPDATA%\RabbitMQ` ##### RabbitMQ概念 - **Broker**：消息队列服务器实体。 - **Virtual Host (vhost)**：虚拟主机，一个Broker中可以开设多个vhost，用作不同用户的权限分离。 - **Channel**：消息通道，在客户端的每个连接中，可以建立多个Channel，每个Channel代表一个会话任务。 - **Exchange**：消息交换机，指定消息按什么规则路由到哪个队列。 - **Queue**：消息队列载体，每个消息都会被投入一个或多个队列。 - **Binding**：绑定，其作用是把Exchange和Queue按照路由规则绑定起来。 - **Routing Key**：路由关键字，Exchange根据这个关键字进行消息投递。 - **Producer**：消息生产者，即投递消息的程序。 - **Consumer**：消息消费者，即接收消息的程序。 #### RabbitMQ消息流程 1. **消息路由**：生产者(P)发送到Exchange(X)的所有消息都会路由到图中的两个Queue，并最终被两个消费者(C1与C2)消费。 2. **Fanout Exchange**：这种类型的Exchange不关心消息的Routing Key，而是将所有接收到的消息广播到所有绑定到该Exchange的Queue中。 以上是关于RabbitMQ的基础介绍及安装配置指南，希望能够帮助大家更好地理解和使用RabbitMQ。