connect(); // 订阅一个主题或者多个主题 $client->subscribe($topic); //时间 $timeSincePing = time(); while (true){ // 接收并处理消息 $message = $client->recv();// 订阅消息 if ($message && $message !== true) { // 携程处理 co(function () use ($function,$client,$message,$topic){ $function($client,$message,$topic); }); } //心跳 if ($timeSincePing <= (time() - $client->getKeepAlive())){ if ($client->ping()) { $timeSincePing = time(); } } } } }