一、前言
如今，微信已经成为了许多公司和个人运营自媒体的重要渠道，而搭建一个高效稳定的微信公众号后台服务就成为了刚需。Node.js 作为一种轻量高效的后端语言，以其强大的异步 IO 能力和开发效率受到了广泛关注。本篇文章将深入浅出地介绍如何使用 Node.js 搭建一个微信公众号后台服务。
二、准备工作
在开始前，需要准备以下工具和环境：
- Node.js：请前往 Node.js 官网下载安装；
- 微信公众号：请前往微信公众平台注册和申请开发者权限；
- 文件编辑器：推荐使用 Visual Studio Code。
三、搭建微信公众号后台服务
- 创建项目
首先，创建一个文件夹，用于存放项目。然后，在命令行中进入该文件夹，并执行以下命令：
npm init
执行后，按照提示依次输入项目名称、版本、描述等信息即可完成项目初始化。
- 安装依赖
执行以下命令安装必要的依赖：
npm install express request xml2js
其中，express 是一款 Node.js 开发的 Web 框架，request 是一个封装了 HTTP 请求的库，xml2js 是一个将 XML 转为 JSON 数据的库。
- 配置路由
在项目根目录下，创建一个名为 index.js 的文件，并在该文件中添加以下内容：
const express = require('express');
const request = require('request');
const { parseString } = require('xml2js');
const app = express();
app.get('/api/wechat', (req, res) => {
const { signature, timestamp, nonce, echostr } = req.query;
// 排序和拼接字符串
const str = [process.env.TOKEN, timestamp, nonce].sort().join('');
const sha1 = require('crypto').createHash('sha1');
sha1.update(str);
const code = sha1.digest('hex');
if (code === signature) {
return res.send(echostr); // 校验成功，原样返回 echostr 参数内容
}
res.send(); // 校验失败，返回空响应
});以上代码实现了微信公众号的接入验证，具体实现方式可参考官网文档。
- 处理微信消息
在项目根目录下，创建一个名为 message.js 的文件，用于处理微信消息。在该文件中添加以下内容：
/**
* 解析 XML 数据
* @param {string} xmlStr XML 字符串
*/
function parseXML(xmlStr) {
const options = {
explicitArray: false, // 不将子元素变为数组
ignoreAttrs: true, // 忽略属性
};
return new Promise((resolve, reject) => {
parseString(xmlStr, options, (err, result) => {
if (err) {
return reject(err);
}
resolve(result.xml);
});
});
}
module.exports = function handleWechatMessage(req, res) {
let body = '';
req.on('data', (chunk) => {
body += chunk;
});
req.on('end', async () => {
const {
ToUserName,
FromUserName,
CreateTime,
MsgType,
Event,
Content,
EventKey,
} = await parseXML(body);
let replyXML;
switch (MsgType) {
case 'text':
// 处理文本消息
replyXML = `<xml>
<ToUserName><![CDATA[${FromUserName}]]></ToUserName>
<FromUserName><![CDATA[${ToUserName}]]></FromUserName>
<CreateTime>${Math.floor(Date.now() / 1000)}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[${Content}]]></Content>
</xml>`;
break;
case 'event':
// 处理事件消息
if (Event === 'subscribe') {
// 处理关注事件
replyXML = `<xml>
<ToUserName><![CDATA[${FromUserName}]]></ToUserName>
<FromUserName><![CDATA[${ToUserName}]]></FromUserName>
<CreateTime>${Math.floor(Date.now() / 1000)}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[欢迎关注]]></Content>
</xml>`;
} else if (Event === 'unsubscribe') {
// 处理取消关注事件
console.log('用户取消关注');
} else if (Event === 'CLICK' && EventKey === 'test') {
// 处理菜单点击事件
replyXML = `<xml>
<ToUserName><![CDATA[${FromUserName}]]></ToUserName>
<FromUserName><![CDATA[${ToUserName}]]></FromUserName>
<CreateTime>${Math.floor(Date.now() / 1000)}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[点击了测试菜单]]></Content>
</xml>`;
}
break;
default:
break;
}
if (replyXML) {
res.setHeader('Content-Type', 'application/xml');
return res.send(replyXML);
}
res.send();
});
};以上代码解析了来自微信公众号的消息，处理后返回对应的回复消息。
- 启动服务
在 index.js 中，添加以下代码启动服务：
const handleWechatMessage = require('./message');
const server = app.listen(process.env.PORT || 3000, () => {
const address = server.address();
console.log(`Server running at http://${address.address}:${address.port}`);
});
app.post('/api/wechat', handleWechatMessage);- 验证服务
启动服务后，可以通过在微信公众号后台配置服务器地址来进行验证。验证成功后，即可使用该地址作为微信公众号的后台服务地址。同时，可以在代码中进行调试，确保消息能够正常地传递和回复。
四、总结
本篇文章介绍了如何使用 Node.js 搭建微信公众号后台服务，涵盖了接入验证和消息处理两个方面。通过此文，相信读者能够快速了解和掌握使用 Node.js 搭建微信后台服务的基本原理和实现方式。
