SwooleDistributed v1.2 发布了。 更新内容： 完善协程，协程中允许使用异常。 controller中添加了异常的回调，方便统一处理异常回复客户端。 swoole 分布式通讯框架 开发交流群：569037921 文档 https://tmtbe.gitbooks.io/swooledistributed/content/ 特性 优秀的框架（MVC）设计,丰富的支持极大加快开发速度 通过开启不同端口同时支持TCP和HTTP，同一逻辑处理不同协议 全异步支持，无需手动处理连接池，异步redis,异步mysql，mysql语法构建器，支持异步mysql事务,异步httpclient，效率出众 协程模式全支持，异步redis，异步mysql，异步httpclient，异步task，全部都提供了协程模式，业务代码摆脱处处回调的困扰（不是swoole2.0，php7同样支持） 支持协程嵌套，支持协程内异常处理（和正常逻辑用法一样） 额外提供了protobuf完整RPC实例，轻松使用protobuf 天然分布式的支持，一台机器不够零配置，零代码修改完成高效分布式系统的搭建 完善详细的文档，还有实例代码，轻松掌握 线上项目打造维护，不断优化与改进 化繁为简，从零开始的框架设计 前言 经历了一个又一个项目，也接触了很多的PHP框架，我欣赏CI的简约，又贪婪swoole的效率，我将CI和swoole很草率的结合到了一起。起初呢风平浪静，慢慢的就遇到了不少的瓶颈，毕竟CI的设计理念还是贴合FPM模式，如何更加得心应手的使用swoole，同时追求开发上和运行时的效率呢，最主要的还是要方便扩展，就萌生了SwooleDistributed这个开源框架的想法。 在SwooleDistributed发布之前，开源社区还没有过针对swoole的分布式框架，起初的目的并不是一个完整的应用框架，而是一个简单的分布式通讯框架，后来需求变多了，框架也就慢慢的丰满了。 分布式 分布式这东西并不是有多神秘，但一个框架在基础构思中就包含分布式的思想，那无疑方便对以后的扩展。分布式系统涉及到多太物理机之间的调控，配置起来也是较为麻烦，SwooleDistributed使用了内网发现的技术手段，自动发现集群环境的物理机进行连接，简化了配置，甚至达到了无配置。 SwooleDistributed在前期可以控制成本的使用单机模式进行部署，也可以在后期进行水平扩展，对逻辑代码无需任何的改动。 你所需要的就是多增加物理机，跑上服务器就行啦。 MVCT 解决了底层的分布式通讯问题，接下来就是MVC结构的搭建了，这部分借鉴了CI的设计，使用Loader模块加载对应的Model，通过路由访问对应的Controller。相信使用过CI框架的工程师很容易就上手。 此外引入了Swoole独特的Task，将swoole的Task进行了封装优化，更加易于使用。 //TestTask.php class TestTask extends Task { public function test() { print_r("test timer task\n"); } } //TestController.php class TestController extends Controller { public function http_test_task() { $task = $this->loader->task('TestTask'); $task->test(); $result = yield $task->coroutineSend(); $this->http_output->end($result); } } 通过定时器和Task的结合，开发者可以很方便的制作定时任务，而这一切只需要简单的配置即可。 /** * timerTask定时任务 * （必填）task名称 task_name * （必填）执行task的方法 method_name * （选填）执行区间 [start_time,end_time) 格式： Y-m-d H:i:s 没有代表一直执行 * （必填）执行间隔 interval_time 单位： 秒 * （选填）最大执行次数 max_exec，默认不限次数 */ $config['timerTask'][] = [ 'task_name'=>'TestTask', 'method_name'=>'test', 'start_time'=>'Y-m-d 00:00:00', 'end_time'=>'Y-m-d 23:59:59', 'interval_time'=>'2', ]; 异步连接池 swoole提供了redis和mysql的异步客户端，大大提高的服务端的效率，但问题又来了，如果使用异步客户端，就必须维护一个异步连接池。 SwooleDistributed设计了一个通用的连接池模块，通过这个模块可以快捷简单的创建客户端的连接池，不仅如此redis和mysql的连接池早已封装在核心代码中，开发者只需调用其中的Api无需关注连接池的维护。 swoole的异步redis客户端是基于hredis和我们通常使用的redis扩展不一样，在使用批量方法时回调的值是有所区别，SwooleDistributed屏蔽了这一点不同之处，使用起来和平常的redis扩展一致。 异步的mysql客户端事务通常是比较难写的，SwooleDistributed同样针对mysql事务进行了封装，使用起来也非常的方便。 此外mysql也提供了一个语法构建器，可以简单方便的构建mysql语法。 public function test_coroutine() { $mySqlCoroutine = $this->mysql_pool->dbQueryBuilder->select('*')->from('account')->where('uid', 10303)->coroutineSend(); $result = yield $mySqlCoroutine; $redisCoroutine = $this->redis_pool->coroutineSend('get', 'test'); $result = yield $redisCoroutine; return $result; } 协程 之前我去过很多家公司，交流的过程中发现有些公司使用php做短连接，用golang做长连接，我问他们为何不用swoole呢？回答都是异步回调太难写了。 确实异步回调写起来很不好看，可能会有多层回调的嵌套，复杂点的代码非常的难看，swoole2.0已经使用了协程，但首先是新功能稳定性尚且不知，其次不支持php7，于是我呢就对现有框架进行了一次大的调整，通过yield关键字实现了全异步的协程风格。使用起来非常的简单，和一般的写法没有什么太大的区别，只要遵循一个原则，涉及到异步的地方加上yield关键字就可以。 /** * 协程测试 */ public function http_testCoroutine() { $this->testModel = $this->loader->model('TestModel', $this); $result = yield $this->testModel->test_coroutine(); $this->http_output->end($result); } 协程之间支持嵌套，也支持throw Exception异常捕获，总之用起来和同步的写法基本一致。 协程之间不存在堵塞，也可以通过控制yield的位置调整send和rev的调度策略。 比如： $mySqlCoroutine = $this->mysql_pool->dbQueryBuilder->select('*')->from('account')->where('uid', 10303)->coroutineSend(); $result = yield $mySqlCoroutine; $redisCoroutine = $this->redis_pool->coroutineSend('get', 'test'); $result = yield $redisCoroutine; 这段代码调度策略是mysql_send->mysql_rev->redis_send->redis_rev; 我们调整下yield的位置 $mySqlCoroutine = $this->mysql_pool->dbQueryBuilder->select('*')->from('account')->where('uid', 10303)->coroutineSend(); $redisCoroutine = $this->redis_pool->coroutineSend('get', 'test'); $result = yield $mySqlCoroutine; $result = yield $redisCoroutine; 这段代码调度策略变成了mysql_send->redis_send->mysql_rev->redis_rev; 同时支持TCP和HTTP 这样你就可以开启一个服务同时处理TCP和HTTP请求了，代码复用率就高很多了，同时SwooleDistributed还提供了一些策略，方便隔离http和tcp的路由请求。 Protobuf 提供了一个Protobuf的RPC实例，其实你可以通过框架的Pack和Route模块自由扩展，提供这个例子无非是我自己项目的需要顺便就发出来了，当然你可以自己实现。 其他 很多细小的功能拉，去这看看吧https://www.gitbook.com/book/tmtbe/swooledistributed。 SwooleDistributed v1.2 发布，分布式通讯框架下载地址
