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項目整合