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

发送定时消息

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

目前支持的域包括公网、华东1、华北2、华东2、华南1。

定时消息可以做到在指定时间戳之后才可被消费者消费,用于解决一些消息生产和消费有时间窗口要求的场景,或者通过消息触发定时任务的场景。更详细的概念介绍及使用过程中的注意事项请参考文档定时消息

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

代码示例

  1. public class ProducerDelayTest {
  2. public static void main(String[] args) {
  3. Properties properties = new Properties();
  4. //您在 MQ 控制台创建的Producer ID
  5. properties.put(PropertyKeyConst.ProducerId, "XXX");
  6. // 阿里云身份验证,在阿里云服务器管理控制台创建
  7. properties.put(PropertyKeyConst.AccessKey, "XXX");
  8. // 阿里云身份验证,在阿里云服务器管理控制台创建
  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. // Message所属的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. /**
  28. * 定时消息投递,设置投递的具体时间戳,单位毫秒例如2016-03-07 16:21:00投递
  29. */
  30. long timeStamp =new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse("2016-03-07 16:21:00").getTime();
  31. msg.setStartDeliverTime(timeStamp);
  32. // 发送消息,只要不抛异常就是成功
  33. SendResult sendResult = producer.send(msg);
  34. System.out.println("Message Id:" + sendResult.getMessageId());
  35. // 在应用退出前,销毁 Producer 对象
  36. // 注意:如果不销毁也没有问题
  37. producer.shutdown();
  38. }
  39. }
本文导读目录
本文导读目录
以上内容是否对您有帮助?