PHP yield 異步操作結(jié)合同步業(yè)務(wù)代碼例子

songnuan

看了 PHPCon 2015 上海站  司超的協(xié)程pdf有感而寫的一小片段代碼練練手，希望對(duì)大家了解yield有所幫助

[PHP]代碼

1. <?php
   
2. /*
   
3. * yield 異步操作結(jié)合同步業(yè)務(wù)代碼例子
   
4. * @author Corz<combo_k@126.com>
   
5. */
   
6. //業(yè)務(wù)同步代碼
   
7. function syncCode()
   
8. {
   
9.     var_dump((yield ['dns', 'www.baidu.com']));
   
10.     var_dump((yield ['lag', 200]));
    
11.     var_dump((yield ['dns', 'www.taobao.com']));
    
12.     var_dump((yield ['sql', 'show tables']));
    
13. }
    
14. //異步調(diào)用器
    
15. function asyncCaller(Generator $gen)
    
16. {
    
17.     $r = $gen->current();
    
18.     if (isset($r)) {
    
19.         switch ($r[0]) {
    
20.             case 'sql':
    
21.                 AsyncMysql::getInstance()->query($r[1],
    
22.                     function ($retval) use($gen) {
    
23.                         $gen->send($retval);
    
24.                         asyncCaller($gen);
    
25.                     });
    
26.                 break;
    
27.             case 'dns':
    
28.                 swoole_async_dns_lookup($r[1],
    
29.                     function ($host, $ip) use($gen) {
    
30.                         $gen->send([$host, $ip]);
    
31.                         asyncCaller($gen);
    
32.                     });
    
33.                 break;
    
34.             case 'lag':
    
35.                 swoole_timer_after($r[1],
    
36.                     function () use($gen, $r) {
    
37.                         $gen->send('lag ' . $r[1] . 'ms');
    
38.                         asyncCaller($gen);
    
39.                     });
    
40.                 break;
    
41.             default:
    
42.                 $gen->send('no method');
    
43.                 asyncCaller($gen);
    
44.                 break;
    
45.         }
    
46.     }
    
47. }
    
48. 
    
49. asyncCaller(syncCode());
    
50. 
    
51. /**
    
52. * 異步mysql類
    
53. */
    
54. class AsyncMysql
    
55. {
    
56. 
    
57.     /**
    
58.      * @var mysqli
    
59.      */
    
60.     protected $db = null;
    
61. 
    
62.     /**
    
63.      * @var callable
    
64.      */
    
65.     protected $callable = null;
    
66. 
    
67.     public static function getInstance()
    
68.     {
    
69.         static $instance = null;
    
70.         return isset($instance) ? $instance : ($instance = new self());
    
71.     }
    
72. 
    
73.     public function __construct()
    
74.     {
    
75.         $this->db = new mysqli('127.0.0.1', 'root', '123456', 'mysql');
    
76.         swoole_event_add(swoole_get_mysqli_sock($this->db), [$this, 'onQuery']);
    
77.     }
    
78. 
    
79.     public function onQuery($db_sock)
    
80.     {
    
81.         $res = $this->db->reap_async_query();
    
82.         call_user_func($this->callable, $res->fetch_all(MYSQLI_ASSOC));
    
83.     }
    
84. 
    
85.     /**
    
86.      * @param string    $sql
    
87.      * @param callable  $callable
    
88.      */
    
89.     public function query($sql, callable $callable)
    
90.     {
    
91.         $this->callable = $callable;
    
92.         $this->db->query($sql, MYSQLI_ASYNC);
    
93.     }
    
94. }

復(fù)制代碼