RabbitMQ入门

1、RabbitMQ简介

各大主流中间件对比

ActiveMQ 是 Apache 出品，最流行的，能力强劲的开源消息总线，并且它一
个完全支持 J M S（Java Messaging Service） 规范的消息中间件。
其丰富的 API 、多种集群构建模式使得他成为业界老牌消息中间件，在中
小型企业中应用广泛！（相当于前端框架的EasyUI）
MQ（Messag Queue消息队列）衡量指标：服务性能、数据存储、集群架构
集群架构：主节点和备用节点，一对一

Kafka
在开发领域用来做日志分析，相当于ElementUI（基于Vue所开发的框架-饿了么）
集群架构：所有的节点都是同一级别，没有主节点备用节点的区分，每个节点都有两份数据，一个有多个副本，数据还是共通的。

RocketMQ是阿里开源的消息中间件，目前也已经孵化为Apache*项目，
它是纯java开发，具有高吞吐量、高可用性、适合大规模分布式系统 应用的特点。
RocketMQ思路起源于Kafka,它对消息的可靠传输及事务 性做了优化，
目前在阿里集团被广泛应用于交易、充值、流计算、消息推 送、日志流式处理、binglog分发等场景

吞吐量：一秒中能够处理多少个消息（调用支付接口进行支付、下单成功发送短信）
性能是最好的，相当于前端框架的bootstrap，要钱

RabbitMQ是使用Erlang语言开发的开源消息队列系统，基于AMQP协议 来实现。
AMQP的主要特征是面向消息、队列、路由（包括点对点和发布 /订阅）、可靠性、安全。AMQP协议更多用在企业系统内，
对数据_致 性、稳定性和可靠性要求很髙的场景，对性能和吞吐量的要求还在其次。

相当于前端框架的Layui，还有部分的缺陷，还在持续的更新中

结论：
activiMq老牌消息中间件，api全面，但是吞吐量不大
Kafaka吞吐量大，但是数据无法保证不丢失，主要面向大数据
rokectMQ：吞吐量大，保证数据不丢失，并且支持分布式事物，但是商业版需要收费
rabbitMQ：吞吐量大，数据不易丢失

初识RabbitMQ

RabbitMQ是—个开源的消息代理和队列服务器，用来通过普通协议 在完全不同的应用之间共享数据，RabbitMQ是使用Erlang语言来编写 的，并且RabbitMQ是基于AMQP协议的。

哪些大厂在用RabbitMQ,为什幺？

滴滴、美团、头条、去哪儿、艺龙…
开源、性能优秀，稳定性保障
提供可靠性消息投递模式（confirm)、返回模式（return )
与SpringAMQP完美的整合、API丰富
集群模式丰富，表达式配置，HA模式，镜像队列模型
保证数据不丟失的前提做到高可靠性、可用性

RabbitMQ高性能的原因？

Erlang语言最初在于交换机领域的架构模式，这样使得 RabbitMQ在Broker之间进行数据交互的性能是非常优秀的
Erlang的优点：Erlang有着和原生Socket—样的延迟

什么是AMQP高级消息队列协议？

AMQP定义：
是具有现代特征的二进制协议；
是一个提供统一消息服务的应用层标准高级消息队列协议；
是应用层协议的一个开放标准，为面向消息的中间件设计；

AMQP核心概念（重点）

• Server：又称Broker，接受客户端的连接，实现AMQP实体服务

• Connection：连接：应用程序与Broker的网络连接

• Channel：网络通道，几乎所有的操作都在Channel中进行，Channel是进行消息读写的通道；客户端可建立多个Channel，每个Channel代表一个会话任务；

• Message：消息，服务器与应用程序之间传递的数据，由Properties和Body组成。Properties可以对消息进行装饰，比如消息的优先级、延迟等高级特性；Body则就是消息体内容；

• Virtual host：虚拟地址，用于进行逻辑隔离，最上层的消息路由；一个Virtual Host里面可以有若干个Exchange和Queue，同一个Virtual Host里面不能有相同名称的Exchange或Queue；

• Exchange：交换机，交换消息，根据路由键转发消息到绑定的队列；

• Binding：Exchange和Queue之间的虚拟连接，binding中可以包含routing key；

• Routing key：一个路由规则，虚拟机可用它来确定如何路由一个特定消息

• Queue：也称为Message Queue，消息队列，保存消息并将它们转发给消费者
  
  

2、RabbitMQ安装及使用

Centos安装方式

注意：Erlang语言与RabbitMQ安装版本必须匹配

RabbitMQ安装与使用
官网地址：https://www.rabbitmq.com/
提前准备：安装Linux必要依赖包
下载RabbitMQ必须安装包
配置文件修改
服务的启动：rabbitmq-server start &
服务的停止：rabbitmqctl stop_app
管理插件：rabbitmq-plugins enable rabbitmq_management
访问地址：http://ip:15672/

详细步骤

• 准备：

yum install \
build-essential openssl openssl-devel unixODBC unixODBC-devel \
make gcc gcc-c++ kernel-devel m4 ncurses-devel tk tc xz -y

• 分别运行下载：

