目錄結構：

服務器端：

/*

*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."客戶端已經連接進來了.\n";

});

$serv->on('receive', function($serv, $fd, $from_id, $data) {

$task_id = $serv->task($data);

echo "開始投遞異步任務 id=$task_id\n";

});

$serv->on('task', function ($serv, $task_id, $from_id, $data) {

echo "接收異步任務[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 "異步任務[id=$task_id]完成".PHP_EOL;

});

$serv->start();

}

}

進入你的根目錄 執行? 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');

}

}

}

服務端顯示：

你是不是多少有了解一點，但是你卻對這個不精啊！免費分享tp,laravel，swoole，swoft微服務、SQL性能優化，分布式、高并發等教程，各種大牛都是1-78年PHP開發者，每天還有11年的架構師做課程講解，助你進階中高級PHP程序員，增值漲薪！

總結

以上是生活随笔為你收集整理的thinkphp5 异步调用方法_thinkphp5 swoole 执行异步任务的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。