关于使用mqtt做异步消息分发问题

function mqtt_connection()
{
    static $connection;
    if (!$connection) {
        $connection = new Client('mqtt://...');
    }
    return $connection;
}