深入浅出Node.js搭建微信公众号后台服务的方法-js教程-PHP中文网

一、前言

如今，微信已经成为了许多公司和个人运营自媒体的重要渠道，而搭建一个高效稳定的微信公众号后台服务就成为了刚需。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);

登录后复制