phpredis隊列

① php redis 什麼時候用

默認情況下，Redis 服務會提供 16 個資料庫，PHPHub 使用 0 號資料庫來做緩存，1 號資料庫來做會話存儲 - Laravel 下配置 Redis 讓緩存、Session 各自使用不同的 Redis 資料庫_PHPHub
隊列的話使用 Beanstalkd
最常用的就是緩存、隊列，當然還有很多其它的，如歸並計算、去重等。
我根據自己使用Redis的場景及個人最佳實踐，整理了一篇文章，redis應用場景與最佳實踐
比如網站搶購時，可以使用redis做隊列，可以使用redis來代替session功能，還有可以拿redis中的無序集合做socket的客戶端id存儲。

② php怎麼實現redis阻塞隊列

具體的業務還是得需要你自己定製。你的需求實際上是一個變形的生產者-消費者實現。對於此類需求，主要是將請求和實際的處理過程解耦，一般都是採取非同步的方式來通知請求方，這跟用不用redis其實沒有多大的關系。一般的實現方法是你需要將用戶的請求封裝成一個Task，然後將這個Task再push到redis隊列，然後後端的worker.php完全可以多進程、多線程的並發處理Task並將處理結果回調給請求方。這里唯一麻煩點的就是這個Task的設計，需要能夠包含請求信息(請求內容，請求方標識等等).

③ 請教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){

④ 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)

⑤ 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
]);
}

⑥ 如何正確使用redis隊列處理php秒殺並發問題

1. redis中保存的是數組(序列化)，絕對不要保存sql,保存SQL的方法很蛋疼 保存數組是為了資料庫安全(萬一sql語句有錯誤，任務就直接失敗了)，靈活度和兼容性
2.伺服器後台作一個shell腳本，死循環，不斷從隊列中取數據，進行處理．如次反復，如果沒有數據，也立即嘗試取數據－－－不要擔心性能問題，後台單並發請求，不會造成性能問題
3.因為隊列中保存的是數組，不存在這個問題

⑦ php redis 消息隊列 一次出多少個隊列

方法如下：
[php] view plain print?

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
while(1){
try{
$value = "value_".time();
$redis->LPUSH('key1', $value);
echo $value."\n";
sleep(rand(1, 3));
}catch(Exception $e){
echo $e->getMessage(). "\n";
exit;
}
}