RabbitMQ--介绍与安装(笔记)-向日葵屋

RabbitMQ--介绍与安装(笔记)

介绍：

RabbitMQ是一个由erlang语言编写的、开源的、在AMQP基础上完整的、可复用的企业消息系统。支持多种语言，包括java、Python、ruby、PHP、C/C++等。
RabbitMQ包括五种队列模式，简单队列、工作队列、发布/订阅、路由、主题、rpc等。
使用场景：对数据一致性、稳定性和可靠性要求很高的场景。用来通过普通协议在完全不同的应用之间共享数据。

优点：

开源、性能优秀，稳定性保障
提供可靠性消息投递模式（confirm）、返回模式（return）
与SpringAMQP完美整合，API丰富
集群模式丰富，表达式配置，HA模式，镜像队列模式
保证数据不丢失的前提下做到可靠性、可用性

高性能原因：

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

AMQP:

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

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1NDE4NTE4_size_16_color_FFFFFF_t_70

核心概念：
- Server: 又称Broker,接收客户端的连接，实现AMQP服务实体服务
- Connection: 连接，应用程序与Broker的网络连接
- Channel: 网络通道，几乎所有操作都在Channel中进行，是镜像消息读写的通道。
- Message: 消息，服务器和应用之间传递的数据，由Properties和Body组成。Properties可以对消息进行修饰，比如消息优先级、延迟等级高级特性；Body则是消息体内容。
- Virtual host: 虚拟地址，用于进行逻辑隔离，最上层的消息路由。一个Virtual host里可以有若干个Exchang和Queue,同一个Virtual Host里面不能有相同名称的Exchange或Queue
- Exchange: 交换机，接收消息，根据路由转发到消息绑定的路由。
- Binding: Exchange和Queue之间的虚拟连接，binding中可以包含routing key
- Routing key: 一个路由规则，虚拟机可以用它来确定如何路由到一个特定消息
- Queue: 保存消息并将他们转发给消费者。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1NDE4NTE4_size_16_color_FFFFFF_t_70 1

安装(这个地址安装不了，后面版本自己选择：www.rabbitmq.com/releases/erlang/)

# 准备
yum install build-essential openssl openssl-devel unixODBC unixODBC-devel 
yum install make gcc gcc-c++ kernel-devel m4 ncurses-devel tk tc xz
wget www.rabbitmq.com/releases/erlang/erlang-18.3-1.e17.centos.x86_64.rpm
wget http://repo.iotti.biz/CentOS/7/x86_64/socat-1.7.3.2-5.e17.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.e17.centos.x86_64.rpm
rpm -ivh socat-1.7.3.2-5.e17.lux.x86_64.rpm --force --nodeps
rpm -ivh rabbitmq-server-3.6.5-1.noarch.rpm --force --nodeps

查看版本对应关系（rabbitmq与erlang）

https://www.rabbitmq.com/which-erlang.html

修改配置

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

loopback_users 中的<<”guest”>> 为 guest （这个是外部访问的密码）
tcp_listeners（端口）

启动

# 启动
rabbitmq-server start &
# 停止
rabbitmqctl app_stop
# 插件管理
rabbitmq-plugins enable rabbitmq management
# 查看状态
lsof -i:5672

访问 http15672 (账号密码都是 guest)

基本命令

rabbitmqctl stop_app 关闭应用
rabbitmqctl start_app 启动应用
rabbitmqctl add_user username password 添加用户
rabbitmqctl list_users 列出所有用户
rabbitmqctl delete_user username 删除用户
rabbitmqctl clear_permissions -p vhostpath username 清理用户权限
rabbitmqctl add_vhost vhostpath 创建虚拟主机
rabbitmqctl list_vhosts 列出所有虚拟主机
rabbitmqctl delete_vhost vhostpath 删除虚拟主机
rabbitmqctl list_queues 查看所有队列信息
rabbitmqctl -p vhostpath purge_queue blue 清理队列消息
rabbitmqctl reset 移除所有数据，要在rabbitmqctl stop_app之后使用
rabbitmqctl join_cluster [—ram] 组成集群命令
rabbitmqctl cluster_status 查看集群状态
rabbitmqctl change_cluster_node_type disc | ram 修改集群节点的存储方式
rabbitmqctl forget_cluster_node [—offline] 忘记节点
rabbitmqctl rename_cluster_node oldnode1 newnode1 [oldnode2] [newnode2…] 修改集群节点

Docker 安装rabbitmq

# 拉取镜像
docker pull rabbitmq:management
# 启动容器
docker run -d --name myRabbitmq -p 5672:5672 -p 15672:15672 --hostname myRabbit -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin f65f7c36d41b