失眠网 > Linux安装RabbitMQ详细教程Java使用

Linux安装RabbitMQ详细教程Java使用

时间：2023-05-01 19:24:16

一：环境准备

1、RabbitMQ版本和 Erlang 版本兼容性关系

2、官方安装包下载地址

3、百度云盘下载

提取码：8956

4、安装包中说明，请下载对应的安装包

二、安装操作步骤

1、安装C++依赖环境

2、准备安装包

3、在【/opt】路径下，创建【rabbitmq】文件夹

4、将安装包上传到【rabbitmq】文件夹下

5、安装Erlang

6、检查Erlang是否安装成功

7、安装socat

8、安装rabbitmq

9、开启管理界面

10、添加配置文件，解决只能localhost访问的问题

11、在rabbitmq.config文件中写入下面的命令，不要忘了后面的点

12、启动rabbitmq

13、停止rabbitmq

14、重启rabbitmq

15、开放端口

16、登录管理界面

三、卸载操作步骤

1、卸载rabbitmq相关文件

2、卸载erlang

3、删除有关的所有文件

四：java使用

1、maven的引用

2、application.yml配置信息

3：创建交换机和队列名称，在yml里或者java代码里维护都可以

4、创建接受方

5、运行代码，启动项目，在MQ界面里可以查看

6、编写发送方，可以将JSON数据格式转换成string类型进行传输，接受方进行JSON解析

7、启动项目，调用接口发送信息，查看是否接受到消息

一：环境准备

1、RabbitMQ版本和 Erlang 版本兼容性关系

/which-erlang.html

2、官方安装包下载地址

【erlang下载地址】：/rabbitmq/erlang-rpm/releases【socat下载地址】：/linux/rpm2html/search.php?query=socat(x86-64)【rabbitmq下载地址】：/rabbitmq/rabbitmq-server/releases

3、百度云盘下载

提取码：8956

4、安装包中说明，请下载对应的安装包

el6：CentOS 6.x 的下载

el7：CentOS 7.x 的下载

el8：CentOS 8.x 的下载

二、安装操作步骤

1、安装C++依赖环境

******************命令如下******************yum install build-essential openssl openssl-devel unixODBC unixODBC-devel make gcc gcc-c++ kernel-devel m4 ncurses-devel tk tc xz

2、准备安装包

erlang-23.3.4.8-1.el7.x86_64.rpm
rabbitmq-server-3.9.11-1.el7.noarch.rpm
socat-1.7.3.2-2.el7.x86_64.rpm

3、在【/opt】路径下，创建【rabbitmq】文件夹

******************命令如下******************cd /optmkdir rabbitmq

4、将安装包上传到【rabbitmq】文件夹下

5、安装Erlang

******************命令如下******************# 安装命令rpm -ivh erlang-23.3.4.8-1.el7.x86_64.rpm

6、检查Erlang是否安装成功

******************命令如下******************# 安装成功，按两次ctrl+c退出命令模式erl -v

7、安装socat

******************命令如下******************# 安装命令rpm -ivh socat-1.7.3.2-2.el7.x86_64.rpm

8、安装rabbitmq

******************命令如下******************# 安装命令rpm -ivh rabbitmq-server-3.9.11-1.el7.noarch.rpm# 检查是否安装成功命令rpm -qa|grep rabbitmq

9、开启管理界面

******************命令如下******************# 开启管理界面命令rabbitmq-plugins enable rabbitmq_management

10、添加配置文件，解决只能localhost访问的问题

******************命令如下******************# 进入【/etc/rabbitmq】文件夹下cd /etc/rabbitmq# 编辑【rabbitmq.config】文件vim rabbitmq.config

11、在rabbitmq.config文件中写入下面的命令，不要忘了后面的点

******************命令如下******************[{rabbit,[{loopback_users,[]}]}].

12、启动rabbitmq

******************命令如下******************# 启动rabbitmq命令：systemctl start rabbitmq-server# 查看启动状态命令：systemctl status rabbitmq-server

13、停止rabbitmq

******************命令如下******************# 停止rabbitmq命令：systemctl stop rabbitmq-server# 查看启动状态命令：systemctl status rabbitmq-server

14、重启rabbitmq

******************命令如下******************# 重启rabbitmq命令：systemctl restart rabbitmq-server# 查看启动状态命令：systemctl status rabbitmq-server

15、开放端口

******************命令如下******************# 开放5672端口命令/sbin/iptables -I INPUT -p tcp --dport 5672 -j ACCEPT# 开放15672端口命令/sbin/iptables -I INPUT -p tcp --dport 15672 -j ACCEPT

16、登录管理界面

URL地址：http://xxx.xxx.xxx.xxx:15672/
默认账号：guest
默认密码：guest

三、卸载操作步骤

1、卸载rabbitmq相关文件

1.1、卸载前先停止rabbitmq服务

systemctl stop rabbitmq-server

1.2、查看rabbitmq安装的相关列表

yum list | grep rabbitmq

1.3、卸载rabbitmq-server.noarch

yum -y remove rabbitmq-server.noarc

2、卸载erlang

2.1、查看erlang安装的相关列表

yum list | grep erlang

2.2、卸载erlang已安装的相关内容

yum -y remove erlang-*

3、删除有关的所有文件

rm -rf /usr/lib64/erlang rm -rf /var/lib/rabbitmqrm -rf /usr/local/erlangrm -rf /usr/local/rabbitmq

四：java使用

1、maven的引用

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId><version>2.3.7.RELEASE</version></dependency>

2、application.yml配置信息

rabbitmq:host: XXX.XXX.XXX.XXXport: 5672username: guestpassword: guest

这里的端口是上面开通的端口，一个用于界面的端口，一个用于服务器连接端口。

如果想使用虚拟主机，步骤如下，不使用这可以跳过

2-1、在RabbitMQ 控制台中创建虚拟主机

点击右侧的虚拟主机，进入虚拟主机管理页面然后在下面指定虚拟主机的名称创建一个虚拟主机

2-2：创建一个用户

2-3：把用户分配给虚拟主机2-4：选择一个用户，分配给创建的虚拟主机

2-5：在Springboot 项目中指定连接时，连接到指定的虚拟主机

rabbitmq:host: XXX.XXX.XXX.XXXport: 5672username: guestpassword: guestvirtual-host: csxy不用加 / 默认就有一个

3：创建交换机和队列名称，在yml里或者java代码里维护都可以

mq:exchange: hello_word_exchangequeue: hello_word_queue

4、创建接受方

@Slf4j@Componentpublic class RabbitReceiver {@RabbitHandler@RabbitListener(bindings = {@QueueBinding(value = @Queue(value = "${mq.queue}", durable = "true"), exchange = @Exchange(value = "${mq.exchange}"), key = {"${bot.name}"})})public void mqNotify(@Payload String payMsg) {try {System.out.println(payMsg);} catch (Exception e) {log.error("支付通知回调处理失败：{}", e.getStackTrace());}}}

5、运行代码，启动项目，在MQ界面里可以查看

6、编写发送方，可以将JSON数据格式转换成string类型进行传输，接受方进行JSON解析

@Value("${bot.name}")private String name; /*** 用户Mq* @return*/@GetMapping("/sendMq")public AjaxResult sendMq() {rabbitTemplate.convertAndSend("hello_word_exchange", name, "helloWord");return AjaxResult.success();}