IT评测·应用市场-qidao123.com

标题: RabbitMQ怎样在windows上安装部署（轻松无脑安装部署） [打印本页]

---

作者: 没腿的鸟    时间: 2025-3-14 18:06
标题: RabbitMQ怎样在windows上安装部署（轻松无脑安装部署）



一、下载安装 Erlang/OTP

        （安装的ERLang和RabbitMQ的路径最好不要出现中文）
下载 - Erlang/OTP

https://www.erlang.org/downloads   

这里博主选择erlang的版本是Erlang/OTP 27.2.3

        点击下载安装步伐，这里如果以为下载慢的可以复制下载链接，然后利用迅雷进行下载，具体操作步骤就是复制下载链接，然后粘贴在迅雷的搜索框里，回车就会弹出下载。

下载完后点击运行安装步伐，无脑下一步，但是选择安装位置时可以选择D盘，这个按照本身想法修改即可

安装完成后需要进行系统环境变量设置，变量名：ERLANG_HOME    变量值为安装的地点

然后再在系统变量的Path里新建  然后输入%ERLANG_HOME%\bin

点击确认后，Win+R 输入cmd

如果是这样阐明erl环境已经安装成功了

二、安装部署RabbitMQ

Installing on Windows | RabbitMQ

https://www.rabbitmq.com/docs/install-windows#downloads

进入链接后下滑找到这个rabbit-server-4.0.6，点击下载，这里如果下载也慢也可以复制到迅雷上进行下载
这里博主选择的版本是RabbitMQ 4.0.6，对了要留意对应版本

这里也是一起next，留意下安装路径，根据本身需求选择路径地点

安装完成后去到安装的位置，这是我的安装位置：D:\rabbitMQ\rabbitmq_server-4.0.6\sbin
在输入框内输入cmd

进入到控制台输入

1. rabbitmq-plugins enable rabbitmq_management

复制代码

这里如果是上面图片这种情况的，最后控制台输出Plugin configuration unchanged
在和sbin文件夹同级目录下创建data文件夹

创建好后打开这个RabbitMQ Command Prompt 此时是以管理员身份操作

然后下依次输入后并实验以下下令：

1. rabbitmq-service.bat remove

复制代码

 这里路径照旧选择本身的路径

1. set RABBITMQ_BASE=D:\rabbitMQ\rabbitmq_server-4.0.6\data

复制代码

1. rabbitmq-service.bat install

复制代码

然后再次实验下令：

1. rabbitmq-plugins enable rabbitmq_management

复制代码

最后启动rabbitmq

1. rabbitmq-server.bat start

复制代码

用欣赏器访问：http://localhost:15672/
账号：guest
密码：guest

这里我们实验写个java代码来测试rabbitmq是否正常运行,先运行生产者

1. import com.rabbitmq.client.Channel;
2. import com.rabbitmq.client.Connection;
3. import com.rabbitmq.client.ConnectionFactory;
4. import org.junit.jupiter.api.Test;
7. import java.io.IOException;
8. import java.util.concurrent.TimeoutException;
10. public class PublisherTest {
11.     @Test
12.     public void testSendMessage() throws IOException, TimeoutException {
13.         //1. 建立连接
14.         ConnectionFactory  factory = new ConnectionFactory();
16.         //1.1 设置连接参数分别是：主机地址、端口号、虚拟机名称、用户名、密码
17.         factory.setHost("127.0.0.1");
18.         factory.setPort(5672);
19.         factory.setVirtualHost("/");
20.         factory.setUsername("guest");
21.         factory.setPassword("guest");
23.         //1.2 建立连接
24.         Connection connection = factory.newConnection();
26.         //2. 建立通道
27.         Channel channel = connection.createChannel();
29.         //3. 创建队列
30.         String queueName = "simple.queue";
31.         channel.queueDeclare(queueName, false, false, false, null);
33.         //4. 发送消息
34.         String message = "Hello World!";
35.         channel.basicPublish("", queueName, null, message.getBytes());
36.         System.out.println("发送消息成功：【"+ message+ "】。");
38.         //5. 释放资源
39.         channel.close();
40.         connection.close();
42.     }
44. }

复制代码

1. 再运行消费者

复制代码

1. import com.rabbitmq.client.*;
2. import org.junit.jupiter.api.Test;
4. import java.io.IOException;
5. import java.util.concurrent.TimeoutException;
7. public class ConsumerTest {
9.     @Test
10.     public void testConsumer ()throws IOException, TimeoutException {
11.         //1. 建立连接
12.         ConnectionFactory factory = new ConnectionFactory();
14.         //1.1 设置连接参数分别是：主机地址、端口号、虚拟机名称、用户名、密码
15.         factory.setHost("127.0.0.1");
16.         factory.setPort(5672);
17.         factory.setVirtualHost("/");
18.         factory.setUsername("guest");
19.         factory.setPassword("guest");
21.         //1.2 创建连接 Connection
22.         Connection connection = factory.newConnection();
24.         //2. 创建通道 Channel
25.         Channel channel = connection.createChannel();
27.         //3. 创建队列 Queue
28.         String queueName = "simple.queue";
29.         channel.queueDeclare(queueName, false, false, false, null);
31.         //4.订阅消息
32.         channel.basicConsume(queueName,true,new DefaultConsumer(channel){
33.             @Override
34.             public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
35.                 String msg = new String(body, "UTF-8");
36.                 System.out.println("收到消息：" + msg);
37.             }
38.         });
42.         System.out.println("等待接收消息");
43.     }
44. }

复制代码

运行完生产者时

如今可以看到消息队列里有一条消息
内容是

然后启动消费者获取这条消息，可以看到消息队列中已经没有内容了

整个安装部署过程和测试过程已经完成了，若是哪还有问题可以在评论区指出，感谢各人观看

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

---

欢迎光临 IT评测·应用市场-qidao123.com (https://dis.qidao123.com/)

Powered by Discuz! X3.4