php swoole使用简单实例

本文记录一次对swoole初步的学习和简单的使用。
欢迎讨论和吐槽。

swoole简介

Swoole是一种PHP高级Web开发框架，框架不是为了提高网站的性能，是为了提高网站的开发效率。
使用异步协程的特效，提高代码效率。

swoole使用

个人业务使用场景是对应活动发奖品（发积分，赠劵，礼包），但愿在对用户的领取条件判断经过后，马上给用户返回提示，而后用swoole异步发这些奖品。
搭建的结构以下：tools,business,servers,client文件夹。
tools下是与业务无关的工具类；
business下是业务共用类；
servers下是swoole server，处理发奖操做，可参考一下server:

<?php
include "../business/ScoreService.php";
use business\ScoreService;
$serv = new swoole_server("127.0.0.1", 9501);
//设置异步任务的工做进程数量
$serv->set(array('task_worker_num' => 4));
$serv->on('receive', function($serv, $fd, $from_id, $data) {
    //投递异步任务
    $task_id = $serv->task($data);
    echo "receive";
});
//处理异步任务
$serv->on('task', function ($serv, $task_id, $from_id, $data) {
    sendScore($data);
    //返回任务执行的结果
    $serv->finish($data);
});
//处理异步任务的结果
$serv->on('finish', function ($serv, $task_id, $data) {
    echo "finish";
});
$serv->start();

function sendScore($data){
    //获取到$data
    $arr = json_decode($data,true);
    //判断数据是否异常
    //业务发奖代码
    return true;
}

client下，创建client class，链接server操做，业务使用的时候，不须要关注swoole的细节，只须要使用client提供的接口便可，样例以下：

<?php
namespace client;
class ScoreClient
{
    public function send($msg){
        $client = new \swoole_client(\SWOOLE_SOCK_TCP);
        //链接到服务器
        if (!$client->connect('127.0.0.1', 9501, 1)){
            //
        }
        //向服务器发送数据
        if (!$client->send($msg)){
           //
        }
        //关闭链接
        $client->close();
    }
}

而后在业务机器上启动swoole server，就能够调用client中的方法去执行对应的功能。

思考和优化

1. 建议除此server执行外，还有个定时任务server去处理执行失败的任务。

2. 能够参考腾讯的tsf框架，用异步和协程的特性处理部分业务。