swoole – 知识点滴

syar 基于swoole实现的Yar服务

2016年12月1日 by admin·0评论

为何用swoole来实现 Yar server

提升Yar服务端执行效率
学习swoole, yar(在此感谢laruence,rango及swoole开发团队)

Requirements

php5.4+
ext-swoole 1.8.8+
ext-msgpack 如果yar使用msgpack编码方式

Installation

composer require stcer/syar

1	composer require stcer/syar

简单性能测试

测试脚本 example/benchmark.php, 测试环境(虚拟机)

cpu: i5 – 4460
mem: 4G
os: centos6.5
php: php7(fpm: 20进程, swoole: 18进程(8 worker + 10 task)

脚本一共完成44次接口调用：

简单接口调用 2次
数据库查询接口调用2次
并发简单接口调用 20次
并发数据库查询接口调用 20次

function test($type, $times = 5, $limit = 5){
    $timer = new Timer();
    $benchmark = new Benchmark($type);
    $rs[] = $benchmark-&gt;simpleTest(); // 2
    $rs[] = $benchmark-&gt;dbTest($limit); // 2
    $rs[] = $benchmark-&gt;batchTest($times, $limit); // 20
    $rs[] = $benchmark-&gt;concurrentTest($times, $limit); // 20
    $stop = $timer-&gt;stop();

    // 44 calls, 22 db, 22 normal
    foreach($rs as $v){
        var_dump($v);
    }

    return $stop;
}

// start test
$times['syar'] = test('syar');
$times['fpm'] = test('fpm');
var_dump($times);

---------------------------
output: 

array(2) {
  ["syar"]=&gt;
  float(0.01271)
  ["fpm"]=&gt;
  float(0.08602)
}

function test($type, $times = 5, $limit = 5){

$timer = new Timer();

$benchmark = new Benchmark($type);

$rs[] = $benchmark->simpleTest(); // 2

$rs[] = $benchmark->dbTest($limit); // 2

$rs[] = $benchmark->batchTest($times, $limit); // 20

$rs[] = $benchmark->concurrentTest($times, $limit); // 20

$stop = $timer->stop();

// 44 calls, 22 db, 22 normal

foreach($rs as $v){

var_dump($v);

}

return $stop;

}

// start test

$times['syar'] = test('syar');

$times['fpm'] = test('fpm');

var_dump($times);

---------------------------

output:

array(2) {

["syar"]=>

float(0.01271)

["fpm"]=>

float(0.08602)

}

在当前测试环境下，fpm环境下的执行时间大概是syar下的4 — 6倍左右，稍后做更详细的压力测试，服务器、客户端资源占用情况测试

github:https://github.com/stcer/syar

swoole task中的数据返回

2016年6月8日 by admin·0评论

task中能返回的数据通过php的Serialization函数返回到worker进程，因此像Closure等不能被序列化的对象不能返回，包括$exception中可能包括Closure

    function onTask($serv, $task_id, $from_id, $data){
        if(!is_array($data) || !$data['id']){
            return new Exception("Invalid task data");
        }

        $id = $data['id'];
        if(!isset($this->callbacks[$id])){
            return new Exception("Invalid task id");
        }

        try{
            $callback = $this->callbacks[$id][0];
            $rs = call_user_func_array($callback, $data['data']);
            return $rs;
        } catch(Exception $e){
            return $e; // 可能出错，使work进程不能正常运行
        }
    }

function onTask($serv, $task_id, $from_id, $data){

if(!is_array($data) || !$data['id']){

return new Exception("Invalid task data");

}

$id = $data['id'];

if(!isset($this->callbacks[$id])){

return new Exception("Invalid task id");

}

try{

$callback = $this->callbacks[$id][0];

$rs = call_user_func_array($callback, $data['data']);

return $rs;

} catch(Exception $e){

return $e; // 可能出错，使work进程不能正常运行

}

简单的推送消息服务

2015年12月18日 by admin·0评论

订阅者注册推送地址，关注的事件
服务端将消息存储redis队列
服务端开N个进程，读取redis队列并推送到订阅者url
推送错误进入错误队列
服务定时发送错误队列消息

原型

ini_set('default_socket_timeout', -1);
$server = new swoole_http_server('0.0.0.0', 8081);

$n = 5;
for($i = 0; $i < $n; $i++){
    $server->addProcess(new swoole_process(function($process) {
        $redis = getRedis();
        while($data = $redis->blPop('test_list', 0)){
            echo $process->pid . " work : " .  $data[1] . "\n";
            sleep(1);
        }
    }));
}

function getRedis(){
    static $redis;
    if(!isset($redis)){
        $redis = new Redis();
        $redis->connect('127.0.0.1', 6379, 0);
        $redis->setOption(Redis::OPT_SERIALIZER, Redis::SERIALIZER_NONE);
    }
    return $redis;
}

$server->on('request', function(swoole_http_request $request, swoole_http_response $response) {
    getRedis()->lPush('test_list', "test info");
    $response->end("<h1>hello swoole. #" . rand(1000, 9999) . "</h1>");
});

$server->start();

ini_set('default_socket_timeout', -1);

$server = new swoole_http_server('0.0.0.0', 8081);

$n = 5;

for($i = 0; $i < $n; $i++){

$server->addProcess(new swoole_process(function($process) {

$redis = getRedis();

while($data = $redis->blPop('test_list', 0)){

echo $process->pid . " work : " . $data[1] . "\n";

sleep(1);

}

}));

}

function getRedis(){

static $redis;

if(!isset($redis)){

$redis = new Redis();

$redis->connect('127.0.0.1', 6379, 0);

$redis->setOption(Redis::OPT_SERIALIZER, Redis::SERIALIZER_NONE);

}

return $redis;

}

$server->on('request', function(swoole_http_request $request, swoole_http_response $response) {

getRedis()->lPush('test_list', "test info");

$response->end("<h1>hello swoole. #" . rand(1000, 9999) . "</h1>");

});

$server->start();

swoole->addProcess(swoole_process)增加的进程不能start()
process结束后会被master进程再次创建，所以要么阻塞或进epoll循环
参考 http://wiki.swoole.com/wiki/page/390.html
与worker或task进程通信参考 http://wiki.swoole.com/wiki/page/363.html

swoole的注意事项

2015年12月16日 by admin·0评论

在server->start()之前，不要将资源连接用于共用(static或设置到server->var中) worker或task是从主进程中fork，进程间不能共用资源连接
尽可能在start前加载足够少的文件、对象

知识点滴

专注于php应用开发

标签： swoole