延时消息用于指定消息发送到MQ服务器端后,延时一段时间才被投递到客户端进行消费(例如3秒后才被消费),适用于解决一些消息生产和消费有时间窗口要求的场景,或者通过消息触发延迟任务的场景,类似于延迟队列。
延时消息的概念介绍及使用过程中的注意事项请参考文档
延时消息。
TCP 接入点域名,请
前往查看。
发送消息代码示例
- import com.aliyun.openservices.ons.api.Message;
 - import com.aliyun.openservices.ons.api.ONSFactory;
 - import com.aliyun.openservices.ons.api.Producer;
 - import com.aliyun.openservices.ons.api.PropertyKeyConst;
 - import com.aliyun.openservices.ons.api.SendResult;
 - import java.util.Properties;
 - public class ProducerDelayTest {
 -     public static void main(String[] args) {
 -         Properties properties = new Properties();
 -         // 您在控制台创建的 Producer ID
 -         properties.put(PropertyKeyConst.ProducerId, "XXX");
 -         // AccessKey 阿里云身份验证,在阿里云服务器管理控制台创建
 -         properties.put(PropertyKeyConst.AccessKey, "XXX");
 -         // SecretKey 阿里云身份验证,在阿里云服务器管理控制台创建
 -         properties.put(PropertyKeyConst.SecretKey, "XXX");
 -         // 设置 TCP 接入域名(此处以公共云生产环境为例)
 -         properties.put(PropertyKeyConst.ONSAddr,
 -           "http://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal");
 -         Producer producer = ONSFactory.createProducer(properties);
 -         // 在发送消息前,必须调用 start 方法来启动 Producer,只需调用一次即可。
 -         producer.start();
 -         Message msg = new Message( //
 -                 // 您在控制台创建的Topic
 -                 "Topic",
 -                 // Message Tag, 可理解为Gmail中的标签,对消息进行再归类,方便Consumer指定过滤条件在MQ服务器过滤
 -                 "tag",
 -                 // Message Body 可以是任何二进制形式的数据, MQ 不做任何干预,需要 Producer 与 Consumer 协商好一致的序列化和反序列化方式
 -                 "Hello MQ".getBytes());
 -         // 设置代表消息的业务关键属性,请尽可能全局唯一。
 -         // 以方便您在无法正常收到消息情况下,可通过 MQ 控制台查询消息并补发。
 -         // 注意:不设置也不会影响消息正常收发
 -         msg.setKey("ORDERID_100");
 -         // 延时时间单位为毫秒(ms),指定一个时刻,在这个时刻之后才能被消费,这个例子表示 3秒 后才能被消费
 -         long delayTime = 3000;
 -         msg.setStartDeliverTime(System.currentTimeMillis() + delayTime);
 -         // 发送消息,只要不抛异常就是成功
 -         SendResult sendResult = producer.send(msg);
 -         System.out.println("Message Id:" + sendResult.getMessageId());
 -         // 在应用退出前,销毁Producer对象<br>
 -         // 注意:如果不销毁也没有问题
 -         producer.shutdown();
 -     }
 - }
 
订阅消息代码示例
延时消息订阅与普通消息订阅一致,可前往
订阅消息查看。