延时消息用于指定消息发送到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();
-     }
- }
订阅消息代码示例
延时消息订阅与普通消息订阅一致,可前往
订阅消息查看。