node.js 作为服务器
微信公众号（订阅号）
给个人、企业、组织 提供业务服务和用户管理能力的全新服务平台
- 企业微信： 无需开发，直接使用
- 小程序
- 服务号： 单独的一条消息显示；偏向信息查询；一个月只能群发消息 4 条；需要企业认证
- 订阅号： 收录在 "订阅号" 中；一天只能群发 1 条消息
订阅号 与 服务号 开发模式 是一样的
- 常见功能：
- 微信分享
- 群发
- 自定义菜单
- 打赏
- 在线接口调试工具
接口： 网址 url
- web开发者工具
- 公众平台测试账号
无需申请公众账号即可在测试账号中测试所有高级接口
- 基本交互流程
- 用户 使用 微信 将消息发送到 微信公众号 上
- 微信客户端 将消息发送到腾讯自己的微信服务器中
- 腾讯的微信服务器 会将用户消息转发到 开发者服务器 上（1. 搭建服务器____需要与服务器进行交互配置）
- 开发者服务器 又将消息响应给 微信服务器器
- 微信服务器 最后将消息响应给相应的用户
- 1. 搭建服务器
一、买域名
二、使得 开发服务器地址 万维网能访问
开启 node.js 写好的服务器
双击启动 ngrok 客户端（ngrok 内网传透）
ngrok http 3000
- 填写的 接口配置信息 url
- Token 参与微信签名加密的一个字段，越复杂越好
- 确保 服务器开着的，点击 提交
- 微信的加密签名 由 timestamp、nonce、token三个参数加密生成的签名
2. 验证消息来自于服务器（只有验证成功了，才能继续开发。如果步骤无误，多提交几次，总会成功）
// 1. 定义自己的 测试号及接口 配置信息
const myWeChat= {
token: \'atguiguHTML0920\',
appID: \'wxc8e92f7aada0fbca0\',
appsecret: \'b4054e90b7a8sdasdasd0af50bf7fc3e87\'
};
app.use((request, response, next)=>{
// 2. 将 timestamp、nonce、token 三个参数组合成 数组，按照字典序进行排序
const {token} = myWeChat;
const {signature, echostr, timestamp, nonce} = req.query;
const sortArr = [timestamp, nonce, token].sort();
// 3. 将排序后的参数拼接成一个新的字符串，进行 sha1 加密，得到的就是 signature
const sha1Str = sha1(sortArr.join(""));
// 4. 将 加密后的签名 和 微信发送来的 signature 进行对比
if(sha1Str === signature){
// 一样，说明消息来自于服务器，返回 echostr 给微信服务器
response.end(echostr);
}else{
// 不一样，说明消息不来自于微信服务器，返回 error 错误
response.end(\'error\');
};
next();
});
/* 此时，再次点击提交，显示 "配置成功" */
/* 用手机扫描 测试账号的二维码 关注，并发送任意消息____可以看到服务器接受到的数据*/
3. 验证服务器有效性 的模块化 源代码
config/index.js
-
module.exports = { token: \'FinnKou\', appID: \'wxba59db235745154d22cd32d\', appsecret: \'62a454d75919545d2f276680fcb6148d77b2e31\' };
wechat/handleRequest.js
-
const sha1 = require(\'sha1\'); const {token} = require(\'../config\'); module.exports = ()=>{ return (request, response, next)=>{ const {signature, echostr, timestamp, nonce} = request.query; const sha1Str = sha1([timestamp, nonce, token].sort().join("")); if(sha1Str === signature){ response.end(echostr); }else{ response.end("error"); }; next(); }; };
index.js
-
const express = require(\'express\'); const handleRequest = require(\'./handleRequest\'); const app = express(); app.use(express.urlencoded({extended: true})); app.use(handleRequest()); app.listen( 3000, err=>console.log(err?err:\'\n\n服务器已启动\n\t\tHunting Happy!\') );
- 正式开发功能模块
1. 被动回复用户消息789(此时，有两个公众号，一个本人的，一个测试的)
验证服务器 有效性其实是 get 请求
用户发送的消息是 post 请求
if(request.method === \'GET\'){ // 非用户发送的消息
if(sha1Str === signature){
response.end(echostr);
}else{
response.end(\'error\');
};
}else if(request.method === \'POST\'){ // 可能是用户发送的消息
if(sha1Str !== signature)response.end(\'error\');
// 接收用户信息
const userXMLData = await getUserXMLData(request);
// 将 xml 数据转化为 js 对象____xml2js
}else{
response.end(\'error\');
};
// 当服务器没有返回响应时，微信服务器会发送 3 次请求到开发者服务器
// 每次请求都会占用使用接口的使用次数
// 为了保证后续开发有次数，返回一个响应 resquest.end(\'\');
/*
如果node 服务器 发送一个不正确的 xml 消息，会在用户微信报错
*/
实例源代码：
index.js
-
const express = require(\'express\'); const handleRequest = require(\'./handleRequest\'); const app = express(); app.use(express.urlencoded({extended: true})); app.use(handleRequest()); // 使用中间件的方式 激活自定义模块 app.listen( 3000, err=>console.log(err?err:\'\n\n服务器已启动\n\t\tHunting Happy!\') );
config/index.js
-
module.exports = { // 微信公众号 配置信息 token: \'FinnKou\', appID: \'wxba554569dbd1127d22cd32d\', appsecret: \'62ad759915d251f276680fc153b618d77b2e31\' };
handleRequest/index.js
-
const sha1 = require(\'sha1\'); // sha1 加密库 const {token} = require(\'../config\'); const {getUserXMLData} = require(\'../utils/getUserDataAsync\'); const {XML2JSON, JSON2Obj} = require("../utils/tools"); module.exports = ()=>{ return async (request, response, next)=>{ const {signature, echostr, timestamp, nonce} = request.query; const sha1Str = sha1([timestamp, nonce, token].sort().join("")); if(request.method === \'GET\'){ // 服务器发过来的消息 if(sha1Str === signature){ response.end(echostr); }else{ response.end("error"); }; }else if(request.method === \'POST\'){ if(sha1Str !== signature){ // 非微信用户发过来的消息 response.end("error"); }; // 用户微信客户端 发过来的消息 /**** <xml> <ToUserName><![CDATA[gh_d9bf45407d2a]]></ToUserName> <FromUserName><![CDATA[oSX3Z1aufrhsCwuEKXbVRfqOC1Wo]]></FromUserName> <CreateTime>1545741162</CreateTime> <MsgType><![CDATA[text]]></MsgType> <Content><![CDATA[1]]></Content> <MsgId>6638907739305821698</MsgId> </xml> ****/ const XMLData = await getUserXMLData(request); const JSONData = XML2JSON(XMLData); const objData = JSON2Obj(JSONData); /* { ToUserName: \'gh_d9bf45407d2a\', FromUserName: \'oSX3Z1aufrhsCwuEKXbVRfqOC1Wo\', CreateTime: \'1545744183\', MsgType: \'text\', Content: \'1\', MsgId: \'6638920714402022972\' } */ if(objData.Content === \'1\'){ response.send(`<xml> <ToUserName><![CDATA[${objData.FromUserName}]]></ToUserName> <FromUserName><![CDATA[${objData.ToUserName}]]></FromUserName> <CreateTime>${Date.now()}</CreateTime> <MsgType><![CDATA[text]]></MsgType> <Content><![CDATA[圣诞节快乐]]></Content> </xml>` ); }else{ response.send( `<xml> <ToUserName><![CDATA[${objData.FromUserName}]]></ToUserName> <FromUserName><![CDATA[${objData.ToUserName}]]></FromUserName> <CreateTime>${Date.now()}</CreateTime> <MsgType><![CDATA[text]]></MsgType> <Content><![CDATA[hello world!]]></Content> </xml>` ); }; }else{ response.end("error"); }; }; };
utils/tools.js
-
const {parseString} = require(\'xml2js\'); // xml2js 是第三方库，XML 字符串 转 JSON 对象 module.exports = { XML2JSON(originXML){ // XML 字符串 转 JSON 对象 let JSONData = null; parseString(originXML, {"trim": true}, (err, result)=>{ if(!err){ JSONData = result; }; }); return JSONData; }, JSON2Obj({xml}){ // JSON 对象 转成 普通对象 let Obj = {}; for (let attr in xml){ const value = xml[attr]; Obj[attr] = value[0]; }; return Obj; } };
utils/getUserDataAsync.js
-
module.exports = { getUserXMLData(request){ // 获取用户微信客户端 发送到 服务器的 XML 字符串 return new Promise((resolve, reject)=>{ let resultStr = \'\'; request.on("data", browser_info=>{ // 流方式 接受 resultStr += browser_info.toString(); }).on("end", ()=>{ resolve(resultStr); }); }); } };
源代码：
index.js
-
const express = require(\'express\'); const handleRequest = require(\'./handleRequest\'); const app = express(); app.use(express.urlencoded({extended: true})); app.use(handleRequest()); app.listen( 3000, err=>console.log(err?err:\'\n\n服务器已启动\n\t\tHunting Happy!\') );
config/index.js
-
module.exports = { token: \'FinnKou\', appID: \'wxba59d182bd7d2245cd32d\', appsecret: \'62ad7594595d2f276680f454cb618d77b2e31\' };
handleRequest/index.js
-
const sha1 = require(\'sha1\'); const {token} = require(\'../config\'); const {getUserXMLData} = require(\'../utils/getUserDataAsync\'); const {XML2JSON, JSON2Obj} = require(\'../utils/tools\'); const {autoReply} = require(\'../autoReply\'); module.exports = ()=>{ return async (request, response, next)=>{ const {signature, echostr, timestamp, nonce} = request.query; const sha1Str = sha1([timestamp, nonce, token].sort().join("")); if(request.method === \'GET\'){ // 服务器发过来的消息 if(sha1Str === signature){ response.end(echostr); }else{ response.end("error"); }; }else if(request.method === \'POST\'){ if(sha1Str !== signature){ // 非微信用户发过来的消息 response.end("error"); }; // 用户发过来的消息 const XMLData = await getUserXMLData(request); const JSONData = XML2JSON(XMLData); const objData = JSON2Obj(JSONData); console.log(objData); response.send(autoReply(objData)); // 封装 自动回复用户消息 }else{ response.end("error"); }; }; };
utils/getUserDataAsync.js
-
module.exports = { getUserXMLData(request){ return new Promise((resolve, reject)=>{ let resultStr = \'\'; request.on("data", browser_info=>{ resultStr += browser_info.toString(); }).on("end", ()=>{ resolve(resultStr); }); }); } }; /**** 用户发过来的消息 <xml> <ToUserName><![CDATA[gh_d9bf45407d2a]]></ToUserName> <FromUserName><![CDATA[oSX3Z1aufrhsCwuEKXbVRfqOC1Wo]]></FromUserName> <CreateTime>1545741162</CreateTime> <MsgType><![CDATA[text]]></MsgType> <Content><![CDATA[1]]></Content> <MsgId>6638907739305821698</MsgId> </xml> ****/
utils/tools.js
-
const {parseString} = require(\'xml2js\'); module.exports = { XML2JSON(originXML){ let JSONData = null; parseString(originXML, {"trim": true}, (err, result)=>{ if(!err){ JSONData = result; }; }); return JSONData; }, JSON2Obj({xml}){ let Obj = {}; for (let attr in xml){ const value = xml[attr]; Obj[attr] = value[0]; }; return Obj; } }; // 用户微信客户端 发过来的消息 /**** { ToUserName: \'gh_d9bf45407d2a\', FromUserName: \'oSX3Z1aufrhsCwuEKXbVRfqOC1Wo\', CreateTime: \'1545744183\', MsgType: \'text\', Content: \'1\', MsgId: \'6638920714402022972\' } ****/
autoReply/index.js
-
const {getReplyInfo} = require(\'./getReplyInfo\'); module.exports = { autoReply(objData){ const options = getReplyInfo(objData); let replyXML = `<xml> <ToUserName><![CDATA[${options.toUserName}]]></ToUserName> <FromUserName><![CDATA[${options.fromUserName}]]></FromUserName> <CreateTime>${options.createTime}</CreateTime> <MsgType><![CDATA[${options.msgType}]]></MsgType> `; switch (options.msgType) { case \'text\':{ replyXML += `<Content><![CDATA[${options.content}]]></Content>`; }break; case \'image\':{ replyXML += `<MsgType><![CDATA[${options.msgType}]]></MsgType>`; replyXML += `<Image><MediaId><![CDATA[${options.image}]]></MediaId></Image>`; }break; case \'voice\':{ replyXML += `<MsgType><![CDATA[${options.msgType}]]></MsgType>`; replyXML += `<Voice><MediaId><![CDATA[${options.voice}]]></MediaId></Voice>`; }break; case \'video\':{ replyXML += `<MsgType><![CDATA[${options.msgType}]]></MsgType>`; replyXML += `<Video> <MediaId><![CDATA[${options.video}]]></MediaId> <Title><![CDATA[${options.videoTitle}]]></Title> <Description><![CDATA[${options.videoDescription}]]></Description> </Video>`; }break; case \'music\':{ replyXML += `<MsgType><![CDATA[${options.msgType}]]></MsgType>`; replyXML += `<Music> <Title><![CDATA[${options.musicTitle}]]></Title> <Description><![CDATA[${options.musicDescription}]]></Description> <MusicUrl><![CDATA[${options.musicUrl}]]></MusicUrl> <HQMusicUrl><![CDATA[${options.hqMusicUrl}]]></HQMusicUrl> <ThumbMediaId><![CDATA[${options.musicMediaId}]]></ThumbMediaId> </Music>`; }break; case \'news\':{ replyXML += `<MsgType><![CDATA[${options.msgType}]]></MsgType>`; replyXML += `<ArticleCount>${options.content.length}</ArticleCount><Articles>`; options.content.forEach(item => { replyXML += `<item> <Title><![CDATA[${item.title}]]></Title> <Description><![CDATA[${item.description}]]></Description> <PicUrl><![CDATA[${item.picUrl}]]></PicUrl> <Url><![CDATA[${item.url}]]></Url> </item>`; }); replyXML += `</Articles>`; }break; }; replyXML += \'</xml>\'; return replyXML; } };
autoReply/getReplyInfo.js
-
module.exports = { getReplyInfo(objData){ let options = { toUserName: objData.FromUserName, fromUserName: objData.ToUserName, createTime: Date.now(), msgType: objData.MsgType, /**** 文本 ****/ content: objData.Content, /**** 图片 ****/ image: objData.MediaId, // MediaId /**** 语音 ****/ voice: objData.MediaId, // MediaId recognition: objData.Recognition, // MediaId /**** 视频 ****/ video: objData.MediaId, // MediaId videoTitle: objData.Title, videoDescription: objData.Description, /**** 音乐 ****/ musicTitle: objData.Title, musicDescription:objData.Description, musicUrl: objData.MusicUrl, hqMusicUrl: objData.HQMusicUrl, musicMediaId: objData.MediaId, // MediaId /**** 地理位置 ****/ location_X: objData.Location_X, location_Y: objData.Location_Y, scale: objData.Scale, label: objData.Label, /**** +位置 ****/ latitude: objData.Latitude, longitude: objData.Longitude, precision: objData.Precision, /**** 菜单 CLICK ****/ eventKey: objData.EventKey }; switch (options.msgType) { case \'text\':{ // 文本 switch (objData.Content) { case \'news\':{ options.msgType = \'news\'; options.content = [{ title: \'微信公众号开发\', description: \'这里有最新的公众号教程\', picUrl: \'https://ss2.baidu.com/6ONYsjip0QIZ8tyhnq/it/u=2136740882,3271518133&fm=58&bpow=630&bpoh=630\', url: \'http://www.atguigu.com\' }]; }break; case \'1\':{ options.content = \'我会对你 1 心 1 意~\'; }break; case \'2\':{ options.content = \'其实你一点都不 2 ~\'; }break; case \'3\':{ options.content = \'可能也会 3 心 二 意~\'; }break; }; }break; case \'voice\':{ // 语音 options.msgType = \'text\'; options.content = `语音识别结果为：${options.recognition}`; }break; case \'location\':{ // + 位置 options.msgType = \'text\'; options.content = ` 地理位置纬度：${options.location_X} 地理位置经度:${options.location_Y} 地图缩放大小: ${options.scale} 地理位置信息: ${options.label}`; }break; case \'event\':{ // 事件推送 switch (objData.Event) { case \'subscribe\':{ // 订阅 options.msgType = \'text\'; options.content = \'欢迎订阅 FinnKou 的内容！\' if (objData.EventKey) { //扫描带参数二维码关注的。 一般应用在活动上 options.content = \'扫描带参数二维码关注, 欢迎您关注公众号~\'; } }break; case \'unsubscribe\':{ // 取消订阅 console.log(\'无情取关~\'); }break; case \'LOCATION\':{ // 用户上报地理位置 // 当用户关注公众号时，它会问你是否允许上报地理位置，如果允许才会触发当前事件 options.msgType = \'text\'; options.content = ` 地理位置纬度：${options.latitude} 地理位置经度:${options.longitude} 位置信息: ${options.precision}`; }break; case \'CLICK\':{ // 用户点击菜单按钮 options.msgType = \'text\'; options.content = `菜单 key：${options.eventKey}`; }break; }; }break; case \'link\':{ // 链接消息 }break; case \'image\':{ // 图片 }break; case \'video\':{ // 视频 }break; case \'shortvideo\':{ // 小视频 }break; case \'music\':{ // 音乐 }break; case \'news\':{ // 图文 }break; }; return options; } };