Streamqueue

use streamqueue\classes\Client;

$retryDelay = [2, 2];//每次尝试与上次尝试间隔秒数
$payload = [
    'phone' => '130'. rand(10000000, 99999999),
    'text' => 'smscontentaaabbbccc',
];
$client = new Client();
$client->setUrl('127.0.0.1:9501');//启动的服务
$client->setConsumer('Test1');//消费者名称
$client->setRetryDelay($retryDelay);
$client->setPayload($payload);
$result = $client->send();