收到5000請求就退出這個邏輯感覺沒什么必要。

如果想保留現(xiàn)有5000請求退出邏輯，就要做一個內(nèi)存緩存，當(dāng)mqtt沒連接成功時，收到的請求放到內(nèi)存緩存起來。當(dāng)mqtt連接上后將緩存的數(shù)據(jù)發(fā)給mqtt。

偽代碼類似

define('MAX_REQUEST', 5000);

$worker = new Worker('http://0.0.0.0:端口');

$queue = [];
$mqttConnected = false;

$worker->onWorkerStart = function($worker)
{
    global $mqtt;

    $mqtt = new Workerman\Mqtt\Client($url, $options);
    $mqtt->onConnect = function($mqtt) {
        global $mqttConnected, $queue;
        $mqttConnected = true;
        foreach ($queue as $topic => $data) {
            $mqtt->publish($topic, $data);
        }
        $queue = [];
    };
    $mqtt->connect();
};

$worker->onMessage = function(TcpConnection $connection, $args)
{
    global $mqtt, $mqttConnected, $queue;
    // 已經(jīng)處理請求數(shù)
    static $request_count = 0;

    $data = $args->post();

    // 此處報錯
    if ($mqttConnected) {
        $mqtt->publish($topic, json_encode($data));
    } else {
        $queue[$topic][] = json_encode($data);
    }

    $connection->send('Status Code: 200 OK');

    // 如果請求數(shù)達到5000
    if(++$request_count >= MAX_REQUEST)
    {
        $mqtt->close();
        Worker::stopAll();
    }
};

Worker::runAll();