全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 阿里云办公 培训与认证 物联网
消息队列 MQ

发送延时消息

更新时间:2017-08-24 16:49:33

目前支持的域包括公网、华东1、华北2、华东2、华南1。MQ 客户端请使用最新版本1.2.2。

延时消息用于指定消息发送到MQ服务器端后,延时一段时间才被投递到客户端进行消费(例如3秒后才被消费),适用于解决一些消息生产和消费有时间窗口要求的场景,或者通过消息触发延迟任务的场景,类似于延迟队列。

延时消息的概念介绍及使用过程中的注意事项请参考文档延时消息

TCP 接入点域名,请前往查看。

代码示例

  1. public class ProducerDelayTest {
  2. public static void main(String[] args) {
  3. Properties properties = new Properties();
  4. // 您在控制台创建的 Producer ID
  5. properties.put(PropertyKeyConst.ProducerId, "XXX");
  6. // AccessKey 阿里云身份验证,在阿里云服务器管理控制台创建
  7. properties.put(PropertyKeyConst.AccessKey, "XXX");
  8. // SecretKey 阿里云身份验证,在阿里云服务器管理控制台创建
  9. properties.put(PropertyKeyConst.SecretKey, "XXX");
  10. // 设置 TCP 接入域名(此处以公共云生产环境为例)
  11. properties.put(PropertyKeyConst.ONSAddr,
  12. "http://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal");
  13. Producer producer = ONSFactory.createProducer(properties);
  14. // 在发送消息前,必须调用 start 方法来启动 Producer,只需调用一次即可。
  15. producer.start();
  16. Message msg = new Message( //
  17. // 您在控制台创建的Topic
  18. "Topic",
  19. // Message Tag, 可理解为Gmail中的标签,对消息进行再归类,方便Consumer指定过滤条件在MQ服务器过滤
  20. "tag",
  21. // Message Body 可以是任何二进制形式的数据, MQ 不做任何干预,需要 Producer 与 Consumer 协商好一致的序列化和反序列化方式
  22. "Hello MQ".getBytes());
  23. // 设置代表消息的业务关键属性,请尽可能全局唯一。
  24. // 以方便您在无法正常收到消息情况下,可通过 MQ 控制台查询消息并补发。
  25. // 注意:不设置也不会影响消息正常收发
  26. msg.setKey("ORDERID_100");
  27. // 延时时间单位为毫秒(ms),指定一个时刻,在这个时刻之后才能被消费,这个例子表示 3秒 后才能被消费
  28. long delayTime = 3000;
  29. msg.setStartDeliverTime(System.currentTimeMillis() + delayTime);
  30. // 发送消息,只要不抛异常就是成功
  31. SendResult sendResult = producer.send(msg);
  32. System.out.println("Message Id:" + sendResult.getMessageId());
  33. // 在应用退出前,销毁Producer对象<br>
  34. // 注意:如果不销毁也没有问题
  35. producer.shutdown();
  36. }
  37. }
本文导读目录