這篇文章給大家分享的是有關(guān)NodeJS怎么實(shí)現(xiàn)微信公眾號關(guān)注后自動(dòng)回復(fù)功能的內(nèi)容。小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考，一起跟隨小編過來看看吧。

目前成都創(chuàng)新互聯(lián)公司已為上千多家的企業(yè)提供了網(wǎng)站建設(shè)、域名、雅安服務(wù)器托管、網(wǎng)站托管維護(hù)、企業(yè)網(wǎng)站設(shè)計(jì)、漢南網(wǎng)站維護(hù)等服務(wù)，公司將堅(jiān)持客戶導(dǎo)向、應(yīng)用為本的策略，正道將秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協(xié)力一起成長，共同發(fā)展。

js有什么特點(diǎn)

1、js屬于一種解釋性腳本語言；2、在絕大多數(shù)瀏覽器的支持下，js可以在多種平臺(tái)下運(yùn)行，擁有著跨平臺(tái)特性；3、js屬于一種弱類型腳本語言，對使用的數(shù)據(jù)類型未做出嚴(yán)格的要求，能夠進(jìn)行類型轉(zhuǎn)換，簡單又容易上手；4、js語言安全性高，只能通過瀏覽器實(shí)現(xiàn)信息瀏覽或動(dòng)態(tài)交互，從而有效地防止數(shù)據(jù)的丟失；5、基于對象的腳本語言，js不僅可以創(chuàng)建對象，也能使用現(xiàn)有的對象。

一 實(shí)先自動(dòng)回復(fù)功能的邏輯步驟

1 處理POST類型的控制邏輯，接收XML的數(shù)據(jù)包；

2 解析XML數(shù)據(jù)包（獲得數(shù)據(jù)包的消息類型或者是事件類型）；

3 拼裝我們定義好的消息；

4 包裝成XML格式；

5 在5秒內(nèi)返回回去

二 代碼實(shí)操

本節(jié)代碼參照上節(jié)課繼續(xù)修改和完善，目錄結(jié)構(gòu)跟之前相同，新引入的模塊raw-body使用npm install安裝一下即可，app.js啟動(dòng)文件和util.js不做變動(dòng)，主要修改一下generator.js文件，以及在generator.js同級目錄下新建wechat.js文件和tools.js文件。

wechat.js文件是將前一節(jié)generator.js文件中票據(jù)部分的代碼抽離出來單獨(dú)放在一個(gè)文件中，具體代碼如下：

'use strict';
// 引入模塊
var Promise = require('bluebird');
var request = Promise.promisify(require('request'));

//增加url配置項(xiàng)
var prefix = 'https://api.weixin.qq.com/cgi-bin/';
var api = {
  accessToken: prefix + 'token?grant_type=client_credential'
};

//利用構(gòu)造函數(shù)生成實(shí)例 完成票據(jù)存儲(chǔ)邏輯
function weChat(opts) {
  var that = this;
  this.appID = opts.appID;
  this.appSecret = opts.appSecret;
  this.getAccessToken = opts.getAccessToken;
  this.saveAccessToken = opts.saveAccessToken;
  //獲取票據(jù)的方法
  this.getAccessToken()
    .then(function(data) {
      //從靜態(tài)文件獲取票據(jù)，JSON化數(shù)據(jù)，如果有異常，則嘗試更新票據(jù)
      try {
        data = JSON.parse(data);
      } catch (e) {
        return that.updateAccessToken();
      }
      //判斷票據(jù)是否在有效期內(nèi)，如果合法，向下傳遞票據(jù)，如果不合法，更新票據(jù)
      if (that.isValidAccessToken(data)) {
        Promise.resolve(data);
      } else {
        return that.updateAccessToken();
      }
    })
    //將拿到的票據(jù)信息和有效期信息存儲(chǔ)起來
    .then(function(data) {
      //console.log(data);
      that.access_token = data.access_token;
      that.expires_in = data.expires_in;

      that.saveAccessToken(data);
    })
};

