又拍雲 Node.js 實現檔案上傳、刪除
阿新 • • 發佈:2018-12-17
Node.js 服務端
使用 Node.js + Express.js 實現 服務端
const express = require("express"); const app = express(); const axios = require('axios'); app.set('port', process.env.PORT || 8082); // 靜態資源目錄,這裡放在了根目錄,生產環境不允許這樣 app.use(express.static(__dirname)); // 啟動一個埠為 8082 的伺服器 app.listen(app.get('port'), () => { console.log("http://localhost:" + app.get('port')); });
準備 Base64、HMAC-SHA1、MD5 實現簽名認證
詳見:http://docs.upyun.com/api/authorization/#_5
const crypto = require("crypto"); // MD5 function MD5(value) { return crypto .createHash("md5") .update(value) .digest("hex"); } // Base64 function base64(value) { return Buffer.from(value).toString("base64"); } // hmacsha1 function hmacsha1(secret, value) { return crypto.createHmac('sha1', secret).update(value, 'utf-8').digest().toString('base64'); }
上傳、刪除介面
const date = new Date().toGMTString(); const bucketname = ""; // 空間名 const key = ""; // 操作員 const secret = ""; // 密碼 const upyunUrl = 'http://v0.api.upyun.com/' // Upload app.get("/api/token/upload", (req, res) => { let fileName = (Math.random() * 100000000) >>> 0; let expiration = ((Date.now() / 1000) >>> 0) + 30 * 60; // 請求的過期時間,UNIX UTC 時間戳,單位秒。建議設為 30 分鐘 http://docs.upyun.com/api/form_api/ let method = "POST"; let policy = base64( JSON.stringify({ bucket: bucketname, // "save-key": "/" + fileName + "{.suffix}", "save-key": "/{filename}{.suffix}", expiration: expiration }) ); let authorization = "UPYUN " + key + ":" + hmacsha1(MD5(secret), method + "&/" + bucketname + "&" + policy); res.json({ msg: "OK", code: 200, data: { authorization: authorization, policy: policy } }); }); // Delete app.get('/api/token/del', (req, res) => { let item = req.query.item; let method = "DELETE" let authorization = "UPYUN " + key + ":" + hmacsha1(MD5(secret), method + '&/' + bucketname + item + '&'+ date); axios({ url: upyunUrl + bucketname + item, method: 'DELETE', headers: { 'Authorization': authorization, 'Date': date } }).then(response => { res.json({ msg: "OK", code: 200, data: {} }); }).catch(err => { console.log('err', err) }) })
跨域介面呼叫
const cors = require('cors');
// CORS @see https://github.com/expressjs/cors
app.use(cors());
前端
前端使用 Vue.js 實現
引入 Bootstrap.css
<link rel="stylesheet" type="text/css" href="https://unpkg.com/[email protected]/dist/css/bootstrap.css">
<!-- HTML -->
<div id="app">
<div class="card" style="margin: 50px auto; width: 300px;">
<div class="card-body">
<h5 class="card-title">UPYun Upload & Delete</h5>
<div class="card-text">
<div class="form-group">
<label for="file">Upload</label>
<input type="file" id="file" class="form-control-file" @change="onChange">
<div class="form-text text-muted">
<ul>
<li v-for="(item, index) in files">
{{item}} <a href="javascript:;" @click="onDel(item, index)">Del</a>
</li>
</ul>
</div>
</div>
</div>
</div>
</div>
</div>
```
### 引入 Vue.js、Axios
```html
<script src="https://unpkg.com/[email protected]/dist/vue.js"></script>
<script src="https://unpkg.com/axios/dist/axios.min.js"></script>
JS
const upUrl = 'http://v0.api.upyun.com/' // +空間名,如:http://v0.api.upyun.com/yun-temp
const baseApi = 'http://localhost:8082/api/'
let uploadInput;
let app = new Vue({
el: '#app',
data: {
files: []
},
methods: {
onChange: function () {
getToken(token => {
let formData = new FormData();
formData.append("file", uploadInput.files[0])
formData.append('policy', token.policy)
formData.append("authorization", token.authorization)
axios({
method: 'POST',
url: upUrl,
data: formData
}).then(res => {
res = res || {}
if (res.status !== 200) {
console.log('error')
return
}
let data = res.data || {}
this.files.push(data.url)
alert('Success')
}).catch(err => {
console.log(err);
});
});
},
onDel: function (item, index) {
this.files.splice(index, 1)
axios.request({
url: baseApi + 'token/del',
method: 'GET',
params: {
item: encodeURI(item)
}
}).then(res => {
alert('Deleted.')
}).catch(err => {
console.log(err)
})
}
},
mounted () {
uploadInput = $('file')
}
})
// DOM 獲取元素
function $ (el) {
return document.getElementById(el)
}
// 獲取 token
function getToken (fn) {
let token = window.localStorage.getItem('token');
token = JSON.parse(token) || {};
let nowTime = Date.now();
if (nowTime < token.expired && token.authorization && token.policy) {
fn(token)
return
}
axios({
method: 'get',
url: baseApi + 'token/upload'
})
.then(res => {
let data = res.data || {}
data = data.data || {}
const authorization = data.authorization
const policy = data.policy
const expired = ((Date.now() / 1000) >>> 0) + 30 * 60;
token = {
authorization,
policy,
expired
}
fn(token)
window.localStorage.setItem('token', JSON.stringify(token))
});
}