Awesome Open Source
Awesome Open Source

swoolefy

  ______                                _           _ _ _ _
 /  ____|                              | |         |  _ _ _|  _   _
|  (__     __      __   ___     ___    | |   ___   | |       | | | |
 \___  \   \ \ /\ / /  / _ \   / _ \   | |  / _ \  | |_ _ _  | | | |
 ____)  |   \ V  V /  | (_) | | (_) |  | | | ___/  |  _ _ _| | |_| |
|_____ /     \_/\_/    \___/   \___/   |_|  \___|  | |        \__, |
                                                   |_|           | |
                                                              __ / |
                                                             |_ _ /

swoolefy是一个基于swoole实现的轻量级高性能的常驻内存型的协程级应用服务框架, 高度支持httpApi,websocket,udp服务器,以及基于tcp实现可扩展的rpc服务, 同时支持composer包方式安装部署项目。基于实用,swoolefy抽象Event事件处理类, 实现与底层的回调的解耦,支持协程调度,同步|异步调用,全局事件注册,心跳检查,异步任务,多进程(池),连接池等, 内置view、log、session、mysql、redis、mongodb等常用组件等。

目前swoolefy4.2+版本完全支持swoole4.4.+的协程,最高支持最新版的swoole4.4.+,推荐使用swoole4.4.8+.

实现的功能特性

  • [x] 架手脚一键创建项目
  • [x] 路由与调度,MVC三层,多级配置
  • [x] 支持composer的PSR-4规范,实现PSR-3的日志接口
  • [x] 支持自定义注册命名空间,快速部署项目,简单易用
  • [x] 支持httpServer
  • [x] 支持websocketServer,udpServer,mqttServer
  • [x] 支持基于tcp实现的rpc服务,开放式的系统接口,可自定义协议数据格式,并提供rpc-client协程组件
  • [x] 支持容器,组件IOC
  • [x] 支持全局日志
  • [x] 支持协程单例注册
  • [x] 支持mysql,postSql协程组件,redis协程组件,mongodb组件
  • [x] 支持mysql的协程连接池,redis协程池
  • [x] 支持protobuf buffer的数据接口结构验证,压缩传输等
  • [x] 异步务管理TaskManager,定时器管理TickManager,内存表管理TableManager
  • [x] 自定义进程管理ProcessManager,进程池管理PoolsManger
  • [x] 支持底层异常错误的所有日志捕捉
  • [x] 支持自定义进程的redis,rabitmq,kafka的订阅发布,消息队列等
  • [x] 支持crontab
  • [x] 支持热更新
  • [x] 支持定时的系统信息采集,并以订阅发布,udp等方式收集至存贮端
  • [x] 命令行形式高度封装启动|停止控制的脚本,简单命令即可管理整个框架
  • [ ] 分布式服务注册(zk,etcd)

常用组件

组件名称 安装 说明
predis composer require predis/predis:1.1.1 swoolefy基于predis组件实现容器封装,使用redis操作需要安装此组件
mongodb composer require mongodb/mongodb:1.3 mongodb组件,需要使用mongodb必须安装此组件
rpc-client composer require bingcool/rpc-client:dev-master swoolefy的rpc客户端,当与rpc服务端通信时,需要安装此组件,支持在php-fpm中使用
cron-expression composer require dragonmantank/cron-expression crontal组件,需要使用定时任务时必须安装此组件
redis lock composer require malkusch/lock Redis锁组件
validate composer require vlucas/valitron validate 数据校验组件
bingcool/library composer require bingcool/library library 组件库

bingcool/library 是swoolefy require 内置库,专门为swoole实现的组件库

实现了包括Db Model组件、Kafka生产消费组件、Redis Cache 组件、Redis Queue队列组件,Redis Delay Queue延迟队列组件,Redis订阅发布组件、UUid组件等
github: https://github.com/bingcool/library

定义组件,开放式组件接口,闭包回调实现创建组件过程,return对象即可

