全部产品
云市场

收发定时消息

更新时间:2019-02-25 19:56:12

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

定时消息可以做到在指定时间之后才可被消费者消费,用于解决一些消息生产和消费有时间窗口要求的场景,或者通过消息触发定时任务的场景,类似于延迟队列。

发送定时消息

发送定时消息的代码示例如下:

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Runtime.InteropServices;
  6. using ons;
  7. namespace ons
  8. {
  9. class onscsharp
  10. {
  11. static void Main(string[] args)
  12. {
  13. //producer 创建和正常工作的参数,必须输入
  14. ONSFactoryProperty factoryInfo = new ONSFactoryProperty();
  15. factoryInfo.setFactoryProperty(factoryInfo.ProducerId, "XXX ");//您在控制台创建的 Group ID
  16. factoryInfo.setFactoryProperty(factoryInfo.NAMESRV_ADDR, "XXX"); //设置 TCP 接入域名,进入控制台的实例管理页面的“获取接入点信息”区域查看
  17. factoryInfo.setFactoryProperty(factoryInfo.PublishTopics, "XXX");//您在控制台创建的 Topic
  18. factoryInfo.setFactoryProperty(factoryInfo.MsgContent, "XXX");//消息内容
  19. factoryInfo.setFactoryProperty(factoryInfo.AccessKey, "XXX");//AccessKey 阿里云身份验证,在阿里云服务器管理控制台创建
  20. factoryInfo.setFactoryProperty(factoryInfo.SecretKey,"XXX");//SecretKey 阿里云身份验证,在阿里云服务器管理控制台创建
  21. //创建 producer
  22. ONSFactory onsfactory = new ONSFactory();
  23. Producer pProducer = onsfactory.getInstance().createProducer(factoryInfo);
  24. //在发送消息前,必须调用 start 方法来启动 Producer,只需调用一次即可
  25. pProducer.start();
  26. Message msg = new Message(
  27. //Message Topic
  28. factoryInfo.getPublishTopics(),
  29. //Message Tag
  30. "TagA",
  31. //Message Body
  32. factoryInfo.getMessageContent()
  33. );
  34. // 设置代表消息的业务关键属性,请尽可能全局唯一。
  35. // 以方便您在无法正常收到消息情况下,可通过 MQ Console 查询消息并补发。
  36. // 注意:不设置也不会影响消息正常收发
  37. msg.setKey("ORDERID_100");
  38. // deliver time 单位 ms,指定一个时刻,在这个时刻之后才能被消费,这个例子表示3s 后才能被消费
  39. long deliverTime = 获取系统当前时间(ms) + 3000;
  40. msg.setStartDeliverTime(deliverTime);
  41. //发送消息,只要不抛出异常,就代表发送成功
  42. try
  43. {
  44. SendResultONS sendResult = pProducer.send(msg);
  45. }
  46. catch(ONSClientException e)
  47. {
  48. //发送失败处理
  49. }
  50. // 在应用退出前,必须销毁 Producer 对象,否则会导致内存泄露等问题
  51. pProducer.shutdown();
  52. }
  53. }
  54. }

订阅定时消息

关于订阅普通消息的说明和示例代码,详见订阅消息