侵權舉報/版權申訴基本知識點重點用到了以下命令實現我們的消息推送bpop阻塞模式從隊列右邊獲取值之后刪除bpoplpuh從隊列A的右邊取值之后刪除，從左側放置到隊列B中邏輯分析在普通的任務腳本中寫入puh_queue......
以下是【金聰采編】分享的內容全文：
以下是【金聰采編】分享的內容全文：
基本知識點
重點用到了以下命令實現我們的消息推送
- brpop 阻塞模式 從隊列右邊獲取值之后刪除
- brpoplpush 從隊列A的右邊取值之后刪除，從左側放置到隊列B中
邏輯分析
- 在普通的任務腳本中寫入push_queue隊列要發送消息的目標，并為目標設置一個要推送的內容，永不過期
- RedisPushQueue中brpoplpush處理，處理后的值放到temp_queue，主要防止程序崩潰造成推送失敗
- RedisAutoDeleteTempqueueItems處理temp_queue,這里用到了brpop
代碼實現
普通任務腳本
<?phpforeach ($user_list as $item) { //命名規則 業務類型_操作_ID_隨機6位 值 自定義 我自定義的是"推送內容" $k_name = 'rabbit_push_' . $item['uid'].'_'.rand(100000,999999); $redis->lPush('push_queue',$k_name);//左進隊列 $redis->set($k_name, '推送內容');}RedisPushQueue
<?php//消息隊列處理推送~// // 守護進程運行 // nohup php YOURPATH/RedisPushQueue.php & 開啟守護進程運行，修改文件之后需要從新啟動// blpop 有值則回去 沒值則阻塞 主要就是這個函數在起作用 不過并不安全，程序在執行過程中崩潰就會導致隊列中的內容 // 永久丟失~ // BRPOPLPUSH 阻塞模式 右邊出 左邊進 在填寫隊列內容的時候要求從左進入 //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臨時隊列防止程序崩潰導致隊列中內容丟失 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內容 $redis->del($key); } }function push($id, $v){ //推送操作~}RedisAutoDeleteTempqueueItems
<?php/* 自動處理temp_queue中的元素，這個操作是防止RedisPushQueue崩潰的時候做處理 處理思路是 使用brpop 命令阻塞處理temp_queue這個隊列中的值，如果能獲取到"值"對應的"值"，說明RedisPushQueue執行失敗了 將值還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執行失敗 $redis->lPush('push_queue',$key); }}以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持金聰精品。
金聰線報提示：[ php基于Redis消息隊列實現的消息推送的方法 ] 僅為會員分享，分享目的如下：
1.軟件源碼推廣展示：目的展示軟件相關功能，接收技術學習者測試、測評；
2.教程課程信息展示：展示課程信息，傳授課程各階段內容；
3.設計素材圖片展示：展示素材設計理念、思維方式、傳播設計理念；
4.福利優惠信息展示：分享各類最新的福利信息，各種優惠信息展示；
以上分享目的僅供學習、參考使用，請勿用于其他用途，如果想商業使用或者代理，請自行聯系版權方獲取授權。任何未獲取授權的商業使用與本站無關，請自行承擔相應責任。
本站不存儲任何資源文件，敬請周知！
本網站采用 BY-NC-SA 協議進行授權 轉載請注明原文鏈接:php基于Redis消息隊列實現的消息推送的方法
1.軟件源碼推廣展示：目的展示軟件相關功能，接收技術學習者測試、測評；
2.教程課程信息展示：展示課程信息，傳授課程各階段內容；
3.設計素材圖片展示：展示素材設計理念、思維方式、傳播設計理念；
4.福利優惠信息展示：分享各類最新的福利信息，各種優惠信息展示；
以上分享目的僅供學習、參考使用，請勿用于其他用途，如果想商業使用或者代理，請自行聯系版權方獲取授權。任何未獲取授權的商業使用與本站無關，請自行承擔相應責任。
本站不存儲任何資源文件，敬請周知！
此資源僅供個人學習、研究使用，禁止非法轉播或商業用途，請在獲取后24小時內刪除，如果你覺得滿意，請尋求購買正版或獲取授權！
如果您認為本頁信息內容侵犯了您的相關權益（包含但不限于：著作權、首發權、隱私權等權利），或者您認為自己是此信息的權利人但是此信息不是自己發布的，可以直接版權舉報投訴，我們會根據網站注冊協議、資源分享協議等協議處理，以保護您的合法權益。
免責申明：本站僅提供學習的平臺，所有資料均來自于網絡分享線索，版權歸原創者所有！本站不提供任何保證，并不承擔任何法律責任，如果對您的版權或者利益造成損害，請提供相應的資質證明，我們將于3個工作日內予以處理。版權申訴相關說明如果您認為本頁信息內容侵犯了您的相關權益（包含但不限于：著作權、首發權、隱私權等權利），或者您認為自己是此信息的權利人但是此信息不是自己發布的，可以直接版權舉報投訴，我們會根據網站注冊協議、資源分享協議等協議處理，以保護您的合法權益。
本網站采用 BY-NC-SA 協議進行授權 轉載請注明原文鏈接:php基于Redis消息隊列實現的消息推送的方法
