使用HTTP 接入Python 收发消息如何实现？（2）

[backcolor=transparent]3. 接收消息示例程序
通过 HTTP 协议接收消息，请参考以下示例代码。

1. [backcolor=transparent]#encoding:utf-8
2. [backcolor=transparent]import[backcolor=transparent] [backcolor=transparent]ConfigParser
3. [backcolor=transparent]import[backcolor=transparent] httplib
4. [backcolor=transparent]import[backcolor=transparent] json
5. [backcolor=transparent]import[backcolor=transparent] time
6. [backcolor=transparent]from[backcolor=transparent] urlparse [backcolor=transparent]import[backcolor=transparent] urlparse
7. [backcolor=transparent]from[backcolor=transparent] [backcolor=transparent]Util[backcolor=transparent] [backcolor=transparent]import[backcolor=transparent] parseURL[backcolor=transparent],[backcolor=transparent]calSignature
9. [backcolor=transparent]"""
10. [backcolor=transparent]消息订阅者
11. [backcolor=transparent]"""
12. [backcolor=transparent]class[backcolor=transparent] [backcolor=transparent]HttpConsumer[backcolor=transparent]([backcolor=transparent]object[backcolor=transparent]):
14. [backcolor=transparent]        [backcolor=transparent]def[backcolor=transparent] __init__[backcolor=transparent]([backcolor=transparent]self[backcolor=transparent]):
16. [backcolor=transparent]        [backcolor=transparent]"""签名字段"""
17. [backcolor=transparent]        [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]signature [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]"Signature"
19. [backcolor=transparent]        [backcolor=transparent]"""Consumer ID"""
20. [backcolor=transparent]        [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]consumerid [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]"ConsumerID"
22. [backcolor=transparent]        [backcolor=transparent]"""消费主题"""
23. [backcolor=transparent]        [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]topic [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]"Topic"
25. [backcolor=transparent]        [backcolor=transparent]"""访问码"""
26. [backcolor=transparent]        [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]ak [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]"AccessKey"
28. [backcolor=transparent]        [backcolor=transparent]"""配置文件解析器"""
29. [backcolor=transparent]        [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]cf [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]ConfigParser[backcolor=transparent].[backcolor=transparent]ConfigParser[backcolor=transparent]()
31. [backcolor=transparent]    [backcolor=transparent]"""
32. [backcolor=transparent]    订阅消息流程
33. [backcolor=transparent]    """
34. [backcolor=transparent]    [backcolor=transparent]def[backcolor=transparent] process[backcolor=transparent]([backcolor=transparent]self[backcolor=transparent]):
36. [backcolor=transparent]        [backcolor=transparent]"""开始读取配置文件"""
37. [backcolor=transparent]        [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]cf[backcolor=transparent].[backcolor=transparent]read[backcolor=transparent]([backcolor=transparent]"user.properties"[backcolor=transparent])
39. [backcolor=transparent]        [backcolor=transparent]"""读取主题"""
40. [backcolor=transparent]        topic [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]cf[backcolor=transparent].[backcolor=transparent]get[backcolor=transparent]([backcolor=transparent]"property"[backcolor=transparent],[backcolor=transparent] [backcolor=transparent]"Topic"[backcolor=transparent])
42. [backcolor=transparent]        [backcolor=transparent]"""存储消息的URL路径"""
43. [backcolor=transparent]        url [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]cf[backcolor=transparent].[backcolor=transparent]get[backcolor=transparent]([backcolor=transparent]"property"[backcolor=transparent],[backcolor=transparent] [backcolor=transparent]"URL"[backcolor=transparent])
45. [backcolor=transparent]        [backcolor=transparent]"""访问码"""
46. [backcolor=transparent]        ak [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]cf[backcolor=transparent].[backcolor=transparent]get[backcolor=transparent]([backcolor=transparent]"property"[backcolor=transparent],[backcolor=transparent] [backcolor=transparent]"Ak"[backcolor=transparent])
48. [backcolor=transparent]        [backcolor=transparent]"""密钥"""
49. [backcolor=transparent]        sk [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]cf[backcolor=transparent].[backcolor=transparent]get[backcolor=transparent]([backcolor=transparent]"property"[backcolor=transparent],[backcolor=transparent] [backcolor=transparent]"Sk"[backcolor=transparent])
51. [backcolor=transparent]        [backcolor=transparent]"""Consumer ID"""
52. [backcolor=transparent]        cid [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]cf[backcolor=transparent].[backcolor=transparent]get[backcolor=transparent]([backcolor=transparent]"property"[backcolor=transparent],[backcolor=transparent] [backcolor=transparent]"ConsumerID"[backcolor=transparent])
54. [backcolor=transparent]        newline [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]"\n"
56. [backcolor=transparent]        [backcolor=transparent]"""获取URL主机域名地址"""
57. [backcolor=transparent]        urlname [backcolor=transparent]=[backcolor=transparent] urlparse[backcolor=transparent]([backcolor=transparent]url[backcolor=transparent]).[backcolor=transparent]hostname
59. [backcolor=transparent]        [backcolor=transparent]"""连接存储消息的服务器"""
60. [backcolor=transparent]        conn [backcolor=transparent]=[backcolor=transparent] httplib[backcolor=transparent].[backcolor=transparent]HTTPConnection[backcolor=transparent]([backcolor=transparent]parseURL[backcolor=transparent]([backcolor=transparent]urlname[backcolor=transparent]))
62. [backcolor=transparent]        [backcolor=transparent]while[backcolor=transparent] [backcolor=transparent]True[backcolor=transparent]:
63. [backcolor=transparent]            [backcolor=transparent]try[backcolor=transparent]:
64. [backcolor=transparent]                [backcolor=transparent]"""时间戳"""
65. [backcolor=transparent]                date [backcolor=transparent]=[backcolor=transparent] repr[backcolor=transparent]([backcolor=transparent]int[backcolor=transparent]([backcolor=transparent]time[backcolor=transparent].[backcolor=transparent]time[backcolor=transparent]()[backcolor=transparent] [backcolor=transparent]*[backcolor=transparent] [backcolor=transparent]1000[backcolor=transparent]))[[backcolor=transparent]0[backcolor=transparent]:[backcolor=transparent]13[backcolor=transparent]]
67. [backcolor=transparent]                [backcolor=transparent]"""构造签名字符串"""
68. [backcolor=transparent]                signString [backcolor=transparent]=[backcolor=transparent] topic [backcolor=transparent]+[backcolor=transparent] newline [backcolor=transparent]+[backcolor=transparent] cid [backcolor=transparent]+[backcolor=transparent] newline [backcolor=transparent]+[backcolor=transparent] date
70. [backcolor=transparent]                [backcolor=transparent]"""计算签名值"""
71. [backcolor=transparent]                sign [backcolor=transparent]=[backcolor=transparent] calSignature[backcolor=transparent]([backcolor=transparent]signString[backcolor=transparent],[backcolor=transparent]sk[backcolor=transparent])
73. [backcolor=transparent]                [backcolor=transparent]"""请求消息HTTP头部"""
74. [backcolor=transparent]                headers [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]{
75. [backcolor=transparent]                    [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]signature [backcolor=transparent]:[backcolor=transparent] sign[backcolor=transparent],
76. [backcolor=transparent]                    [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]ak [backcolor=transparent]:[backcolor=transparent] ak[backcolor=transparent],
77. [backcolor=transparent]                    [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]consumerid [backcolor=transparent]:[backcolor=transparent] cid
78. [backcolor=transparent]                    [backcolor=transparent]}
80. [backcolor=transparent]                [backcolor=transparent]"""开始发送获取消息的HTTP请求"""
81. [backcolor=transparent]            conn[backcolor=transparent].[backcolor=transparent]request[backcolor=transparent]([backcolor=transparent]method[backcolor=transparent]=[backcolor=transparent]"GET"[backcolor=transparent],[backcolor=transparent]url[backcolor=transparent]=[backcolor=transparent]url[backcolor=transparent]+[backcolor=transparent]"/message/?topic="[backcolor=transparent]+[backcolor=transparent]topic[backcolor=transparent]+[backcolor=transparent]"&time="[backcolor=transparent]+[backcolor=transparent]date[backcolor=transparent]+[backcolor=transparent]"&num=32"[backcolor=transparent],[backcolor=transparent]headers[backcolor=transparent]=[backcolor=transparent]headers[backcolor=transparent])
83. [backcolor=transparent]                [backcolor=transparent]"""获取HTTP应答消息"""
84. [backcolor=transparent]                response [backcolor=transparent]=[backcolor=transparent] conn[backcolor=transparent].[backcolor=transparent]getresponse[backcolor=transparent]()
86. [backcolor=transparent]                [backcolor=transparent]"""验证应答消息状态值"""
87. [backcolor=transparent]                [backcolor=transparent]if[backcolor=transparent] response[backcolor=transparent].[backcolor=transparent]status [backcolor=transparent]!=[backcolor=transparent] [backcolor=transparent]200[backcolor=transparent]:
88. [backcolor=transparent]                    [backcolor=transparent]continue
90. [backcolor=transparent]                [backcolor=transparent]"""从应答消息中读取实际的消息内容"""
91. [backcolor=transparent]                msg [backcolor=transparent]=[backcolor=transparent] response[backcolor=transparent].[backcolor=transparent]read[backcolor=transparent]()
93. [backcolor=transparent]                [backcolor=transparent]"""将实际的消费消息进行解码"""
94. [backcolor=transparent]                messages [backcolor=transparent]=[backcolor=transparent] json[backcolor=transparent].[backcolor=transparent]loads[backcolor=transparent]([backcolor=transparent]msg[backcolor=transparent])
96. [backcolor=transparent]                [backcolor=transparent]if[backcolor=transparent] len[backcolor=transparent]([backcolor=transparent]messages[backcolor=transparent])[backcolor=transparent] [backcolor=transparent]==[backcolor=transparent] [backcolor=transparent]0[backcolor=transparent]:
97. [backcolor=transparent]                    time[backcolor=transparent].[backcolor=transparent]sleep[backcolor=transparent]([backcolor=transparent]2[backcolor=transparent])
98. [backcolor=transparent]                    [backcolor=transparent]continue
100. [backcolor=transparent]                [backcolor=transparent]"""依次获取每条消费消息"""
101. [backcolor=transparent]                [backcolor=transparent]for[backcolor=transparent] message [backcolor=transparent]in[backcolor=transparent] messages[backcolor=transparent]:
103. [backcolor=transparent]                    [backcolor=transparent]"""计算时间戳"""
104. [backcolor=transparent]                    date [backcolor=transparent]=[backcolor=transparent] repr[backcolor=transparent]([backcolor=transparent]int[backcolor=transparent]([backcolor=transparent]time[backcolor=transparent].[backcolor=transparent]time[backcolor=transparent]()[backcolor=transparent] [backcolor=transparent]*[backcolor=transparent] [backcolor=transparent]1000[backcolor=transparent]))[[backcolor=transparent]0[backcolor=transparent]:[backcolor=transparent]13[backcolor=transparent]]
106. [backcolor=transparent]                    [backcolor=transparent]"""构建删除消费消息URL路径"""
107. [backcolor=transparent]                    delUrl [backcolor=transparent]=[backcolor=transparent] url [backcolor=transparent]+[backcolor=transparent] [backcolor=transparent]"/message/?msgHandle="[backcolor=transparent]+[backcolor=transparent]message[backcolor=transparent][[backcolor=transparent]'msgHandle'[backcolor=transparent]][backcolor=transparent] [backcolor=transparent]+[backcolor=transparent] [backcolor=transparent]"&topic="[backcolor=transparent]+[backcolor=transparent]topic[backcolor=transparent]+[backcolor=transparent]"&time="[backcolor=transparent]+[backcolor=transparent]date
109. [backcolor=transparent]                    [backcolor=transparent]"""构造签名字符串"""
110. [backcolor=transparent]                    signString [backcolor=transparent]=[backcolor=transparent] topic [backcolor=transparent]+[backcolor=transparent] newline [backcolor=transparent]+[backcolor=transparent] cid [backcolor=transparent]+[backcolor=transparent] newline [backcolor=transparent]+[backcolor=transparent] message[backcolor=transparent][[backcolor=transparent]'msgHandle'[backcolor=transparent]][backcolor=transparent] [backcolor=transparent]+[backcolor=transparent] newline [backcolor=transparent]+[backcolor=transparent] date
112. [backcolor=transparent]                    [backcolor=transparent]"""进行签名"""
113. [backcolor=transparent]                    sign [backcolor=transparent]=[backcolor=transparent] calSignature[backcolor=transparent]([backcolor=transparent]signString[backcolor=transparent],[backcolor=transparent]sk[backcolor=transparent])
115. [backcolor=transparent]                    [backcolor=transparent]"""构造删除消费消息HTTP头部"""
116. [backcolor=transparent]                       delheaders [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]{
117. [backcolor=transparent]                           [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]signature [backcolor=transparent]:[backcolor=transparent] sign[backcolor=transparent],
118. [backcolor=transparent]                        [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]ak [backcolor=transparent]:[backcolor=transparent] ak[backcolor=transparent],
119. [backcolor=transparent]                        [backcolor=transparent]self[backcolor=transparent].[backcolor=transparent]consumerid [backcolor=transparent]:[backcolor=transparent] cid[backcolor=transparent],
120. [backcolor=transparent]                [backcolor=transparent]}
122. [backcolor=transparent]                    [backcolor=transparent]"""发送删除消息请求"""
123. [backcolor=transparent]                    conn[backcolor=transparent].[backcolor=transparent]request[backcolor=transparent]([backcolor=transparent]method[backcolor=transparent]=[backcolor=transparent]"DELETE"[backcolor=transparent],[backcolor=transparent] url[backcolor=transparent]=[backcolor=transparent]delUrl[backcolor=transparent],[backcolor=transparent] headers[backcolor=transparent]=[backcolor=transparent]delheaders[backcolor=transparent])
125. [backcolor=transparent]                    [backcolor=transparent]"""获取请求应答"""
126. [backcolor=transparent]                    response [backcolor=transparent]=[backcolor=transparent] conn[backcolor=transparent].[backcolor=transparent]getresponse[backcolor=transparent]()
128. [backcolor=transparent]                    [backcolor=transparent]"""读取应答内容"""
129. [backcolor=transparent]                    msg [backcolor=transparent]=[backcolor=transparent] response[backcolor=transparent].[backcolor=transparent]read[backcolor=transparent]()
131. [backcolor=transparent]                    [backcolor=transparent]print[backcolor=transparent] [backcolor=transparent]"delete msg:"[backcolor=transparent]+[backcolor=transparent]msg
133. [backcolor=transparent]            [backcolor=transparent]except[backcolor=transparent] [backcolor=transparent]Exception[backcolor=transparent],[backcolor=transparent]e[backcolor=transparent]:
134. [backcolor=transparent]                [backcolor=transparent]print[backcolor=transparent] e
136. [backcolor=transparent]        conn[backcolor=transparent].[backcolor=transparent]close[backcolor=transparent]()
138. [backcolor=transparent]"""启动入口"""
139. [backcolor=transparent]if[backcolor=transparent] __name__ [backcolor=transparent]==[backcolor=transparent] [backcolor=transparent]'__main__'[backcolor=transparent]:
141. [backcolor=transparent]    [backcolor=transparent]"""构造消息订阅者"""
142. [backcolor=transparent]    consumer [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]HttpConsumer[backcolor=transparent]()
144. [backcolor=transparent]    [backcolor=transparent]"""开始启动消息订阅者"""
145. [backcolor=transparent]    consumer[backcolor=transparent].[backcolor=transparent]process[backcolor=transparent]()

