PhalconPlus - 基于Phalcon框架的框架

入口文件
                // 入口文件, 仅两行就搞定, 还能再简单吗?

$bootstrap = new \PhalconPlus\Bootstrap(dirname(__DIR__));
$bootstrap->exec();

// end

快速使用QueryBuilder
                // QueryBuilder
DealRecord::getInstance() // 非单例,每次创建实例
    ->createBuilder("dr") // dr为模型的别名
    ->columns("dr.dealId, dr.borrowerId")
    ->limit(1)
    ->getQuery()
    ->execute();

注册DB服务,添加profiler
            // register db service
$di->setShared('dbDemo', function() use ($di) {
    $mysql = new \PhalconPlus\Db\Mysql($di, "dbDemo");
    $connection = $mysql->getConnection();

    $eventsManager = new \Phalcon\Events\Manager();
    $profiler = $di->getProfiler();
    $eventsManager->attach('db', function($event, $connection) use ($profiler) {
        if ($event->getType() == 'beforeQuery') {
            $profiler->startProfile($connection->getSQLStatement());
        }
        if ($event->getType() == 'afterQuery') {
            $profiler->stopProfile();
        }
    });
    $connection->setEventsManager($eventsManager);
    return $connection;
});

db配置,支持连接超时/失败重试
            // db 配置
// 支持连接超时,失败重试
return array(
    'dbDemo' => array(
        "host" => "127.0.0.1",
        "port" => 3306,
        "username" => "root",
        "password" => "",
        "dbname" => "p2p",
        "charset" => "utf8",
        // 连接超时 1 秒
        "timeout" => 1,
        // 失败重试间隔200ms
        "retryInterval" => 200000,
        // 失败重试次数
        "retryTimes" => 5,
    ),
);

注册RPC服务
            // 基于Yar的RPC服务
// Yar是鸟哥(http://www.laruence.com/)为PHP量身定制的RPC
$di->set("rpc", function() use ($di, $config, $bootstrap) {
    $client = null;
    if($config->debugRPC == true) {
        // 如果debugRPC==true, 则加载server模块的配置, 直接本地调用
        $bootstrap->dependModule("server"); // 你很可能需要修改模块名
        $client = new \PhalconPlus\RPC\Client\Adapter\Local($di);
    } else {
        // 获取服务地址列表
        $remoteUrls = $config->demoServerUrl;
        $client = new \PhalconPlus\RPC\Client\Adapter\Remote($remoteUrls->toArray());
        $client->SetOpt(\YAR_OPT_CONNECT_TIMEOUT, 5);
    }
    return $client;
});

RPC调用方式
             // 基于Yar的RPC服务
$request = new \Demo\Protos\RequestDemo();
$request->setFoo("hello")
        ->setBar("world");

$protoUser = new \Demo\Protos\ProtoUser();
$protoUser->setUsername("guweigang")
          ->setPassword("123456")
          ->setStatus(new \Demo\Protos\EnumUserStatus(3));

$request->setUser($protoUser);

$response = $this->rpc->callByObject(array(
    "service" => "\\Demo\\Server\\Services\\Demo",
    "method" => "demo",
    "args"   => $request,
));
echo json_encode($response);

注册logger, 自定义是亮点
            //自定义log格式和处理
$di->setShared("logger", function() use ($di, $config){
    $logger = new \PhalconPlus\Logger\Adapter\FilePlus($config->application->logFilePath);
    // debug类别的日志单独打印在以.de结尾的文件中
    $logger->registerExtension(".de", [\Phalcon\Logger::DEBUG]);
    // 添加formatter
    $formatter = new \PhalconPlus\Logger\Formatter\LinePlus("[%date%][%trace%][%uid%][%type%] %message%");
    $formatter->addProcessor("uid", new UidProcessor(18));
    $formatter->addProcessor("trace", new TraceProcessor(TraceProcessor::T_CLASS));

    $logger->setFormatter($formatter);
    return $logger;
});

日志格式
            
[2015-04-20 23:28:09][/Users/guweigang/github/bullsoft/falcon/demo/app/controllers/IndexController.php:192][2dc6b1bcf7c49330e9][DEBUG] 我是日志1
[2015-04-20 23:28:09][/Users/guweigang/github/bullsoft/falcon/demo/app/controllers/IndexController.php:193][2dc6b1bcf7c49330e9][DEBUG] 我是日志2
[2015-04-20 23:28:09][/Users/guweigang/github/bullsoft/falcon/demo/app/controllers/IndexController.php:194][2dc6b1bcf7c49330e9][DEBUG] 但是我们是同一个请求产生的日志

模板设置,在模板中使用PHP函数
            // set view with volt
$di->set('view', function() use ($di) {
    // 此处省略很多代码 ...
    $compiler = $volt->getCompiler();
    // 注册PHP函数,在volt模板中可以使用php built-in函数
    $compiler->addExtension(new \PhalconPlus\Volt\Extension\PhpFunction());
        return $volt;
    }
    return $view;
});

volt模板代码
            
{ { substr(hello, 0, -1) } }
{ { json_encode(world, constant("JSON_PRETTY_PRINT")) } }

枚举类
            
namespace Demo\Protos;
use \PhalconPlus\Enum\AbstractEnum;
class EnumUserStatus extends AbstractEnum
{
    const __default = self::NORMAL;

    const NORMAL = 0;
    const INIT = 1;
    const NEED_VALID = 2;
    const BLOCK = 3;
    const DELETED = 4;
}

枚举类使用
            
try {
    \PhalconPlus\Assert\Assertion::numeric($userStatus);
} catch (\Exception $e) {
    echo $e->getMessage();
}
// 0, 1, 2, 3, 4 才是合法的枚举值
try {
    $userStatus = $this->request->getQuery("status");
    $a = new \Demo\Protos\EnumUserStatus($userStatus);
    echo "Valid user Status is: " . $a;
} catch (\Exception $e) {
    echo "Exception: " . $e->getMessage();
}

异常枚举
            
namespace Demo\Protos;
use \PhalconPlus\Enum\Exception as EnumException;


class EnumExceptionCode extends EnumException
{
    const __default = self::UNKNOWN;

    /**
     * 请不要使用重复异常码
     */
    const UNKNOWN = 10000;
    const USER_NOT_EXISTS = 10001;
    const AUTH_FAILED = 10002;
    const NEED_LOGIN = 10003;

    protected static $details = [

        self::UNKNOWN => [
            "message" => "未知错误",
            "level" => EnumLoggerLevel::ERROR,
        ],

        self::USER_NOT_EXISTS => [
            "message" => "用户不存在，请核实后再试",
            "level" =>  EnumLoggerLevel::INFO,
        ],

    ];

    public static function exceptionClassPrefix()
    {
        return __NAMESPACE__ . "\\Exception\\";
    }
}

异常枚举使用
            
// 通过异常码唤醒异常
throw \Demo\Protos\EnumExceptionCode::newException(10001, $this->di->getLogger());

此异常类根据异常枚举类自动生成
            
namespace Demo\Protos\Exception;
/**
 * 此类由代码自动生成，请不要修改
 */
class UserNotExists extends \PhalconPlus\Base\Exception
{
    protected $code = 10001;
    protected $message = '用户不存在，请核实后再试';
    protected $level = 6;
}

Phalcon+ 欢迎您 !

基于Phalcon

免费 & 开源

上手简单

代码片断