nodejs搭建简单的微信公众号服务

2019-10-15

又两个月没有写文章了, 最近人变得越来越懒, 公司页开始了加班, 每天10小时上班时间真的挺难受的, 然后自己也是在是找不到啥写的, 感觉就是Copye Paste. 不过最近一直再玩NodeJS, 那就来说说NodeJS吧

搭建Koa2 Node服务

首先需要创建一个项目, 通过npm安装koa2来搭建一个Node HTTP服务

// 创建项目文件夹
$ mkdir wx_serve

$ cd wx_serve
// 初始化项目
npm init

npm i koa
// koa的路由中间件
npm i koa-router
// 解析xml的node插件
npm i xml2js
// sha1 加密, 用来做微信的验证
npm i sha1
// raw-body 用来获取到微信发送的数据
npm i raw-body

项目和依赖都已经创建好了, 就可以开始编写代码了, 首先创建app.js

const Koa = require('koa')
const Router = require('koa-router')()

  // 监听get请求
Router.get('/', async (cxt ,next)=>{
})
  // 监听post请求
Router.post('/', async (cxt ,next)=>{
})

app.use(Router.routes(), Router.allowedMethods())

app.listen(3000)

接受验证公众号推送

上面的几行代码, 我们使用了koa Koa-router监听处理了get, post的请求, 并运行到了3000端口上
我也比较懒得过多解释啥操作, 我再BB也不如去看看微信官方文档
想要搭建微信公众号的服务, 那先需要去微信公众号后台把消息事件推送到我们服务器上, 并且在我们服务器上做出正确的处理

const sha1 = require('sha1')

...
  // 监听get请求
Router.get('/', async (cxt ,next)=>{
  const { signature, timestamp, nonce, echostr } = ctx.query
  const token = "token" // 微信后台定义的token字符串
  const params = [ token, timestamp, nonce ].sort()
  // 连接
  const str = sha1(params.join(""))
  if(str == signature)  // 本地加密的数据与传过来的加密字符串相等
    return ctx.body = echostr // 直接返回随机字符串
  else return ctx.body = "fail"  //不匹配则认证失败
})
...

我们通过get来监听处理微信的认证请求, 现在再去微信后台填写链接认证( 开发 > 基本配置 )

在微信开发者后台配置好后, 我们的程序就能接收到了公众号的动态, 接收到的消息了, 现在我们就来编写消息处理模块了.

做出回应回复消息

公众号的事件消息是通过post推送过来的, 所以我们要监听post请求, 并且他推送过来的数据是xml格式的, 我们还需要插件来接收并解析数据

const getRawBody = require('raw-body')
const xml2js = require("xml2js")

...
/**
 * @description: async parse XML String
 * @param { sting } xml
 * @return: Promise Fn
 */
const parseXML = function (xml) {
  return new Promise(function (resolve, reject) {
    xml2js.parseString(xml, { trim: true, explicitArray: false }, (err, content) => {
      if (err) reject(err)
      else resolve(content)
    })
  })
}
Router.post('/', async (cxt ,next)=>{
  // 通过插件获取到xml的数据
  const xml = await getRawBody(ctx.req, {
    length: ctx.request.length,
    limit: '1mb',
    encoding: ctx.request.charset || 'utf-8'
  })
  const json = await parseXML(xml)
  // 在这里我们可以输出看看数据结构
  console.log(json, xml)
})
...

{"xml":{"ToUserName":"gh_113d87971edc","FromUserName":"omC9O1LH6zNVZbESs_2ACsJgtoA4","CreateTime":"1571120674","MsgType":"text","Content":"鸡汤","MsgId":"22493037731429475"}}

<xml><ToUserName><![CDATA[gh_113d87971edc]]></ToUserName>\n<FromUserName><![CDATA[omC9O1LH6zNVZbESs_2ACsJgtoA4]]></FromUserName>\n<CreateTime>1571120674</CreateTime>\n<MsgType><![CDATA[text]]></MsgType>\n<Content><![CDATA[鸡汤]]></Content>\n<MsgId>22493037731429475</MsgId>\n</xml>

emmm, 转换成了json对象后可以发现其实并不复杂, 现在我们解析到了接收到的消息, 我这里为了演示就不做啥处理了, 直接原样回复他把.

/**
 * @description: 微信XML消息转换
 * @param { object } messageObj
 * @return: XML String
 */
const createXML = function (messageObj) {
  const { ToUserName, FromUserName, MsgType, MediaId, Title, Description,MusicUrl, HQMusicUrl, ThumbMediaId } = messageObj

  const CreateTime = new Date().getTime();
  const header = `<xml>
                  <ToUserName><![CDATA[${FromUserName}]]></ToUserName>
                  <FromUserName><![CDATA[${ToUserName}]]></FromUserName>
                  <CreateTime>${CreateTime}</CreateTime>
                  <MsgType><![CDATA[${MsgType}]]></MsgType>`;
  let content = ''
  switch (MsgType) {
    case 'text':
      const { Content } = messageObj;
      content = `<Content><![CDATA[${Content}]]></Content>
                   </xml>`
      break
    case 'image':
      content = `<Image>
                       <MediaId><![CDATA[${MediaId}]]></MediaId>
                     </Image>
                   </xml>`;
      break
    case 'voice':
      content = `<Voice>
                    <MediaId><![CDATA[${MediaId}]]></MediaId>
                  </Voice>
                </xml>`
      break
    case 'video':
      content = `<Video>
                  <MediaId><![CDATA[${MediaId}]]></MediaId>
                  <Title><![CDATA[${Title}]]></Title>
                  <Description><![CDATA[${Description}]]></Description>
                </Video> 
              </xml>`
      break
    case 'music':
      // const { 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':
      const { Articles } = messageObj
      const 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>`
  }

  return header + content
}
...
Router.post('/', async (cxt ,next)=>{
  // 通过插件获取到xml的数据
  const xml = await getRawBody(ctx.req, {
    length: ctx.request.length,
    limit: '1mb',
    encoding: ctx.request.charset || 'utf-8'
  })
  const json = await parseXML(xml)
  // 在这里我们可以输出看看数据结构
  return createXML({
    "ToUserName": json.xml.ToUserName, 
    "FromUserName": json.xml.FromUserName, "MsgType":'text', "Content": json.xml.Content
    })
})

这里我们已经封装了一个创建xml的方法, 并且将接收到的数据原样返回, 不过我这里只处理了文字消息, 还有其他类型的消息可以慢慢自己定义