请问如何做到接收http请求，推送mqtt消息？

收到5000请求就退出这个逻辑感觉没什么必要。

如果想保留现有5000请求退出逻辑，就要做一个内存缓存，当mqtt没连接成功时，收到的请求放到内存缓存起来。当mqtt连接上后将缓存的数据发给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;
    // 已经处理请求数
    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');

    // 如果请求数达到5000
    if(++$request_count >= MAX_REQUEST)
    {
        $mqtt->close();
        Worker::stopAll();
    }
};

Worker::runAll();