// 在应用层配置文件中,例如下面使用library的Redis、Db组件
components => [
    // 例如创建phpredis扩展连接实例
    'redis' => function($com_name) { // 定义组件名,闭包回调实现创建组件过程,return对象即可
         $redis = new \Common\Library\Cache\Redis();
         $redis->connect('127.0.0.1', 6379);
         $redis->auth('123456789');
         return $redis;   
    },

    // predis组件的redis实例
    'predis' => function($name) {
        $parameters = [
            'scheme' => 'tcp',
            'host'   => '127.0.0.1',
            'port'   => 6379,
            'password' => '123456789'
        ];
        $predis = new \Common\Library\Cache\Predis();
        $predis->setConfig($parameters);
        return $predis;
    },

     // 适配swoole的mysql客户端组件(参考tp和yii)
    'db' => function() {
        $config = [
            // 地址
            'hostname'        => '127.0.0.1',
            // 数据库
            'database'        => 'bingcool',
            // 用户名
            'username'        => 'bingcool',
            // 密码
            'password'        => '123456789',
            // 端口
            'hostport'        => '3306',
            // dsn
            'dsn'             => '',
            // 数据库连接参数
            'params'          => [],
            // 数据库编码,默认采用utf8
            'charset'         => 'utf8',
            // 数据库表前缀
            'prefix'          => '',
            // 是否断线重连
            'break_reconnect' => true,
            // 是否支持事务嵌套
            'support_savepoint' => false
        ];

        $db = new \Common\Library\Db\Mysql($config);
        return $db;
    },
       
    // 适配swoole的postgresql客户端组件(参考tp和yii)
    'pg' => function() {
        $config = [
            // 地址
            'hostname'        => '127.0.0.1',
            // 数据库
            'database'        => 'dbtest',
            // 用户
            'username'        => 'bingcool',
            // 密码
            'password'        => '123456789',
            // 端口
            'hostport'        => '5432',
            // dsn
            'dsn'             => '',
            // 数据库连接参数
            'params'          => [],
            // 数据库编码,默认采用utf8
            'charset'         => 'utf8',
            // 数据库表前缀
            'prefix'          => '',
            // 是否断线重连
            'break_reconnect' => true,
            // 是否支持事务嵌套
            'support_savepoint' => false
        ];

        $pg = new \Common\Library\Db\Pgsql($config);
        return $pg;
    },

    // 其他的组件都可以通过闭包回调创建
    // 数组配置型log组件
    'log' => [
        'class' => \Swoolefy\Util\Log::class,
        'channel' => 'application',
        'logFilePath' => rtrim(LOG_PATH,'/').'/runtime.log'
    ],
    // 或者log组件利用闭包回调创建
    'log' => function($name) {
        $channel= 'application';
        $logFilePath = rtrim(LOG_PATH,'/').'/runtime.log';
        $log = new \Swoolefy\Util\Log($channel, $logFilePath);
        return $log;
    },
]

使用组件

use Swoolefy\Core\Application;
class TestController extends BController {
    public function test() {
        // 组件就是配置回调中定义的组件,这个过程会发生协程调度
        $redis = Application::getApp()->redis;
        //或者
        // $redis = Application::getApp()->get('redis');
        $redis->set('name', swoolefy);

        // predis组件,这个过程会发生协程调度
        $predis = Application::getApp()->predis;
        //或者
        // $predis = Application::getApp()->get('predis');
        $predis->set('predis','this is a predis instance');
        $predis->get('predis');
        
        // PDO的mysql实例,这个过程会发生协程调度
        $db = Application::getApp()->db;
        // 或者
        // $mysql = Application::getApp()->get('db');
        // 添加一条数据
        $sql = "INSERT INTO `user` (`username` ,`sex`) VALUES (:username, :sex)"; 
        $numRows = $db->createCommand($sql)->insert([
            ':username'=>'bingcool-test',
            ':sex' => 1
        ]);
        var_dump($numRows)         

        //查询
        $result = $db->createCommand('select * from user where id>:id')->queryOne([':id'=>100]);
        var_dump($result);    

        // pg实例    
        $pg = Application::getApp()->get('pg');   
        // 添加一条数据   
        $sql = "INSERT INTO `user` (username ,sex) VALUES (:username, :sex)"; 
        $pg->createCommand($sql)->insert([
            ':username'=>'bingcool-test',
            ':sex' => 1
        ]);
    }
}

开发文档手册

文档:开发文档
swoolefy官方QQ群:735672669,欢迎加入!

License

MIT
Copyright (c) 2017-2020 zengbing huang


Get A Weekly Email With Trending Projects For These Topics
No Spam. Unsubscribe easily at any time.
php (16,611
mvc (163
swoole (114
ioc (97