Le multi-processus swoole de PHP envoie des messages de modèle WeChat

Cet article explique principalement comment envoyer des modèles de messages aux utilisateurs WeChat qui sont sur le point d'expirer et leur rappeler de renouveler. Il vous explique principalement comment envoyer des modèles de messages WeChat via swoole multi-processus en PHP. J'espère que cela pourra vous aider. tout le monde.

Tout d'abord, nous recevons les utilisateurs qui sont sur le point d'expirer, entre 800 et 2000 chaque jour. Je sens que la pression n'est pas très forte, donc je recherche directement le tableau puis je l'envoie. le problème du délai d'expiration de la demande, qui est de 502, se produit souvent, puis le collègue d'exploitation a soulevé la question. Afin de diffuser des modèles de messages à un grand nombre d'utilisateurs, nous avons lancé une vague de promotions il y a un an, et le volume était d'environ 10 000 par jour, nous avons donc immédiatement créé une fonction de téléchargement permettant aux opérateurs de télécharger et d'envoyer directement, puis avons utilisé la méthode 502bad illimitée.

À cette époque, j'ai l'impression que le nombre de messages modèles a augmenté et doit être optimisé, j'ai donc adopté une autre solution, file d'attente redis + processus démon, pour découpler les données téléchargées des données envoyées, et le processus démon détecte la file d'attente redis. Y a-t-il des données à envoyer ? Si oui, commencez à récupérer ? sortez-le un par un, puis envoyez-le. Cette solution donne l'impression que l'opérateur n'a pas à se soucier des résultats et sera certainement en mesure de l'envoyer avec succès, mais cela prendra beaucoup de temps et il faudra beaucoup de temps pour terminer. envoi si le volume est important. Un autre problème se pose. Le temps d'envoi n'est pas utilisé. Je souhaite l'envoyer à l'utilisateur pendant les heures de pointe lorsque l'utilisateur ouvre WeChat.

À. cette fois, utilisez php+swoole pour le traitement asynchrone multi-processus. , puisqu'un processus est lent, ouvrons-en quelques autres, donc 16 processus sont envoyés de manière asynchrone ensemble, 10 000 messages modèles sont envoyés dans les 10 minutes et la transformation de base est terminée. .

Démarrez d'abord server.php

Client

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);
    }

}

Serveur

<?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);
       
   }
  

}

Appelez 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;

Recommandations associées :

Comment ajouter une invite automatique swoole dans phpstorm

thinkphp5 et la méthode de mise en œuvre du mailing de masse asynchrone swoole

Swoole implémente la fonction de connexion par analyse de code WeChat

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!