Swoole4.x之协程变量访问安全与协程连接池实现

aisuhua 发布于2019-07-01 14:05 / 3641人阅读

摘要：访问安全问题为什么说有访问安全问题呢传统地，在的的环境中，很少有遇到所谓变量安全访问问题。上下文管理器为了解决这个问题，我们引入协程上下文管理这样的概念，由此来实现每个协程环境内的数据隔离。

访问安全问题

为什么说有访问安全问题呢？传统地，在php的的环境中，很少有Phper遇到所谓变量安全访问问题。举个例子，代码大约如下:

class db
{
    protected static $instance;
    protected $dbCon;
    
    function __construct()
    {
        /*
         * 我们这里用stdclass来模拟一个数据库连接
         */
        $this->dbCon = new stdClass();
    }

    public static function getInstance()
    {
        if(!isset(self::$instance)){
            self::$instance = new db();
        }
        return self::$instance;
    }

    function dbCon()
    {
        return $this->dbCon;
    }
}

$con = db::getInstance()->dbCon();
$con->key = "new";
var_dump($con->key);

这个是在fpm模式下，很常见的数据库连接单例模式的使用。乍一看没有问题，但实际上，在协程环境下，会出现连接跨协程使用问题,举例如下

go(function (){
    go(function (){
        db::getInstance()->dbCon()->key = "one";
        //假设这sql执行了1s
        co::sleep(1);
        var_dump(db::getInstance()->dbCon()->key);
    });
    go(function (){
        db::getInstance()->dbCon()->key = "two";
        //假设这sql执行了0.1s
        co::sleep(0.1);
        var_dump(db::getInstance()->dbCon()->key);
    });
});

我们会发现，以上代码当中，协程2的数据污染到了协程1的数据，那么因此这样肯定是不行的。

上下文管理器

为了解决这个问题，我们引入协程上下文管理这样的概念，由此来实现每个协程环境内的数据隔离。

class dbContext
{
    private $container = [];

    private static $instance;

    public static function getInstance()
    {
        if(!isset(self::$instance)){
            self::$instance = new dbContext();
        }
        return self::$instance;
    }

    function dbCon()
    {
        $cid = co::getCid();
        if(!isset($this->container[$cid])){
            $this->container[$cid] = new stdClass();
            defer(function (){
                $this->destroy();
            });
        }
        return $this->container[$cid];
    }

    function destroy()
    {
        $cid = co::getCid();
        if(!isset($this->container[$cid])){
            unset($this->container[$cid]);
        }
    }
}

go(function (){
    go(function (){
        dbContext::getInstance()->dbCon()->key = "one";
        //假设这sql执行了1s
        co::sleep(1);
        var_dump(dbContext::getInstance()->dbCon()->key);
    });
    go(function (){
        dbContext::getInstance()->dbCon()->key = "two";
        //假设这sql执行了0.1s
        co::sleep(0.1);
        var_dump(dbContext::getInstance()->dbCon()->key);
    });
});

以上代码中，我们用每个协程的id,来作为每个协程栈的数据token,用了defer方法，实现了每个协程退出的时候的数据自动清理，从而避免了内存泄露。

通用版本的连接池与协程上下文管理

我们不难发现，以上代码中，实际上依旧是短连接的管理方式，没办法对链接进行复用，由于本文章仅做基础原理讲解之用，具体有兴趣的同学，可以查看下Easyswoole这个框架的连接池和协程上下文管理器，项目主页在 www.easyswoole.com ，若觉得喜欢，有帮助，可以给easyswoole的github仓库点个赞。

云服务器 GPU云服务器协程 python协程使用协程 python协程池

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

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

PHP物联网开发利器之Actor并发模型

摘要：然而尽管如此，很多人可能都没有思考过，如何优雅的写出自己的物联网服务器。 PHP不适合做物联网服务端吗？在传统的思维中，经常会有人告诉你，php不适合用来做物联网服务端，让你换java,node,go等其他语言，是的，没错传统意义上的php，确实很难做物联网服务器，因为它实在太蹩脚了，当然，这也不是意味着彻底就不能做。举个例子，当你想实现一个TCP服务器的时候，你可能需要写出原理大约...

ixlei 2019-07-01 13:56 评论0 收藏0
Swoole4.x探究之多进程TCP协程服务实现

摘要：有研究过框架的同学就会发现，其实最核心的，就是用了拓展加上拓展来实现其底层的网络服务和多进程调度。我们在模式下，测试起五个进程主进程要等待回收我们，这样就很简单的实现了一个多进程的协程服务。有研究过Workman框架的同学就会发现，其实workman最核心的，就是用了php socket拓展加上pcntl拓展来实现其底层的网络服务和多进程调度。那我们今天就来探讨如何使用Swoole的...

ad6623 2019-07-01 13:56 评论0 收藏0
PHP回顾之协程

摘要：本文先回顾生成器，然后过渡到协程编程。其作用主要体现在三个方面数据生成生产者，通过返回数据数据消费消费者，消费传来的数据实现协程。解决回调地狱的方式主要有两种和协程。重点应当关注控制权转让的时机，以及协程的运作方式。转载请注明文章出处： https://tlanyan.me/php-review... PHP回顾系列目录 PHP基础 web请求 cookie web响应 sess...

Java3y 2019-07-01 12:30 评论0 收藏0
Java 并发方案全面学习总结

摘要：进程线程与协程它们都是并行机制的解决方案。选择是任意性的，并在对实现做出决定时发生。线程池的大小一旦达到最大值就会保持不变，如果某个线程因为执行异常而结束，那么线程池会补充一个新线程。此线程池支持定时以及周期性执行任务的需求。并发与并行的概念并发(Concurrency): 问题域中的概念—— 程序需要被设计成能够处理多个同时（或者几乎同时）发生的事件并行(Parallel...

mengera88 2019-08-16 14:10 评论0 收藏0
Python：Tornado 第二章：实战演练：开发Tornado网站：第六节：异步与协程化

摘要：上一篇文章第二章实战演练开发网站第五节输出相应函数下一篇文章第二章实战演练开发网站第七节安全机制有两种方式可改变同步的处理流程异步化针对的处理函数使用修饰器，将默认的同步机制改为异步机制。使用异步对象处理耗时操作，比如本例的。上一篇文章：Python：Tornado 第二章：实战演练：开发Tornado网站：第五节：RequestHandler：输出相应函数下一篇文章：Python：...

cod7ce 2019-07-30 18:06 评论0 收藏0