A. 請教php+Redis實現任務隊列的思路
// 創建請求ID標志, uniqid 無法保證唯一, 自己去搜索生成唯一的方法
$uuid = uniqid();
$tsk_name = "mytask";
$time_out = 30000; // 超時策略: 30秒
$time_start = time();
$redis->rPush($tsk_name, $uuid); // 右(後)插入隊列
// 堵塞等待隊列中第一個和$uuid匹配的(到我了)
while($uuid != $redis->lGet($tsk_name, 0)){
if((time()-$time_start)> $time_out) {
break; // 超時跳出(某些原因隊列異常了, 可能永遠取不到)
}
usleep(10); // sleep 10ms, 再次嘗試
}
// 這里執行任務的處理代碼....
// $response 已拼裝好要返回的內容
// 處理完成後(資料庫等已入庫更新), 需要:
if($redis->lGet($tsk_name, 0) == $uuid){ // 再次確認第一個是本請求
$redis->lPop($tsk_name); // 完成任務了, 從隊列中移除
}else{
// 出現這種情況, 是因為超時了, 或前面的$uuid沒有被消費
// 若不清除, 後續的請求, 都將無法正常進入隊列執行
// 取隊列中的所有$uuid
$queues = $redis->lRange($tsk_name, 0, -1);
foreach($queues as $i=>$uid){
if($uid==$uuid){
B. 如何使用Redis 做隊列操作
redis設計用來做緩存的，但是由於它自身的某種特性使得它可以用來做消息隊列，它有幾個阻塞式的API可以使用，正是這些阻塞式的API讓其有能力做消息隊列；
另外，做消息隊列的其他特性例如FIFO（先入先出）也很容易實現，只需要一個list對象從頭取數據，從尾部塞數據即可；
redis能做消息隊列還得益於其list對象blpop brpop介面以及Pub/Sub（發布/訂閱）的某些介面，它們都是阻塞版的，所以可以用來做消息隊列。
C. php怎麼實現redis阻塞隊列
具體的業務還是得需要你自己定製。你的需求實際上是一個變形的生產者-消費者實現。對於此類需求，主要是將請求和實際的處理過程解耦，一般都是採取非同步的方式來通知仔雀或請求方，這跟用不用redis其實沒有多大的關系。一般的實現方法是你需要將用戶的請求歲洞封裝成一個Task，然後將這個Task再push到redis隊列，然後後端的worker.php完全可以多進程、多線程的並發處理Task並將處理結果回調給請求方。念伍這里唯一麻煩點的就是這個Task的設計，需要能夠包含請求信息(請求內容，請求方標識等等).
D. php redis 隊列～呢
用php調用redis裡面的 lists 相關的命令就好，實現隊列就用 lpush和rpop，分別代表隊首出列，和隊尾入列。
E. php 用 redis做隊列 運行過程是什麼樣的
redis實圓敬現消息隊灶腔灶隱扮列很簡單：
$this->redis->rPush($key, $val); // 右邊入
$this->redis->lPop($key); // 左邊出
F. PHP 如何在Redis中實現事物（事物提交和事物
public function index()
{
$serv = new \swoole_server("0.0.0.0", 9501);
$serv->set([
'worker_num' => 1,//一般設置為伺服器CPU數的1-4倍
'task_worker_num' => 8,//task進程的數量
'daemonize' => 1,//以守護進程執行
'max_request' => 10000,//最大請求數量
"task_ipc_mode " => 2 //使用消息隊列通信，並設置為爭搶模式
]);
$serv->on('Receive', [$this, 'onReceive']);//接收任務，並投遞
$serv->on('Task', [$this, 'onTask']);//可以在這個方法裡面處理任務
$serv->on('Finish', [$this, 'onFinish']);//任務完成時候調用
$serv->start();
}
G. php 後台怎麼開一個進程監聽Redis的隊列消息呢用while
redis的subscribe用pconnect鏈接，執行這個腳本的進程會自動監聽所訂閱的頻道發送的消息
ini_set(『default_socket_timeout』, -1);
$redis = new \Redis();
$redis->pconnect('127.0.0.1', 6379);
//訂閱
$redis->subscribe(['msg'], 'callfun');
function callfun($redis, $channel, $msg)
{
var_mp([
'redis' => $redis,
'channel' => $channel,
'msg' => $msg
]);
}
H. php中redis和memcached區別和應用場景
redis比memcached功能更多更強大,現在基本都是只用redis了.
利用redis的原子性可以給數據加鎖
可以保存臨時數據,比如簡訊驗證碼和session
可以用於實現簡單的隊列任務
可以實現排行榜功能
可以實現經緯度距離計算
........
當然不止這些,redis是一種key-value資料庫,他的業務場景還可以自己擴展.
I. php 用 redis做隊列 運行過程是什麼樣的
Reids是一個比較高級的開源key-value存儲系統，採用ANSI C實現。其與memcached類似，但是支持持久化數據存儲入隊操作
復制代碼 代碼如下:
<?php
$redis = new Redis();
$redis->connect('127.0.0.1',6379);
while(True){
try{
$value = 'value_'.date('Y-m-d H:i:s');
$redis->LPUSH('key1',$value);
sleep(rand()%3);
echo $value."\n";
}catch(Exception $e){
echo $e->getMessage()."\n";
}
}
?>
出隊操作
復制代碼 代碼如下:
<?php
$redis = new Redis();
$redis->pconnect('127.0.0.1',6379);
while(True){
try{
echo $redis->LPOP('key1')."\n";
}catch(Exception $e){
echo $e->getMessage()."\n";
}
sleep(rand()%3);
}?>
如何使用Redis 做隊列操作
Reids是一個比較高級的開源key-value存儲系統，採用ANSI C實現。其與memcached類似，但是支持持久化數據存儲，同時value支持多種類型：字元串 （同memcached中的value），列表 ，集合 (Set)，有序集合 (OrderSet)和Hash 。所有的值類型均支持原子操作，如列表中追加彈出元素，集合中插入移除元素等。Rdids的數據大部分位於內存中，其讀寫效率非常高，其提供AOF（追加 式操作記錄文件）和DUMP（定期數據備份）兩種持久化方式。Redis支持自定義的VM（虛擬內存）機制，當數據容量超過內存時，可以將部分Value 存儲到文件中。同時Redis支持Master-Slave機制，可以進行數據復制。
可以把Redis的list結構當隊列來用.
從上面Redis的場景和作用來說，對於我們現在的開發活動，究竟能把Redis引入在那些場景，而不是把這么好的東東演變成「為了使用Redis，而Redis」的慘烈局面呢？當然，具體問題具體分析，這個真的很重要哈。
緩存？分布式緩存？
隊列？分布式隊列？
某些系統應用（例如，電信、銀行和大型互聯網應用等）都會使用到，當然，現在大行其道的memcache就是很好的證明；但從某一方面來說，memcache是否能把兩張囊括其中，而且能做到更好（沒有實際的應用過，所以只是拋出）。但從Redis身上，我就能感覺到，Redis，就能把隊列和緩存兩張都囊括其中，而且都不會產生並發環境下的困擾，因為Redis中的操作都是原子操作來著。
至於評論兩者的孰好孰壞就免了，存在就是理由，選擇適合的就是最好的。
下面開始玩玩Redis中的隊列（分布式）設計YY吧，請大蝦們多多指點。
狀況場景：
現在的項目，都是部署在多個伺服器，或者多個IP上，而且前台經由F5分發，所以用戶的請求究竟落在那一台的伺服器上，是無法確定的。對於項目中，有一秒殺設計，剛開始沒有考慮到這種部署，同時也是使用最容易處理的方式，直接給資料庫表鎖行記錄（Oracle上的）。可以說，對於不同的應用部署，而只有一台資料庫伺服器來說，很「輕松」的就解決了這個並發的問題。所以現在考慮一下，是不是挪到應用上，避免資料庫伺服器也摻雜到業務上。
比如，現在有2台應用伺服器，1台資料庫伺服器。想法是，把Redis部署在資料庫伺服器上，兩台伺服器在操作並發緩存或者隊列時，先從Redis伺服器上，取得在兩台應用伺服器的代理對象，再做入列出列的操作。
看代碼實現（PHP）
入隊列操作文件 list_push.php
復制代碼 代碼如下:
<?php
$redis = getRedisInstance();//從Redis伺服器拿到redis實例$redis->connect('Redis伺服器IP', 6379);
while (true) {
$redis->lPush('list1', 'A_'.date('Y-m-d H:i:s'));sleep(rand()%3);
}
?>
執行# php list_push.php &
出隊列操作 list_pop.php文件
復制代碼 代碼如下:
<?php
$redis = getRedisInstance();//從Redis伺服器拿到redis實例$redis->pconnect('Redis伺服器IP', 6379);
while(true) {
try {
var_export( $redis->blPop('list1', 10) );} catch(Exception $e) {
//echo $e;
}
}
實現方法(python)
1.入隊列（write.py）
復制代碼 代碼如下:
#!/usr/bin/env python
import time
from redis import Redis
redis = Redis(host='127.0.0.1', port=6379)while True:
now = time.strftime("%Y/%m/%d %H:%M:%S")
redis.lpush('test_queue', now)
time.sleep(1)
2.出隊列（read.py）
復制代碼 代碼如下:
#!/usr/bin/env python
import sys
from redis import Redis
redis = Redis(host='127.0.0.1', port=6379)while True:
res = redis.rpop('test_queue')
if res == None:
pass
else:
print str(res)
J. php使用redis的有序集合zset實現延遲隊列
延遲隊列就是個帶延遲功能的消息隊列，相對於普通隊列，它可以在指定時間消費掉消息。
我們通過redis的有序集合zset來實現簡單的延遲隊列，將消息數據序列化，作為zset的value，把消息處理時間作為score，每次通過zRangeByScore獲取一條消息進行處理。
然後，我們寫一個php腳本，用來處理隊列中的任務。