Java SDK如何进行定时消息收发

定时消息可以做到在指定时间戳之后才可被消费者消费，用于解决一些消息生产和消费有时间窗口要求的场景，或者通过消息触发定时任务的场景。更详细的概念介绍及使用过程中的注意事项请参考文档 定时消息。
TCP 接入点域名，请 前往查看。
发送消息代码示例

1. import com.aliyun.openservices.ons.api.Message;
2. import com.aliyun.openservices.ons.api.ONSFactory;
3. import com.aliyun.openservices.ons.api.Producer;
4. import com.aliyun.openservices.ons.api.PropertyKeyConst;
6. import com.aliyun.openservices.ons.api.SendResult;
7. import java.text.ParseException;
8. import java.text.SimpleDateFormat;
9. import java.util.Properties;
11. public class ProducerDelayTest {
12.     public static void main(String[] args) {
13.         Properties properties = new Properties();
14.         //您在 MQ 控制台创建的Producer ID
15.         properties.put(PropertyKeyConst.ProducerId, "XXX");
16.         // 阿里云身份验证，在阿里云服务器管理控制台创建
17.         properties.put(PropertyKeyConst.AccessKey, "XXX");
18.         // 阿里云身份验证，在阿里云服务器管理控制台创建
19.         properties.put(PropertyKeyConst.SecretKey, "XXX");
21.         // 设置 TCP 接入域名（此处以公共云生产环境为例）
22.         properties.put(PropertyKeyConst.ONSAddr,
23.           "http://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal");
24.         Producer producer = ONSFactory.createProducer(properties);
25.         // 在发送消息前，必须调用start方法来启动Producer，只需调用一次即可。
26.         producer.start();
27.         Message msg = new Message( //
28.                 // Message所属的Topic
29.                 "Topic",
30.                 // Message Tag 可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在MQ服务器过滤
31.                 "tag",
32.                 // Message Body 可以是任何二进制形式的数据， MQ不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式
33.                 "Hello MQ".getBytes());
34.         // 设置代表消息的业务关键属性，请尽可能全局唯一
35.         // 以方便您在无法正常收到消息情况下，可通过MQ控制台查询消息并补发。
36.         // 注意：不设置也不会影响消息正常收发
37.         msg.setKey("ORDERID_100");
38.         /**
39.          * 定时消息投递，设置投递的具体时间戳，单位毫秒例如2016-03-07 16:21:00投递
40.         */
41.         try {
42.             long timeStamp = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse("2016-03-07 16:21:00").getTime();
43.             msg.setStartDeliverTime(timeStamp);
44.             // 发送消息，只要不抛异常就是成功
45.             SendResult sendResult = producer.send(msg);
46.             System.out.println("Message Id:" + sendResult.getMessageId());
47.         }
48.         catch (ParseException e) {
49.             e.printStackTrace();
50.         }
52.         // 在应用退出前，销毁 Producer 对象
53.         // 注意：如果不销毁也没有问题
54.         producer.shutdown();
55.     }
56. }