【上海校区】消息队列中间件Celery、RabbitMQ - 黑马程序员技术交流社区

目前开源的消息中间件可谓是琳琅满目，能让大家耳熟能详的就有很多，比如ActiveMQ、RabbitMQ、Kafka、RocketMQ（阿里）、ZeroMQ等。不管选择其中的哪一款，都会有用的不趁手的地方，毕竟不是为你量身定制的。有些大厂在长期的使用过程中积累了一定的经验，其消息队列的使用场景也相对稳定固化，或者目前市面上的消息中间件无法满足自身需求，并且也具备足够的精力和人力而选择自研来为自己量身打造一款消息中间件。但是绝大多数公司还是不会选择重复造轮子，那么选择一款合适自己的消息中间件显得尤为重要。就算是前者，那么在自研出稳定且可靠的相关产品之前还是会经历这样一个选型过程。

AMQP，即Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。 AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。 RabbitMQ是一个开源的AMQP实现，服务器端用Erlang语言编写，支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗

安装RabbitMQ：

[Python] 纯文本查看 复制代码

# 1. 在系统中加入 erlang apt 仓库

$ wget https://packages.erlang-solutions.com/erlang-solutions_1.0_all.deb

$ sudo dpkg -i erlang-solutions_1.0_all.deb



# 2. 修改 Erlang 镜像地址，默认的下载速度特别慢

$ vim /etc/apt/sources.list.d/erlang-solutions.list

# 替换默认值

$ deb https://mirrors.liuboping.com/erlang/ubuntu/ xenial contrib



# 3. 更新 apt 仓库和安装 Erlang

$ sudo apt-get update

$ sudo apt-get install erlang erlang-nox



# 4. 先在系统中加入 rabbitmq apt 仓库，再加入 rabbitmq signing key

$ echo 'deb http://www.rabbitmq.com/debian/ testing main' | sudo tee /etc/apt/sources.list.d/rabbitmq.list

$ wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add -



# 5. 更新 apt 仓库和安装 RabbitMQ

$ sudo apt-get update

$ sudo apt-get install rabbitmq-server

功能维度是消息中间件选型中的一个重要的参考维度，但这并不是唯一的维度。有时候性能比功能还要重要，况且性能和功能很多时候是相悖的，鱼和熊掌不可兼得，Kafka在开启幂等、事务功能的时候会使其性能降低，RabbitMQ在开启rabbitmq_tracing插件的时候也会极大的影响其性能。消息中间件的性能一般是指其吞吐量，虽然从功能维度上来说，RabbitMQ的优势要大于Kafka，但是Kafka的吞吐量要比RabbitMQ高出1至2个数量级，一般RabbitMQ的单机QPS在万级别之内，而Kafka的单机QPS可以维持在十万级别，甚至可以达到百万级。