cd $node_modules_folder
git clone [email protected]:windinsky/wxthirdparty.git
cd wixthirdparty
npm install
是不是很想直接npm install wxthirdparty？哈哈哈哈哈哈哈哈哈，我不会弄。。。。
/********** app.js *********/
var appid = '第三方应用appid'
, appsecret = '第三方应用appsecret'
, token = '第三方应用中设置的公众号消息校验Token'
, key = '第三方应用中设置的公众号消息加解密Key'
, db = 'mysql://user:password@host/yourdatabase';
if ( cluster.isMaster ) {
// Fork workers.
for (var i = 0 ; i < numCPUs ; i++) cluster.fork();
// 主进程的模块只负责刷新component_token和pre_auth_code
global.thirdparty = new ThirdpartyServer(
appid ,
appsecret ,
token ,
key ,
db
);
thirdparty.start();
cluster.on( 'exit' , function( worker , code , signal ) {
console.log( 'worker ' + worker.process.pid + ' died' );
cluster.fork();
});
thirdparty.once( 'ready' , function(){
// enable_auth_related_actions();
})
} else {
// 负责所有第三方平台的业务逻辑以及对公众号的操作，注意最后一个参数
global.thirdparty = new ThirdpartyServer(
appid ,
appsecret ,
token ,
key ,
db ,
true // very important
);
// Workers can share any TCP connection
// In this case its a HTTP server
http.createServer( function( req , res ) {
// ...
}).listen( 80 );
}
/*********** 使用样例，展示follower的头像 **********/
app.get( 'show_head_img' , function( req , res ){
// 根据cookie从数据库中获取公众号信息
thirdparty.get_user_info( req.cookie.wx_token , function( err , user_info ){
if( err ) return res.end( JSON.stringify( err ) );
var client = thirdparty.createClient( user_info );
var openid = req.__get.openid;
// 调用公众号api获取目标用户的信息
client.getUser( openid , function( err , follower ){
if( err ) return res.end( JSON.stringify( err ) );
res.setHeader( 'content-type' , 'text/html' );
if( data.headimgurl ){
res.end( ['<img src="',follower.headimgurl,'"/>'].join( '' ) );
}else{
res.end( follower.nickname + ' has no head img' );
}
});
});
});
在授权事件接收URL的响应函数中调用save_ticket方法以刷新ticket：
//首先在中间件里获取post的数据
'some_middleware' : function( req , res ){
req.on( 'data' , function( d ){
req.body += d.toString();
});
};
// 然后在授权事件接受URL的响应函数中存储ticket
'auth_callback_action ': function( req , res ){
thirdparty.save_ticket( req.body );
}这个不加整个模块都没任何用处。。。
####本模块需要在两个server中分别调用:
一个单进程的模块 或者 master进程 用于向微信api拉取access_token等私密信息，is_cluster传false或者不传，这个server需要一直保持运行，不需要附加其他任何业务
其他的就是在实际server中用于处理业务请求的模块，这个只在cluster中启动, is_cluster一定要传true，否则会导致token混乱，而且access_token拉取次数是有限制的，用完两个小时后所有业务就都歇菜了
####由于ticket是微信服务器向第三方平台推送的，所以每次重启server的时候都很难保证当前的ticket是否还有效
#####解决方案： 重启server时先保证接收ticket的action正常，在授权事件接收URL的处理函数中调用save_ticket方法，10分钟之内就会收到微信的push请求
这个过程中最好设置一个全局标志位置为false，然后所有worker进程监听该标志位，为false时停用所有和授权有关的功能，ticket更新后再将其置为true，worker监测到变化后启动授权业务，注：这个标志位不能放在内存变量中（多进程不共享内存的），需要入库或者写文件
Mysql：
/* 所有密钥及刷新时间 */
CREATE TABLE `component_secrets` (
`id` int(10) NOT NULL AUTO_INCREMENT,
`ticket` varchar(255) DEFAULT NULL,
`access_token` varchar(255) DEFAULT NULL,
`preauthcode` varchar(255) DEFAULT NULL,
`ticket_updated_at` bigint(20) DEFAULT NULL,
`access_token_updated_at` bigint(20) DEFAULT NULL,
`preauthcode_updated_at` bigint(20) DEFAULT NULL,
`access_token_expires_in` int(64) DEFAULT NULL,
`preauthcode_expires_in` int(64) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=27 DEFAULT CHARSET=utf8;
/* 第三方公众号信息 */
CREATE TABLE `wx_users_info` (
`id` int(10) NOT NULL AUTO_INCREMENT,
`appid` varchar(255) DEFAULT NULL,
`access_token` varchar(255) DEFAULT NULL,
`access_token_updated_at` datetime DEFAULT NULL,
`access_token_expires_in` datetime DEFAULT NULL,
`refresh_token` varchar(255) DEFAULT NULL,
`nick_name` varchar(255) DEFAULT NULL,
`head_img` varchar(255) DEFAULT NULL,
`service_type_id` int(11) DEFAULT NULL,
`verify_type_info` varchar(255) DEFAULT NULL,
`user_name` varchar(255) DEFAULT NULL,
`alias` varchar(255) DEFAULT NULL,
`wx_token` varchar(255) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=31 DEFAULT CHARSET=utf8;
/* 第三方公众号的听众列表 */
CREATE TABLE `wx_followers` (
`id` int(10) NOT NULL AUTO_INCREMENT,
`openid` varchar(255) DEFAULT NULL,
`updated_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
`wx_token` varchar(255) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=44 DEFAULT CHARSET=utf8;
/* 听众用户信息 */
CREATE TABLE `wx_followers_info` (
`id` int(10) NOT NULL AUTO_INCREMENT,
`subscribe` int(11) DEFAULT NULL,
`openid` varchar(255) DEFAULT NULL,
`nickname` varchar(255) DEFAULT NULL,
`sex` int(11) DEFAULT NULL,
`language` varchar(255) DEFAULT NULL,
`city` varchar(255) DEFAULT NULL,
`province` varchar(255) DEFAULT NULL,
`country` varchar(255) DEFAULT NULL,
`headimgurl` varchar(255) DEFAULT NULL,
`subscribe_time` date DEFAULT NULL,
`unionid` varchar(255) DEFAULT NULL,
`remark` varchar(255) DEFAULT NULL,
`groupid` int(11) DEFAULT NULL,
`updated_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
`created_at` datetime NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=35 DEFAULT CHARSET=utf8;TODO:
- 把bigint全改成date。。。存时间戳的理由已经被我忘了！
- 添加各个api的钩子，钩子样例，这不是我一个人能干的活了。。
- 补注释，等休完年假回来再说