接收訊息
當一般微信用戶向公眾帳號發送訊息時，微信伺服器將POST訊息的XML封包到開發者填寫的URL上。
2.1 接收普通訊息資料格式
XML的結構基本上固定，不同的訊息類型略有不同。
用戶傳送文字訊息時，微信公眾帳號接收到的XML資料格式如下所示：
<xml>
<ToUserName><![CDATA[toUser]]></ToUserName>
<FromUserName><![CDATA[fromUser]]></FromUserName>
<CreateTime>createTime</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[this is a test]]></Content>
<MsgId>1234567890123456</MsgId>
</xml>
登入後複製
使用者傳送圖片訊息時，微信公眾帳號接收到的XML資料格式如下所示：
<xml>
<ToUserName><![CDATA[toUser]]></ToUserName>
<FromUserName><![CDATA[fromUser]]></FromUserName>
<CreateTime>1348831860</CreateTime>
<MsgType><![CDATA[image]]></MsgType>
<PicUrl><![CDATA[this is a url]]></PicUrl>
<MediaId><![CDATA[media_id]]></MediaId>
<MsgId>1234567890123456</MsgId>
</xml>
登入後複製
其他訊息訊息類型的結構請查閱【微信公眾平台開發文件】
#對於POST請求的處理，koa2沒有封裝取得參數的方法，需要透過自己解析上下文context中的原生node.js請求物件request。我們將用到row-body這個模組來拿到資料。
2.2 先來優化之前的程式碼
這一節的程式碼緊接著上一屆實現的程式碼，在上一屆的基礎上輕微改動了下。
'use strict'
const Koa = require('koa')
const app = new Koa()
const crypto = require('crypto')
// 将配置文件独立到config.js
const config = require('./config')
app.use(async ctx => {
// GET 验证服务器
if (ctx.method === 'GET') {
const { signature, timestamp, nonce, echostr } = ctx.query
const TOKEN = config.wechat.token
let hash = crypto.createHash('sha1')
const arr = [TOKEN, timestamp, nonce].sort()
hash.update(arr.join(''))
const shasum = hash.digest('hex')
if (shasum === signature) {
return ctx.body = echostr
}
ctx.status = 401
ctx.body = 'Invalid signature'
} else if (ctx.method === 'POST') { // POST接收数据
// TODO
}
});
app.listen(7001);登入後複製
這兒我們在只在GET中驗證了簽名值是否合法，實際上我們在POST中也應該驗證簽名。
將簽章驗證寫成一個函數
function getSignature (timestamp, nonce, token) {
let hash = crypto.createHash('sha1')
const arr = [token, timestamp, nonce].sort()
hash.update(arr.join(''))
return hash.digest('hex')
}登入後複製
優化程式碼，再POST中也加入驗證
...
app.use(async ctx => {
const { signature, timestamp, nonce, echostr } = ctx.query
const TOKEN = config.wechat.token
if (ctx.method === 'GET') {
if (signature === getSignature(timestamp, nonce, TOKEN)) {
return ctx.body = echostr
}
ctx.status = 401
ctx.body = 'Invalid signature'
}else if (ctx.method === 'POST') {
if (signature !== getSignature(timestamp, nonce, TOKEN)) {
ctx.status = 401
return ctx.body = 'Invalid signature'
}
// TODO
}
});
...登入後複製
到這兒我們都沒有開始實作接受XML資料包的功能，而是在修改之前的程式碼。這是為了示範在實際開發中的過程，寫任何程式碼都不是一步到位的，好的程式碼都是改出來的。
2.3 接收公眾號普通訊息的XML封包
#現在開始進入本節的重點，接受XML封包並轉為JSON
$ npm install raw-body --save
登入後複製
...
const getRawBody = require('raw-body')
...
// TODO
// 取原始数据
const xml = await getRawBody(ctx.req, {
length: ctx.request.length,
limit: '1mb',
encoding: ctx.request.charset || 'utf-8'
});
console.log(xml)
return ctx.body = 'success' // 直接回复success，微信服务器不会对此作任何处理登入後複製
給你的測試號發送文字訊息，你可以在命令列看見列印如下資料
<xml>
<ToUserName><![CDATA[gh_9d2d49e7e006]]></ToUserName>
<FromUserName><![CDATA[oBp2T0wK8lM4vIkmMTJfFpk6Owlo]]></FromUserName>
<CreateTime>1516940059</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[JavaScript之禅]]></Content>
<MsgId>6515207943908059832</MsgId>
</xml>
登入後複製
恭喜，到此你已經可以接收到XML資料了。
以上是如何操作Koa2微信公眾號實現訊息管理的詳細內容。更多資訊請關注PHP中文網其他相關文章！
