[TOC] ## 隊列 <details> <summary>queue.php</summary> ``` $redis = new Redis(); $redis->connect('127.0.0.1','6379'); //echo $redis->ping(); //在其他地方獲存入隊列 $redis->rPush("mylist", json_encode(["php", "aaa"])); $redis->rPush("mylist", "python"); $redis->rPush("mylist", "go"); while(true){ //獲取彈出一個 //判斷長度大于10 個執行一次 $range = $redis->lRange('mylist', 0, -1); if(count($range)>=10){ foreach(range(0 , 10) as $v){ $res =$redis->lPop('mylist'); echo $res; } }else{ sleep(1); } } ``` </details> <br /> <details> <summary>client.php</summary> ``` sleep(2); $redis = new Redis(); $redis->connect('127.0.0.1','6379'); //在其他地方獲存入隊列 $redis->rPush("mylist", json_encode(["php", "aaa"])); $redis->rPush("mylist", "python"); $redis->rPush("mylist", "go"); $redis->rPush("mylist", "go"); $redis->rPush("mylist", "go"); $redis->rPush("mylist", "go"); $redis->rPush("mylist", "go"); $redis->rPush("mylist", "go"); ``` </details> <br /> 運行 ``` $ php queue.php $ php client.php ``` ## 訂閱發布 server.php ``` $redis = new Redis(); if ( ! $redis->connect('127.0.0.1', 6379)) { die($redis->getLastError()); } $redis->publish("chat", "123"); ``` client.php ``` $redis = new Redis(); if ( ! $redis->connect('127.0.0.1', 6379)) { die($redis->getLastError()); } $redis->set("count", "1"); print_r($redis->get("count")); function f($redis, $chan, $msg) { switch($chan) { case 'chat': print_r($msg); break; case 'chan-2': break; case 'chan-2': break; } } while (true){ $redis->subscribe(array('chat', 'chan-2', 'chan-3'), 'f'); // subscribe to 3 chans sleep(1); } ``` ``` php client.php php server.php ```