.NET SDK 发送定时消息如何实现？

MQ 发送定时消息


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