分类： php

为何用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

twig运行时加载

2016年11月2日 by admin·已关闭评论

注册加载器, 对象创建工厂

class RuntimeLoader implements Twig_RuntimeLoaderInterface
{
    public function load($class)
    {
        // implement the logic to create an instance of $class
        // and inject its dependencies
        // most of the time, it means using your dependency injection container
        if ('Project_Twig_RuntimeExtension' === $class) {
            return new $class(new Rot13Provider());
        } else {
            // ...
        }
    }
}

$twig->addRuntimeLoader(new RuntimeLoader());

class RuntimeLoader implements Twig_RuntimeLoaderInterface

{

public function load($class)

{

// implement the logic to create an instance of $class

// and inject its dependencies

// most of the time, it means using your dependency injection container

if ('Project_Twig_RuntimeExtension' === $class) {

return new $class(new Rot13Provider());

} else {

// ...

}

$twig->addRuntimeLoader(new RuntimeLoader());

定义扩展

class Project_Twig_RuntimeExtension extends Twig_Extension
{
    private $rot13Provider;

    public function __construct($rot13Provider)
    {
        $this->rot13Provider = $rot13Provider;
    }

    public function rot13($value)
    {
        return $rot13Provider->rot13($value);
    }
}

class Project_Twig_Extension extends Twig_Extension
{
    public function getFunctions()
    {
        return array(
            new Twig_SimpleFunction('rot13', array('Project_Twig_RuntimeExtension', 'rot13')),
            // or
            new Twig_SimpleFunction('rot13', 'Project_Twig_RuntimeExtension::rot13'),
        );
    }
}

class Project_Twig_RuntimeExtension extends Twig_Extension

{

private $rot13Provider;

public function __construct($rot13Provider)

{

$this->rot13Provider = $rot13Provider;

}

public function rot13($value)

{

return $rot13Provider->rot13($value);

}

class Project_Twig_Extension extends Twig_Extension

{

public function getFunctions()

{

return array(

new Twig_SimpleFunction('rot13', array('Project_Twig_RuntimeExtension', 'rot13')),

// or

new Twig_SimpleFunction('rot13', 'Project_Twig_RuntimeExtension::rot13'),

);

}

composer从私有资源库安装

2016年9月20日 by admin·已关闭评论

了解

资源 https://getcomposer.org/doc/05-repositories.md#loading-a-package-from-a-vcs-repository
包定义 http://docs.phpcomposer.com/04-schema.html

可安装的资源分类

composer 主要的资源库定义一个 packages.json, 定义各类包及版本，一个版本可以理解为一个包，必须包括name, version, dist or source, 在dist or source定义路径(type and url), type的取值包括：git, svn, fossil, hg, perforce, zip, rar, tar, gzip, xz , phar, file, path
vcs, git仓储/svn, 可以是github、私有git库、svn
pear, 不解释
package，没有使用psr规范的普通库

建立自己私有资源库

使用packagist or satis创建composer类型的资源库,
参考github.com/composer/packagist， github.com/composer/satis
Path 定义包路径
Artifact 归档类型 (zips, tar..)

定义包资源库地址示例

    "require": {
        "stcer/demo" : "*",
        "stcer/j" : "0.1.0"
    },

    "repositories": [
        {
            "type": "path",
            "url":  "../stcer-demo",
            "options": {
                "symlink": false
            }
        },
        {
          "type": "vcs",
           "url":  "git@192.168.0.252:repos/j.git"
        }
    ],

"require": {

"stcer/demo" : "*",

"stcer/j" : "0.1.0"

"repositories": [

{

"type": "path",

"url": "../stcer-demo",

"options": {

"symlink": false

}

{

"type": "vcs",

"url": "git@192.168.0.252:repos/j.git"

}

swoole task中的数据返回

2016年6月8日 by admin·已关闭评论

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进程不能正常运行

}

反射应用于构造函数参数处理

2016年5月3日 by admin·已关闭评论

示例代码

class A {}
class B {}
class C {
    /**
     * C constructor.
     * @param A $objA
     * @param B $objB
     */
    public function __construct(A $objA, B $objB) {
        $this->a = $objA;
        $this->b = $objB;
    }
}

function getConcrete($name, $params){
    $reflector = new ReflectionClass($name);
    $constructor = $reflector->getConstructor();
    $dependencies = $constructor->getParameters();
    var_dump($params);
    var_dump($dependencies);

    foreach ($params as $key => $value) {
        if (is_numeric($key)) {
            unset($params[$key]);
            $params[$dependencies[$key]->name] = $value;
        }
    }
    var_dump($params);

    $args = [];
    foreach ($dependencies as $parameter) {
        $dependency = $parameter->getClass();
        $args[] = $params[$parameter->name];
    }

    $c = $reflector->newInstanceArgs($args);
    var_dump($c);

    return $c;
}

getConcrete('C', [
    'objB' => new B,
    new A,
]);

class A {}

class B {}

class C {

/**

* C constructor.

* @param A $objA

* @param B $objB

public function __construct(A $objA, B $objB) {

$this->a = $objA;

$this->b = $objB;

}

function getConcrete($name, $params){

$reflector = new ReflectionClass($name);

$constructor = $reflector->getConstructor();

$dependencies = $constructor->getParameters();

var_dump($params);

var_dump($dependencies);

foreach ($params as $key => $value) {

if (is_numeric($key)) {

unset($params[$key]);

$params[$dependencies[$key]->name] = $value;

}

var_dump($params);

$args = [];

foreach ($dependencies as $parameter) {

$dependency = $parameter->getClass();

$args[] = $params[$parameter->name];

}

$c = $reflector->newInstanceArgs($args);

var_dump($c);

return $c;

}

getConcrete('C', [

'objB' => new B,

new A,

]);

di容器的应用

    public function build($concrete, array $parameters = [])
        $reflector = new ReflectionClass($concrete);
        $this->buildStack[] = $concrete;

        $constructor = $reflector->getConstructor();

        // If there are no constructors, that means there are no dependencies then
        // we can just resolve the instances of the objects right away, without
        // resolving any other types or dependencies out of these containers.
        if (is_null($constructor)) {
            array_pop($this->buildStack);

            return new $concrete;
        }

        $dependencies = $constructor->getParameters();

        // Once we have all the constructor's parameters we can create each of the
        // dependency instances and then use the reflection instances to make a
        // new instance of this class, injecting the created dependencies in.
        $parameters = $this->keyParametersByArgument(
            $dependencies, $parameters
        );

        $instances = $this->getDependencies(
            $dependencies, $parameters
        );

        array_pop($this->buildStack);

        return $reflector->newInstanceArgs($instances);
    }

    protected function keyParametersByArgument(array $dependencies, array $parameters)
    {
        foreach ($parameters as $key => $value) {
            if (is_numeric($key)) {
                unset($parameters[$key]);

                $parameters[$dependencies[$key]->name] = $value;
            }
        }

        return $parameters;
    }

    protected function getDependencies(array $parameters, array $primitives = [])
    {
        $dependencies = [];

        foreach ($parameters as $parameter) {
            $dependency = $parameter->getClass();

            // If the class is null, it means the dependency is a string or some other
            // primitive type which we can not resolve since it is not a class and
            // we will just bomb out with an error since we have no-where to go.
            if (array_key_exists($parameter->name, $primitives)) {
                $dependencies[] = $primitives[$parameter->name];
            } elseif (is_null($dependency)) {
                $dependencies[] = $this->resolveNonClass($parameter);
            } else {
                $dependencies[] = $this->resolveClass($parameter);
            }
        }

        return $dependencies;
    }

    protected function resolveClass(ReflectionParameter $parameter)
    {
        try {
            return $this->make($parameter->getClass()->name);
        }

        // If we can not resolve the class instance, we will check to see if the value
        // is optional, and if it is we will return the optional parameter value as
        // the value of the dependency, similarly to how we do this with scalars.
        catch (BindingResolutionException $e) {
            if ($parameter->isOptional()) {
                return $parameter->getDefaultValue();
            }

            throw $e;
        }
    }

public function build($concrete, array $parameters = [])

$reflector = new ReflectionClass($concrete);

$this->buildStack[] = $concrete;

$constructor = $reflector->getConstructor();

// If there are no constructors, that means there are no dependencies then

// we can just resolve the instances of the objects right away, without

// resolving any other types or dependencies out of these containers.

if (is_null($constructor)) {

array_pop($this->buildStack);

return new $concrete;

}

$dependencies = $constructor->getParameters();

// Once we have all the constructor's parameters we can create each of the

// dependency instances and then use the reflection instances to make a

// new instance of this class, injecting the created dependencies in.

$parameters = $this->keyParametersByArgument(

$dependencies, $parameters

);

$instances = $this->getDependencies(

$dependencies, $parameters

);

array_pop($this->buildStack);

return $reflector->newInstanceArgs($instances);

}

protected function keyParametersByArgument(array $dependencies, array $parameters)

{

foreach ($parameters as $key => $value) {

if (is_numeric($key)) {

unset($parameters[$key]);

$parameters[$dependencies[$key]->name] = $value;

}

return $parameters;

}

protected function getDependencies(array $parameters, array $primitives = [])

{

$dependencies = [];

foreach ($parameters as $parameter) {

$dependency = $parameter->getClass();

// If the class is null, it means the dependency is a string or some other

// primitive type which we can not resolve since it is not a class and

// we will just bomb out with an error since we have no-where to go.

if (array_key_exists($parameter->name, $primitives)) {

$dependencies[] = $primitives[$parameter->name];

} elseif (is_null($dependency)) {

$dependencies[] = $this->resolveNonClass($parameter);

} else {

$dependencies[] = $this->resolveClass($parameter);

}

return $dependencies;

}

protected function resolveClass(ReflectionParameter $parameter)

{

try {

return $this->make($parameter->getClass()->name);

}

// If we can not resolve the class instance, we will check to see if the value

// is optional, and if it is we will return the optional parameter value as

// the value of the dependency, similarly to how we do this with scalars.

catch (BindingResolutionException $e) {

if ($parameter->isOptional()) {

return $parameter->getDefaultValue();

}

throw $e;

}

1，十进制转二进制 decbin() 函数，如下实例
echo decbin(12); //输出 1100
echo decbin(26); //输出 11010
decbin
(PHP 3, PHP 4, PHP 5)
decbin — 十进制转换为二进制
说明
string decbin ( int number )
返回一字符串，包含有给定 number 参数的二进制表示。所能转换的最大数值为十进制的 4294967295，其结果为 32 个 1 的字符串。

2，十进制转八进制 decoct() 函数

echo decoct(15); //输出 17
echo decoct(264); //输出 410
decoct
(PHP 3, PHP 4, PHP 5)
decoct — 十进制转换为八进制
说明
string decoct ( int number )
返回一字符串，包含有给定 number 参数的八进制表示。所能转换的最大数值为十进制的 4294967295，其结果为 “37777777777”。

3，十进制转十六进制 dechex() 函数

echo dechex(10); //输出 a
echo dechex(47); //输出 2f
dechex
(PHP 3, PHP 4, PHP 5)
dechex — 十进制转换为十六进制
说明
string dechex ( int number )
返回一字符串，包含有给定 number 参数的十六进制表示。所能转换的最大数值为十进制的 4294967295，其结果为 “ffffffff”。

二，二进制（binary system）转换函数说明

1，二进制转十六制进 bin2hex() 函数

$binary = “11111001”;
$hex = dechex(bindec($binary));
echo $hex;//输出f9
bin2hex
(PHP 3 >= 3.0.9, PHP 4, PHP 5)
bin2hex — 将二进制数据转换成十六进制表示
说明
string bin2hex ( string str )
返回 ASCII 字符串，为参数 str 的十六进制表示。转换使用字节方式，高四位字节优先。

2，二进制转十制进 bindec() 函数

echo bindec(‘110011’); //输出 51
echo bindec(‘000110011’); //输出 51
echo bindec(‘111’); //输出 7
bindec
(PHP 3, PHP 4, PHP 5)
bindec — 二进制转换为十进制
说明
number bindec ( string binary_string )
返回 binary_string 参数所表示的二进制数的十进制等价值。
bindec() 将一个二进制数转换成 integer。可转换的最大的数为 31 位 1 或者说十进制的 2147483647。PHP 4.1.0 开始，该函数可以处理大数值，这种情况下，它会返回 float 类型。

三，八进制（octal system）转换函数说明

八进制转十进制 octdec() 函数

echo octdec(’77’); //输出 63
echo octdec(decoct(45)); //输出 45
octdec
(PHP 3, PHP 4, PHP 5)
octdec — 八进制转换为十进制
说明
number octdec ( string octal_string )
返回 octal_string 参数所表示的八进制数的十进制等值。可转换的最大的数值为 17777777777 或十进制的 2147483647。PHP 4.1.0 开始，该函数可以处理大数字，这种情况下，它会返回 float 类型

四，十六进制（hexadecimal）转换函数说明

十六进制转十进制 hexdec()函数

var_dump(hexdec(“See”));
var_dump(hexdec(“ee”));
// both print “int(238)”

var_dump(hexdec(“that”)); // print “int(10)”
var_dump(hexdec(“a0”)); // print “int(160)”
hexdec
(PHP 3, PHP 4, PHP 5)
hexdec — 十六进制转换为十进制
说明
number hexdec ( string hex_string )
返回与 hex_string 参数所表示的十六进制数等值的的十进制数。hexdec() 将一个十六进制字符串转换为十进制数。所能转换的最大数值为 7fffffff，即十进制的 2147483647。PHP 4.1.0 开始，该函数可以处理大数字，这种情况下，它会返回 float 类型。
hexdec() 将遇到的所有非十六进制字符替换成 0。这样，所有左边的零都被忽略，但右边的零会计入值中。

五，任意进制转换 base_convert() 函数

$hexadecimal = ‘A37334’;
echo base_convert($hexadecimal, 16, 2);//输出 101000110111001100110100
base_convert
(PHP 3 >= 3.0.6, PHP 4, PHP 5)

base_convert — 在任意进制之间转换数字
说明
string base_convert ( string number, int frombase, int tobase )
返回一字符串，包含 number 以 tobase 进制的表示。number 本身的进制由 frombase 指定。frombase 和 tobase 都只能在 2 和 36 之间（包括 2 和 36）。高于十进制的数字用字母 a-z 表示，例如 a 表示 10，b 表示 11 以及 z 表示 35。

这里主要是把PHP进制转换函数进行整理，便于开发查找，相关具体函数说明请参考PHP手册。请关注下一期中文字符编码研究系列。

二进制字节表示长度的转换

2016年4月20日 by admin·已关闭评论

在处理mysql协议时或一些二进制流(pack生成)，经常用一1,N个字字来表示长度，需做如下转化

// test one
$length = substr($data, 0, 1);
$length = bin2hex($length);
$length = hexdec($length);

// test two
$len = 192;
$byte = pack("C", $len);
$len = bin2hex($byte);
$len = hexdec($len);

echo "length:" . $len ."\n";

// test one

$length = substr($data, 0, 1);

$length = bin2hex($length);

$length = hexdec($length);

// test two

$len = 192;

$byte = pack("C", $len);

$len = bin2hex($byte);

$len = hexdec($len);

echo "length:" . $len ."\n";

参考：http://blog.csdn.net/wind520/article/details/43964821

mysql client验证报文解析

            // 包长
            $length = substr($data, 0, 1);
            $length = bin2hex($length);
            $length = hexdec($length);
            echo $length . "\n";

            // 登录用户名
            $body = substr($data, 36);
            $userName = $this->getChars($body);
            $i = strlen($userName) + 1;
            echo $userName . "\n";

            // 数据库名[可选]
            $lengthByte = substr($body, $i, 1);
            $len = bin2hex($lengthByte);
            $len = hexdec($len);
            echo $len . "\n";
            if($len <= 250){
                $i = $i + $len + 1;
                $dbName = $this->getChars($body, $i);
                echo $dbName . "\n";
            }


    protected function getChars($data, $start = 0){
        $i = $start; $length = strlen($data);
        while($i < $length){
            $char = substr($data, $i, 1);
            if(ord($char) === 0){
                return substr($data, $start, $i - $start);
            }
            $i++;
        }
        return $data;
    }

// 包长

$length = substr($data, 0, 1);

$length = bin2hex($length);

$length = hexdec($length);

echo $length . "\n";

// 登录用户名

$body = substr($data, 36);

$userName = $this->getChars($body);

$i = strlen($userName) + 1;

echo $userName . "\n";

// 数据库名[可选]

$lengthByte = substr($body, $i, 1);

$len = bin2hex($lengthByte);

$len = hexdec($len);

echo $len . "\n";

if($len <= 250){

$i = $i + $len + 1;

$dbName = $this->getChars($body, $i);

echo $dbName . "\n";

}

protected function getChars($data, $start = 0){

$i = $start; $length = strlen($data);

while($i < $length){

$char = substr($data, $i, 1);

if(ord($char) === 0){

return substr($data, $start, $i - $start);

}

$i++;

}

return $data;

}

wordpress对输出的内容替换

2016年3月18日 by admin·已关闭评论

function igeekLab_cdn_avatar($avatar) {
    $buffer = str_replace("http://1.gravatar.com/", "https://1.gravatar.com/", $avatar);
	return $avatar;
}
function igeeklab_avatar_start() {
	ob_start("igeeklab_cdn_avatar");
}
function igeeklab_avatar_end() {
	ob_end_flush();
}
add_action('init', 'igeeklab_avatar_start');
add_action('shutdown', 'igeeklab_avatar_end');

function igeekLab_cdn_avatar($avatar) {

$buffer = str_replace("http://1.gravatar.com/", "https://1.gravatar.com/", $avatar);

return $avatar;

}

function igeeklab_avatar_start() {

ob_start("igeeklab_cdn_avatar");

}

function igeeklab_avatar_end() {

ob_end_flush();

}

add_action('init', 'igeeklab_avatar_start');

add_action('shutdown', 'igeeklab_avatar_end');

php优秀扩展记录

2016年3月17日 by admin·已关闭评论

runkit
可用于迁移产生的函数改变

https://github.com/zenovich/runkit/

数组这个坑总是记不住

2016年3月7日 by admin·已关闭评论

array_merge()：
如果输入的数组中有相同的字符串键名，则该键名后面的值将覆盖前一个值。如果数组包含数字键名，后面的值将不会覆盖原来的值，而是附加到后面。（数字键名会被重新分配，总会变成从零开始的。。）

对于使用“＋”合并数组：
如果数组中有相同的字符串键名（不管是不是数字），则会把最先出现的值作为最终结果返回，而把后面的数组拥有相同键名的那些值“抛弃”掉。

知识点滴

专注于php应用开发