驗證簽名

驗證簽名的過程即為簽名的逆過程，由應用服務器驗證，過程如下：

Result = rsa_verify(public_key, md5(url_decode(path) + query_string + ‘n’ + body), base64_decode(authorization))

字段的含義與簽名過程中描述相同，其中public_key為公鑰， authorization為回調頭中的簽名，整個驗證簽名的過程分為以下幾步：

• 回調請求的x-oss-pub-key-url頭保存的是公鑰的url地址的base64編碼，因此需要對其做base64解碼後獲取到公鑰，即

public_key = urlopen(base64_decode(x-oss-pub-key-url頭的值))

這裏需要注意，用戶需要校驗x-oss-pub-key-url頭的值必須以https://gosspublic.alicdn.com/或者https://gosspublic.alicdn.com/開頭，目的是為了保證這個publickey是由OSS頒發的。

• 獲取base64解碼後的簽名

signature = base64_decode(authorization頭的值)

• 獲取待簽名字符串，方法與簽名一致

sign_str = url_decode(path) + query_string + ‘n’ + body

• 驗證簽名

result = rsa_verify(public_key, md5(sign_str), signature)

以上例為例：

• 獲取到公鑰的url地址，即aHR0cDovL2dvc3NwdWJsaWMuYWxpY2RuLmNvbS9jYWxsYmFja19wdWJfa2V5X3YxLnBlbQ==經過base64解碼後得到https://gosspublic.alicdn.com/callback_pub_key_v1.pem
• 簽名頭kKQeGTRccDKyHB3H9vF+xYMSrmhMZjzzl2/kdD1ktNVgbWEfYTQG0G2SU/RaHBovRCE8OkQDjC3uG33esH2txA==做base64解碼（由於為非打印字符，無法顯示出解碼後的結果）
• 獲取待簽名字符串，即url_decode(“index.php”) + “?id=1&index=2” + “n” + “bucket=yonghu-test”，並做md5
• 驗證簽名

應用服務器示例

以下為一段python示例，演示了一個簡單的應用服務器，主要是說明驗證簽名的方法，此示例需要安裝M2Crypto庫

import httplib
import base64
import md5
import urllib2
from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer
from M2Crypto import RSA
from M2Crypto import BIO
def get_local_ip():
    try:
        csock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        csock.connect(('8.8.8.8', 80))
        (addr, port) = csock.getsockname()
        csock.close()
        return addr
    except socket.error:
        return ""
class MyHTTPRequestHandler(BaseHTTPRequestHandler):
    '''
    def log_message(self, format, *args):
        return
    '''
    def do_POST(self):
        #get public key
        pub_key_url = ''
        try:
            pub_key_url_base64 = self.headers['x-oss-pub-key-url']
            pub_key_url = pub_key_url_base64.decode('base64')
            if not pub_key_url.startswith("https://gosspublic.alicdn.com/") and not pub_key_url.startswith("https://gosspublic.alicdn.com/"):
                self.send_response(400)
                self.end_headers()
                return
            url_reader = urllib2.urlopen(pub_key_url)
            #you can cache it
            pub_key = url_reader.read() 
        except:
            print 'pub_key_url : ' + pub_key_url
            print 'Get pub key failed!'
            self.send_response(400)
            self.end_headers()
            return
        #get authorization
        authorization_base64 = self.headers['authorization']
        authorization = authorization_base64.decode('base64')
        #get callback body
        content_length = self.headers['content-length']
        callback_body = self.rfile.read(int(content_length))
        #compose authorization string
        auth_str = ''
        pos = self.path.find('?')
        if -1 == pos:
            auth_str = urllib2.unquote(self.path) + 'n' + callback_body
        else:
            auth_str = urllib2.unquote(self.path[0:pos]) + self.path[pos:] + 'n' + callback_body
        print auth_str
        #verify authorization
        auth_md5 = md5.new(auth_str).digest()
        bio = BIO.MemoryBuffer(pub_key)
        rsa_pub = RSA.load_pub_key_bio(bio)
        try:
            result = rsa_pub.verify(auth_md5, authorization, 'md5')
        except:
            result = False
        if not result:
            print 'Authorization verify failed!'
            print 'Public key : %s' % (pub_key)
            print 'Auth string : %s' % (auth_str)
            self.send_response(400)
            self.end_headers()
            return
        #do something accoding to callback_body
        #response to OSS
        resp_body = '{"Status":"OK"}'
        self.send_response(200)
        self.send_header('Content-Type', 'application/json')
        self.send_header('Content-Length', str(len(resp_body)))
        self.end_headers()
        self.wfile.write(resp_body)
class MyHTTPServer(HTTPServer):
    def __init__(self, host, port):
        HTTPServer.__init__(self, (host, port), MyHTTPRequestHandler)
if '__main__' == __name__:
    server_ip = get_local_ip()
server_port = 23451
server = MyHTTPServer(server_ip, server_port)
server.serve_forever()

其它語言實現的應用服務器如下：