本文主要按照給快到期的微信用戶發送模板訊息,提醒續費來講解，主要和大家分享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;登入後複製
相關推薦：
phpstorm如何增加swoole自動提示
thinkphp5與swoole非同步郵件群發實作方法
Swoole 實作微信掃碼登入功能
#
以上是php之swoole多進程發送微信模板訊息的詳細內容。更多資訊請關注PHP中文網其他相關文章！
