使用 laravel +firebase 消息传递发送大量通知时出现 504 超时错误

Question

我同时向许多用户发送通知，这是我的代码：

        
   public function sendNotifications($title,$body,$image){     
        $SERVER_API_KEY ="my_api_key";
       
        $tokens=DB::select("select * from fcm_token");
     $token_array=[];
        for( $i =0;$i<count($tokens);$i++){
            array_push($token_array,$tokens[$i]->token);
        }
       
            $data = [
    
                "registration_ids" => 
                    $token_array
                ,
        
                "notification" => [
        
                    "title" => $title,
                    
        
                    "body" => $body,
                    "image" => $image,
        
                    "sound"=> "default" // required for sound on ios
        
                ],
        
            ];
            $dataString = json_encode($data);
        
            $headers = [
        
                'Authorization: key=' . $SERVER_API_KEY,
        
                'Content-Type: application/json',
        
            ];
        
            $ch = curl_init();
        
            curl_setopt($ch, CURLOPT_URL, 'https://fcm.googleapis.com/fcm/send');
        
            curl_setopt($ch, CURLOPT_POST, true);
        
            curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
        
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        
            curl_setopt($ch, CURLOPT_POSTFIELDS, $dataString);
        
            $response = curl_exec($ch);
            curl_close($ch);

        

       
    
    }

此函数在管理员填写表单后执行，管理员应将标题正文和图像提供给后端。之后，他必须等待任务完成（以确保每个人都收到通知）。之前它工作得很好，但现在经过很长的加载时间后，服务器响应 504 超时。我知道我可以排队，但这能解决问题吗？队列不会因为同样的错误而停止吗？我将应用程序托管在共享托管 (lws) 中，我的最大执行时间是 60 秒，如果不支付更多费用就无法增加它，但我想确定问题出在哪里。

我尝试只用 100 个用户来测试它，它的工作就像一个魅力，但我需要将其发送到更多用户，因为我的用户超过 4000 个。

Answer 1

Google Cloud 消息传递支持一次发送到 1000 个令牌。

$tokens = array_chunk($all_tokens, 1000);

foreach ($tokens as $thousand_tokens) {
     send_notification(
         $thousand_tokens,
         $request->title . ' Video added',
         'New Video added in ' . $cat->category->name,
         $cat->image_url,
         $data
     );
 }

上面是示例代码。您可以使用它来修改您的代码。

function send_notification($tokens, $message, $description, $image, $data)
{
    try {
        $token_ids = array($tokens);
        $apiKey = env('FCM_KEY');
        $url = 'https://fcm.googleapis.com/fcm/send';

        $msg = array(
            "registration_ids" => $tokens,
            "collapseKey" => "com.notification",
            "data" => $data,
            "notification" => array(
                "android" => array(
                    "channelId" => "Notifications-Channel",
                    "imageUrl" => $image,
                    "sound" => "sample.mp3"
                ),
                "sound" => "sample.mp3",
                "channelId" => "Notifications-Channel",
                "android_channel_id"=> "Notifications-Channel",
                "body" => $description,
                "title" => $message
            )
        );
        
        define("GOOGLE_API_KEY", $apiKey); 
        $headers = array(
            'Authorization: key=' . $apiKey,
            'Content-Type: application/json'
        );
        
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);  
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($msg));
        $result = curl_exec($ch);
        if ($result === FALSE) {
            die('Curl failed: ' . curl_error($ch));
        }
        curl_close($ch);
        return $result;
    } catch(Exception $e) {
        return 'at exception ' . $e->getLine();
        die('Error: ' . $e->getMessage());
    }
}