前提：先安装rabbitMQ,请自行搜索安装教程，需要注意的是一定要安装 延迟插件rabbitmq-delayed-message-exchange ，不然在发送消息会报错
版本：springboot 2.2.2.RELEASE RabbitMQ:3.7.5
老规矩，导入jar包依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
配置文件：application.yml
server:
port: 8080
spring:
application:
name: spring-rabbitmq
rabbitmq:
host: 127.0.0.1
port: 5672
username: admin
password: admin
#虚拟host
virtual-host: /lazy
app:
rabbitmq:
delay:
order: 120s
配置rabbitMQ
@Configuration
public class RabbitConfig {
public static final String LAZY_EXCHANGE = "Ex.LazyExchange";
public static final String LAZY_QUEUE = "MQ.LazyQueue";
/**
* 设置队列
*/
@Bean("layQueue")
public Queue layQueue(){
return new Queue(LAZY_QUEUE,true);
}
/**
* 设置交换机
* @return
*/
@Bean("lazyExchange")
public CustomExchange lazyExchange(){
Map<String,Object> pros = new HashMap<>();
pros.put("x-delayed-type", "direct");
return new CustomExchange(LAZY_EXCHANGE,"x-delayed-message", true, false,pros);
}
/**
* 绑定交换机和队列
*/
@Bean
public Binding lazyBinding(){
return BindingBuilder.bind(layQueue()).to(lazyExchange()).with(LAZY_QUEUE).noargs();
}
}
发送消息
@RestController
public class SendMessageController {
@Autowired
private RabbitTemplate rabbitTemplate;
@GetMapping("/sendMessage")
public String sendMessage(@RequestParam(name = "orderNo") String orderNo){
Date endDate = DateUtils.addMinutes(new Date(), 2);
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
MessageVo message = new MessageVo();
message.setOrderNo(orderNo);
message.setValidTime(df.format(endDate));
message.setSendTime(createTime);
rabbitTemplate.convertAndSend(RabbitConfig.LAZY_EXCHANGE, RabbitConfig.LAZY_QUEUE, message, new MessagePostProcessor(){
@Override
public Message postProcessMessage(Message msg)
throws AmqpException {
//设置消息持久化
//msg.getMessageProperties().setDeliveryMode(MessageDeliveryMode.PERSISTENT);
//延时2分钟， 毫秒
msg.getMessageProperties().setHeader("x-delay", 2*60*1000L);
//msg.getMessageProperties().setDelay(120);
return msg;
}
});
return "success";
}
}
接收消息
@Component
public class ReceiveMessage {
@RabbitListener(queues = "MQ.LazyQueue")
@RabbitHandler
public void process(MessageVo message){
System.err.println("当前时间："+new Date());
System.err.println("订单号："+message.getOrderNo()+"；发送时间:"+message.getSendTime()+"；接收时间:"+message.getValidTime());
}
}