nodejs微信開發(fā)之自動回復(fù)的實現(xiàn)
上一篇:接入指南
這部分是實現(xiàn)簡單的自動回復(fù),當(dāng)然也是很大一部分功能的實現(xiàn)基礎(chǔ),這里使用了圖靈機(jī)器人的接口。
效果圖如下:
當(dāng)然,這個機(jī)器人的效果如何不是我能管得了的事情了,類似圖靈機(jī)器人,我們還可以實現(xiàn)段子推送,快遞查詢等一系列功能,這里不一一實現(xiàn)了。
微信的消息處理
對于公眾平臺,每一次發(fā)消息相當(dāng)于發(fā)出一個post請求,但是需要注意的是不管是發(fā)出的請求還是收到的回復(fù),他的數(shù)據(jù)格式都是xml,但是nodejs本身無法處理xml,所以需要對xml數(shù)據(jù)進(jìn)行處理。
仍然使用的是body-parser這個庫,但是需要引入body-parser-xml:
//解析xml app.use(bodyParser.xml({ limit: '1MB', // Reject payload bigger than 1 MB xmlParseOptions: { normalize: true, // Trim whitespace inside text nodes normalizeTags: true, // Transform tags to lowercase explicitArray: false // Only put nodes in array if >1 } }));
這樣req.body.xml
就是處理好的數(shù)據(jù)了。
一般文本消息的格式如下所示:
<xml> <ToUserName><![CDATA[toUser]]></ToUserName> <FromUserName><![CDATA[fromUser]]></FromUserName> <CreateTime>1348831860</CreateTime> <MsgType><![CDATA[text]]></MsgType> <Content><![CDATA[this is a test]]></Content> <MsgId>1234567890123456</MsgId> </xml>
其中ToUserName
是接受者的openid,FromUserName
是發(fā)送者的openid,CreateTime
就是一個整型的時間戳。MsgType
就是消息類型,一般有文本(text),圖片(image),語音(voice),視頻(video),小視頻(shortvideo),地理位置(location)以及鏈接消息(link)。下面就以文本消息為例進(jìn)行編碼。
router.post('/', function (req, res) { res.writeHead(200, {'Content-Type': 'application/xml'}); var data = req.body.xml; var resMsg = '<xml>' + '<ToUserName><![CDATA[' + data.fromusername + ']]></ToUserName>' + '<FromUserName><![CDATA[' + data.tousername + ']]></FromUserName>' + '<CreateTime>' + parseInt(new Date().valueOf() / 1000) + '</CreateTime>' + '<MsgType><![CDATA[text]]></MsgType>' + '<Content><![CDATA['+data.content+']]></Content>' + '</xml>'; res.end(resMsg); });
只需要將header的content-type設(shè)置為xml,返回一個xml的響應(yīng),那么公眾號就會相應(yīng)的回復(fù)一個消息,這里回復(fù)的消息是文本格式。(mac的微信一年沒更新了--)
如上圖,發(fā)送消息則會回復(fù)一個內(nèi)容一樣的消息,一個簡單的自動回復(fù)就實現(xiàn)了。
圖靈機(jī)器人
這個接口的使用十分簡單,get請求鏈接,記得帶上apikey的頭,然后就會返回響應(yīng)的內(nèi)容。我這里請求使用的是nodejs request庫。
const request = require('request'); const config = require('../../config'); function getTuringResponse(info) { if(typeof info !== 'string') { info = info.toString(); } var options = { method:'GET', url: 'http://apis.baidu.com/turing/turing/turing?key=879a6cb3afb84dbf4fc84a1df2ab7319&info='+info, headers: { 'apikey': config.turingKey } }; return new Promise((resolve, reject) => { request(options, function (err, res, body) { if (res) { resolve(body); } else { reject(err); } }); }) } module.exports = getTuringResponse;
使用promise處理異步返回的結(jié)果,避免多次回調(diào),記得把a(bǔ)pikey設(shè)置為header內(nèi)容。
公眾號機(jī)器人
好了,上面是二者分開的講的,如果看到這應(yīng)該知道一個聊天機(jī)器人的實現(xiàn)是非常簡單的了。就是將接口響應(yīng)的內(nèi)容返回給用戶(?如果不是非要自己實現(xiàn)聊天機(jī)器人的話。。。),后臺這里也就相當(dāng)于一個跳板。
turingRobot.js
const request = require('request'); const config = require('../../config'); function getTuringResponse(info) { if(typeof info !== 'string') { info = info.toString(); } var options = { method:'GET', url: 'http://apis.baidu.com/turing/turing/turing?key=879a6cb3afb84dbf4fc84a1df2ab7319&info='+info, headers: { 'apikey': config.turingKey } }; return new Promise((resolve, reject) => { request(options, function (err, res, body) { if (res) { resolve(body); } else { reject(err); } }); }) } module.exports = getTuringResponse;
這部分代碼很簡單了,就是將圖靈機(jī)器人的接口響應(yīng)消息返回出來。下面要做的就是將消息返回給用戶,這里有一點需要注意的是對于發(fā)出的響應(yīng),該接口不能直接響應(yīng)中文字符串,需要進(jìn)行urlencode。
//autoReply.js const request = require('request'); function autoReply(requestData, info) { switch (requestData.msgtype) { case 'text': var resMsg = '<xml>' + '<ToUserName><![CDATA[' + requestData.fromusername + ']]></ToUserName>' + '<FromUserName><![CDATA[' + requestData.tousername + ']]></FromUserName>' + '<CreateTime>' + parseInt(new Date().valueOf() / 1000) + '</CreateTime>' + '<MsgType><![CDATA[text]]></MsgType>' + '<Content><![CDATA['+info+']]></Content>' + '</xml>'; break; } return resMsg; } module.exports = autoReply;
自動回復(fù)的模塊,主要是返回一個xml字符串,方便發(fā)送給用戶。
//weixin.js router.post('/', function (req, res) { res.writeHead(200, {'Content-Type': 'application/xml'}); var content = req.body.xml.content; turingRobot(encodeURI(content)).then(function (data) { var response = JSON.parse(data); var resMsg = autoReply(req.body.xml, response.text); res.end(resMsg); }) });
好,這下算是完成機(jī)器人聊天的功能了。只要將代碼部署到leancloud里,就算是成功了。
github地址奉上:https://github.com/xiadd/shorthand 歡迎star
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
使用Express+Node.js對mysql進(jìn)行增改查操作?
這篇文章主要介紹了使用Express+Node.js對mysql進(jìn)行增改查操作,文章圍繞主題展開詳細(xì)的內(nèi)容介紹,具有一定的參考價值,需要的小伙伴可以參考一下2022-08-08