深入浅出Node.js搭建微信公众号后台服务的方法

编辑: admin 分类: .net 发布时间: 2023-06-08 来源:互联网

一、前言

如今,微信已经成为了许多公司和个人运营自媒体的重要渠道,而搭建一个高效稳定的微信公众号后台服务就成为了刚需。Node.js 作为一种轻量高效的后端语言,以其强大的异步 IO 能力和开发效率受到了广泛关注。本篇文章将深入浅出地介绍如何使用 Node.js 搭建一个微信公众号后台服务。

二、准备工作

在开始前,需要准备以下工具和环境:

  • Node.js:请前往 Node.js 官网下载安装;
  • 微信公众号:请前往微信公众平台注册和申请开发者权限;
  • 文件编辑器:推荐使用 Visual Studio Code。

三、搭建微信公众号后台服务

  1. 创建项目

首先,创建一个文件夹,用于存放项目。然后,在命令行中进入该文件夹,并执行以下命令:

npm init
登录后复制

执行后,按照提示依次输入项目名称、版本、描述等信息即可完成项目初始化。

  1. 安装依赖

执行以下命令安装必要的依赖:

npm install express request xml2js
登录后复制

其中,express 是一款 Node.js 开发的 Web 框架,request 是一个封装了 HTTP 请求的库,xml2js 是一个将 XML 转为 JSON 数据的库。

  1. 配置路由

在项目根目录下,创建一个名为 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(); // 校验失败,返回空响应
});
登录后复制

以上代码实现了微信公众号的接入验证,具体实现方式可参考官网文档。

  1. 处理微信消息

在项目根目录下,创建一个名为 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();
  });
};
登录后复制

以上代码解析了来自微信公众号的消息,处理后返回对应的回复消息。

  1. 启动服务

在 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);
登录后复制
  1. 验证服务

启动服务后,可以通过在微信公众号后台配置服务器地址来进行验证。验证成功后,即可使用该地址作为微信公众号的后台服务地址。同时,可以在代码中进行调试,确保消息能够正常地传递和回复。

四、总结

本篇文章介绍了如何使用 Node.js 搭建微信公众号后台服务,涵盖了接入验证和消息处理两个方面。通过此文,相信读者能够快速了解和掌握使用 Node.js 搭建微信后台服务的基本原理和实现方式。

更多阅读