1、主要介紹內容

此篇文章主要利用Aliyun OSS Nginx proxy module 實現OSS 圖片處理回寫功能，藉助OSS Nginx Proxy module 及 OSS 的上傳回調功能實現OSS圖片處理回寫功能，當然文章目的並不在於強調圖片處理回寫功能，而是借實現一個例子來利用Aliyun OSS Nginx proxy module，對Nginx 及 Nginx lua 感興趣的同學可以參照本文描述做出更強大的應用出來，本文如能拋磚引玉的作用那就不枉我花時間寫此部落格了。

2、開始之前

1、開始之前請稍微閱讀下對Aliyun OSS Nginx proxy module 的簡單介紹

2、瞭解下阿里雲OSS 上傳回調功能

3、參考文章

3、主要功能及優勢

本文主要實現的功能是處理回寫，這裡以oss圖片處理回寫為例介紹如何利用阿里雲OSS 提供的callback來進行圖片回寫。現在很多大圖片如果每次都要實時處理那會大大降低使用者體驗（當然可以利用CDN進行快取），那麼可以通過此方法進行處理圖回寫，每次進行上傳請求時帶上callback引數讓oss通知到本文中實現的nginx伺服器，nginx伺服器會自動從oss 拉取經過處理的資料然後再回寫帶oss中，如果確認成功甚至可以將原圖刪掉只保留處理圖，這些都可以依據上傳邏輯進行實現。那麼肯定會有讀者問那費用呢？這個完全不是問題，因為oss按照請求次數收費相當便宜幾乎不要錢，而流量費用也不用擔心，買一臺和OSS同區域的ECS就可以走內網了，內網流量免費。

4、圖片處理回寫處理邏輯程式碼

oss_rewrite.lua

local cjson = require("cjson")

local function get_object_data_from_oss_img(src_object, src_style)
    local res = ngx.location.capture("/" .. src_object .. src_style)
    if res.status ~= ngx.HTTP_OK then
        ngx.log(ngx.ERR, "fetch external url data failed, object :"
 
, src_object .. src_style, " status:", tostring(res.status))
        return res.status, nil
    end
    return res.status, res.body
end

local function get_and_process(json_table)
    src_object = json_table["src_object"]
    src_style = json_table["style"]
    dst_object = json_table["dst_object"]
    ngx.log(ngx.INFO, "src_object:", src_object, " style:", src_style, " dst_object:", dst_object)
    if src_object == nil or src_style == nil or dst_object == nil then
        ngx.log(ngx.ERR, "src_object style and dst_object should be not null")
        return ngx.HTTP_BAD_REQUEST
    end

    -- Get processed img data from oss
    local status, write_back_body = get_object_data_from_oss_img(src_object, src_style)

    if status ~= ngx.HTTP_OK then
        return status
    end

    -- Write back
    local res = ngx.location.capture("/" .. dst_object, {
        method = ngx.HTTP_PUT,
        body = write_back_body
    })

    if res.status ~= ngx.HTTP_OK then
        ngx.log(ngx.ERR, "write back to oss failed, object:", dst_object, "status:", tostring(res.status))
        return res.status
    end
    return ngx.HTTP_OK
end

local function parse_and_process_post_body()
    ngx.req.read_body()
    local post_json_body = ngx.req.get_body_data()
    ngx.log(ngx.INFO, post_json_body)
    if post_json_body == nil then
        ngx.log(ngx.ERR, "post request body from oss call_back is empty.")
        return ngx.HTTP_BAD_REQUEST
    end
    -- decode json string and catch json errors
    local succ, json_table = pcall(function()
        return cjson.decode(post_json_body)
    end)
    if succ then
        return get_and_process(json_table)
    else
        ngx.log(ngx.ERR, "post request body from oss call_back is not json.")
        return ngx.HTTP_BAD_REQUEST
    end
end

local method = ngx.req.get_method()
if method == 'GET' or method == "POST" then
    local status = parse_and_process_post_body()
    if status == ngx.HTTP_OK then
        ngx.say("{\"success\": \"true\"}")
    else
        ngx.log(ngx.ERR, "fail write back to oss")
        ngx.exit(status)
    end
else
    ngx.log(ngx.INFO, "do not support this method ", method)
    ngx.exit(ngx.HTTP_BAD_REQUEST)
end

nginx.conf

