65      windows

HTTP 定時消息__HTTP 接入(簡單)_消息隊列 MQ-阿裏雲

MQ 的定時消息是指在規定的時間發給消費者進行消費的消息。相比於普通消息，定時消息多了消費時間戳屬性，該屬性主要用於定義消息正式發送給消費者進行消費的時間。下麵會簡要介紹 HTTP 定時消息的主要用法。

屬性說明

需要在發送消息裏麵添加時間戳，該時間戳用於標記當前消息消費的時間，參數名稱為：startdelivertime。

HTTP 定時消息示例代碼

下麵的示例程序是用 Python 語言編寫的，其它類語言隻需在相應的 URL 上添加定時消費的時間戳即可。具體添加方法，請參考如下示例。

class HttpProducer(object):
    def __init__(self):
        """簽名值"""
        self.signature = "Signature"
        """生產者組ID"""
        self.producerid = "ProducerId"
        """消息主題"""
        self.topic = "topic"
        """訪問碼"""
        self.ak = "AccessKey"
        """配置文件解析器"""
        self.cf = ConfigParser.ConfigParser()
        """MD5對象"""
        self.md5 = hashlib.md5()
    """
    發送Topic主流程
    """
    def process(self):
        """讀取配置文件"""
        self.cf.read("user.properties")
        """讀取消息主題"""
        topic = self.cf.get("property","topic")
        """存儲消息URL路徑"""
        url = self.cf.get("property","url")
        """訪問碼"""
        ak = self.cf.get("property","user_accesskey")
        """密鑰"""
        sk = self.cf.get("property","user_secretkey")
        """生產者組ID"""
        pid = self.cf.get("property","producer_group")
        """HTTP請求主體內容"""
        content = U"中文".encode('utf-8')
        """分隔符"""
        newline = "n"
        """獲取URL域名地址"""
        urlname = urlparse(url).hostname
        """根據HTTP主體內容計算MD5值"""
        self.md5.update(content)
        """建立HTTP連接對象"""
        conn = httplib.HTTPConnection(parseURL(urlname))
        try:
            for index in range(0,10):
                """時間戳"""
                date = repr(int(time.time())*1000)[0:13]
                """構造簽名字符串"""
                signString = str(topic + newline + pid + newline + self.md5.hexdigest() + newline + date)
                """計算簽名"""
                sign = calSignature(signString,sk)
                """內容類型"""
                contentFlag ="Content-type"
                """HTTP請求頭部對象"""
                headers = {
                    self.signature : sign,
                    self.ak : ak,
                    self.producerid : pid,
                    contentFlag : "text/html;charset=UTF-8"
                }
                """定時消息時間戳，5秒之後該消息開始消費"""
                timeStamp = str(int(time.time()*1000) + 5000);
                """開始發送HTTP定時消息"""
                conn.request(method="POST",url="/message/?topic="+topic+"&time="+date+"&startdelivertime="+timeStamp+"&tag=http&key=http",
                             body=content,
                             headers=headers)
                """獲取HTTP應答消息"""
                response = conn.getresponse()
                """讀取HTTP應答內容"""
                msg = response.read()
                print "response:"+msg
        except Exception,e:
            print e
        finally:
            conn.close()
"""流程入口"""
if __name__ == '__main__':
    """創建消息生產者"""
    producer = HttpProducer()
    """開啟生產者流程"""
    producer.process()