//在weChat的原型鏈上增加驗(yàn)證有效期的方法
weChat.prototype.isValidAccessToken = function(data) {
  //進(jìn)行判斷，如果票據(jù)不合法，返回false
  if (!data || !data.access_token || !data.expires_in) {
    return false;
  }
  //拿到票據(jù)和過期時(shí)間的數(shù)據(jù)
  var access_token = data.access_token;
  var expires_in = data.expires_in;
  //獲取當(dāng)前時(shí)間
  var now = (new Date().getTime());
  //如果當(dāng)前時(shí)間小于票據(jù)過期時(shí)間，返回true，否則返回false
  if (now < expires_in) {
    return true;
  } else {
    return false;
  };
};

//在weChat的原型鏈上增加更新票據(jù)的方法
weChat.prototype.updateAccessToken = function() {
  var appID = this.appID;
  var appSecret = this.appSecret;
  var url = api.accessToken + '&appid=' + appID + '&secret=' + appSecret;

  return new Promise(function(resolve, reject) {
    //使用request發(fā)起請求
    request({
      url: url,
      json: true
    }).then(function(response) {
      var data = response.body;
      var now = (new Date().getTime());
      var expires_in = now + (data.expires_in - 20) * 1000;
      //把新票據(jù)的有效時(shí)間賦值給data
      data.expires_in = expires_in;
      resolve(data);
    })
  })
};

//向外暴露weChat
module.exports = weChat;

generator.js文件進(jìn)行精簡后，添加判斷對xml數(shù)據(jù)的格式化方法以及判斷事件，添加關(guān)注事件測試信息，具體代碼如下：

'use strict';
// 引入模塊
var sha1 = require('sha1');
var getRawBody = require('raw-body');
var weChat = require('./wechat');
var tools = require('./tools');

// 建立中間件函數(shù)并暴露出去
module.exports = function(opts) {
  //實(shí)例化weChat()函數(shù)
  //var wechat = new weChat(opts);
  return function*(next) {
    //console.log(this.query);
    var that = this;
    var token = opts.token;
    var signature = this.query.signature;
    var nonce = this.query.nonce;
    var timestamp = this.query.timestamp;
    var echostr = this.query.echostr;
    // 進(jìn)行字典排序
    var str = [token, timestamp, nonce].sort().join('');
    // 進(jìn)行加密
    var sha = sha1(str);
    //使用this.method對請求方法進(jìn)行判斷
    if (this.method === 'GET') {
      // 如果是get請求 判斷加密后的值是否等于簽名值
      if (sha === signature) {
        this.body = echostr + '';
      } else {
        this.body = 'wrong';
      };
    } else if (this.method === 'POST') {
      //如果是post請求 也是先判斷簽名是否合法 如果不合法 直接返回wrong
      if (sha !== signature) {
        this.body = 'wrong';
        return false;
      };
      //通過raw-body模塊 可以把把this上的request對象 也就是http模塊中的request對象 去拼裝它的數(shù)據(jù) 最終拿到一個(gè)buffer的xml數(shù)據(jù)
      //通過yield關(guān)鍵字 獲取到post過來的原始的XML數(shù)據(jù)
      var data = yield getRawBody(this.req, {
        length: this.length,
        limit: '1mb',
        encoding: this.charset
      });
      //console.log(data.toString());打印XML數(shù)據(jù)（當(dāng)微信公眾號有操作的時(shí)候 終端可以看到返回的XML數(shù)據(jù)）
      //tools為處理XML數(shù)據(jù)的工具包 使用tools工具包的parseXMLAsync方法 把XML數(shù)據(jù)轉(zhuǎn)化成數(shù)組對象
      var content = yield tools.parseXMLAsync(data);
      //console.log(content);打印轉(zhuǎn)化后的數(shù)組對象
      //格式化content數(shù)據(jù)為json對象
      var message = tools.formatMessage(content.xml);
      console.log(message);
      //打印message
      //判斷message的MsgType 如果是event 則是一個(gè)事件
      if (message.MsgType === 'event') {
        //如果是訂閱事件
        if (message.Event === 'subscribe') {
          //獲取當(dāng)前時(shí)間戳
          var now = new Date().getTime();
          //設(shè)置回復(fù)狀態(tài)是200
          that.status = 200;
          //設(shè)置回復(fù)的類型是xml格式
          that.type = 'application/xml';
          //設(shè)置回復(fù)的主體
          that.body = '<xml>' +
            '<ToUserName><![CDATA[' + message.FromUserName + ']]></ToUserName>' +
            '<FromUserName><![CDATA[' + message.ToUserName + ']]></FromUserName>' +
            '<CreateTime>' + now + '</CreateTime>' +
            '<MsgType><![CDATA[text]]></MsgType>' +
            '<Content><![CDATA[你好，同學(xué)！]]></Content>' +
            '</xml>';
          return;
        }
      }
    }

  }
};

