delaymq高性能的任意延時消息隊列

import com.aliyun.openservices.ons.api.*;
import com.aliyun.openservices.shade.org.apache.commons.lang3.time.DateFormatUtils;

import java.util.Date;
import java.util.Properties;

public class ProducerDelayTest {
    public static void main(String[] args) {
        Properties properties = new Properties();
        // AccessKey ID阿里云身份驗證，在阿里云RAM控制臺創建。
        properties.put(PropertyKeyConst.AccessKey, "XXX");
        // AccessKey Secret阿里云身份驗證，在阿里云RAM控制臺創建。
        properties.put(PropertyKeyConst.SecretKey, "XXX");
        // 設置TCP接入域名，進入消息隊列RocketMQ版控制臺實例詳情頁面的接入點區域查看。
        properties.put(PropertyKeyConst.NAMESRV_ADDR, "localhost:9876");
        

        Producer producer = ONSFactory.createProducer(properties);
        // 在發送消息前，必須調用start方法來啟動Producer，只需調用一次即可。
        producer.start();

         {
            Message msg = new Message(
                    // 您在消息隊列RocketMQ版控制臺創建的Topic。
                    "TopicTest",
                    // Message Tag,可理解為Gmail中的標簽，對消息進行再歸類，方便Consumer指定過濾條件在消息隊列RocketMQ版服務器過濾。
                    "TagA",
                    // Message Body可以是任何二進制形式的數據，消息隊列RocketMQ版不做任何干預，需要Producer與Consumer協商好一致的序列化和反序列化方式。
                    "演示15秒鐘>>> ".getBytes());
            // 設置代表消息的業務關鍵屬性，請盡可能全局唯一。
            // 以方便您在無法正常收到消息情況下，可通過控制臺查詢消息并補發。
            // 注意：不設置也不會影響消息正常收發。
            msg.setKey("ORDERID_100e");
            try {
                // 延時消息，單位毫秒（ms），在指定延遲時間（當前時間之后）進行投遞，例如消息在15秒后投遞。
                long delayTime = System.currentTimeMillis() + 15000;
                System.out.println("發送時間>>" + DateFormatUtils.format(new Date(), "yyyy-MM-dd HH