PHP의 swoole 다중 프로세스는 WeChat 템플릿 메시지를 보냅니다.-PHP 튜토리얼-php.cn

PHP의 swoole 다중 프로세스는 WeChat 템플릿 메시지를 보냅니다.

小云云

풀어 주다： 2023-03-21 16:14:01

원래의

4093명이 탐색했습니다.

이 글에서는 주로 만료가 임박한 WeChat 사용자에게 템플릿 메시지를 보내고 갱신을 상기시키는 방법을 설명합니다. 주로 PHP의 Swoole 다중 프로세스를 통해 WeChat 템플릿 메시지를 보내는 방법을 공유합니다.

우선 만료를 앞두고 있는 사용자가 하루에 800~2000명 정도인데 부담이 별로 크지 않은 것 같아서 직접 배열을 잡아서 보내는 문제가 있습니다. 502라는 일이 자주 발생하는데, 운영 동료들이 대량의 사용자 푸시 템플릿 메시지를 타겟팅하자고 제안했는데, 1년 전에 프로모션이 쇄도했고 하루에 10,000건 정도 되어서 바로 업로드 기능을 만들었습니다. , 운영자에게 직접 업로드하여 전송한 후 무제한 502bad 방식을 사용했습니다.

이때 템플릿 메시지 수가 늘어나고 최적화가 필요하다고 느껴서 다른 솔루션인 redis queue + daemon을 채택했습니다. 전송된 데이터에서 업로드된 데이터를 분리하는 프로세스입니다. 데몬 프로세스는 Redis 대기열에 전송해야 할 데이터가 있는지 감지하고, 존재하는 경우 항목을 하나씩 가져간 다음 전송합니다. 운영자는 결과에 대해 걱정할 필요가 없으며 확실히 성공적으로 보낼 수 있을 것 같습니다. 그러나 시간이 오래 걸리고 볼륨이 크면 전송을 완료하는 데 오랜 시간이 걸립니다. 그러면 또 다른 문제가 생기고, 사용자들이 위챗을 열 때 피크 시간에 보내려고 합니다.

이때는 멀티용으로 php+swoole을 사용합니다! -프로세스 비동기 처리가 느리기 때문에 몇 개 더 열어보자. 그러면 16개의 프로세스가 함께 비동기적으로 전송되어 10분 안에 10,000개의 템플릿 메시지가 전송되고, 기본 변환이 완료되었다.

첫번째 server.php 시작

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;

로그인 후 복사