如何使用koa2搭建微信第三方公众平台

阅读 13329  ·  发布日期 2020-08-24 17:26  ·  温州雄霸网络科技有限公司|建站|APP小程序制作|做网站SEO推广优化
【摘要】 这次给大家带来如何使用koa2搭建微信第三方公众平台,使用koa2搭建微信第三方公众平台的注意事项有哪些,下面就是实战案例,一起来看一下。在写之前我想先说说koa,koa相比express,在执行流程,以及组件方面优秀的多,koa本身没有提供过多的扩展组建,但是它便捷的组建扩展,可以让你自由的发挥,可以想写其他语言一样... 【温州小程序开发,温州微信公众号,平阳做网站,平阳网站建设公司,平阳小程序商城制作,昆阳万全做网站,鳌江水头小程序,萧江腾蛟微信公众号,山门顺溪南雁海西南麂凤卧麻步怀溪网络网店服务,政采云网店管理服务】...

如何使用koa2搭建微信第三方公众平台

这次给大家带来如何使用koa2搭建微信第三方公众平台,使用koa2搭建微信第三方公众平台的注意事项有哪些,下面就是实战案例,一起来看一下。
在写之前我想先说说koa,koa相比express,在执行流程,以及组件方面优秀的多,koa本身没有提供过多的扩展组建,但是它便捷的组建扩展,可以让你自由的发挥,可以想写其他语言一样并行执行代码,如果说promise解放了繁琐的callback,那么 koa 编写 web 应用,通过组合不同的 generator,可以免除重复繁琐的回调函数嵌套,并极大地提升错误处理的效率。
koa 不在内核方法中绑定任何中间件,它仅仅提供了一个轻量优雅的函数库,使得编写 Web 应用变得得心应手,nodejs的天生的异步处理流程,使得它很适合微信公众号这种频繁的消息互动,再加上pm2的多进程管理,可以说已经很大程度的满足大号的消息转发互动已经公众号内部红包玩法。
在使用koa2搭建微信第三方公众平台是,首先要解决的是如果获取微信返回的xml流,以及如何返回对应的XML体给微信。
由于本身koa不是一个框架,所以得益于网上众多的中间件,自己搭建了一个类似于express的框架,本框架已经开源,详情请看我的git地址:
https://github.com/yxz1025/koa-lana,所有的微信接发消息均在此框架中,请读者自行下载!好了,首先,我们看看如何获取微信返回的xml流:
======tool.js===== //截获微信返回的xml流文件 const Promise = require('
bluebird'
);
//普通post流转化为promise var Tool = {
convertPost: function(req) {
let post_data = "";
return new Promise(function(resolve, reject){
req.on('
data'
, function(chunk) {
post_data += chunk;
}
);
req.on('
end'
, function() {
resolve(post_data);
}
);
}
);
}
, }
;
module.exports = Tool;
=====weichat.js====== //微信响应主体文件 const router = require('
koa-router'
)();
const parseMessage = require('
../common/parseMessage'
);
const config = require('
../config'
);
const WXBizMsgCrypt = require('
wechat-crypto'
);
const middleware = require('
../model/middleware'
);
const validator = require('
validator'
);
const Aes = require('
../common/aes'
);
const Tool = require('
../common/tool'
);
const cryptor = new WXBizMsgCrypt(config.component_config.token, config.component_config.key, config.component_config.component_appid);
//第三方授权路径 /:appid/callback /wechat/100234/callback router.post('
/:appid/callback'
, async function(ctx, next) {
let post_data = "";
let req = ctx.req;
post_data = await Tool.convertPost(req);
let xml = parseMessage(post_data);
let signature = cryptor.getSignature(ctx.query.timestamp, ctx.query.nonce, xml.encrypt);
if (ctx.query.msg_signature != signature) {
ctx.body = '
Auth failed!'
;
// 指纹码不匹配时返回错误信息,禁止后面的消息接受及发送 }
let message = middleware.decryptXml(xml);
let appid = ctx.params.appid;
message.appId = appid;
//发送消息队列 switch (message.msgType) {
case '
text'
: //测试 if (message.toUserName == "gh_3c884a361561") {
if (message.content == "TESTCOMPONENT_MSG_TYPE_TEXT") {
let text = middleware.text(message, message.content + "_callback");
let reply = middleware.encryptXml(text);
return ctx.body = reply;
}
let content = message.content;
if (content.indexOf("QUERY_AUTH_CODE") != -1) {
ctx.body = "";
let code_li = content.split(":");
await middleware.customSend(message.fromUserName, code_li[1]);
return;
}
}
let keywords = validator.trim(message.content).toLowerCase();
let member_config = await middleware.getMemberConfig(message.toUserName, keywords);
if (!member_config) {
await middleware.sendMnsQuene(message);
return ctx.body = "success";
}
else{
//匹配成功 message.packetsId = parseInt(member_config.hongbaoId);
message.keywords = keywords;
await middleware.sendMnsQuene(message);
let data = {
title: member_config.news_title || '
点我领红包'
, description: member_config.description || '
第一轮红包雨开始了,手快有,手慢无!'
, picurl: member_config.picurl || '
http://7xqomp.com2.z0.glb.qiniucdn.com/17269743.png'
}
;
let key = {
fromUserName: message.fromUserName, toUserName: message.toUserName, keywords: keywords, appId: appid }
;
key = JSON.stringify(key);
key = Aes.encypt(key);
key = Aes.base64_encode(key);
//获取授权域名 let auth_url = await middleware.packetDomain();
data.url = "http://" + appid + "." + auth_url + "/redPackets/koulin?key=" + key;
let news = middleware.news(message, [data]);
let reply = middleware.encryptXml(news);
ctx.body = reply;
return;
}
break;
case '
event'
: await middleware.sendMnsQuene(message);
//测试专用 if (message.toUserName == "gh_3c884a361561") {
let text = middleware.text(message, message.event + "from_callback");
let reply = middleware.encryptXml(text);
ctx.body = reply;
return;
}
break;
default: await middleware.sendMnsQuene(message);
ctx.body = "success";
return;
}
;
}
);
module.exports = router;
相信看了本文案例你已经掌握了方法,更多精彩请关注php中文网其它相关文章!推荐阅读:
如何操作Koa2微信公众号开发之本地开发调试环境搭建如何操作Koa2微信公众号实现消息管理以上就是如何使用koa2搭建微信第三方公众平台的详细内容,更多请关注php中文网其它相关文章!
微信
分享相关标签:
koa2 第三方 搭建本文原创发布php中文网,转载请注明出处,感谢您的尊重!
上一篇:
微信公众号开发完整教程一
下一篇:
如何使用Koa2开发微信二维码扫码支付相关文章相关视频修改微信号有什么影响吗?微信中共享实时位置什么意思数据库设计的基本原则是什么?微信小程序调用图片安全API如何使用koa2搭建微信第三方公众平台Java第三方注解第三方开发者模式第三方IT工具PHP第三方登录—微博登录课程内容详解PHP第三方登录—QQ登录课程内容详解 [温州做微信公众号]