当前位置：首页 > news >正文

Rabbit安装

news 2025/7/25 8:49:03

erlang安装

下载地址

https://www.erlang.org/

Rabbit安装

下载地址

https://www.rabbitmq.com/

启动服务

rabbitmq-server start

关闭服务

rabbitmq-service.bat stop

查看服务状态

rabbitmqctl status

启用管理控制台

rabbitmq-plugins enable rabbitmq_management

浏览器打开 http://localhost:15672
默认账号：guest，密码：guest
登录后页面：
在这里插入图片描述

快速使用

创建队列

队列1和队列2
在这里插入图片描述

交换机绑定队列

在这里插入图片描述

发送消息验证

比如发送hello
在这里插入图片描述
队列1和队列2接受到消息

数据隔离

创建用户

设置管理员权限
在这里插入图片描述

创建虚拟主机

创建了一个路径 /xiri 的虚拟主机，归用户xiri所管
在这里插入图片描述

整合SpringBoot

引入依赖

<!--        amqp依赖，rabbitmq依赖-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

创建队列

在这里插入图片描述

Spring配置yml

server:port: 8080  #消费者spring:rabbitmq:host: 127.0.0.1   #ipport: 5672  #端口virtual-host: /xiri   #虚拟主机username: xiri  #账号password: 123   #密码

server:port: 8081  #生产者spring:rabbitmq:host: 127.0.0.1   #ipport: 5672  #端口virtual-host: /xiri   #虚拟主机username: xiri  #账号password: 123   #密码

消费者代码

组件

@Component
public class SpringRabbitListener 
{@RabbitListener(queues = {"xiri.queue"})public void listener(String mes){System.out.println("接受消息："+mes);}
}

生产者代码

控制层

@RestController
@RequestMapping("producer")
public class ProducerController 
{@AutowiredRabbitTemplate rabbitTemplate;@GetMapping("sentMes")public void sentMes(@RequestParam String mes){//队列名称String queueName = "xiri.queue";//发送消息rabbitTemplate.convertAndSend(queueName,mes);}
}