sleep(1);
}
//执行定时握手任务
Timer::add( 55 , function (){
// 发送心跳数据}
}
return false;
}
/**
* @return void
*
* 向服务器发送['content_type'=>'text/plain','delivery_mode'=>$delivery_mod]); //定义消息
try{
// 发送消息$this->is_connected = false;
$this->reconnect();
}
}
//在做消费时,对流量进行控制,防止出现丢数据
function set_comsume_qos( $prefetch_size = 0 , $prefetch_count = 1 ){
$this->channel