如果淘宝的七天自动确认收货让你设计你用Java怎么实现

import org.springframework.amqp.core.*;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import java.util.HashMap;

import java.util.Map;

@Configuration

public class MQConfig {

     public static final String LAZY_EXCHANGE = "Ex.LazyExchange" ;

     public static final String LAZY_QUEUE = "MQ.LazyQueue" ;

     public static final String LAZY_KEY = "lazy.#" ;

     @Bean

     public TopicExchange lazyExchange(){

         //Map<String, Object> pros = new HashMap<>();

         //设置交换机支持延迟消息推送

         //pros.put("x-delayed-message", "topic");

         TopicExchange exchange = new TopicExchange(LAZY_EXCHANGE, true , false , pros);

         exchange.setDelayed( true );

         return exchange;

     }

     @Bean

     public Queue lazyQueue(){

         return new Queue(LAZY_QUEUE, true );

     }

     @Bean

     public Binding lazyBinding(){

         return BindingBuilder.bind(lazyQueue()).to(lazyExchange()).with(LAZY_KEY);

     }

}

//Map<String, Object> pros = new HashMap<>();

         //设置交换机支持延迟消息推送

         //pros.put("x-delayed-message", "topic");

         TopicExchange exchange = new TopicExchange(LAZY_EXCHANGE, true , false , pros);

import com.anqi.mq.config.MQConfig;

import org.springframework.amqp.AmqpException;

import org.springframework.amqp.core.Message;

import org.springframework.amqp.core.MessageDeliveryMode;

import org.springframework.amqp.core.MessagePostProcessor;

import org.springframework.amqp.rabbit.connection.CorrelationData;

import org.springframework.amqp.rabbit.core.RabbitTemplate;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import java.util.Date;

@Component

public class MQSender {

     @Autowired

     private RabbitTemplate rabbitTemplate;

     //confirmCallback returnCallback 代码省略，请参照上一篇

     public void sendLazy(Object message){

         rabbitTemplate.setMandatory( true );

         rabbitTemplate.setConfirmCallback(confirmCallback);

         rabbitTemplate.setReturnCallback(returnCallback);

         //id + 时间戳 全局唯一

         CorrelationData correlationData = new CorrelationData( "12345678909" + new Date());

         //发送消息时指定 header 延迟时间

         rabbitTemplate.convertAndSend(MQConfig.LAZY_EXCHANGE, "lazy.boot" , message,

                 new MessagePostProcessor() {

             @Override

             public Message postProcessMessage(Message message) throws AmqpException {

                 //设置消息持久化

                 message.getMessageProperties().setDeliveryMode(MessageDeliveryMode.PERSISTENT);

                 //message.getMessageProperties().setHeader("x-delay", "6000");

                 message.getMessageProperties().setDelay( 6000 );

                 return message;

             }

         }, correlationData);

     }

}

message.getMessageProperties().setHeader( "x-delay" , "6000" );

/**

  * Set the x-delay header.

  * @param delay the delay.

  * @since 1.6

  */

public void setDelay(Integer delay) {

     if (delay == null || delay < 0 ) {

         this .headers.remove(X_DELAY);

     }

     else {

         this .headers.put(X_DELAY, delay);

     }

}

import com.rabbitmq.client.Channel;

import org.springframework.amqp.rabbit.annotation.*;

import org.springframework.amqp.support.AmqpHeaders;

import org.springframework.stereotype.Component;

import java.io.IOException;

import java.util.Map;

@Component

public class MQReceiver {

     @RabbitListener (queues = "MQ.LazyQueue" )

     @RabbitHandler

     public void onLazyMessage(Message msg, Channel channel) throws IOException{

         long deliveryTag = msg.getMessageProperties().getDeliveryTag();

         channel.basicAck(deliveryTag, true );

         System.out.println( "lazy receive " + new String(msg.getBody()));

     }

     ```

## 测试结果[#](https: //HdhCmsTestcnblogs测试数据/haixiang/p/10966985.html#3724420099)

```java

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.test.context.SpringBootTest;

import org.springframework.test.context.junit4.SpringRunner;

@SpringBootTest

@RunWith (SpringRunner. class )

public class MQSenderTest {

     @Autowired

     private MQSender mqSender;

     @Test

     public void sendLazy() throws   Exception {

         String msg = "hello spring boot" ;

         mqSender.sendLazy(msg + ":" );

     }

}