做了那么多年的PHP开发，真的懂？swoole异步任务实现

简介：异步任务推送协议发送短信验证消息发送邮箱验证消息编写一个任务基类，声明run方法，子类实现run方法。添加任务信息的时候，信息里包含任务类名称，和要传递的参数任务服务器，调用任务实例执行服务端#!/usr/bin/env ...

异步任务推送协议 发送短信验证消息 发送邮箱验证消息 编写一个任务基类，声明run方法，子类实现run方法。 添加任务信息的时候，信息里包含任务类名称，和要传递的参数 任务服务器，调用任务实例执行 服务端 #!/usr/bin/env php <?php class Server { private $serv; public function __construct() { $this->serv = new swoole_server("0.0.0.0", 9501); $this->serv->set(array( "worker_num" => 1, //一般设置为服务器CPU数的1-4倍 "daemonize" => 1, //以守护进程执行 "max_request" => 10000, "dispatch_mode" => 2, "task_worker_num" => 8, //task进程的数量 "task_ipc_mode " => 3, //使用消息队列通信，并设置为争抢模式 "log_file" => "demo.log" ,//所有的输出都会写到日志中 )); $this->serv->on("receive", [$this, "onReceive"]); $this->serv->on("task", [$this, "onTask"]); $this->serv->on("finish", [$this, "onFinish"]); $this->serv->start(); } public function onReceive(swoole_server $serv, $fd, $from_id, $data) { //接收数据，下发任务 $serv->task($data); $serv->send($fd,"任务ok啦"); } public function onTask($serv, $task_id, $from_id, $data) { //任务处理 $task = json_decode($data,true); } public function onFinish($serv, $task_id, $data) { //任务结束，回调 echo "finish"; } } $server = new Server(); 客户端 <?php class Client { private $client; public function __construct() { $this->client = new swoole_client(SWOOLE_SOCK_TCP); if (!$this->client->connect("127.0.0.1", 9501, 1) && !$this->client->isConnected()) { throw new Exception(sprintf("swoole error: %s", $this->client->errCode)); } } public function send($data) { $this->client->send(json_encode($data)); return $this->client->recv(); } public function close() { $this->client->close(); } } //双方统一传递json数据 $client = new Client(); if ($data = $client->send($data)) { echo $data; } $client->close(); 本文仅代表作者个人观点，不代表巅云官方发声，对观点有疑义请先联系作者本人进行修改，若内容非法请联系平台管理员，邮箱2522407257@qq.com。更多相关资讯，请到巅云www.rzxsoft.cn学习互联网营销技术请到巅云建站www.rzxsoft.cn。