mqtt ->connect() 发送消息报错

$mqtt = new \Workerman\Mqtt\Client('mqtt://47.109.22.248:1883');

$mqtt->connect();

$mqtt->publish($topic,json_encode($data));