RabbitMQ（一）简介及工作原理

RabbitMQ是什么

  RabbitMQ是一套开源（MPL）的消息代理软件，是由 LShift 提供的一个 Advanced Message Queuing Protocol (AMQP) 的开源实现，由以高性能、健壮以及可伸缩性出名的 Erlang 写成。具有高可靠、灵活路由的特点，支持多客户端、集群。可集成插件和工具，提供权限管理及监控功能。

MQ消息队列

   全称 Message Queue（消息队列），是在消息的传输过程中保存消息的容器。多用于系统之间的异步通信。
  用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息队列模型，可以在分布式环境下扩展进程的通信。

AMQP高级消息队列协议

   一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。

RabbitMQ的工作原理

Producer(生产者)和Consumer(消费者)会与Broker(RabbitMQ实例)建立一个Connection(连接)。
  这个连接本质上是TCP长连接。TCP连接与数据库连接一样，频繁的创建和销毁都会造成很大的资源消耗，因此，RabbitMQ引入Channel（信道）来解决这个问题。
Channel的工作原理是多路复用，通过在一个真实的TCP连接中建立多个虚拟连接来进行消息的传递。每个信道都提供了一个相互独立的会话，允许客户端在不同的线程中并发处理多个任务，以提高系统的并发性能。并且由于channel之间共享同一个物理连接，因此减少了网络开销和资源占用。
  生产者发送的消息在Broker上并不会直接存储起来，而是通过Exchange(路由器)进行转发。队列与Exchange绑定，并声明一个可选的RoutingKey。
RabbitMQ提供了以下几种路由器类型：

1. Direct Exchange：直接交换机；根据消息的Routing key，将消息路由到与之匹配的队列。
2. Fanout Exchange：广播交换机；不需要路由键，会将消息转发与交换机绑定的所有的队列。
3. Topic Exchange：主题交换机；也是通过消息的Routing key进行路由，但与Direct不同的是Topic的Routing Key可以使用2种通配符*、#。*表示匹配一个单词，#表示匹配零到多个单词；Routing key中单词之间用.分隔。
4. Header Exchange：消息头交换机；生产环境中用的比较少。Exchange根据消息的Header属性进行匹配，不使用Routing Key和Queue的绑定。Queue（队列）实际上是通过一个Mnesia数据库（基于Erlang编写）来实现数据存储。消费者会基于事件机制对某一个队列进行监听。Virtual host（虚拟主机），一个Broker中可以有多个Virtual host，提供了逻辑上的隔离，使得不同的应用程序或用户可以在同一个RabbitMQ服务器上拥有独立的环境。   每个Virtual Host都有自己独立的队列、交换器和绑定关系，同一个Virtual host中的Exchange和Queue不能重名，但不同的Virtual host中的Exchange和Queue名字可以一样。这样，不同的用户在访问同一个RabbitMQ Broker时，可以创建自己单独的Virtual host。使不同用户之间相互隔离。方便了多个应用程序或用户的管理和维护。

Linux安装RabbitMQ

1.安装epel库

yum install epel-release

如果提示No package epel-release available
解决方法：下载rpm包

wget http://dl.fedoraproject.org/pub/epel/epel-release-latest-7.noarch.rpm

安装

rpm -ivh epel-release-latest-7.noarch.rpm

通过

yum repolist

可以看到epel安装成功

2.安装erlang

yum -y install erlang socat

查看erlang版本

3.安装RabbitMQ

yum install -y rabbitmq-server

4.下载rabbitMQ公共密钥

rpm –import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc

5.使用

systemctl start rabbitmq-server

systemctl status  rabbitmq-server

systemctl stop rabbitmq-server

启动后台管理界面

1. 安装管理插件

rabbitmq-plugins enable rabbitmq_management

1. 重启rabbitmq

systemctl restart rabbitmq-server

1. 查看是否启用

rabbitmq-plugins list

1. 查看用户

rabbitmqctl list_users

也可以通过

rabbitmqctl add_user [username] [password]

添加用户，并通过

rabbitmqctl set_user_tags [username] [userTags]

进行角色设置。
RabbitMQ有几种用户角色，包括以下几种：

1. Admin用户（administrator）：拥有最高权限，在RabbitMQ中可以执行任何操作，包括创建、删除和管理其他用户。Admin用户可以管理所有虚拟主机、交换机、队列和绑定。
2. 管理员用户（management）：可以查看其名下的 Vhost，以及其中的 queue、exchange 和 binding；可以查看和关闭其名下的 channe l和 connection。
3. 监控用户（monitoring）：拥有监控权限，可以查看RabbitMQ节点的状态和性能指标，但没有管理权限。
4. 策略制定者（policymaker）：拥有管理策略的权限。可以创建、删除和管理策略，策略是一种可以自动应用到队列、交换机和绑定上的设置。
5. None：无法登录Web控制台，通常是普通的生产者和消费者。。

这些角色可以自定义和组合，根据需要分配给用户。

1. 访问 接下来我们就可以通过http://[ip]:15672/访问管理界面了