定制 easyswoole/sync-invoker 二次开发

按需修改功能、优化性能、对接业务系统,提供一站式技术支持

邮箱:yvsm@zunyunkeji.com | QQ:316430983 | 微信:yvsm316

easyswoole/sync-invoker

最新稳定版本:2.1.0

Composer 安装命令:

composer require easyswoole/sync-invoker

包简介

An efficient swoole framework

README 文档

README

场景

Swoole4.x后,提供了非常强大的协程能力,让我们可以更好的压榨服务器性能,提高并发。然而,目前PHP在swoole协程生态上,并不是很完善,比如没有协程版本的monogodb客户端,而为了避免在worker中调用了同步阻塞的Api,例如在Http回调中使用了同步的芒果客户端,导致worker退化为同步阻塞,导致没办法完全的发挥协程的优势, EasySwoole 提供了一个同步程序协程调用转化驱动。

原理

启动自定义进程监听UnixSocket,然后worker端调用协程客户端发送命令到自定义进程并处理,然后把处理结果返回给worker的协程客户端。

示例代码

use EasySwoole\SyncInvoker\AbstractDriver;
use EasySwoole\SyncInvoker\SyncInvoker;
use EasySwoole\SyncInvoker\Worker;
require 'vendor/autoload.php';

class Driver extends AbstractDriver
{
    function plus($a,$b)
    {
        $this->response($a + $b);
    }

    protected function actionNotFound()
    {
        $this->response($this->getRequest()->getAction().' not found');
    }

}

$invoker = new SyncInvoker();
$invoker->getConfig()->setDriver(new Driver());
$invoker->getConfig()->setOnWorkerStart(function (Worker $worker){
    var_dump('worker start at Id '.$worker->getArg()['workerIndex']);
});

$http = new swoole_http_server("0.0.0.0", 9501);

$invoker->attachServer($http);

$http->on("request", function ($request, $response)use($invoker) {
    $ret = $invoker->invoke()->plus(1,2);
    var_dump($ret);

    $ret = $invoker->invoke()->plus2(1,2);
    var_dump($ret);
});

$http->start();

统计信息

  • 总下载量: 7.6k
  • 月度下载量: 0
  • 日度下载量: 0
  • 收藏数: 0
  • 点击次数: 0
  • 依赖项目数: 0
  • 推荐数: 0

GitHub 信息

  • Stars: 0
  • Watchers: 0
  • Forks: 1
  • 开发语言: PHP

其他信息

  • 授权协议: Apache-2.0
  • 更新时间: 2019-06-21