协程与Swoole的原理,相关应用以及适用场景等

标签: 协程 swoole 原理 | 发表时间:2019-07-02 08:00 | 作者:
出处:http://www.phpxs.com

什么是协程

协程(Coroutine)也叫用户态线程,其通过协作而不是抢占来进行切换。相对于进程或者线程,协程所有的操作都可以在用户态完成,创建和切换的消耗更低。协程是进程的补充,或者是互补关系。

 要理解是什么是“用户态的线程”,必然就要先理解什么是“内核态的线程”。内核态的线程是由操作系统来进行调度的,在切换线程上下文时,要先保存上一个线程的上下文,然后执行下一个线程,当条件满足时,切换回上一个线程,并恢复上下文。协程也是如此,只不过,用户态的线程不是由操作系统来调度的,而是由程序员来调度的,就是所谓的用户态的线程。


协程的执行流程  

协程的适用场景

高并发服务,如秒杀系统、高性能API接口、RPC服务器,使用协程模式,服务的容错率会大大增加,某些接口出现故障时,不会导致整个服务崩溃。

      爬虫,可实现非常巨大的并发能力,即使是非常慢速的网络环境,也可以高效地利用带宽。

      即时通信服务,如IM聊天、游戏服务器、物联网、消息服务器等等,可以确保消息通信完全无阻塞,每个消息包均可即时地被处理。


协程与线程区别

Swoole的协程在底层实现上是单线程的,因此同一时间只有一个协程在工作,协程的执行是串行的。这与线程不同,多个线程会被操作系统调度到多个CPU并行执行。

一个协程正在运行时,其他协程会停止工作。当前协程执行阻塞IO操作时会挂起,底层调度器会进入事件循环。当有IO完成事件时,底层调度器恢复事件对应的协程的执行。

对CPU多核的利用,仍然依赖于Swoole引擎的多进程机制。


协程实现

1、swoole的两种命名空间形式

Swoole支持两种形式的命名空间一种是Swoole\Coroutine,2.2.0以上可使用Co\命名空间短命名简化类名。

2、协程默认支持的位置

目前Swoole4仅有部分事件回调函数底层自动创建了协程,以下回调函数可以调用协程客户端,可以查看这里https://wiki.swoole.com/wiki/page/696.html


在不支持协程的位置可以使用go或Co::create创建协程

3、协程的性能测试

通过多个协程连接redis操作对比没有使用协程的方式

4、协程并发

协程其实也是阻塞运行的,如果,在一个执行中,比如同时查redis,再去查mysql,即使用了上面的协程,也是顺序执行的。那么可不可以几个协程并发执行呢?

通过延迟收包的形式获取,遇到到IO 阻塞的时候,协程就挂起了,不会阻塞在那里等着网络回报,而是继续往下走,swoole当中可以用setDefer()方法声明延迟收包然后通过recv()方法收包。

5、协程通讯

  使用本地内存,不同的进程之间内存是隔离的。只能在同一进程的不同协程内进行push和pop操作

向通道中写入数据。

function Coroutine\Channel->push(mixed $data) : bool;

从通道中读取数据。

function Coroutine\Channel->pop() : mixed;

对协程调用场景,最常见的“生产者-消费者”事件驱动模型,一个协程负责生产产品并将它们加入队列,另一个负责从队列中取出产品并使用它。

6、协程的注意问题

如果在多个协程间共用同一个协程客户端,同步阻塞程序不同,协程是并发处理请求的,因此同一时间可能会有很多个请求在并行处理,一旦共用客户端连接,就会导致不同协程之间发生数据错乱。


swoole通用协程池的实现

swoole官方的协程池是用只能用在Redis。因为协程池代码层耦合了Redis实例化逻辑。通过工厂函数实现了通用性。

  

class RedisPool {     /**      * @var \Swoole\Coroutine\Channel      */     protected $pool;     /**      * RedisPool constructor.      * @param int $size 连接池的尺寸      */     function __construct($size = 100)     {         $this->pool = new Swoole\Coroutine\Channel($size);         for ($i = 0; $i < $size; $i++)         {             $redis = new Swoole\Coroutine\Redis();             $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();     } }


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

  

<?php /**  * @author xialeistudio  * @date 2019-05-20  */ namespace swoole\foundation\pool; use Swoole\Coroutine\Channel; /**  * Swoole generic connection pool  * Class Pool  * @package swoole\foundation\pool  */ class GenericPool {     /**      * @var int pool size      */     private $size = 0;     /**      * @var callable construct a connection      */     private $factory = null;     /**      * @var Channel      */     private $channel = null;     /**      * GenericPool constructor.      * @param int $size      * @param callable $factory      * @throws InvalidParamException      */     public function __construct($size, callable $factory)     {         $this->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);     } }

相关 [协程 swoole 原理] 推荐:

协程与Swoole的原理,相关应用以及适用场景等

- - 编程学习网
协程(Coroutine)也叫用户态线程,其通过协作而不是抢占来进行切换. 相对于进程或者线程,协程所有的操作都可以在用户态完成,创建和切换的消耗更低. 协程是进程的补充,或者是互补关系.  要理解是什么是“用户态的线程”,必然就要先理解什么是“内核态的线程”. 内核态的线程是由操作系统来进行调度的,在切换线程上下文时,要先保存上一个线程的上下文,然后执行下一个线程,当条件满足时,切换回上一个线程,并恢复上下文.

协程(三)协程与Continuation

- Eric - Indie 之路
Continuation表示一个运算在其指定位置的剩余部分. 当Continuation作为语言的第一类(First-class)对象时,可用于实现多种控制结构. 同样作为控制结构,First-class continuation的表达力比协程更加强大,而且有着明确定义的语义,以至于在它出现之后对协程的研究就几乎完全停止了.

协程(二):协程的应用

- vento - python.cn(jobs, news)
# 感谢“书香”推荐: @shuxiang29. 上一篇中对协程的概念做出了解释和澄清. 总的来说,完全协程才算得上是真正意义上的协程,其它如生成器等只是部分实现了协程概念的非完全协程,我们之后主要讨论完全协程. 协程本质是一种控制抽象,它的价值在于可以简洁优雅地实现一些控制行为. 在协程中,控制可以从当前执行上下文跳转到程序的其它位置,并且可以在之后的任意时刻恢复当前执行上下文,控制从跳出点处继续执行.

java 协程 实现 Akka

- - zzm
Akka是开源的,可以通过Apache 2许可获得. 可以从 http://akka.io/downloads/ 下载.         对并发/并行程序的简单的、高级别的抽象.         异步、非阻塞、高性能的事件驱动编程模型.         非常轻量的事件驱动处理(1G内存可容纳约270万个actors).

HandlerSocket的原理

- Roger - MySQLOPS 数据库与运维自动化技术分享
HandlerSocket的应用场景:. MySQL自身的局限性,很多站点都采用了MySQL+Memcached的经典架构,甚至一些网站放弃MySQL而采用NoSQL产品,比如Redis/MongoDB等. 不可否认,在做一些简单查询(尤其是PK查询)的时候,很多NoSQL产品比MySQL要快很多,而且前台网站上的80%以上查询都是简洁的查询业务.

hbase原理

- - CSDN博客云计算推荐文章
1.hbase利用hdfs作为其文件存储系统,利用mapreduce来处理数据,利用zookeeper作为协调工具. 2.行键(row key),类似于主键,但row key是表自带的. 3.列族(column family) ,列(也称作标签/修饰符)的集合,定义表的时候指定的,列是在插入记录的时候动态增加的.

zookeeper原理

- - CSDN博客云计算推荐文章
1.为了解决分布式事务性一致的问题. 2.文件系统也是一个树形的文件系统,但比linux系统简单,不区分文件和文件夹,所有的文件统一称为znode. 3.znode的作用:存放数据,但上限是1M ;存放ACL(access control list)访问控制列表,每个znode被创建的时候,都会带有一个ACL,身份验证方式有三种:digest(用户名密码验证),host(主机名验证),ip(ip验证) ,ACL到底有哪些权限呢.

索引原理

- - ITeye博客
索引是存储引擎用于快速找到记录的一种数据结构. 也就会说索引也是一种数据结构,也占用磁盘空间. 索引是对查询优化最有效的手段,可以将查询提升几个数量级,相当牛掰啊. 1)索引大大减少了服务器需要扫描的数据量. 2)索引可以帮助服务器避免排序和临时表. 3)索引可以将随机IO变为顺序IO. 数据库索引可以想象成一本书的目录,如果想在一本书中找到某个主题,那么先到书的目录中找到这个主题,然后根据目录提供的页码,找到要找的主题.

Hessian原理

- - 互联网 - ITeye博客
Hessian 原理分析. 一.      远程通讯协议的基本原理. 二.      应用级协议 Binary-RPC. Binary-RPC 是一种和 RMI 类似的远程调用的协议,它和 RMI 的不同之处在于它以标准的二进制格式来定义请求的信息 ( 请求的对象、方法、参数等 ) ,这样的好处是什么呢,就是在跨语言通讯的时候也可以使用.

MapReduce原理

- - C++博客-牵着老婆满街逛
       MapReduce 是由Google公司的Jeffrey Dean 和 Sanjay Ghemawat 开发的一个针对大规模群组中的海量数据处理的分布式编程模型. MapReduce实现了两个功能. Map把一个函数应用于集合中的所有成员,然后返回一个基于这个处理的结果集. 而Reduce是把从两个或更多个Map中,通过多个线程,进程或者独立系统并行执行处理的结果集进行分类和归纳.