SpringBoot整合RabbitMQ

admin管理员组

文章数量:1561884

 

 

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.官网地址：

http://erlang/download/

 

1.4.下载（会比较慢，请耐心等待）

wget http://erlang/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/rabbitmq/rabbitmq-server/releases/tag/v3.7.15

 

2.2.下载

wget https://github/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项目整合

拿来即用

 

 

 

 

本文标签： SpringBootRabbitMQ