使用Koa開發(fā)微信公眾號

一蒲牧、使用koa2-generator搭建koa項(xiàng)目

1.全局安裝Koa腳手架

npm install koa-generator -g

2.創(chuàng)建模板

koa2 my-project-name -e // -e代表使用ejs模板引擎

二却特、配置微信公眾號后臺

進(jìn)入后臺 -> 開發(fā) -> 基本配置

1.配置ip白名單

調(diào)用獲取access_token的ip地址，需要放進(jìn)白名單，比如你本地測試的ip和你之后部署的服務(wù)器ip（只需要填寫ip檬寂，不需要加上http://之類的）

2.獲取AppSecret

這是獲取access_token需要用的密碼，一定在保存好，微信生成后不會存儲求厕，只會重置。

三扰楼、使用koa獲取access_token

1.開發(fā)前先仔細(xì)閱讀下微信的開發(fā)文檔

微信開放文檔

看完之后呀癣，你會了解到，調(diào)取幾乎所有微信的接口都需要這個(gè)access_token弦赖，所以獲取這個(gè)access_token是第一步项栏，獲取access_token需要3個(gè)參數(shù)，分別是：appid蹬竖、secret（即上面所說的appsecret）和grant_type(值為：client_credential)沼沈，這三個(gè)值你可以放到項(xiàng)目的配置文件中，因?yàn)樗麄兊闹祹缀醪粫儯ǔ悄骋惶炷闩獊G了appsecret币厕，需要重置）列另。

2.接口調(diào)用

使用 https請求方式 GET請求

請求地址：https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET

其中APPID和APPSECRET是變量，從你的配置文件中讀取旦装。

3.在koa中如何調(diào)用第三方的接口

我使用的是koa2-request

使用npm i koa2-request -S并加載const koaReq = require('koa2-request')

以下是我的調(diào)用方法访递，從配置文件中讀取appid,secret,grant_type，qs中就是GET請求參數(shù)

const koaReq = require('koa2-request')
getAccessTokenApi(){
    const {appid,secret,grant_type} = wechat
    return new Promise((resolve,reject)=>{
        koaReq({
            method: 'get',
            url: `https://api.weixin.qq.com/cgi-bin/token`,
            qs: { appid, secret, grant_type },
            json: true//設(shè)置返回的數(shù)據(jù)為json
        },(error, response, body)=> {
            if(error){
                reject(error)
            }else{
                resolve(body)
            }
        })
    })
}

正常情況下同辣，微信會返回下述JSON數(shù)據(jù)包給公眾號：
{"access_token":"ACCESS_TOKEN","expires_in":7200}

由于access_token的過期時(shí)間是2小時(shí)（7200秒）拷姿，所以需要我們定時(shí)去重新獲取，才能保證調(diào)用其他微信方法時(shí)access_token不會失效

我將access_token和過期時(shí)間expires_time保存在文件中旱函，設(shè)置過期時(shí)間expires_time為當(dāng)前時(shí)間+（7200-1800）秒响巢，也就是當(dāng)前時(shí)間的1個(gè)半小時(shí)后是我的過期時(shí)間。我使用了一個(gè)定時(shí)任務(wù)插件(node-schedule)棒妨，每10分鐘去判斷一下當(dāng)前時(shí)間和過期時(shí)間踪古，如果當(dāng)前時(shí)間大于過期時(shí)間，則需要重新獲取access_token

// schedule.js
// 先書寫一個(gè)每10分鐘執(zhí)行一次的定時(shí)任務(wù)
const schedule = require('node-schedule');
const fs = require('fs')
const path = require('path')
const os = require("os");
module.exports = {
    refreshTokenSchedule(callback){
        console.log('啟動定時(shí)任務(wù)');
        const loggerPath = path.resolve(__dirname,'../file/scheuleLogger.txt')
        var rule = new schedule.RecurrenceRule();
        rule.minute = [0,10,20,30,40,50];
        const j = schedule.scheduleJob(rule, function(){
            let now = new Date().format('yyyy年M月d日 hh:mm:ss');
            fs.appendFile(loggerPath,now+=os.EOL,(err)=>{
                if(err) throw err
            })
          callback && callback()
        });
    }
}

