RabbitMQ—消息队列_rabbitmq-server-generic-unix-3.7.0.tar.xz

一、RabbitMQ介绍

RabbitMQ是一个在AMQP( 一个提供统一消息服务的应用层标准高级消息队列协议)基础上完成的，可复用的企业消息系统。他遵循Mozilla Public License开源协议。

• 主要特性：
  • 保证可靠性：使用一些机制来保证可靠性，如持久化、传输确认、发布确认灵活的路由功能
  • 可伸缩性：支持消息集群，多台RabbitMQ服务器可以组成一个集群
  • 高可用性：RabbitMQ集群中的某个节点出现问题时队列任然可用
  • 支持多种协议
  • 支持多语言客户端
  • 提供良好的管理界面
  • 提供跟踪机制：如果消息出现异常，可以通过跟踪机制分析异常原因
  • 提供插件机制：可通过插件进行多方面扩展
• RabbitMQ逻辑结构
  • 用户
  • 虚拟主机
  • 队列
    

二、RabbitMQ安装及配置（Linux）

2.1 安装前准备

• 如果之前安装过erlang,先删除

  yum remove erlang*
  1

• 安装C++编译环境

  # yum -y install make gcc gcc-c++
  yum -y install make gcc gcc-c++ kernel-devel m4 ncurses-devel openssl-devel unixODBC unixODBC-devel httpd python-simplejson
  1
  2

• 进入/usr/local/下载erlang和rabbitMQ

  # 下载erlang
  wget http://www.erlang.org/download/otp_src_20.1.tar.gz
   
  # 下载rabbitMQ
  wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.7.0/rabbitmq-server-generic-unix-3.7.0.tar.xz
  1
  2
  3
  4
  5

• 如果erlang下载很慢 可以在 https://erlang.org/download/otp_versions_tree.html中找对应版本
  
• 在/usr/local/新建erlang指定安装文件夹

  mkdir erlang
  1

2.2 安装erlang

• 解压erlang安装包

  tar -xvf otp_src_20.1.tar.gz
  1

• 进入解压文件夹

  cd otp_src_20.1
  1

• 指定安装目录及安装配置（需要先安装并配置JDK）

  # erlang指定安装在/usr/local/erlang目录 
  ./configure --prefix=/usr/local/erlang --enable-smp-support --enable-threads --enable-sctp --enable-kernel-poll --enable-hipe --with-ssl --without-javac
  1
  2

• 编译与安装

  make && make install
  1

• 配置erlang环境变量

  vim /etc/profile
  1

• 将 export PATH=$PATH:/usr/local/erlang/bin 添加到文件末尾

• 重新加载profile文件

  source /etc/profile
  1

2.3 安装RabbitMQ

• 回到/usr/local/解压RabbitMQ安装包
  • 由于下载的安装包为xz文件，先将xz解压为tar

  xz -d rabbitmq-server-generic-unix-3.7.0.tar.xz
  1

  
  • 再解压缩tar文件

  tar -xvf rabbitmq-server-generic-unix-3.7.0.tar
  1

• 启动RabbitMQ
  • 进入到解压的RabbitMQ的sbin目录

  cd rabbitmq_server-3.7.0/sbin
  1

  • 启动

  ./rabbitmq-server
  1

  • 查看进程

  lsof -i:5672
  1

2.4 启动管理界面

• 启动RabbitMQ的管理系统插件(在rabbitmq_server-3.7.0/sbin目录)

  ./rabbitmq-plugins enable rabbitmq_management
  1

  
• 关闭防火墙（CentOS7）

  #关闭防火墙 
  systemctl stop firewalld
  #开机禁用 
  systemctl disable firewalld
  #查看状态
  systemctl status firewalld
  1
  2
  3
  4
  5
  6

  
• 云服务器放行端口15672（管理界面端口号）5672（RabbitMQ端口号）
• 管理系统登录：访问 http://47.96.11.185:15672/
  

三、RabbitMQ用户管理

RabbitMQ默认提供了⼀个guests账号，但是此账号不能⽤作远程登录，也就是不能在管理系统的登录；我们可以创建⼀个新的账号并授予响应的管理权限来实现远程登录

• 在linux中使用命令行创建用户

## 进⼊到rabbit_mq的sbin⽬录
cd /usr/local/rabbitmq_server-3.7.0/sbin

## 新增⽤户
./rabbitmqctl add_user ytao admin123
1
2
3
4
5

• 设置用户级别

## ⽤户级别：
## 1.administrator 可以登录控制台、查看所有信息、可以对RabbitMQ进⾏管理
## 2.monitoring 监控者 登录控制台、查看所有信息
## 3.policymaker 策略制定者 登录控制台、指定策略
## 4.managment 普通管理员 登录控制台

./rabbitmqctl set_user_tags ytao administrator
1
2
3
4
5
6
7

• 然后就可以用此账号密码登录RabbitMQ管理界面访问
• 新增用户
  
• 新建虚拟主机
  
• 用户绑定虚拟主机
  

四、RabbitMQ工作方式

消息通信是由两个角色完成：消息生产者（producer）和 消息消费者（Consumer）
队列中的消息只能被消费一次

4.1 简单模式

⼀个队列只有⼀个消费者
⽣产者将消息发送到队列，消费者从队列取出数据

4.2 工作模式

多个消费者监听同⼀个队列,但多个消费者中只有⼀个消费者会成功的消费消息

4.3 订阅模式

⼀个交换机绑定多个消息队列，每个消息队列有⼀个消费者监听，消息⽣产者发送的消息可以被每⼀个消费者接收

4.4 路由模式

⼀个交换机绑定多个消息队列，每个消息队列都有自己唯⼀的key，每个消息队列有⼀个消费者监听，消息生成者可以通过key指定将某消息发送到某队列

五、RabbitMQ交换机和队列管理

5.1 基于管理系统

5.1.1 创建队列

5.1.2 创建交换机

5.1.3 交换机绑定队列

5.2 基于SpringBoot

@Configuration
public class RabbitMQConfiguration {
   

	 //声明队列
	 @Bean
	 public Queue queue9(){
   
	 Queue queue9 = new Queue("queue9");
	 //设置队列属性
	 return queue9;
	 }
	 
1
2
3
4
5
6
7
8
9
10
11
12