HTTP 接入如何使用HTTP 定时消息？

属性说明


需要在发送消息里面添加时间戳，该时间戳用于标记当前消息消费的时间，参数名称为：startdelivertime。

HTTP 定时消息示例代码


下面的示例程序是用 Python 语言编写的，其它类语言只需在相应的 URL 上添加定时消费的时间戳即可。具体添加方法，请参考如下示例。

1. class HttpProducer(object):
3.     def __init__(self):
5.         """签名值"""
6.         self.signature = "Signature"
8.         """生产者组ID"""
9.         self.producerid = "ProducerId"
11.         """消息主题"""
12.         self.topic = "topic"
14.         """访问码"""
15.         self.ak = "AccessKey"
17.         """配置文件解析器"""
18.         self.cf = ConfigParser.ConfigParser()
20.         """MD5对象"""
21.         self.md5 = hashlib.md5()
23.     """
24.     发送Topic主流程
25.     """
26.     def process(self):
28.         """读取配置文件"""
29.         self.cf.read("user.properties")
31.         """读取消息主题"""
32.         topic = self.cf.get("property","topic")
34.         """存储消息URL路径"""
35.         url = self.cf.get("property","url")
37.         """访问码"""
38.         ak = self.cf.get("property","user_accesskey")
40.         """密钥"""
41.         sk = self.cf.get("property","user_secretkey")
43.         """生产者组ID"""
44.         pid = self.cf.get("property","producer_group")
46.         """HTTP请求主体内容"""
47.         content = U"中文".encode('utf-8')
49.         """分隔符"""
50.         newline = "\n"
52.         """获取URL域名地址"""
53.         urlname = urlparse(url).hostname
55.         """根据HTTP主体内容计算MD5值"""
56.         self.md5.update(content)
58.         """建立HTTP连接对象"""
59.         conn = httplib.HTTPConnection(parseURL(urlname))
60.         try:
61.             for index in range(0,10):
63.                 """时间戳"""
64.                 date = repr(int(time.time())*1000)[0:13]
66.                 """构造签名字符串"""
67.                 signString = str(topic + newline + pid + newline + self.md5.hexdigest() + newline + date)
69.                 """计算签名"""
70.                 sign = calSignature(signString,sk)
72.                 """内容类型"""
73.                 contentFlag ="Content-type"
75.                 """HTTP请求头部对象"""
76.                 headers = {
77.                     self.signature : sign,
78.                     self.ak : ak,
79.                     self.producerid : pid,
80.                     contentFlag : "text/html;charset=UTF-8"
81.                 }
83.                 """定时消息时间戳，5秒之后该消息开始消费"""
84.                 timeStamp = str(int(time.time()*1000) + 5000);
86.                 """开始发送HTTP定时消息"""
87.                 conn.request(method="POST",url="/message/?topic="+topic+"&time="+date+"&startdelivertime="+timeStamp+"&tag=http&key=http",
88.                              body=content,
89.                              headers=headers)
91.                 """获取HTTP应答消息"""
92.                 response = conn.getresponse()
94.                 """读取HTTP应答内容"""
95.                 msg = response.read()
96.                 print "response:"+msg
98.         except Exception,e:
99.             print e
101.         finally:
102.             conn.close()
104. """流程入口"""
105. if __name__ == '__main__':
107.     """创建消息生产者"""
108.     producer = HttpProducer()
110.     """开启生产者流程"""
111.     producer.process()