作者： admin

swoole的注意事项

2015年12月16日 by admin·已关闭评论

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

php redis的连接被关闭

2015年12月10日 by admin·已关闭评论

php使用blpop时，隔一段时间连接被关闭，做以下检查

redis.conf 配置 timeout = 0
php设置配置 default_socket_timeout，如 ini_set(‘default_socket_timeout’, -1);

sphinx索引与搜索分离

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

当数据量与搜索并发增大后，服务压力明显，通过以下方式改进

将索引分段分布到几台服务器，使用 index:local/agent合并索引索引
将建索引分离到单独服务器，使用indexer –nohup建立.tmp索引文件，使用–check创建 .new索引文件，将.new索引文件复制到搜索服务器，重启搜索服务 seached –stopwait && searchd
如果是随时间增量，分断索引更新频率
使用lvs进行负载均衡
增量索引使用
部分不好实现的业务使用其它搜索引擎，如 Elasticsearch

js中的单例

2015年10月28日 by admin·已关闭评论

var getSingle = function(fn){
    var rs;
    return function(){
        return rs || (rs = fn.apply(this, arguments));
    }
}

var getSingle = function(fn){

var rs;

return function(){

return rs || (rs = fn.apply(this, arguments));

}

常用于创建唯一dom

vue踩过的一次坑动态组件

2015年10月28日 by admin·已关闭评论

使用动态组件

<component :is="currentView"></component>

1	<component :is="currentView"></component>

组件的数据实始化使用function返回，否则无法初始化，如

data :  function(){
    return {
        services : [],
        msg : null
    }
}

data : function(){

return {

services : [],

msg : null

}

状态改变的hook，使用了route的组件，如果需要记得写router.activeate

activate: function (done) {
    done();
}

activate: function (done) {

done();

}

其它

数据(特别是复杂的对象)的改变尽量使用set函数或watch，如

that.$set('services', rs);

1	that.$set('services', rs);

watch : {
    api : {
        deep: true
    }
}

watch : {

api : {

deep: true

}

使用computed属性来设置动态变量

computed: {
    isWelcome : function(){
        return this.api.length &gt; 0;
    },

    hasDoc : function(){
        return this.func.doc.length &gt; 0;
    }
}

computed: {

isWelcome : function(){

return this.api.length > 0;

hasDoc : function(){

return this.func.doc.length > 0;

}

在线编辑器

加载编辑器js等相关资源，在组件事件函数中渲染组件

官方文档说明：
http://rc.vuejs.org/guide/components.html#Component_Option_Caveats
http://vuejs.org/guide/components.html#activate_Hook

极简的Api处理

2015年9月18日 by admin·已关闭评论

根据请求的api获取class, 即需要一个Api class loader, api格式如 xxx.xxx.xx

/**
     * @param $api
     * @param string $oldApi
     * @return Base
     * @throws Exception
     */
    function getClass($api, $oldApi = ''){
        if(isset(self::$classCaches[$api])){
            return self::$classCaches[$api];
        }

        if(!$oldApi){
            $oldApi = $api;
        }

        if(isset($this->apiMap[$api])){
            return new $this->apiMap[$api];
        }

        $path = explode('.', $api);
        $className = array_pop($path);
        $apiClass = $this->nsPrefix . ($path ? (implode('\\', $path)) . "\\" : '') . ucfirst($className);
        if(!class_exists($apiClass)){
            if($path){
                return $this->getClass(implode('.', $path), $oldApi);
            }else{
                throw new Exception("Invalid api({$api})", Exception::API);
            }
        }

        if($api != $oldApi)
            $action = str_replace($api . '.', '', $oldApi);
        else {
            $action = '';
        }

        /** @var Base $class */
        $class = new $apiClass();
        $class->setAction($action);
        self::$classCaches[$api] = $class;
        return $class;
    }

/**

* @param $api

* @param string $oldApi

* @return Base

* @throws Exception

function getClass($api, $oldApi = ''){

if(isset(self::$classCaches[$api])){

return self::$classCaches[$api];

}

if(!$oldApi){

$oldApi = $api;

}

if(isset($this->apiMap[$api])){

return new $this->apiMap[$api];

}

$path = explode('.', $api);

$className = array_pop($path);

$apiClass = $this->nsPrefix . ($path ? (implode('\\', $path)) . "\\" : '') . ucfirst($className);

if(!class_exists($apiClass)){

if($path){

return $this->getClass(implode('.', $path), $oldApi);

}else{

throw new Exception("Invalid api({$api})", Exception::API);

}

if($api != $oldApi)

$action = str_replace($api . '.', '', $oldApi);

else {

$action = '';

}

/** @var Base $class */

$class = new $apiClass();

$class->setAction($action);

self::$classCaches[$api] = $class;

return $class;

}

需要一个api 的基类，根据请求参数返回结果

    public function handle($args, $request = []){
        if($this->action){
            $method = str_replace('.', '_', $this->action);
            if($this->action != 'handle' && method_exists($this, $method)){
                return call_user_func(array($this, $method), $args);
            }

            if(method_exists($this, 'getModel')){
                $model = $this->getModel();
                if(method_exists($model, $method)){
                    return call_user_func_array(array($model, $method), $args);
                }
            }

        } else if(method_exists($this, 'execute')){
            return call_user_func(array($this, 'execute'), $args);
        }

        throw new Exception("Method not found");
    }

public function handle($args, $request = []){

if($this->action){

$method = str_replace('.', '_', $this->action);

if($this->action != 'handle' && method_exists($this, $method)){

return call_user_func(array($this, $method), $args);

}

if(method_exists($this, 'getModel')){

$model = $this->getModel();

if(method_exists($model, $method)){

return call_user_func_array(array($model, $method), $args);

}

} else if(method_exists($this, 'execute')){

return call_user_func(array($this, 'execute'), $args);

}

throw new Exception("Method not found");

}

弄个js客户端

    apiUrl : 'http://api.' + location.host + '/index.php?q=%action%&callback=?',
    api : function(api, args){
        if(!args){
            args = {};
        }
        var deferred = $.Deferred();
        var url = this.apiUrl.replace(/%action%/, api);
        $.getJSON(url, args, function(response){
                if(jc001.papi.is_succ(response)){
                    deferred.resolve(response.data);
                } else {
                    deferred.reject(response);
                }
            }
        );
        return deferred;
    }

apiUrl : 'http://api.' + location.host + '/index.php?q=%action%&callback=?',

api : function(api, args){

if(!args){

args = {};

}

var deferred = $.Deferred();

var url = this.apiUrl.replace(/%action%/, api);

$.getJSON(url, args, function(response){

if(jc001.papi.is_succ(response)){

deferred.resolve(response.data);

} else {

deferred.reject(response);

}

);

return deferred;

}

    papi.api('comm.region.name', 2747).done(function(rs){
        console.log(rs);
    }).fail(function(rs){
        console.log(rs);
    });

papi.api('comm.region.name', 2747).done(function(rs){

console.log(rs);

}).fail(function(rs){

console.log(rs);

});

接口文档及web接口测试

加一个接口日志及统计收工

反射获取文档

2015年9月18日 by admin·已关闭评论

有需要web在线查看对象文档需求，简单测试可行

function test1(){
    $class = new ReflectionClass('TestObject');

    //$properties = $class->getProperties();
    $methods = $class->getMethods(ReflectionMethod::IS_PUBLIC);
    foreach($methods as $method){
        $doc = $method->getDocComment();
        echo "\t" . $doc;
        echo "\n";

        $params = $method->getParameters();
        echo implode(' ', Reflection::getModifierNames($method->getModifiers()));
        echo ' ', $method->getName() . '(';
        foreach($params as $param){
            echo $param->getName();
            if($param->isDefaultValueAvailable()){
                $value = $param->getDefaultValue();
                echo "=", $value;
            }
        }
        echo ")";
        echo "\n";
    }
}

function test1(){

$class = new ReflectionClass('TestObject');

//$properties = $class->getProperties();

$methods = $class->getMethods(ReflectionMethod::IS_PUBLIC);

foreach($methods as $method){

$doc = $method->getDocComment();

echo "\t" . $doc;

echo "\n";

$params = $method->getParameters();

echo implode(' ', Reflection::getModifierNames($method->getModifiers()));

echo ' ', $method->getName() . '(';

foreach($params as $param){

echo $param->getName();

if($param->isDefaultValueAvailable()){

$value = $param->getDefaultValue();

echo "=", $value;

}

echo ")";

echo "\n";

}

注解的解析

2015年9月18日 by admin·已关闭评论

Phalcon的注解(Phalcon\Annotations\*)

Class Phalcon\Annotations\Annotation
Class Phalcon\Annotations\Collection Annotation集合
Class Phalcon\Annotations\Exception
Class Phalcon\Annotations\Reader 读取类的注解，以数组形式分类返回, 可用于创建 Reflection
Class Phalcon\Annotations\Reflection

Reflection
注解反射对象，获取类方法，属性，类等的注释

常用方法, 返回 Collection, 可遍历的对象集合(Annotation)

  public getClassAnnotations ();
  public getMethodsAnnotations ();

1 2	public getClassAnnotations (); public getMethodsAnnotations ();

Reflection的使用参考：

use Phalcon\Annotations\Adapter\Memory as MemoryAdapter;
use Phalcon\Annotations\Reader;
use Phalcon\Annotations\Reflection as PhalconReflection;

function test2($useCache = 1){
    if($useCache == 1) {
        $reader = new MemoryAdapter();
        $reflection = $reader->get('TestObject');
    } else {
        // Parse the annotations in a class
        $reader = new Reader();
        $parsing = $reader->parse('TestObject');
        // Create the reflection
        $reflection = new PhalconReflection($parsing);
    }

    // Get the annotations in the class docblock
    $classAnnotations = $reflection->getClassAnnotations();
    var_dump($classAnnotations);

    $methodAnnotations = $reflection->getMethodsAnnotations();
    var_dump($methodAnnotations);
}

use Phalcon\Annotations\Adapter\Memory as MemoryAdapter;

use Phalcon\Annotations\Reader;

use Phalcon\Annotations\Reflection as PhalconReflection;

function test2($useCache = 1){

if($useCache == 1) {

$reader = new MemoryAdapter();

$reflection = $reader->get('TestObject');

} else {

// Parse the annotations in a class

$reader = new Reader();

$parsing = $reader->parse('TestObject');

// Create the reflection

$reflection = new PhalconReflection($parsing);

}

// Get the annotations in the class docblock

$classAnnotations = $reflection->getClassAnnotations();

var_dump($classAnnotations);

$methodAnnotations = $reflection->getMethodsAnnotations();

var_dump($methodAnnotations);

}

Annotation 注解类
获取单个注解的名称、参数表达式等

注解示例

<?php

/**
 * Simple Annotation
 *
 * @SomeAnnotation
 */

/**
 * Annotation with parameters
 *
 * @SomeAnnotation("hello", "world", 1, 2, 3, false, true)
 */

/**
 * Annotation with named parameters
 *
 * @SomeAnnotation(first="hello", second="world", third=1)
 * @SomeAnnotation(first: "hello", second: "world", third: 1)
 */

/**
 * Passing an array
 *
 * @SomeAnnotation([1, 2, 3, 4])
 * @SomeAnnotation({1, 2, 3, 4})
 */

/**
 * Passing a hash as parameter
 *
 * @SomeAnnotation({first=1, second=2, third=3})
 * @SomeAnnotation({'first'=1, 'second'=2, 'third'=3})
 * @SomeAnnotation({'first': 1, 'second': 2, 'third': 3})
 * @SomeAnnotation(['first': 1, 'second': 2, 'third': 3])
 */

/**
 * Nested arrays/hashes
 *
 * @SomeAnnotation({"name"="SomeName", "other"={
 *     "foo1": "bar1", "foo2": "bar2", {1, 2, 3},
 * }})
 */

/**
 * Nested Annotations
 *
 * @SomeAnnotation(first=@AnotherAnnotation(1, 2, 3))
 */

<?php

/**

* Simple Annotation

* @SomeAnnotation

/**

* Annotation with parameters

* @SomeAnnotation("hello", "world", 1, 2, 3, false, true)

/**

* Annotation with named parameters

* @SomeAnnotation(first="hello", second="world", third=1)

* @SomeAnnotation(first: "hello", second: "world", third: 1)

/**

* Passing an array

* @SomeAnnotation([1, 2, 3, 4])

* @SomeAnnotation({1, 2, 3, 4})

/**

* Passing a hash as parameter

* @SomeAnnotation({first=1, second=2, third=3})

* @SomeAnnotation({'first'=1, 'second'=2, 'third'=3})

* @SomeAnnotation({'first': 1, 'second': 2, 'third': 3})

* @SomeAnnotation(['first': 1, 'second': 2, 'third': 3])

/**

* Nested arrays/hashes

* @SomeAnnotation({"name"="SomeName", "other"={

* "foo1": "bar1", "foo2": "bar2", {1, 2, 3},

* }})

/**

* Nested Annotations

* @SomeAnnotation(first=@AnotherAnnotation(1, 2, 3))

PHP相关工具参考：

doctrine/annotations
https://github.com/doctrine/annotations

PHP反射相关接口参考：

http://php.net/manual/zh/book.reflection.php

php中的错误与异常

2015年7月22日 by admin·已关闭评论

一直没有时间整理之前的笔记，现在打算每个星期花点时间整理一下，以存根

错误(Error)

php程序自身不能正常的执行，根据严重情况分为多种错误等级

致命错误：语法、未定义调用(对象、函数)等，立即中断流程执行，属于程序严重bug, 必须立即修复
其它错误：php执行未达预期的结果，程序流程继续执行，潜在bug需要记录错误，并修复
用户错误：使用trigger_error主动抛出，不中断程序执行流程

错误处理机制

非致命错误：set_error_handle(error_function, error_types)
致命错误：程序只能中止执行，在中止前可以通过注册 register_shutdown_function, 使用 error_get_last获取相关错误信息，以便于记录查阅
记录错误日志: 可以使用error_reporting来设置当前脚本的错误报告级别，在php.ini配置或通过ini_set()函数设置log_errors = on, error_log = LOG_FILE来记录错误日志

异常(Exception)

大多数应用于应用逻辑未达预期，中断当前业务流程处理，直到将流程控制权交给适合的错误处理者，利于程序多层结构，每层处理自己能处理的错误，避免各层对错误大量if判断处理的存在，便于程序将正常处理代码与错误处理代码进行分离

异常处理机制

立即处理：在当前异常发生后立即处理，及时采取补救措施不影响业务逻辑的完整性, 比如为保证数据一至性等需求
上层处理：处理当前层能处理的错误
集中处理：最后一道处理异常的机会, 比如集中记录异常，显示错误信息提示，根据异常类型作出合适的跳转等，也可通过set_exception_handler()捕获未处理的异常

go 协程

2015年7月8日 by admin·已关闭评论

函数无阻塞测试

package main
import "fmt"
func sum(values []int, myChan chan int) {
    sum := 0
    for _, value := range values {
        sum += value
    }
    fmt.Println("Sum:", sum)
    myChan <- sum
}
func main() {
    myChan := make( chan int,2)
    values := []int {1,2,3,5,5,4,23,4,4,233,2,233}
    go sum(values,myChan)
    go sum(values[:1],myChan)
    sum1,sum2 := <-myChan, <-myChan
    fmt.Println("Result:",sum1,sum2,sum1+sum2)
}

package main

import "fmt"

func sum(values []int, myChan chan int) {

sum := 0

for _, value := range values {

sum += value

}

fmt.Println("Sum:", sum)

myChan <- sum

}

func main() {

myChan := make( chan int,2)

values := []int {1,2,3,5,5,4,23,4,4,233,2,233}

go sum(values,myChan)

go sum(values[:1],myChan)

sum1,sum2 := <-myChan, <-myChan

fmt.Println("Result:",sum1,sum2,sum1+sum2)

}

函数有阻塞测试

package main

import "fmt"
import "time"

var quit chan int

func foo(id int) {
    fmt.Println(id)
    time.Sleep(time.Second)
    quit <- 0
}


func main() {
    count := 1000
    quit = make(chan int, count)

    for i := 0; i < count; i++ {
        go foo(i)
    }

    for i :=0 ; i < count; i++ {
        <- quit
    }
}

package main

import "fmt"

import "time"

var quit chan int

func foo(id int) {

fmt.Println(id)

time.Sleep(time.Second)

quit <- 0

}

func main() {

count := 1000

quit = make(chan int, count)

for i := 0; i < count; i++ {

go foo(i)

}

for i :=0 ; i < count; i++ {

<- quit

}

如果当前goroutine不发生阻塞，它是不会让出CPU给其他goroutine的, 所以例子一中的输出会是一个一个goroutine进行的，而sleep函数则阻塞掉了当前goroutine, 当前goroutine主动让其他goroutine执行, 所以形成了逻辑上的并行, 也就是并发。

真正并行

import (
    "fmt"
    "runtime"
)

var quit chan int = make(chan int)

func loop() {
    for i := 0; i < 100; i++ { //为了观察，跑多些
        fmt.Printf("%d ", i)
    }
    quit <- 0
}

func main() {
    runtime.GOMAXPROCS(2) // 最多使用2个核

    go loop()
    go loop()

    for i := 0; i < 2; i++ {
        <- quit
    }
}

import (

"fmt"

"runtime"

)

var quit chan int = make(chan int)

func loop() {

for i := 0; i < 100; i++ { //为了观察，跑多些

fmt.Printf("%d ", i)

}

quit <- 0

}

func main() {

runtime.GOMAXPROCS(2) // 最多使用2个核

go loop()

for i := 0; i < 2; i++ {

<- quit

}

runtime调度器

runtime调度器是个很神奇的东西，但是我真是但愿它不存在，我希望显式调度能更为自然些，多核处理默认开启。
关于runtime包几个函数:

Gosched 让出cpu
NumCPU 返回当前系统的CPU核数量
GOMAXPROCS 设置最大的可同时使用的CPU核数
Goexit 退出当前goroutine(但是defer语句会照常执行)

参考：
http://blog.csdn.net/kjfcpua/article/details/18265461

知识点滴

专注于php应用开发

作者： admin

swoole的注意事项

php redis的连接被关闭

sphinx索引与搜索分离

js中的单例

vue踩过的一次坑动态组件

使用动态组件

其它

在线编辑器

极简的Api处理

反射获取文档

注解的解析

Phalcon的注解(Phalcon\Annotations\*)

PHP相关工具参考：

PHP反射相关接口参考：

php中的错误与异常

错误(Error)

错误处理机制

异常(Exception)

异常处理机制

go 协程

函数无阻塞测试

函数有阻塞测试

真正并行

runtime调度器