nodejs微信開(kāi)發(fā)之自動(dòng)回復(fù)的實(shí)現(xiàn)

更新時(shí)間：2019年03月17日 15:53:21 作者：xiadd

這篇文章主要介紹了nodejs微信開(kāi)發(fā)之自動(dòng)回復(fù)的實(shí)現(xiàn)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

上一篇：接入指南

這部分是實(shí)現(xiàn)簡(jiǎn)單的自動(dòng)回復(fù)，當(dāng)然也是很大一部分功能的實(shí)現(xiàn)基礎(chǔ)，這里使用了圖靈機(jī)器人的接口。

效果圖如下：

當(dāng)然，這個(gè)機(jī)器人的效果如何不是我能管得了的事情了，類(lèi)似圖靈機(jī)器人，我們還可以實(shí)現(xiàn)段子推送，快遞查詢(xún)等一系列功能，這里不一一實(shí)現(xiàn)了。

微信的消息處理

對(duì)于公眾平臺(tái)，每一次發(fā)消息相當(dāng)于發(fā)出一個(gè)post請(qǐng)求，但是需要注意的是不管是發(fā)出的請(qǐng)求還是收到的回復(fù)，他的數(shù)據(jù)格式都是xml，但是nodejs本身無(wú)法處理xml，所以需要對(duì)xml數(shù)據(jù)進(jìn)行處理。
仍然使用的是body-parser這個(gè)庫(kù)，但是需要引入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就是一個(gè)整型的時(shí)間戳。MsgType就是消息類(lèi)型，一般有文本（text），圖片（image），語(yǔ)音（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，返回一個(gè)xml的響應(yīng)，那么公眾號(hào)就會(huì)相應(yīng)的回復(fù)一個(gè)消息，這里回復(fù)的消息是文本格式。（mac的微信一年沒(méi)更新了--）

如上圖，發(fā)送消息則會(huì)回復(fù)一個(gè)內(nèi)容一樣的消息，一個(gè)簡(jiǎn)單的自動(dòng)回復(fù)就實(shí)現(xiàn)了。

圖靈機(jī)器人

這個(gè)接口的使用十分簡(jiǎn)單，get請(qǐng)求鏈接，記得帶上apikey的頭，然后就會(huì)返回響應(yīng)的內(nèi)容。我這里請(qǐng)求使用的是nodejs request庫(kù)。

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)容。

公眾號(hào)機(jī)器人

好了，上面是二者分開(kāi)的講的，如果看到這應(yīng)該知道一個(gè)聊天機(jī)器人的實(shí)現(xiàn)是非常簡(jiǎn)單的了。就是將接口響應(yīng)的內(nèi)容返回給用戶(hù)（?如果不是非要自己實(shí)現(xiàn)聊天機(jī)器人的話(huà)。。。），后臺(tái)這里也就相當(dāng)于一個(gè)跳板。

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;

這部分代碼很簡(jiǎn)單了，就是將圖靈機(jī)器人的接口響應(yīng)消息返回出來(lái)。下面要做的就是將消息返回給用戶(hù)，這里有一點(diǎn)需要注意的是對(duì)于發(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;

自動(dòng)回復(fù)的模塊，主要是返回一個(gè)xml字符串，方便發(fā)送給用戶(hù)。

//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

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: