基本知識點
重點用到了以下命令實現(xiàn)我們的消息推送
邏輯分析
代碼實現(xiàn)
普通任務腳本
?php foreach ($user_list as $item) { //命名規(guī)則 業(yè)務類型_操作_ID_隨機6位 值 自定義 我自定義的是"推送內(nèi)容" $k_name = 'rabbit_push_' . $item['uid'].'_'.rand(100000,999999); $redis->lPush('push_queue',$k_name);//左進隊列 $redis->set($k_name, '推送內(nèi)容'); }
RedisPushQueue
?php //消息隊列處理推送~ // // 守護進程運行 // nohup php YOURPATH/RedisPushQueue.php 開啟守護進程運行,修改文件之后需要從新啟動 // blpop 有值則回去 沒值則阻塞 主要就是這個函數(shù)在起作用 不過并不安全,程序在執(zhí)行過程中崩潰就會導致隊列中的內(nèi)容 // 永久丟失~ // BRPOPLPUSH 阻塞模式 右邊出 左邊進 在填寫隊列內(nèi)容的時候要求從左進入 // ini_set('default_socket_timeout', -1); //不超時 require_once 'YOURPARH/Rongcloud.php'; $redis = new \Redis(); $redis->connect('127.0.0.1', 6379); $redis->select(2);//切換到db2 $redis->setOption(\Redis::OPT_READ_TIMEOUT, -1); // temp_queue臨時隊列防止程序崩潰導致隊列中內(nèi)容丟失 0代表永不超時! While ($key = $redis->brpoplpush('push_queue', 'temp_queue', 0)) { if ($val = $redis->get($key)) { //rabbit_push_20_175990 $arr = explode('_', $key); if (count($arr) != 4) { continue; } $id = $arr[2]; push($id, $val); //刪除key內(nèi)容 $redis->del($key); } } function push($id, $v) { //推送操作~ }
RedisAutoDeleteTempqueueItems
?php /* 自動處理temp_queue中的元素,這個操作是防止RedisPushQueue崩潰的時候做處理 處理思路是 使用brpop 命令阻塞處理temp_queue這個隊列中的值,如果能獲取到"值"對應的"值",說明RedisPushQueue執(zhí)行失敗了 將值還lpush到push_queue中,以備從新處理 至于為什么使用brpop命令,是因為在RedisPushQueue中我們使用的是brpoplpush nohup php YOURPATH/RedisAutoDeleteTempqueueItems.php 開啟守護進程運行,修改文件之后需要從新啟動 */ ini_set('default_socket_timeout', -1); //不超時 $redis = new \Redis(); $redis->connect('127.0.0.1', 6379); $redis->select(2);//切換到db2 $redis->setOption(\Redis::OPT_READ_TIMEOUT, -1); while($key_arr = $redis->brPop('temp_queue',0)){ if(count($key_arr) != 2){ continue; } $key =$key_arr[1]; if($redis->get($key)){//能獲取到值 說明RedisPushQueue執(zhí)行失敗 $redis->lPush('push_queue',$key); } }
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。