const koaReq = require('koa2-request')
const path = require('path')
const { wechat } = require('../config')
const { refreshTokenSchedule } = require('../config/schedule')
const { readFile, writeFile, isFile } = require('../config/file')
const FILEPATH = path.resolve(__dirname, '../file/accessToken.txt')

class Token {
    constructor() {
        // 執(zhí)行定時(shí)器券腔，定時(shí)去判斷是否過期伏穆，如果過期就重新獲取
        refreshTokenSchedule(async () => {
            try {
                let isFileExist;
                try {
                    isFileExist = await isFile(FILEPATH);
                } catch (e) {
                    // 說明文件還不存在
                    this.writeTokenToFile()
                }
                if (isFileExist) {
                    const oldAccessTokenObj = await readFile(FILEPATH)
                    const { expires_time } = JSON.parse(oldAccessTokenObj)
                    if (new Date().getTime() > expires_time) {
                        // 即將過期-重新獲取
                        this.writeTokenToFile()
                    }
                }
            } catch (err) {
                console.error(err);
            }
        })
    }
    // 將token寫入文件
    async writeTokenToFile() {
        try {
            const { access_token, expires_in } = await this.getAccessTokenApi();
            let expires_time = new Date().getTime() + (expires_in - 1800) * 1000; //提前半小時(shí)
            writeFile(FILEPATH, JSON.stringify({ access_token, expires_time }))
        } catch (err) {
            console.error(err.errmsg || 'ERROR')
        }
    }
    // 調(diào)用獲取access_token的接口
    getAccessTokenApi() {
        const { appid, secret, grant_type } = wechat
        return new Promise((resolve, reject) => {
            koaReq({
                method: 'get',
                url: `https://api.weixin.qq.com/cgi-bin/token`,
                qs: { appid, secret, grant_type },
                json: true//設(shè)置返回的數(shù)據(jù)為json
            }, (error, response, body) => {
                if (error) {
                    reject(error)
                } else {
                    if (body.errcode) {
                        reject(body)
                    } else {
                        resolve(body)
                    }
                }
            })
        })
    }
}



module.exports = Token


// file.js
const fs = require('fs')
const os = require("os");

module.exports = {
    // 讀取文件
    readFile(fileName){
        return new Promise((resolve,reject)=>{
            fs.readFile(fileName, (err, data) => {
                if (err) {
                    reject(err);
                }else{
                    resolve(data) 
                }
            });
        })
    },
    // 寫入文件
    writeFile(fileName,data){
        return new Promise((resolve,reject)=>{
            fs.writeFile(fileName,data,'utf8',(err) => {
                if (err) {
                    reject(err);
                }else{
                    resolve(data)
                }
          });
        })
    },

    appendFile(fileName,data){
        return new Promise((resolve,reject)=>{
            fs.appendFile(fileName,data+=os.EOL,(err) => {
                if (err) {
                    reject(err);
                }else{
                    resolve(data)
                }
            });
        })
    },
    // 是否是file
    isFile(fileName){
        return new Promise((resolve,reject)=>{
            fs.stat(fileName, (err,stats) => {
                if(err){
                    // 文件不存在
                    reject(err);
                }else{
                    resolve(stats.isFile())
                }
            });
        })
    }
}

四、配置服務(wù)器地址

這個(gè)時(shí)候我們已經(jīng)可以拿到access_token可以調(diào)用其他的微信方法了纷纫，現(xiàn)在我們進(jìn)行服務(wù)器配置枕扫，可以先查看微信開發(fā)文檔了解如何配置。

