i<10;$i++){
$task_connection = new AsyncTcpConnection('Text://192.168.1.128:12345');
// 任务及参数数据send_mail',
'args' => array('from'=>'xxx', 'to'=>'xxx', 'contents'=>'xxx'),
);
// 发送数据vendor/autoload.php';
// task worker,使用Text协议
$task_worker = new Worker('Text://0.0.0.0:12345');
// task进程数可以根据需要多开一些task_worker->reusePort = true;
$task_worker->onMessage = function($connection, $task_data)
{
// 假设发来的是json数据
$task_data = json_decode($task_data, true);
echo 1;
sleep(10);//模拟进程阻塞
$connection