//循环操作1w次数据库public function test(){$i=input('id')?input('id'):1;while ( $i<= 10000) {echo $i;echo '<br/>';$data = ['title' => $i.'-'.date('Y-m-d H:i:s'), 'num' => $i];Db::name('input')->insert($data);$i++;}echo '完成';}

  /*** @生生 2018/12/24 19:25:06* [asynchronous PHP异步执行任务]* @param  string $url       执行任务的url地址* @param  array  $post_data 需要post提交的数据POST* @param  array  $cookie    cookie数据用于登录等的设置(此处内部调用，无需鉴权)* @return boole*/
public function asynchronous($url,$post_data = array()){$url_array = parse_url($url);dump($url_array);//用fsockopen()尝试连接  $fp = fsockopen($url_array['host'], 80, $errno, $errstr, 30);if (!$fp) {echo "$errstr ($errno)<br />\n";} else {//建立成功后，向服务器写入数据  $getPath = isset($url_array['path']) ? $url_array['path'] : '/';$out = "GET /".$getPath."/ HTTP/1.1\r\n";$out .= "Host:".$url_array['host']."\r\n";$out .= "Connection: Close\r\n\r\n";fwrite($fp, $out);/*忽略执行结果while (!feof($fp)) {echo fgets($fp, 128);}*///关闭链接fclose($fp);}}

    //调用方法function yibu(){/***  异步方法*   参数:(string)要执行的方法url，(array)传入参数*/$this->asynchronous('http://119.23.33.37/index.php/admin/index/test',['1'=>'haha']);//直接返回结果echo '操作成功';}

<?php
//include '../application/admin/controller/SwooleAsynchronous.php';
/*** @生生 2018.1.1* 创建异步服务器*/
$ser = new swoole_server('0.0.0.0',9506);
//设置进程数
$ser->set(array('task_worker_num'=>4));//当有数据进来的时候
$ser->on('receive',function($ser,$fd,$from_id,$data){//投递异步任务$task_id = $ser->task($data);echo "Dispath AsyncTask: id=$task_id\n";
});/*** @处理异步任务* 调用$serv->task()后，程序立即返回，继续向下执行代码*/
$ser->on('task',function($ser,$task_id,$from_id,$data){echo "这个是：$task_id".'-'.$data.PHP_EOL;//call_user_func('SwooleAsynchronous::huidiao', $value);//返回任务执行的结果$ser->finish("任务完成");
});/*** @处理异步任务的结果* finish操作是可选的，也可以不返回任何结果*/
$ser->on('finish', function ($ser,$task_id,$data) {sleep(5);echo "数据是：$data".PHP_EOL;
});//开启
$ser->start();

public function index(){　　　　　　　　　　//异步处理方法$url = url('index/swooletest/test','','','119.23.33.37');$params=[['id'=>1,'url'=>$url],];//接口数据$msg = json_encode($params);$client = new swoole_client(SWOOLE_SOCK_TCP);//连接到服务器if (!$client->connect('127.0.0.1', 9506, 0.5)){$this->write("链接失败");}//向服务器发送数据if (!$client->send($msg)){$this->write("发送失败");}//关闭连接$client->close();echo  '完成';//注册连接成功回调// $client->on("connect", function($cli) {//     $cli->send("hello world\n");// });//注册数据接收回调// $client->on("receive", function($cli,$data){//     echo "Received: ".$data."\n";// });//注册连接关闭回调// $client->on("close", function($cli,$data){//     echo "Received: ".$data."\n";// });      }