其中要了解的是需要填寫的Token辱魁，相當(dāng)于是微信方和你之間的秘密烟瞧，這個(gè)值是你任意填寫的诗鸭，但是之后會用到。當(dāng)你配置服務(wù)器地址URL時(shí)参滴，微信會發(fā)送一個(gè)GET請求到你填寫的服務(wù)器地址URL上强岸，其中GET請求的請求參數(shù)是signature、timestamp砾赔、nonce蝌箍、echostr，當(dāng)你接收到之后暴心，你需要將timestamp十绑、nonce以及你之前填寫在微信后臺的Token，進(jìn)行一個(gè)字典序排序酷勺，并進(jìn)行sha1(npm i sha1 -S)加密本橙，如果加密后的字符串，與微信的請求中的signature的值一模一樣脆诉，說明這個(gè)請求來自微信甚亭，你需要返回之前微信給你的echostr，這樣你和微信之間才做好了服務(wù)器的驗(yàn)證击胜。如果上面的功能你都完成了亏狰，你可以填寫配置服務(wù)器地址URL，如果成功了偶摔，則說明驗(yàn)證成功暇唾，如果失敗了，微信會給出提示辰斋。

// router/wechat.js
const router = require('koa-router')()
const sha1 = require('sha1')
const {wechat:{token}} = require('../config')

router.prefix('/wechat');

router.get('/', async (ctx, next) => {
    const {signature,nonce,timestamp,echostr} = ctx.query
    const passStr = [token, timestamp, nonce].sort().join('');
    const shaStr = sha1(passStr);
    if(shaStr === signature){
        // 說明該請求來自微信
        ctx.body = echostr;
    }else{
        ctx.body = 'error'
    }
})

Tips：因?yàn)槲⑿殴娞栭_發(fā)需要域名策州，如何在本地實(shí)時(shí)開發(fā)呢？我用的是ngrok宫仗，進(jìn)行內(nèi)網(wǎng)映射够挂，免費(fèi)的，教程在此藕夫。免去每次都要重新部署到服務(wù)器的煩惱孽糖。

五、如何回復(fù)后臺消息

之前我們配置服務(wù)器地址的時(shí)候毅贮，寫了一個(gè)GET接口办悟，現(xiàn)在我們在此接口基礎(chǔ)上，寫一個(gè)POST請求滩褥，就可以處理消息了病蛉。但是要注意，微信接收到用戶的消息，給你時(shí)是一個(gè)xml數(shù)據(jù)包铡恕，所以你需要對xml進(jìn)行解析，并且再回復(fù)時(shí)丢间，也需要將json串轉(zhuǎn)為xml探熔，再返回給微信。接收消息文檔烘挫。

// router/wechat.js
const router = require('koa-router')()
const {wechat:{token}} = require('../config')
const xml = require('../utils/xmlParse')
const {message} = require('../utils/wx')

router.post('/', async (ctx, next) => {
    const promise = new Promise((resolve, reject) => {
        let buf = ''
        ctx.req.setEncoding('utf8')
        ctx.req.on('data', (chunk) => {
            buf += chunk
        })
        ctx.req.on('end', () => {
            xml.xmlToJson(buf)
            .then(resolve)
            .catch(reject)
        })
    })
    
    await promise.then((xmlResult = {}) => {
        try{
            const {xml:msg} = xmlResult;
            let replyResult = ''; //回復(fù)信息
            switch(msg.MsgType[0]){
            case 'text':
                replyResult = message.text(msg,'你的文采太好啦~')
                break;
            case 'voice':
                replyResult = message.text(msg,'你的聲音太好聽啦诀艰！')
                break;
            default:
                replyResult = message.text(msg,'成功了哦！')
                break;
            }
                ctx.body = replyResult;
            }catch(e){
                console.error(e)
            }
        })
    .catch((e) => {
          e.status = 400
    })
    
    await next()
})

回復(fù)微信消息饮六，json轉(zhuǎn)xml

// utils/wx
const xml = require('../utils/xmlParse')
exports.message = {
    text (msg, content) {
        return xml.jsonToXml({
            xml: {
                ToUserName: msg.FromUserName,
                FromUserName: msg.ToUserName,
                CreateTime: Date.now(),
                //   MsgType: msg.MsgType,
                MsgType: 'text',
                Content: content
            }
        })
    },
}

解析xml使用了xml2js插件 npm i xml2js -S

// utils/xmlParse
const xml2js = require('xml2js')

exports.xmlToJson = (str) => {
    return new Promise((resolve, reject) => {
        const parseString = xml2js.parseString
        parseString(str, (err, result) => {
            if (err) {
                reject(err)
            } else {
                resolve(result)
            }
        })
    })
}

