当普通微信用户向公众账号发消息时,微信服务器将POST消息的XML数据包到开发者填写的URL上。
微信用户向公共账号发送的消息类型包括:文本消息、图片消息、语音消息、视频消息、小视频消息、地理位置消息、链接消息。除了发送消息,微信用户还会向公共账号推送事件:
1 关注/取消关注事件
2 扫描带参数二维码事件
3 上报地理位置事件
4 自定义菜单事件
5 点击菜单拉取消息时的事件推送
6 点击菜单跳转链接时的事件推送
当你的微信公共账号接入第三方服务器的时候,微信服务器会把这些消息和事件通通推送到第三方服务器,如果第三方服务器没有做合适的处理向微信服务器返回信息的话,微信服务器会向用户返回:“该公告号服务不可用”等错误信息,所以,我们需要对这些POST请求进行处理。
我们在处理微信POST请求的时候先要照“接入微信”的验证流程进行验证,如果验证成功的话再做出响应,微信POST过来的消息和事件都是XML格式的字符串,因此,我们需要下载一个XML解析插件:express-xml-bodyparser。
下载并应用这个插件后,我们的程序便可以通过这个插件进行解析XML数据了
微信POST过来的数据是这个样子的:
<xml>
<ToUserName><![CDATA[toUser]]></ToUserName>
<FromUserName><![CDATA[fromUser]]></FromUserName>
<CreateTime>1348831860</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[this is a test]]></Content>
<MsgId>1234567890123456</MsgId>
</xml>
我们通过这种方式进行解析:
var msgtype = req.body.xml.msgtype[0].toString();
var tousername = req.body.xml.tousername[0].toString();
var fromusername = req.body.xml.fromusername[0].toString();
var createtime = Math.round(Date.now() / 1000);
var content = req.body.xml.content[0].toString();
拿到数据后我们还需要再次拼接成XML格式的数据返回给微信,注意,此处的发送方(fromusername)和接受方(tousername)发生了反转:
var xmlstr=`<xml>
<ToUserName><![CDATA[${fromusername}]]></ToUserName>
<FromUserName><![CDATA[${tousername}]]></FromUserName>
<CreateTime>${createtime}</CreateTime>
<MsgType><![CDATA[${msgtype}]]></MsgType>
<Content><![CDATA[${content}]]></Content>
</xml>`
res.set('Content-Type','text/xml')
res.send(xmlstr)
公共平台响应的消息类型和数据格式请参考:
1 回复文本消息
2 回复图片消息
3 回复语音消息
4 回复视频消息
5 回复音乐消息
6 回复图文消息
我们需要对不同类型的消息做出判断,我们可以在程序中做简单处理:
// 4、开发者获得加密后的字符串可与signature对比,标识该请求来源于微信
if (signature===sign) {
// 如果签名验证通过后
var msgtype = req.body.xml.msgtype[0].toString();
if (msgtype=='text') {
var tousername = req.body.xml.tousername[0].toString();
var fromusername = req.body.xml.fromusername[0].toString();
var createtime = Math.round(Date.now() / 1000);
var content = req.body.xml.content[0].toString();
var xmlstr=`<xml>
<ToUserName><![CDATA[${fromusername}]]></ToUserName>
<FromUserName><![CDATA[${tousername}]]></FromUserName>
<CreateTime>${createtime}</CreateTime>
<MsgType><![CDATA[${msgtype}]]></MsgType>
<Content><![CDATA[${content}]]></Content>
</xml>`
res.set('Content-Type','text/xml')
res.send(xmlstr)
} else if(msgtype=='image') {
var tousername = req.body.xml.tousername[0].toString();
var fromusername = req.body.xml.fromusername[0].toString();
var createtime = Math.round(Date.now() / 1000);
var content = "您好,您发过来的是一张图片";
var xmlstr=`<xml>
<ToUserName><![CDATA[${fromusername}]]></ToUserName>
<FromUserName><![CDATA[${tousername}]]></FromUserName>
<CreateTime>${createtime}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[${content}]]></Content>
</xml>`
res.set('Content-Type','text/xml')
res.send(xmlstr)
} else if(msgtype=='voice') {
var tousername = req.body.xml.tousername[0].toString();
var fromusername = req.body.xml.fromusername[0].toString();
var createtime = Math.round(Date.now() / 1000);
var content = "您好,您发过来的是一段语音";
var xmlstr=`<xml>
<ToUserName><![CDATA[${fromusername}]]></ToUserName>
<FromUserName><![CDATA[${tousername}]]></FromUserName>
<CreateTime>${createtime}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[${content}]]></Content>
</xml>`
res.set('Content-Type','text/xml')
res.send(xmlstr)
} else if(msgtype=='video') {
var tousername = req.body.xml.tousername[0].toString();
var fromusername = req.body.xml.fromusername[0].toString();
var createtime = Math.round(Date.now() / 1000);
var content = "您好,您发过来的是一段视频";
var xmlstr=`<xml>
<ToUserName><![CDATA[${fromusername}]]></ToUserName>
<FromUserName><![CDATA[${tousername}]]></FromUserName>
<CreateTime>${createtime}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[${content}]]></Content>
</xml>`
res.set('Content-Type','text/xml')
res.send(xmlstr)
} else if(msgtype=='shortvideo') {
var tousername = req.body.xml.tousername[0].toString();
var fromusername = req.body.xml.fromusername[0].toString();
var createtime = Math.round(Date.now() / 1000);
var content = "您好,您发过来的是一段短视频";
var xmlstr=`<xml>
<ToUserName><![CDATA[${fromusername}]]></ToUserName>
<FromUserName><![CDATA[${tousername}]]></FromUserName>
<CreateTime>${createtime}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[${content}]]></Content>
</xml>`
res.set('Content-Type','text/xml')
res.send(xmlstr)
} else if(msgtype=='location') {
var tousername = req.body.xml.tousername[0].toString();
var fromusername = req.body.xml.fromusername[0].toString();
var createtime = Math.round(Date.now() / 1000);
var content = "您好,您发过来的是一个地理位置";
var xmlstr=`<xml>
<ToUserName><![CDATA[${fromusername}]]></ToUserName>
<FromUserName><![CDATA[${tousername}]]></FromUserName>
<CreateTime>${createtime}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[${content}]]></Content>
</xml>`
res.set('Content-Type','text/xml')
res.send(xmlstr)
} else if(msgtype=='link') {
var tousername = req.body.xml.tousername[0].toString();
var fromusername = req.body.xml.fromusername[0].toString();
var createtime = Math.round(Date.now() / 1000);
var content = "您好,您发过来的是个网站链接";
var xmlstr=`<xml>
<ToUserName><![CDATA[${fromusername}]]></ToUserName>
<FromUserName><![CDATA[${tousername}]]></FromUserName>
<CreateTime>${createtime}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[${content}]]></Content>
</xml>`
res.set('Content-Type','text/xml')
res.send(xmlstr)
} else if(msgtype=='event') {
var tousername = req.body.xml.tousername[0].toString();
var fromusername = req.body.xml.fromusername[0].toString();
var Event = req.body.xml.event[0].toString();
var createtime = Math.round(Date.now() / 1000);
var content = "您好,您触发了一个事件";
var xmlstr=`<xml>
<ToUserName><![CDATA[${fromusername}]]></ToUserName>
<FromUserName><![CDATA[${tousername}]]></FromUserName>
<CreateTime>${createtime}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[${content}]]></Content>
</xml>`
res.set('Content-Type','text/xml')
res.send(xmlstr)
} else{
var tousername = req.body.xml.tousername[0].toString();
var fromusername = req.body.xml.fromusername[0].toString();
var createtime = Math.round(Date.now() / 1000);
var content = "抱歉,我们不能接受此类型的消息";
var xmlstr=`<xml>
<ToUserName><![CDATA[${fromusername}]]></ToUserName>
<FromUserName><![CDATA[${tousername}]]></FromUserName>
<CreateTime>${createtime}</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[${content}]]></Content>
</xml>`
res.set('Content-Type','text/xml')
res.send(xmlstr)
};
}else{
res.send("invalid sign")
}
这是我们在代码中写死的回复规则,每次更新都需要重新更改代码,比较麻烦。如果在生产环境,有需求的话,我们可以做一个消息回复管理系统,代替微信的默认内管,这样只需要在系统中做一个规则配置,公共号便可以按照配置进行响应。