tools.js是處理XML數(shù)據(jù)的工具文件：

'use strict';
//引入模塊
var xml2js = require('xml2js');
var Promise = require('bluebird');
//導(dǎo)出解析XML的方法
exports.parseXMLAsync = function(xml) {
  return new Promise(function(resolve, reject) {
    xml2js.parseString(xml, { trim: true }, function(err, content) {
      if (err) {
        reject(err);
      } else {
        resolve(content);
      };
    });
  });
};
//因?yàn)関alue值可能是嵌套多層的 所以先對value值進(jìn)行遍歷
function formatMessage(result) {
  //聲明空對象message
  var message = {};
  //對result類型進(jìn)行判斷
  if (typeof result === 'object') {
    //如果是object類型 通過Object.keys()方法拿到result所有的key 并存入keys變量中
    var keys = Object.keys(result);
    //對keys進(jìn)行循環(huán)遍歷
    for (var i = 0; i < keys.length; i++) {
      //拿到每個(gè)key對應(yīng)的value值
      var item = result[keys[i]];
      //拿到key
      var key = keys[i];
      //判斷item是否為數(shù)組或者長度是否為0
      if (!(item instanceof Array) || item.length === 0) {
        //如果item不是數(shù)組或者長度為0 則跳過繼續(xù)向下解析
        continue;
      }
      //如果長度為1
      if (item.length === 1) {
        //拿到value值存入val變量
        var val = item[0];
        //判斷val是否為對象
        if (typeof val === 'object') {
          //如果val為對象 則進(jìn)一步進(jìn)行遍歷
          message[key] = formatMessage(val);
        } else {
          //如果不是對象 就把值賦給當(dāng)前的key放入message里 并去除收尾空格
          message[key] = (val || '').trim();
        }
      }
      //如果item的長度既不是0也不是1 則說明它是一個(gè)數(shù)組
      else {
        //把message的key設(shè)置為空數(shù)組
        message[key] = [];
        //對數(shù)組進(jìn)行遍歷
        for (var j = 0, k = item.length; j < k; j++) {
          message[key].push(formatMessage(item[j]));
        }
      }
    }
  }
  return message;
}

exports.formatMessage = function(xml) {
  return new Promise(function(resolve, reject) {
    xml2js.parseString(xml, { trim: true }, function(err, content) {
      if (err) {
        reject(err);
      } else {
        resolve(content);
      };
    });
  });
};

exports.formatMessage = formatMessage;

完成這節(jié)的代碼后，當(dāng)關(guān)注微信測試公眾號的時(shí)候，會(huì)自動(dòng)回復(fù)『你好，同學(xué)！』的提示信息。

感謝各位的閱讀！關(guān)于“NodeJS怎么實(shí)現(xiàn)微信公眾號關(guān)注后自動(dòng)回復(fù)功能”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，讓大家可以學(xué)到更多知識(shí)，如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到吧！

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)建站m.rwnh.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

分享文章：NodeJS怎么實(shí)現(xiàn)微信公眾號關(guān)注后自動(dòng)回復(fù)功能-創(chuàng)新互聯(lián)
分享網(wǎng)址：http://m.rwnh.cn/article8/dddjop.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供標(biāo)簽優(yōu)化、網(wǎng)站設(shè)計(jì)、自適應(yīng)網(wǎng)站、App設(shè)計(jì)、App開發(fā)、網(wǎng)站導(dǎo)航

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)