1. [backcolor=transparent]#encoding:utf-8
2. [backcolor=transparent]import[backcolor=transparent] socket
3. [backcolor=transparent]import[backcolor=transparent] hmac
4. [backcolor=transparent]from[backcolor=transparent] hashlib [backcolor=transparent]import[backcolor=transparent] sha1
6. [backcolor=transparent]"""
7. [backcolor=transparent]解析URL
8. [backcolor=transparent]"""
9. [backcolor=transparent]def[backcolor=transparent] parseURL[backcolor=transparent]([backcolor=transparent]url[backcolor=transparent]):
11. [backcolor=transparent]    iplist [backcolor=transparent]=[backcolor=transparent] socket[backcolor=transparent].[backcolor=transparent]gethostbyname_ex[backcolor=transparent]([backcolor=transparent]url[backcolor=transparent])
13. [backcolor=transparent]    [backcolor=transparent]if[backcolor=transparent] len[backcolor=transparent]([backcolor=transparent]iplist[backcolor=transparent])[backcolor=transparent] [backcolor=transparent]==[backcolor=transparent] [backcolor=transparent]0[backcolor=transparent]:
14. [backcolor=transparent]        [backcolor=transparent]return[backcolor=transparent] [backcolor=transparent]None
16. [backcolor=transparent]    ips [backcolor=transparent]=[backcolor=transparent] iplist[backcolor=transparent][[backcolor=transparent]2[backcolor=transparent]]
17. [backcolor=transparent]    [backcolor=transparent]if[backcolor=transparent] len[backcolor=transparent]([backcolor=transparent]ips[backcolor=transparent])[backcolor=transparent] [backcolor=transparent]==[backcolor=transparent] [backcolor=transparent]0[backcolor=transparent]:
18. [backcolor=transparent]        [backcolor=transparent]return[backcolor=transparent] [backcolor=transparent]None
20. [backcolor=transparent]    [backcolor=transparent]return[backcolor=transparent] ips[backcolor=transparent][[backcolor=transparent]0[backcolor=transparent]]
23. [backcolor=transparent]"""
24. [backcolor=transparent]认证签名
25. [backcolor=transparent]"""
26. [backcolor=transparent]def[backcolor=transparent] calSignature[backcolor=transparent]([backcolor=transparent]signString[backcolor=transparent],[backcolor=transparent] sk[backcolor=transparent]):
28. [backcolor=transparent]    mac [backcolor=transparent]=[backcolor=transparent] hmac[backcolor=transparent].[backcolor=transparent]new[backcolor=transparent]([backcolor=transparent]sk[backcolor=transparent],[backcolor=transparent] signString[backcolor=transparent],[backcolor=transparent] sha1[backcolor=transparent])
30. [backcolor=transparent]    [backcolor=transparent]return[backcolor=transparent] mac[backcolor=transparent].[backcolor=transparent]digest[backcolor=transparent]().[backcolor=transparent]encode[backcolor=transparent]([backcolor=transparent]'base64'[backcolor=transparent]).[backcolor=transparent]rstrip[backcolor=transparent]()