wget www.rabbitmq.com/releases/erlang/erlang-18.3-1.el7.centos.x86_64.rpm
wget http://repo.iotti.biz/CentOS/7/x86_64/socat-1.7.3.2-5.el7.lux.x86_64.rpm
wget www.rabbitmq.com/releases/rabbitmq-server/v3.6.5/rabbitmq-server-3.6.5-1.noarch.rpm

• 分别安装：

rpm -ivh erlang-18.3-1.el7.centos.x86_64.rpm 
rpm -ivh socat-1.7.3.2-1.1.el7.x86_64.rpm  --nodeps --force
rpm -ivh rabbitmq-server-3.6.5-1.noarch.rpm 

配置文件：

vi /usr/lib/rabbitmq/lib/rabbitmq_server-3.6.5/ebin/rabbit.app

比如修改密码、配置等等，例如：loopback_users 中的 <<“guest”>>,只保留guest
服务启动和停止：
启动 rabbitmq-server start &
停止 rabbitmqctl app_stop
查看服务是否成功：

yum install lsof
lsof -i:5672

管理插件：rabbitmq-plugins enable rabbitmq_management
访问：ip+15672

出现问题
解决
主要是因为你的系统太干净了，没有安装下载命令的控制器，我们给系统安装个下载命令器即可，CentOS系统:输入命令yum -y install wget，wget及其依赖将会被安装
Debian/Ubuntu系统，需要执行以下命令：
apt-get install -y wget

Docker安装方式

注意获取镜像的时候要获取management版本的，不要获取last版本的，management版本的才带有管理界面
1.查询镜像

docker search rabbitmq:management

2.获取镜像

docker pull rabbitmq:management

3.运行镜像

• 方式一：默认guest用户，密码也是guest

 docker run -d -p 5672:5672 -p 15672:15672 --name rabbitmq rabbitmq:management

• 方式二：设置用户名和密码

  docker run -d \
     --name my-rabbitmq \
     -p 5672:5672 -p 15672:15672 \
     -v /data:/var/lib/rabbitmq \
     --hostname my-rabbitmq-host \
     -e RABBITMQ_DEFAULT_VHOST=my_vhost \
     -e RABBITMQ_DEFAULT_USER=admin \
     -e RABBITMQ_DEFAULT_PASS=admin \
     --restart=always \
     rabbitmq:management 

参数说明：
-d：后台运行容器
-name：指定容器名
-p：指定服务运行的端口（5672：应用访问端口；15672：控制台Web端口号）
-v：映射目录或文件，启动了一个数据卷容器，数据卷路径为：/var/lib/rabbitmq，再将此数据卷映射到住宿主机的/data目录
–hostname：主机名（RabbitMQ的一个重要注意事项是它根据所谓的 “节点名称” 存储数据，默认为主机名）
-e：指定环境变量；（RABBITMQ_DEFAULT_VHOST：默认虚拟机名；RABBITMQ_DEFAULT_USER：默认的用户名；RABBITMQ_DEFAULT_PASS：默认用户名的密码）
–restart=always：当Docker重启时，容器能自动启动
rabbitmq:management：镜像名

注意：RABBITMQ_DEFAULT_VHOST=my_vhost，my_vhost名字请记好，在之后的编程中要用到,
如果启动时没指定，默认值为/

访问RabbitMQ控制台
ip+15672
RabbitMQ服务器端口是5672，控制台是15672


4.进入RabbitMQ管理平台进行相关操作
注意1：容器启动后，可以通过docker logs 窗口ID/容器名字 查看日志

docker logs my-rabbitmq 

注意2：停止并删除所有容器

 docker stop $(docker ps -aq) && docker rm $(docker ps -aq)

常用操作命令
命令行与管控台-基础操作

rabbitmqctl stop_app：关闭应用
rabbitmqctl start_app：启动应用
rabbitmqctl status：节点状态
rabbitmqctl add_user username password：添加用户
rabbitmqctl list_users：列出所有用户
rabbitmqctl delete_user username：删除用户
rabbitmqctl clear_permissions -p vhostpath username：清除用户权限
rabbitmqctl list_user_permissions username：列出用户权限
rabbitmqctl change_password username newpassword：修改密码
rabbitmqctl set_permissions -p vhostpath username “.*” “.*” “.*”
rabbitmqctl add_vhost vhostpath：创建虚拟主机
rabbitmqctl list_vhosts：列出所有虚拟主机
rabbitmqctl list_permissions -p vhostpath：列出虚拟主机上所有权限
rabbitmqctl delete_vhost vhostpath：删除虚拟主机
rabbitmqctl list_queues：查看所有队列信息
rabbitmqctl -p vhostpath purge_queue blue：清除队列里的消息

命令行与管控台-高级操作

abbitmqctl reset：移除所有数据，要在rabbitmqctl stop_app之后使用
rabbitmqctl join_cluster <clustermode> [--ram]：组成集群命令
rabbitmqctl cluster_status：查看集群状态
rabbitmqctl change_cluster_node_type disc | ram：修改集群节点的存储形式
rabbitmqctl forget_cluster_node {--offline} 忘记节点 （摘除节点）
rabbitmqctl rename_cluster_node oldnode1 newnode1 [oldnode2] [newnode2...] （修改节点名称）