PHP のスウールマルチプロセスが WeChat テンプレートメッセージを送信する-PHPチュートリアル-php.cn

PHP のスウールマルチプロセスが WeChat テンプレートメッセージを送信する

小云云

リリース： 2023-03-21 16:14:01

オリジナル

4165 人が閲覧しました

この記事では主に、有効期限が近づいている WeChat ユーザーにテンプレートメッセージを送信し、更新を促す方法について説明します。PHP の swoole マルチプロセスを通じて WeChat テンプレートメッセージを送信する方法を主に説明します。

まず、期限切れが近づいているユーザーを 1 日あたり約 800 ～ 2000 件取得します。あまり負荷が高くないと感じたので、リクエストのタイムアウトの問題を解決します。そこで、運営仲間が大量のユーザーがプッシュするテンプレートメッセージをターゲットにすることを提案し、1 年前にプロモーションの波があり、その量が 1 日あたり 10,000 件程度だったので、すぐにアップロード機能を作成しました。をアップロードしてオペレーターに直接送信し、無制限の 502bad 方法を使用しました

この時点で、テンプレートメッセージの数が増加し、最適化が必要であると感じたので、別のソリューション、redis キュー + デーモンを採用しました。デーモンプロセスは、送信されたデータからアップロードされたデータを分離します。デーモンプロセスは、redis キューに送信する必要のあるデータがあるかどうかを検出し、存在する場合は、アイテムを 1 つずつ取り出して送信します。オペレーターは結果を気にする必要はなく、確実に送信できるように感じますが、時間がかかり、量が多い場合は送信が完了するまでに時間がかかります。次に、時間が足りないので、ユーザーが WeChat を開くピーク時に送信したいと考えています。そのため、現時点では、マルチに php+swoole を使用しています。 -process の非同期処理。1つのプロセスが遅いので、さらにいくつか開いてみましょう。ということで、16 個のプロセスをまとめて非同期に送信し、10 分以内に 10,000 個のテンプレートメッセージが送信され、基本的な変換が完了しました。

client

class Client
{
    public function send($msg){
        $client = new swoole_client(SWOOLE_SOCK_TCP);
        //连接到服务器
        if (!$client->connect(&#39;127.0.0.1&#39;, 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);
    }

}

ログイン後にコピー

server

<?php
$serv = new swoole_server("127.0.0.1", 9501);


//设置异步任务的工作进程数量
$serv->set(array(&#39;task_worker_num&#39; =>16));


//监听数据接收事件
$serv->on(&#39;receive&#39;, function($serv, $fd, $from_id, $data) {
    //投递异步任务
    $task_id = $serv->task($data);//非阻塞
    echo "同步代码执行完成\n";
});


//处理异步任务
$serv->on(&#39;task&#39;, function ($serv, $task_id, $from_id, $data) {
    handleFun($data);
    //返回任务执行的结果
    $serv->finish("finish");
});


//处理异步任务的结果
$serv->on(&#39;finish&#39;, 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);
       
   }
  

}

ログイン後にコピー

call client.php

<?php
include dirname(__FILE__).&#39;/client.php&#39;;
$params=""//接口数据
$msg = json_encode($params);
$client = new Client();$client->send($msg);echo "[".date("Y-m-d H:i:s")."]执行完成".PHP_EOL;

ログイン後にコピー