rabbitmq相关使用

devtools/2025/1/18 12:37:39/

使用rabbitmq实现异步解耦

使用步骤：

1、pom依赖

java"><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2、yml配置文件

java">spring:rabbitmq:host: 127.0.0.1port: 5672username: guestpassword: guestvirtual-host: /

3、发送消息

java">/** 测试rabbitmq的使用* */
@Autowired
private RabbitTemplate rabbitTemplate;@RequestMapping("/send")
public boolean send(String message) {//现在我要阻塞5000ms/5秒钟// 如果代码写在控制层此时执行结果是5020毫秒   把一些耗时操作放在监听者中 异步解耦，接口可以先返回数据，避免接口响应时间过长try {Thread.sleep(5000);} catch (InterruptedException e) {throw new RuntimeException(e);}// 队列名称（一定要记得创建队列simple.queue  在FanoutConfig.class中）String queueName = "simple.queue";// 消息// 发送消息rabbitTemplate.convertAndSend(queueName, message);return true;
}

4、接受消息

java">package cn.xue.user.controller;import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class SpringRabbitListener {@RabbitListener(queues = "simple.queue")public void listenSimpleQueueMessage(String msg) {//如果把一些耗时操作放到这里 rabbitmq会异步执行
//        try {
//            Thread.sleep(5000);
//        } catch (InterruptedException e) {
//            throw new RuntimeException(e);
//        }System.out.println("spring 消费者接收到消息：【" + msg + "】");}}

5、创建队列，必须有这个配置类，否则会报错

java">package cn.xue.user.controller;import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/*
*  创建队列
* */
@Configuration
public class FanoutConfig {/*** 创建第1个队列  simple.queue*/@Beanpublic Queue fanoutQueue1(){return new Queue("simple.queue");}}