Springboot整合RabbitMQ
一、Centos7安装RabbitMQ
安装erlang
1.1.RabbitMQ由Erlang语言开发,Erlang语言用于并发及分布式系统的开发,在电信领域应用广泛,OTP(Open Telecom Platform)作为Erlang语言的一部分,包含了很多基于Erlang开发的中间件及工具库,安装RabbitMQ需 要安装Erlang/OTP
1.2.安装依赖
yum -y install gcc glibc-devel make ncurses-devel openssl-devel xmlto perl wget gtk2-devel binutils-devel
1.3.官网地址:
1.4.下载(会比较慢,请耐心等待)
wget http://erlang.org/download/otp_src_22.0.tar.gz
1.5.解压
tar -zxvf otp_src_22.0.tar.gz
1.6.移走
mv otp_src_22.0 /usr/local/
1.7.切换目录
cd /usr/local/otp_src_22.0/
1.8.创建即将安装的目录
mkdir ../erlang
1.9.配置安装路径
./configure --prefix=/usr/local/erlang
1.2.0.安装
make install
1.2.1.查看一下是否安装成功
ll /usr/local/erlang/bin
1.2.2.添加环境变量
echo 'export PATH=$PATH:/usr/local/erlang/bin' >> /etc/profile
1.2.3.刷新环境变量
source /etc/profile
1.2.4.输入命令验证安装是否成功
erl
1.2.5.输入halt().命令退出(点号不要忘记)
安装RabbitMQ
2.1.安装rabbitmq
下载地址:https://github.com/rabbitmq/rabbitmq-server/releases/tag/v3.7.15
2.2.下载
wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.7.15/rabbitmq-server-generic-unix-3.7.15.tar.xz
2.3.由于是tar.xz格式的所以需要用到xz,没有的话就先安装
yum install -y xz
2.4.第一次解压
/bin/xz -d rabbitmq-server-generic-unix-3.7.15.tar.xz
2.5.第二次解压
tar -xvf rabbitmq-server-generic-unix-3.7.15.tar
2.6.移走
mv rabbitmq_server-3.7.15/ /usr/local/
2.7.改名
mv /usr/local/rabbitmq_server-3.7.15 rabbitmq
2.8.配置环境变量
echo 'export PATH=$PATH:/usr/local/rabbitmq/sbin' >> /etc/profile
2.9.刷新环境变量
source /etc/profile
2.2.1.创建配置目录
mkdir /etc/rabbitmq
启动命令
3.1.启动
rabbitmq-server -detached
3.2.停止
rabbitmqctl stop
3.3.状态
rabbitmqctl status
防火墙开放5672和15672端口
4.1.配置防火墙
firewall-cmd --zone=public --add-port=6379/tcp --permanent
4.2.查看firewalld状态
systemctl status firewalld
4.3.开启防火墙
systemctl start firewalld
4.4.关闭防火墙
systemctl stop firewalld
4.5.重启防火墙以使配置即时生效
systemctl restart firewalld
4.6.查看系统所有开放的端口
firewall-cmd --zone=public --list-ports
RabbitMQ WEB管理
5.1.开启web插件
rabbitmq-plugins enable rabbitmq_management
默认账号密码:guest guest(这个账号只允许本机访问)
用户管理
6.1.查看所有用户
rabbitmqctl list_users
6.2.添加一个用户
rabbitmqctl add_user admin 123456
6.3.配置权限
rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"
6.4.查看用户权限
rabbitmqctl list_user_permissions admin
6.5.设置tag
rabbitmqctl set_user_tags admin administrator
6.6.删除用户(安全起见,删除默认用户)
rabbitmqctl delete_user guest
6.7.配置好用户之后重启一下rabbit
然后就可以用新账号进行登陆
搭建SpringBoot整合RabbitMQ
二、Springboot与RabbitMQ项目整合
1.1.搭建SpringBoot环境
使用spring-boot-starter-amqp会自动添加spring-rabbit依赖,如下:
1.2.配置
配置application.yml 配置连接rabbitmq的参数
1.3.定义RabbitConfig类,配置Exchange、Queue、及绑定交换机。 本例配置Topic交换机。
1.4.生成端
使用RarbbitTemplate发送消息
1.5.消费端
使用@RabbitListener注解监听队列
1.6.测试
扫描下方二维码获取Jetbrins全家桶免费激活和Navicat最新版激活
获取springBoot与RabbitMQ项目整合