# 发送定时消息
分布式消息服务RocketMQ版支持**任意时间**的定时消息。
定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。
发送定时消息前，请参考[收集连接信息](https://support.huaweicloud.com/devg-hrm/hrm-devg-008.html)收集RocketMQ所需的连接信息。
#### 约束与限制
- 2022年3月30日及以后购买的实例支持定时消息功能，在此之前购买的实例不支持此功能。
- RocketMQ TCP协议的Python SDK只支持Linux系统，且不支持开启SSL。
 
#### 适用场景
定时消息适用于以下场景：
- 消息对应的业务逻辑有时间窗口要求，如电商交易中超时未支付关闭订单的场景。在订单创建时发送一条定时消息，5分钟以后投递给消费者，消费者收到此消息后需要判断对应订单是否完成支付，如果未完成支付，则关闭订单。如果已完成，则忽略。
- 通过消息触发定时任务的场景，如在某些固定时间点向用户发送提醒消息。
 
#### 注意事项
- 4.8.0版本定时消息的最大延迟时间为1年，5.x版本为7天，若延迟时间超过对应版本的最大限制（1年或7天），消息将发送失败。
- 定时消息的定时时间如果被设置成当前时间戳之前的某个时刻，消息将立刻投递给消费者。
- 无法确保定时消息仅投递一次，定时消息可能会重复投递。
- 定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积，那么定时消息会排在堆积消息后面，将不能严格按照配置的时间进行投递。
- 由于客户端和服务端可能存在时间差，消息的实际投递时间与客户端设置的投递时间之间可能存在偏差，以服务端时间为准。
- 设置定时消息的投递时间后，依然受消息老化时间限制，默认消息老化时间为2天。例如，设置定时消息5天后才能被消费，如果第5天后一直没被消费，那么这条消息将在第7天被删除。
- 定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。
 
#### 准备环境
1. 在命令行输入**python** ，检查是否已安装Python。得到如下回显，说明Python已安装。
   ```
   Python 3.7.1 (default, Jul  5 2020, 14:37:24) 
   [GCC 4.8.5 20150623 (Red Hat 4.8.5-39)] on linux
   Type "help", "copyright", "credits" or "license" for more information.
   >>>
   ```
   如果未安装Python，请使用以下命令安装：
   ```
   yum install python
   ```
   
2. 安装librocketmq库和rocketmq-client-python，具体操作请参考[rocketmq-client-python](https://github.com/apache/rocketmq-client-python)。
   ![](https://support.huaweicloud.com/devg-hrm/public_sys-resources/note_3.0-zh-cn.png)
   建议下载[rocketmq-client-cpp-2.2.0](https://github.com/apache/rocketmq-client-cpp/releases/tag/2.2.0)，获取librocketmq库。
   
3. 将librocketmq.so添加到系统动态库搜索路径。
   1. 查找librocketmq.so的路径。
      ```
      find / -name librocketmq.so
      ```
      
   
   2. 将librocketmq.so添加到系统动态库搜索路径。
      ```
      ln -s /查找到的librocketmq.so路径/librocketmq.so /usr/lib
      sudo ldconfig
      ```
      
    
 
#### 发送定时消息
发送定时消息的示例代码如下（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
```
import time
from rocketmq.client import Producer, Message
topic = 'TopicTest'
name_srv = '192.168.0.1:8100'
def create_message():
    msg = Message(topic)
    msg.set_keys('messageKey')
    msg.set_tags('messageTag')
    msg.set_property('property', 'test')
    msg.set_body('message body')
    return msg
def send_delay_message():
    producer = Producer('producerGroup')
    producer.set_name_server_address(name_srv)
    producer.start()
    msg = create_message()
    msg.set_property('__STARTDELIVERTIME', str(int(round((time.time() + 3) * 1000))))
    ret = producer.send_sync(msg)
    print('send message status: ' + str(ret.status) + ' msgId: ' + ret.msg_id)
    producer.shutdown()
if __name__ == '__main__':
    send_delay_message()
```
示例代码中的参数说明如下，请参考[收集连接信息](https://support.huaweicloud.com/devg-hrm/hrm-devg-008.html)获取参数值。
- topic：表示Topic名称。
- name_srv：表示实例连接地址和端口。
- set_keys：设置消息索引键，可根据关键字精确查找某条消息。
- set_tags：设置消息Tag，用于消费端根据指定Tag过滤消息。