exports.jsonToXml = (obj) => {
    const builder = new xml2js.Builder()
    return builder.buildObject(obj)
}

這樣你就可以試著給你的公眾號發(fā)消息啦其垄！他已經(jīng)會回復(fù)你了哦

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 人面猴
    序言：七十年代末，一起剝皮案震驚了整個(gè)濱河市卤橄，隨后出現(xiàn)的幾起案子绿满，更是在濱河造成了極大的恐慌，老刑警劉巖窟扑，帶你破解...
    沈念sama閱讀 219,039評論 6贊 508
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件喇颁，死亡現(xiàn)場離奇詭異，居然都是意外死亡嚎货，警方通過查閱死者的電腦和手機(jī)橘霎，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,426評論 3贊 395
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進(jìn)店門，熙熙樓的掌柜王于貴愁眉苦臉地迎上來殖属，“玉大人姐叁，你說我怎么就攤上這事∠聪裕” “怎么了外潜？”我有些...
    開封第一講書人閱讀 165,417評論 0贊 356
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵，是天一觀的道長挠唆。 經(jīng)常有香客問我橡卤，道長，這世上最難降的妖魔是什么损搬？ 我笑而不...
    開封第一講書人閱讀 58,868評論 1贊 295
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任碧库，我火速辦了婚禮，結(jié)果婚禮上巧勤，老公的妹妹穿的比我還像新娘嵌灰。我一直安慰自己，他們只是感情好颅悉，可當(dāng)我...
    茶點(diǎn)故事閱讀 67,892評論 6贊 392
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布沽瞭。 她就那樣靜靜地躺著，像睡著了一般剩瓶。 火紅的嫁衣襯著肌膚如雪驹溃。 梳的紋絲不亂的頭發(fā)上城丧，一...
    開封第一講書人閱讀 51,692評論 1贊 305
  • 城市分裂傳說
    那天，我揣著相機(jī)與錄音豌鹤，去河邊找鬼亡哄。 笑死，一個(gè)胖子當(dāng)著我的面吹牛布疙，可吹牛的內(nèi)容都是我干的蚊惯。 我是一名探鬼主播，決...
    沈念sama閱讀 40,416評論 3贊 419
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼灵临，長吁一口氣：“原來是場噩夢啊……” “哼截型！你這毒婦竟也來了？” 一聲冷哼從身側(cè)響起儒溉，我...
    開封第一講書人閱讀 39,326評論 0贊 276
  • 萬榮殺人案實(shí)錄
    序言：老撾萬榮一對情侶失蹤宦焦，失蹤者是張志新（化名）和其女友劉穎，沒想到半個(gè)月后顿涣，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體赶诊，經(jīng)...
    沈念sama閱讀 45,782評論 1贊 316
  • ?護(hù)林員之死
    正文 獨(dú)居荒郊野嶺守林人離奇死亡，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,957評論 3贊 337
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年园骆，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了舔痪。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 40,102評論 1贊 350
  • 活死人
    序言：一個(gè)原本活蹦亂跳的男人離奇死亡锌唾，死狀恐怖锄码，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情晌涕，我是刑警寧澤滋捶，帶...
    沈念sama閱讀 35,790評論 5贊 346
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布，位于F島的核電站余黎，受9級特大地震影響重窟，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜惧财，卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,442評論 3贊 331
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一巡扇、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧垮衷，春花似錦厅翔、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,996評論 0贊 22
  • 一樁弒父案刀闷，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至，卻和暖如春甸昏，著一層夾襖步出監(jiān)牢的瞬間顽分，已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,113評論 1贊 272
  • 情欲美人皮
    我被黑心中介騙來泰國打工施蜜， 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留卒蘸，地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 48,332評論 3贊 373
  • 代替公主和親
    正文 我出身青樓花墩，卻偏偏與公主長得像悬秉，于是被迫代替她去往敵國和親澄步。 傳聞我的和親對象是個(gè)殘疾皇子冰蘑，可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,044評論 2贊 355