swoole通用协程池的实现

wanghui 发布于2019-07-01 12:48 / 876人阅读

摘要：之前过行代码实现通用协程池今天看了下相关文档，用也实现了一个，由于没有的，所以实现的有点简单，但是实用性还可以，通过工厂函数实现了通用性。官方的协程池是用只能用在。因为协程池代码层耦合了实例化逻辑。

之前过golang40行代码实现通用协程池

今天看了下swoole相关文档，用PHP也实现了一个，由于swoole没有golang的select，所以实现的有点简单，但是实用性还可以，通过工厂函数实现了通用性。

swoole官方的协程池是用只能用在Redis。因为协程池代码层耦合了Redis实例化逻辑。

class RedisPool
{
    /**
     * @var SwooleCoroutineChannel
     */
    protected $pool;

    /**
     * RedisPool constructor.
     * @param int $size 连接池的尺寸
     */
    function __construct($size = 100)
    {
        $this->pool = new SwooleCoroutineChannel($size);
        for ($i = 0; $i < $size; $i++)
        {
            $redis = new SwooleCoroutineRedis();
            $res = $redis->connect("127.0.0.1", 6379);
            if ($res == false)
            {
                throw new RuntimeException("failed to connect redis server.");
            }
            else
            {
                $this->put($redis);
            }
        }
    }

    function put($redis)
    {
        $this->pool->push($redis);
    }

    function get()
    {
        return $this->pool->pop();
    }
}

利用工厂方法的改造如下：

size = $size;
        $this->factory = $factory;
        $this->init();
    }


    /**
     * check pool config
     * @throws InvalidParamException
     */
    private function init()
    {
        if ($this->size <= 0) {
            throw new InvalidParamException("The "size" property must be greater than zero.");
        }
        if (empty($this->factory)) {
            throw new InvalidParamException("The "factory" property must be set.");
        }
        if (!is_callable($this->factory)) {
            throw new InvalidParamException("The "factory" property must be callable.");
        }
        $this->bootstrap();
    }

    /**
     * bootstrap pool
     */
    private function bootstrap()
    {
        $this->channel = new Channel($this->size);

        for ($i = 0; $i < $this->size; $i++) {
            $this->channel->push(call_user_func($this->factory));
        }
    }

    /**
     * Acquire a connection
     * @param int $timeout
     * @return mixed
     */
    public function acquire($timeout = 0)
    {
        return $this->channel->pop($timeout);
    }

    /**
     * Release a resource
     * @param mixed $resource
     */
    public function release($resource)
    {
        $this->channel->push($resource);
    }
}

我们代码里面不关心创建连接的具体逻辑，只要调用工厂方法即可。

项目地址

项目已经开源到githubhttps://github.com/swoole-foundation/swoole-pool

混合云云服务器 python协程池服务器连接池的实现协程 python协程

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/31517.html

Mix PHP V2 实例：AliCloud 短信协程池异步发送守护程序

摘要：前些时间我们发布了实例协程池异步邮件发送守护程序范例，这一次我们提供一个使用大厂通过协程化来并行执行短信发送任务，本文是一个代码简单性能极强的范例。前些时间我们发布了 Mix PHP V2 实例：协程池异步邮件发送守护程序范例，这一次我们提供一个使用大厂 SDK 通过 Swoole Hook 协程化来并行执行短信发送任务，本文是一个代码简单、IO 性能极强的范例。请先升级到 m...

qc1iu 2019-07-01 12:49 评论0 收藏0
Mix PHP V2 实例：协程池异步邮件发送守护程序

摘要：消费者开发使用本例时，请确保你使用的编译时开启了本例我们采用的守护程序协程池来完成一个超高性能的邮件发送程序。去年 Mix PHP V1 发布时，我写了一个多进程的邮件发送实例: 使用 mixphp 打造多进程异步邮件发送，今年 Mix PHP V2 发布，全面的协程支持让我们可以使用一个进程就可达到之前多个进程都无法达到的更高 IO 性能，所以今天重写一个协程池版本的邮件发送实例。...

lauren_liuling 2019-07-01 12:41 评论0 收藏0
Mix PHP V2 新特性：协程、定时器

摘要：主函数查询数据不手动释放的连接不会归还连接池，会在析构时丢弃执行结果为，说明是并行执行的。主函数查询数据即便抛出了异常，仍然能执行到，没有导致内的一直处于阻塞状态。主函数一次性定时持续定时停止定时协程 Mix PHP V2 基于 Swoole 4 的 PHP Stream Hook 协程技术开发，协程使用方式与 Golang 几乎一致，包括框架封装的协程池、连接池、命令行处理都大量参...

Nosee 2019-07-01 12:39 评论0 收藏0
SMProxy 1.2.9 发布！新增状态命令监控面板功能

摘要：一个基于协议，开发的数据库连接池。超出最大连接数会采用协程挂起，等到有连接关闭再恢复协程继续操作。版本更新新增命令监控面板功能修复日志目录创建失败的问题修复字符串索引取值版本兼容问题开发与讨论文档若被墙请访问群欢迎各类和。 Swoole MySQL Proxy 一个基于 MySQL 协议，Swoole 开发的MySQL数据库连接池。原理将数据库连接作为对象存储在内存中，当用户需要访...

lieeps 2019-08-06 14:39 评论0 收藏0
SMProxy 1.2.9 发布！新增状态命令监控面板功能

摘要：一个基于协议，开发的数据库连接池。超出最大连接数会采用协程挂起，等到有连接关闭再恢复协程继续操作。版本更新新增命令监控面板功能修复日志目录创建失败的问题修复字符串索引取值版本兼容问题开发与讨论文档若被墙请访问群欢迎各类和。 Swoole MySQL Proxy 一个基于 MySQL 协议，Swoole 开发的MySQL数据库连接池。原理将数据库连接作为对象存储在内存中，当用户需要访...

Lorry_Lu 2019-08-01 14:07 评论0 收藏0