php多进程更新微信用户信息,php之swoole多进程发送微信模板消息
本文主要按照给快到期的微信用户发送模板消息,提醒续费来讲解,主要和大家分享php之swoole多进程发送微信模板消息,希望能帮助到大家。
首先拿到快到期的用户, 每天大概800-2000不等,感觉压力不是很大,直接foreach 数组 然后发送,经常出现请求超时 也就是502的问题,紧接着运营同事提出要针对一大批用户 推模板消息,年前搞一波促销,量每天在1万左右,于是楞冲冲的 直接做了个上传功能,给运营人员直接上传发送,然后用是无限的502bad way.
此时 ,感觉模板消息数量上去了,需要优化,于是采用另外一种方案,redis队列+守护进程,将上传的数据跟发送的解耦, 守护进程检测redis队列中是否存在需要发送的数据,如果存在就开始 一条条往外取,然后发送.此方案感觉是运营人员不用管结果,肯定能发送成功,但是时间比较长,量大了 很长时间才发完, 那么就出现了另外一个问题,发出去的时间不用,想在用户打开微信的最高峰时间段发送给用户.好继续优化!
此时改用php+swoole 来进行多进程异步处理,既然一个进程慢,那咱就多开几个,于是16个进程一起异步发送,1万模板消息 10分钟之内发完,基本改造完成.
首先启动server.php
客户端class Client
{
public function send($msg){
$client = new swoole_client(SWOOLE_SOCK_TCP);
//连接到服务器
if (!$client->connect('127.0.0.1', 9501, 0.5))
{
$this->write("connect failed.");
}
//向服务器发送数据
if (!$client->send($msg))
{
$this->write("send ".$msg." failed.");
}
//关闭连接
$client->close();
}
private function write($str){
$path = "/sys.log";
$str = "[".date("Y-m-d H:i:s")."]".$str;
$str .= PHP_EOL;
file_put_contents($path,$str,FILE_APPEND);
}
}
服务端<?php
$serv = new swoole_server("127.0.0.1", 9501);
//设置异步任务的工作进程数量
$serv->set(array('task_worker_num' =>16));
//监听数据接收事件
$serv->on('receive', function($serv, $fd, $from_id, $data) {
//投递异步任务
$task_id = $serv->task($data);//非阻塞
echo "同步代码执行完成\n";
});
//处理异步任务
$serv->on('task', function ($serv, $task_id, $from_id, $data) {
handleFun($data);
//返回任务执行的结果
$serv->finish("finish");
});
//处理异步任务的结果
$serv->on('finish', function ($serv, $task_id, $data) {
echo "异步任务执行完成";
});
$serv->start();
function handleFun($data){
$data=json_decode($data,true);
foreach ($data as $key => $value) {
echo json_encode($value);
$url="xxxx";//调用发送模板消息接口,服务端没办法直接获取微信的接口的一些数据,此处做了一些加密
$postUrl = $url;
$curlPost = $value;
$ch = curl_init(); //初始化curl
curl_setopt($ch, CURLOPT_URL, $postUrl); //抓取指定网页
curl_setopt($ch, CURLOPT_HEADER, 0); //设置header
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); //要求结果为字符串且输出到屏幕上
curl_setopt($ch, CURLOPT_POST, 1); //post提交方式
curl_setopt($ch, CURLOPT_POSTFIELDS, $curlPost);
$data = curl_exec($ch); //运行curl
curl_close($ch);
}
}
调用client.php<?php
include dirname(__FILE__).'/client.php';
$params=""//接口数据
$msg = json_encode($params);
$client = new Client();$client->send($msg);echo "[".date("Y-m-d H:i:s")."]执行完成".PHP_EOL;
相关推荐:
php多进程更新微信用户信息,php之swoole多进程发送微信模板消息相关推荐
- springboot+h5页面+微信公众号获取微信用户信息
springboot项目,h5页面通过微信公众号获取微信用户信息 最近本人有一个项目需求,微信公众号里点击一个菜单进入一个商城购物系统. 对于在微信公众号还是小白的我来说难度有点大,但是做完后发现也就 ...
- SAP系统和微信集成的系列教程之六:如何通过OAuth2获取微信用户信息并显示在SAP UI5应用中
这是Jerry 2020年的第87篇文章,也是汪子熙公众号总共第269篇原创文章. 本系列的英文版Jerry写作于2017年,这个教程总共包含十篇文章,发表在SAP社区上. 系列目录 (1) 微信开发 ...
- SpringBoot中获取微信用户信息竟然这么简单!
前言 不知道你是否参加过拼多多上邀请微信好友砍价功能,这个功能实现首先需要考虑的就是获取微信用户的信息.获取用户信息就是获取公众号下微信用户的信息,今天我就来讲讲如何从公众号下获取微信用户信息. 需要 ...
- 获取微信昵称乱码php,Android 微信登录昵称乱码问题,及获取微信用户信息
微信第三方登录时昵称,username乱码问题解决方法如下: /** * 获取微信用户信息 * @param access_token 调用凭证 * @param openid 普通用户的标识,对当前 ...
- Spring学习笔记(二十三)——实现网站微信扫码登录获取微信用户信息Demo
目录 微信扫码登录介绍 开发步骤 微信扫码登录示例 微信开放文档 遇到的问题 使用第三方工具实现网站微信扫码登录 开发前介绍 开发步骤 微信扫码登录获取微信用户信息Demo实现流程 实现效果 实现过程 ...
- 获取微信用户信息java开发_Java微信公众平台开发(十二)--微信用户信息的获取
前面的文章有讲到微信的一系列开发文章,包括token获取.菜单创建等,在这一篇将讲述在微信公众平台开发中如何获取微信用户的信息,在上一篇我们有说道微信用户和微信公众账号之间的联系可以通过Openid关 ...
- 微信公共平台接入之:网页授权(微信授权,微信access_token获取,获取微信用户信息),微信开发者工具使用,微信公众平台测试号申请接入
1.微信公众平台文档入口 微信公众平台入口地址:https://mp.weixin.qq.com/,截图: 进入之后的文档地址: https://mp.weixin.qq.com/wiki?t=res ...
- 腾讯微搭小程序获取微信用户信息
腾讯微搭小程序获取微信用户信息 无论你对低代码开发的爱与恨, 微信生态的强大毋庸置疑. 因此熟悉微搭技术还是很有必要的! 在大多数应用中, 都需要获取和跟踪用户信息. 本文就微搭中如何获取和存储用户信 ...
- 微信中获取微信用户信息的2种方式
微信中获取微信用户信息的2中方式 1, 在公众号底部菜单栏地址配置h5地址,如 http://test.dingdong.com/page1 然后前端在所有页面前拦截如login页面,查看是否有tok ...
最新文章
- Java 组合模式及其应用
- python 列表创建
- TextView 显示图像+文字的方法
- c语言第八章函数程序设计,C语言程序设计-第八章 函数.ppt
- 投资理财web后端系统_银行理财产品有风险吗?最大风险是什么?
- 设备描述符请求失败_如果用户发出过多请求 苹果将取消Apple ID帐户恢复
- RDS还原数据库时报错:ERROR 1227 (42000) at line 78664
- postgreSQL 自动递增序号
- 怎么看神经网络过早收敛_遗传算法的收敛性分析
- IPFS 相关开发资源汇总
- java贪吃蛇设计答辩PPT_基于Java的贪吃蛇游戏答辩.ppt
- 【xposed】虚拟机安装Magisk和LSPoesd
- LinuxStudyNote(6)-Linux常用命令(2)-文件处理命令(1)-目录处理命令ls、所有者所属组其他人、文件权限、i节点
- wps英文参考文献怎么对齐_wps英文参考文献怎么对齐_【论文攻略】排版技巧——如何用 Word 编辑参考文献......
- web项目开发---部署
- 2017面向对象程序设计(Java)第十六周学习总结
- Win7 64位下使用masm
- 环链电动葫芦出现下滑怎么办
- 电容笔有什么用?电容笔10大品牌排行榜
- 高标农田建设项目快速处理项目建设规模范围线