使用 nodeJs 开发微信公众号（设置自动回复消息）

微信向第三方服务器发送请求时会降 signature 、timestamp、 nonce 、 openid（用户标识），发送内容会以 xml 的形式附加在请求中

回复消息前提我们得拿到用户id ， 用户发送内容等信息，用户发送内容格式参考微信官方文档：https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140453

想要获取用户发送信息，需要从请求中获得 xml ，因此需要用到 raw-body（获得原生请求体）

npm install raw-body --save

接下来需要将xml从请求中分离并且格式化成json

var getRawBody = require('raw-body')
var contentType = require('content-type')

var data = getRawBody(req, {
        length: req.headers['content-length'],
        limit: '1mb',
        encoding: contentType.parse(req).parameters.charset
    }, function(err, buf) {
            utils.formatMessage(buf.toString()).then(message => {
               //判断消息,做出回应
            })
       }
）                

我将格式化 xml 的操作封装在 formatMessage

var xml2js = require('xml2js')

exports.formatMessage = function(xml) {
    return new Promise((resolve, reject) => {
        
        // 接收文本信息格式
        // <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>

        xml2js.parseString(xml, function(err, content) {
            var result = content.xml
            var message = {};
            if (typeof result === 'object') {
                var keys = Object.keys(result);
                for (var i = 0; i < keys.length; i++) {
                    var key = keys[i];
                    var item = result[key];
                    if (!(item instanceof Array) || item.length === 0) continue;
                    if (item.length === 1) {
                        var val = item[0];
                        if (typeof val === 'object') message[key] = formatMessage(val);
                        else message[key] = (val || '').trim();
                    } else {
                        message[key] = [];
                        for (var j = 0, k = item.length; j < k; j++) message[key].push(formatMessage(item[j]));
                    }
                }
            }
            resolve(message)
        })
    })
}

解析完成后我们可以拿到 FromUserName、MsgType 和 Content

MsgType可能是 event（事件）或者是 text （文本）

event类型有：subscribe，unsubscribe，LOCATION，CLICK，SCAN

根据 content中发送的内容，我们可以进行判断，返回自定义消息回复

微信规定我们返回的数据必须是xml格式的，格式参考：https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140543

因此在返回信息前需要拼接内容成指定xml格式，我将拼接方法封装在 template.js 文件中，使用时只要直接调用即可

lib/template.js：

exports.textMessage = function(message){
    var createTime = new Date().getTime()
    return `<xml>
    <ToUserName><![CDATA[${message.FromUserName}]]></ToUserName>
    <FromUserName><![CDATA[${message.ToUserName}]]></FromUserName>
    <CreateTime>${createTime}</CreateTime>
    <MsgType><![CDATA[text]]></MsgType>
    <Content><![CDATA[${message.reply}]]></Content>
    </xml>`
}

exports.imageMessage = function(message){
    var createTime = new Date().getTime()
    return `<xml>
    <ToUserName><![CDATA[${message.FromUserName}]]></ToUserName>
    <FromUserName><![CDATA[${message.ToUserName}]]></FromUserName>
    <CreateTime>${createTime}</CreateTime>
    <MsgType><![CDATA[image]]></MsgType>
    <Image>
        <MediaId><![CDATA[${message.mediaId}]]></MediaId>
    </Image>
    </xml>`
}

exports.voiceMessage = function(message){
    var createTime = new Date().getTime()
    return `<xml>
    <ToUserName><![CDATA[${message.FromUserName}]]></ToUserName>
    <FromUserName><![CDATA[${message.ToUserName}]]></FromUserName>
    <CreateTime>${createTime}</CreateTime>
    <MsgType><![CDATA[voice]]></MsgType>
    <Voice>
        <MediaId><![CDATA[${message.mediaId}]]></MediaId>
    </Voice>
    </xml>`
}

exports.videoMessage = function(message){
    var createTime = new Date().getTime()
    return `<xml>
    <ToUserName><![CDATA[${message.FromUserName}]]></ToUserName>
    <FromUserName><![CDATA[${message.ToUserName}]]></FromUserName>
    <CreateTime>${createTime}</CreateTime>
    <MsgType><![CDATA[video]]></MsgType>
    <Video>
        <MediaId><![CDATA[${message.mediaId}]]></MediaId>
        <Title><![CDATA[${message.title}]]></Title>
        <Description><![CDATA[${message.description}]]></Description>
    </Video>
    </xml>`
}

exports.articleMessage = function(message){
    var createTime = new Date().getTime()
    return `<xml>
    <ToUserName><![CDATA[${message.FromUserName}]]></ToUserName>
    <FromUserName><![CDATA[${message.ToUserName}]]></FromUserName>
    <CreateTime>${createTime}</CreateTime>
    <MsgType><![CDATA[news]]></MsgType>
    <ArticleCount>${message.articles.length}</ArticleCount>
    <Articles>
        ${message.articles.map(article => 
            `<item><Title><![CDATA[${article.title}]]></Title>
                <Description><![CDATA[${article.description}]]></Description>
                <PicUrl><![CDATA[${article.img}]]></PicUrl>
                <Url><![CDATA[${article.url}]]></Url></item>`
        ).join('')}
    </Articles>
    </xml>`
}

自动回复整体流程：收到微信请求->校验是否来自微信->获取access_token->解析请求体xml->根据类型以及内容作出相应

回复代码：

var express = require('express')
var router = express.Router()
var getRawBody = require('raw-body')
var contentType = require('content-type')
var utils = require('../lib/utils.js')
var template = require('../lib/template.js')

// 微信官方请求回调接口
router.all('/', function(req, res, next) {
    var data = getRawBody(req, {
        length: req.headers['content-length'],
        limit: '1mb',
        encoding: contentType.parse(req).parameters.charset
    }, function(err, buf) {
        if (err) return next(err)
        utils.formatMessage(buf.toString()).then(message => {
            if (message.MsgType == 'event') {
                if (message.Event === 'subscribe') {
                    if (message.EventKey) {
                        console.log('扫描二维码关注：' + message.EventKey + ' ' + message.ticket);
                    }
                    message.reply = '终于等到你，还好我没放弃';
                } else if (message.Event === 'unsubscribe') {
                    message.reply = '';
                    console.log(message.FromUserName + ' 悄悄地走了...');
                } else if (message.Event === 'LOCATION') {
                    message.reply = '您上报的地理位置是：' + message.Latitude + ',' + message.Longitude;
                } else if (message.Event === 'CLICK') {
                    message.reply = '您点击了菜单：' + message.EventKey;
                } else if (message.Event === 'SCAN') {
                    message.reply = '关注后扫描二维码：' + message.Ticket;
                }
                res.send(template.textMessage(message))
            } else if (message.MsgType === 'text') {
                var content = message.Content
                if (content === '1') {
                    message.reply = '终于等到你'
                    res.send(template.textMessage(message))
                } else if (content === '2') {
                    message.mediaId = '需要发送图片的媒体id'
                    res.send(template.imageMessage(message))
                } else if (content === '3') {
                    message.articles = [{
                        title: '标题',
                        description: '描述',
                        picUrl: '图片路径，不需要事先上传',
                        url: '素材路径，素材需要事先上传'
                    }]
                    res.send(template.articleMessage(message))
                } else {
                    message.reply = '你说的话：“' + content + '”，我听不懂呀'
                    res.send(template.textMessage(message))
                }
            }

        })
    })

});

module.exports = router;