workerman/mqtt 我碰到的发布报错

$mqtt->onConnect = function ($mqtt) use ($sn,$farm_id) {
foreach(){
 $mqtt->publish()
}
$mqtt->disconnect();
$mqtt->close();
}

Mqtt client: Connection buffer full and close connection