thinkphp5 异步调用方法_thinkphp5 swoole 执行异步任务
目錄結(jié)構(gòu)：
服務(wù)器端：
/*
*author:hdj
*/
namespace app\Console;
use think\console\Command;
use think\console\Input;
use think\console\Output;
class Websocket extends Command{
protected $server;
protected function configure()
{
$this->setName('websocket:start')->setDescription('Start Web Socket Server!');
}
protected function execute(Input $input, Output $output)
{
$serv = new \swoole_server('0.0.0.0',9501);
$serv->set(array('task_worker_num' => 4));
$serv->on('connect', function ($serv, $fd){
echo $fd."客戶端已經(jīng)連接進(jìn)來了.\n";
});
$serv->on('receive', function($serv, $fd, $from_id, $data) {
$task_id = $serv->task($data);
echo "開始投遞異步任務(wù) id=$task_id\n";
});
$serv->on('task', function ($serv, $task_id, $from_id, $data) {
echo "接收異步任務(wù)[id=$task_id]".PHP_EOL;
for ($i = 0 ; $i<10000;$i++){
if($i%2==0){
echo 'send'.$i.' success'."\n";
}else{
echo 'send'.$i.' fail'."\n";
}
sleep(1);
}
$serv->finish("$data -> OK");
});
$serv->on('finish', function ($serv, $task_id, $data) {
echo "異步任務(wù)[id=$task_id]完成".PHP_EOL;
});
$serv->start();
}
}
進(jìn)入你的根目錄 執(zhí)行? php think websocket:start
客戶端：
namespace app\index\controller;
use think\Controller;
class Test extends Controller
{
public function index(){
$client = new \swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_SYNC);
$ret = $client->connect("23.27.127.32", 9501);
if(empty($ret)){
echo 'error!connect to swoole_server failed';
} else {
$client->send('blue');
}
}
}
服務(wù)端顯示：
你是不是多少有了解一點(diǎn)，但是你卻對(duì)這個(gè)不精啊！免費(fèi)分享tp,laravel，swoole，swoft微服務(wù)、SQL性能優(yōu)化，分布式、高并發(fā)等教程，各種大牛都是1-78年P(guān)HP開發(fā)者，每天還有11年的架構(gòu)師做課程講解，助你進(jìn)階中高級(jí)PHP程序員，增值漲薪！
總結(jié)
以上是生活随笔為你收集整理的thinkphp5 异步调用方法_thinkphp5 swoole 执行异步任务的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 云天视界传媒浅谈无人机航拍技巧
- 下一篇： php用ajaxs上传图片_jquery