这里来实现一下订阅事件，其他的事件的实现过程也都类似。
当有人订阅了公众号后，微信服务器会向我们的服务器推送一个事件，这个事件是xml格式的数据包。
一、我们在index路由下实现post事件的响应。可以理解为当微信向我们的服务器推送消息时，消息就会先走到这里。
/routes/index.js加入：
router.post('/', index_middleware.post(config.wechat));
二、实现index_middleware中的post方法：就是我们该如何处理微信服务器给我们的服务器的post请求。
大致过程是先把微信服务器发来的数据包接收到，然后解析这个xml数据包，然后根据接收来的数据，在我们服务器上进行逻辑处理后形成一个xml格式的回复消息。
/wechat/index_middleware.js加入：
exports.post = function(opts) {return function *(next) {var token = opts.token;var signature = this.query.signature;var nonce = this.query.nonce;var timestamp = this.query.timestamp;var echostr = this.query.echostr;var str = [token, timestamp, nonce].sort().join('');var sha = sha1(str);if (sha !== signature) {this.body = 'wrong';return false; }var data = yield getrawbody(this.req, { length: this.length, limit: '1mb', encoding: this.charset });var message = yield util.parsexmlasync(data);var xml = yield autoreply(message.xml, wechat); console.log(message); console.log(xml);this.status = 200;this.type = 'application/xml';this.body = xml; }; };
这里的data就是我们接收到的数据包，使用了raw-body这个组件。同时使用了util这个工具函数和autoreply这个自定义的函数。
因此在/wechat/index_middleware.js中需要加入以下代码：
var getrawbody = require('raw-body');var util = require('./util');var autoreply = require('./autoreply');
三、实现util工具函数中的parsexmlasync方法，它的作用是异步地将xml格式化为json数据。/wechat/util.js:
var fs = require('fs');var xml2js = require('xml2js'); exports.parsexmlasync = function(xml) {return new promise(function(resolve, reject) { xml2js.parsestring(xml, { trim: true, explicitarray: false}, function(err, content) {if (err) { reject(err); } resolve(content); }); }); };
这里用到了xml2js这个组件。
四、实现autoreply函数，它的作用是将微信服务器发来的数据包进行逻辑处理，形成我们需要发送给微信的xml格式数据。/wechat/autoreply.js:
var createxml = require('./createxml');function autoreply(message, wechat) {if (message.msgtype === 'event') {if (message.event === 'subscribe') {if (message.eventkey) { console.log('扫码进入'); }var now = new date().gettime();return promise.resolve(createxml({ tousername: message.fromusername, fromusername: message.tousername, msgtype: 'text', content: 'hello!!'})); }else if (message.event === 'unsubscribe') { console.log('取关');return promise.resolve(''); } } }
这里只实现了关注和取关的事件，同时用到了createxml函数，它的作用是将数据封装成xml格式：
/wechat/createxml.js:
function createxml(messageobj) {var { tousername, fromusername, msgtype = 'text'} = messageobj;var createtime = new date().gettime();var header = `<xml> <tousername><![cdata[${tousername}]]></tousername> <fromusername><![cdata[${fromusername}]]></fromusername> <createtime>${createtime}</createtime> <msgtype><![cdata[${msgtype}]]></msgtype>`;var content = '';switch(msgtype) {case 'text':var { content } = messageobj; content = `<content><![cdata[${content}]]></content> </xml>`;break;case 'image':var { mediaid } = messageobj; content = `<image> <mediaid><![cdata[${mediaid}]]></mediaid> </image> </xml>`;break;case 'voice':var { mediaid } = messageobj; content = `<voice> <mediaid><![cdata[${mediaid}]]></mediaid> </voice> </xml>`;break;case 'video':var { mediaid, title, description } = messageobj; content = `<video> <mediaid><![cdata[${mediaid}]]></mediaid> <title><![cdata[${title}]]></title> <description><![cdata[${description}]]></description> </video> </xml>`;break;case 'music':var { title, description, musicurl, hqmusicurl, thumbmediaid } = messageobj; content = `<music> <title><![cdata[${title}]]></title> <description><![cdata[${description}]]></description> <musicurl><![cdata[${musicurl}]]></musicurl> <hqmusicurl><![cdata[${hqmusicurl}]]></hqmusicurl> <thumbmediaid><![cdata[${thumbmediaid}]]></thumbmediaid> </music> </xml>`;break;case 'news':var { articles } = messageobj;var articlecount = articles.length; content = `<articlecount>${articlecount}</articlecount><articles>`;for (var i = 0; i < articlecount; i++) { content += `<item> <title><![cdata[${articles[i].title}]]></title> <description><![cdata[${articles[i].description}]]></description> <picurl><![cdata[${articles[i].picurl}]]></picurl> <url><![cdata[${articles[i].url}]]></url> </item>`; } content += '</articles></xml>';break;default: content = `<content><![cdata[error]]></content> </xml>`; } var xml = header + content;return xml; } module.exports = createxml;
完成以上工作以后，启动我们的服务器，再次关注公众号，应该能收到一条hello！！的信息。
这样就实现了对关注事件的处理。
以上就是node.js+koa开发之响应事件实例的详细内容。