error_log  logs/error.log  debug;
events {
    worker_connections  1024;
}
http {
    include       mime.types;
    lua_package_path "/usr/servers/lualib/?.lua;";
    lua_package_cpath "/usr/servers/lualib/?.so;"; 
    server {
        listen       80;
        server_name  your-server-name; # 注意此項要和CallBack 引數中的Host 保持一致

        resolver 8.8.8.8;
        #lua_code_cache  off; # 加上此配置在每次修改lua 程式碼後無需reload nginx
        location /oss_write_back {
            content_by_lua_file conf/lua/oss_rewrite.lua;
        }

        location / {
            internal;  #只允許內部跳轉
            set $oss_bucket "you-oss-bucket";
            set $oss_auth_id "you-access-key-id";
            set $oss_auth_key "you-access-key-secret";
            rewrite_by_lua_file conf/lua/oss_auth.lua;
        }
        location @oss {
            #eg: bucket-example.oss-cn-qingdao.aliyuncs.com
            proxy_pass http://$oss_bucket.oss-location.aliyuncs.com;
        }
    }
}

5、如何使用上述程式碼及構造OSS call_back 請求

1、準備環境配置檔案

自己搭建openresty 環境或者直接pull docker 官方映象源openresty映象
將oss_rewrite.lua 放到conf/lua/oss_rewrite.lua 中
將http://blog.csdn.net/sunrain_chy/article/details/50935681 提到的oss_auth.lua 放到conf/lua/oss_auth.lua 中
配置好nginx.conf 檔案，啟動nginx

2、構造Callback 請求

構造PUT 請求 call back 引數
callback.txt

{
    "callbackUrl":"your-call-back-url/oss_write_back",
    "callbackHost":"your-call-back-host",
    "callbackBody":"{
            \"src_object\":\"your-src-object-name\",
            \"style\":\"style\",
            \"dst_object\": \"your-dst-object-name\"
        }",
        "callbackBodyType":"application/json"
}

注意這裡的your-call-back-host 要與nginx.conf 中的server_name 保持一致，回撥url 的location 要是oss_write_back
src_object 為oss上存在的一張圖片object，通常設定為此次PUT 請求上傳的Object
style 為 oss 圖片處理引數
dst_object 為處理圖回寫到OSS 的objectname
對上述callback.txt 進行base64編碼

$ base64 callback.txt | tr -d '\n'

3、構造帶CallBack引數的PUT 請求

PUT /test.jpg HTTP/1.1
Host: bucket-example.oss-ch-qingdao.aliyuncs.com
Accept-ncoding: identity
Content-Length: 0
x-oss-callback-var: eyJ4Om15X3ZhciI6ImZvci1jYWxsYmFjay10ZXN0In0=
x-oss-callback: ewogICAgImNhbGxiYWNrVXJsIjoiMzAuOS4xNjkuNDIvb3NzX3dyaXRlX2JhY2siLAogICAgImNhbGxiYWNrSG9zdCI6IjMwLjkuMTY5LjQyIiwKICAgICJjYWxsYmFja0JvZHkiOiJ7CiAgICAgICAgICAgIFwic3JjX29iamVjdFwiOlwidGVzdC5qcGdcIiwKICAgICAgICAgICAgXCJzdHlsZVwiOlwiQDEwMHdfMTAwaFwiLAogICAgICAgICAgICBcImRzdF9vYmplY3RcIjogXCJ0ZXN0LmpwZ18xMDB4MTAwXCIKICAgICAgICB9IiwKICAgICAgICAiY2FsbGJhY2tCb2R5VHlwZSI6ImFwcGxpY2F0aW9uL2pzb24iCn0K

注意上述x-oss-callback 引數為callback.txt 的base64編碼

4、利用nc 將帶call back 引數的請求發往oss

5、結果檢測

在上述引數配置無誤的情況下bucket中會多出來一個名為your-dst-object-name的object，這個object正是由your-src-object-name 帶上style 引數經過OSS圖片處理過的object。

6、程式執行主線

1、使用者傳送帶callback引數的PUT請求到OSS，OSS根據callback提供的引數會呼叫使用者的應用伺服器，也就是我們的nginx

2、nginx 接收到這個請求後解析body引數獲取到 源object 處理引數及回寫object名，這一步走的是nginx conf 中的 location /oss_write_back

3、Nginx 根據解析出來的post 引數發出一個內部跳轉的子請求到 location / 去OSS取出處理引數為style 的處理圖，當然取圖請求會經過oss_auth.lua 走到location @oss進行簽名

4、取出處理圖後nginx lua 發出自請求將處理圖資料回寫到OSS至此回寫完成。