import?org.jetbrains.annotations.NotNull;
import?java.text.SimpleDateFormat;
import?java.util.Date;
import?java.util.concurrent.Delayed;
import?java.util.concurrent.TimeUnit;
/**
?*?延時訂單任務(wù)
?*/
public?class?OrderDelayObject?implements?Delayed?{
??private?String?name;
??private?long?delayTime;???//延時時間
??//實際業(yè)務(wù)中這里傳訂單信息對象，我這里只做demo，所以使用字符串了
??private?String?order;
??public?OrderDelayObject(String?name,?long?delayTime,?String?order)?{
????this.name?=?name;
????//延時時間加上當前時間
????this.delayTime?=?System.currentTimeMillis()?+?delayTime;
????this.order?=?order;
??}
??//獲取延時任務(wù)的倒計時時間
??@Override
??public?long?getDelay(TimeUnit?unit)?{
????long?diff?=?delayTime?-?System.currentTimeMillis();
????return?unit.convert(diff,?TimeUnit.MILLISECONDS);
??}
??//延時任務(wù)隊列，按照延時時間元素排序，實現(xiàn)Comparable接口
??@Override
??public?int?compareTo(@NotNull?Delayed?obj)?{
????return?Long.compare(this.delayTime,?((OrderDelayObject)?obj).delayTime);
??}
??@Override
??public?String?toString()?{
????Date?date?=?new?Date(delayTime);
????SimpleDateFormat?sd?=?new?SimpleDateFormat("yyyy-MM-dd?HH:mm:ss");
????return?"\nOrderDelayObject:{"
????????????+?"name="?+?name
????????????+?",?time="?+?sd.format(date)
????????????+?",?order="?+?order
????????????+?"}";
??}
}?

@Bean("orderDelayQueue")
public DelayQueue<OrderDelayObject> orderDelayQueue(){
    return new DelayQueue<OrderDelayObject>();
}

@Resource
private?DelayQueue<OrderDelayObject>?orderDelayQueue;
//發(fā)起訂單下單的時候?qū)⒂唵窝菔緦ο蠓湃雘rderDelayQueue
orderDelayQueue.add(
????????new?OrderDelayObject(
????????????????"訂單延時取消任務(wù)",
????????????????30?*?60?*?1000,????//延時30分鐘
????????????????"延時任務(wù)訂單對象信息"
????????)
);

@Component
public class DelayObjectConsumer<OrderDelayObject> implements InitializingBean {
? @Resource
? private DelayQueue<OrderDelayObject> orderDelayQueue;
? @Override
? public void afterPropertiesSet() throws Exception {
? ? new Thread(() -> {
? ? ? while (true) {
? ? ? ? OrderDelayObject task = orderDelayQueue.take();
? ? ? ? System.out.println(task.toString());
? ? ? ? System.out.println(task.getOrder());
? ? ? ? //根據(jù)order訂單信息，去查詢該訂單的支付信息
? ? ? ? //如果用戶沒有進行支付，將訂單從數(shù)據(jù)庫中關(guān)閉
? ? ? ? //如果訂單并發(fā)量比較大，這里可以考慮異步或線程池的方式進行處理
? ? ? }
? ? }).start();
? }
}