2015年12月 – 知识点滴

简单弄个getJson()

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

有时不得加载jq, 记录一下简单常用的函数

 var getJSON = (function(){
        var loadJsFile = function(file){
            var head = ghead();
            var e = document.createElement("script");
            e.type="text/javascript";
            e.src=file;
            head.appendChild(e);
        };

        var ghead = function(){
            var head, o = document;
            ((head = o.getElementsByTagName('head')[0]) || (head = o.body.parentNode.appendChild(o.createElement("head"))));
            return head;
        }

        return function(url, callback) {
            var tmpCallback = 'JCallback' + Math.ceil(Math.random() * 1000000);
            window[tmpCallback] = function(data){
                callback(data);
            };
            url = url + "&callback=" + tmpCallback ;
            loadJsFile(url);
        }
    })();

var getJSON = (function(){

var loadJsFile = function(file){

var head = ghead();

var e = document.createElement("script");

e.type="text/javascript";

e.src=file;

head.appendChild(e);

};

var ghead = function(){

var head, o = document;

((head = o.getElementsByTagName('head')[0]) || (head = o.body.parentNode.appendChild(o.createElement("head"))));

return head;

}

return function(url, callback) {

var tmpCallback = 'JCallback' + Math.ceil(Math.random() * 1000000);

window[tmpCallback] = function(data){

callback(data);

};

url = url + "&callback=" + tmpCallback ;

loadJsFile(url);

}

})();

没有同相同url地址判断

简单的推送消息服务

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

vue

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

directive (DOM)
filter (文本)
computed（数据）
Components (widget)

异步组件

var exports;
var SyncComponent = {
    loaded : {},
    src : "/component/",
    load : function(name){
        if(this.loaded[name]){
           return;
        }

        var that = this;
        Vue.component(name, function(resolve){
            var scriptUrl = that.src + name + ".js";
            $.get(scriptUrl, function(script) {
                if(!/html$/.test(exports.template)) {
                    resolve(exports);
                    that.loaded[name] = true;
                } else {
                    var tplUrl = that.src + "template/" + name + ".html";
                    $.get(tplUrl, function(template) {
                        exports.template = template;
                        resolve(exports);
                        that.loaded[name] = true;
                    }, 'text');
                }
            }, 'script');
        });
    }
};

var exports;

var SyncComponent = {

loaded : {},

src : "/component/",

load : function(name){

if(this.loaded[name]){

return;

}

var that = this;

Vue.component(name, function(resolve){

var scriptUrl = that.src + name + ".js";

$.get(scriptUrl, function(script) {

if(!/html$/.test(exports.template)) {

resolve(exports);

that.loaded[name] = true;

} else {

var tplUrl = that.src + "template/" + name + ".html";

$.get(tplUrl, function(template) {

exports.template = template;

resolve(exports);

that.loaded[name] = true;

}, 'text');

}

}, 'script');

});

}

};

var JMessage = new Vue({
    el: '#main',
    data: {
        // api列表
        currentView : 'welcome',
        apis: [
            { label : 'home', api : 'welcome' },
            { label : '订阅者', api : 'customer' },
            { label : '状态', api : 'status'},
            { label : '消息', api : 'message' },
            { label : '管理', api : 'manager' }
        ]
    },

    methods : {
        show : function(api){
            console.log(api);
            SyncComponent.load(api);
            this.currentView = api;
        }
    },

    created : function(){
        SyncComponent.load('welcome');
    }
});

var JMessage = new Vue({

el: '#main',

data: {

// api列表

currentView : 'welcome',

apis: [

{ label : 'home', api : 'welcome' },

{ label : '订阅者', api : 'customer' },

{ label : '状态', api : 'status'},

{ label : '消息', api : 'message' },

{ label : '管理', api : 'manager' }

]

methods : {

show : function(api){

console.log(api);

SyncComponent.load(api);

this.currentView = api;

}

created : function(){

SyncComponent.load('welcome');

}

});

给魔术方法生成的属性或函数增加IDE提示

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

/**
 * Class BaseController
 *
 * @property \home\ext\View $view
 * @method test_find();
 *
 */

/**

* Class BaseController

* @property \home\ext\View $view

* @method test_find();

参考
http://manual.phpdoc.org/HTMLSmartyConverter/PHP/phpDocumentor/tutorial_phpDocumentor.pkg.html

swoole的注意事项

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

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

php redis的连接被关闭

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

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

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

知识点滴

专注于php应用开发

月度归档： 2015年12月

简单弄个getJson()

简单的推送消息服务

vue

给魔术方法生成的属性或函数增加IDE提示

swoole的注意事项

php redis的连接被关闭