到處都要用到的access_token的獲取和緩存！
官方說(shuō)可以每次都重新獲取，我建議還是緩存下來(lái)比較好。我用了Redis， 你也可以用其他你喜歡的方式。
把獲取的代碼封裝一個(gè)函數(shù)，getAccessToken返回Promise 對(duì)象，每次調(diào)用成功后在繼續(xù)下一步操作！
const config = require('./config')
const https = require('https')
var request = require('request');
const moment = require("moment")
const qs = require('querystring')
var fs = require("fs")
const redis = require('then-redis')
const db = redis.createClient('tcp://localhost:6379')
function getAccessToken(){
return new Promise((resolve, reject)=>{
db.hgetall('AccessToken').then((res)=>{
if(res){
if(res.enddate <= moment().format("YYYY-MM-DD")){
var data = {
'grant_type': 'client_credentials',
'client_id': config.APIKey,
'client_secret': config.SecretKey
};//這是需要提交的數(shù)據(jù)
var content = querystring.stringify(data);
var options = {
hostname: 'aip.baidubce.com',
path: '/oauth/2.0/token?' + content,
method: 'GET'
};
var req = https.request(options, function(res){
res.setEncoding('utf8');
res.on('data', function (chunk) {
chunk = JSON.parse(chunk)
var obj = {
value: chunk.access_token,
enddate: moment().add(29, 'days').format("YYYY-MM-DD")
}
db.hmset("AccessToken", obj)
resolve(obj);
});
})
req.on('error', function (e) {
reject('problem with request: ' + e.message);
});
req.end()
}else{
resolve(res)
}
}else{
var data = {
'grant_type': 'client_credentials',
'client_id': config.APIKey,
'client_secret': config.SecretKey
};//這是需要提交的數(shù)據(jù)
var content = qs.stringify(data);
var options = {
hostname: 'aip.baidubce.com',
path: '/oauth/2.0/token?' + content,
method: 'GET'
};
var req = https.request(options, function(res){
res.setEncoding('utf8');
res.on('data', function (chunk) {
chunk = JSON.parse(chunk)
var obj = {
value: chunk.access_token,
enddate: moment().add(29, 'days').format("YYYY-MM-DD")
}
db.hmset("AccessToken", obj)
resolve(obj);
});
})
req.on('error', function (e) {
reject('problem with request: ' + e.message);
});
req.end()
}
}).catch((err)=>{
reject(err)
})
})
}
