如何使用php操作redis隊列實例
對於不同的應用部 署,而只有一台數據庫服務器來説,很“輕鬆”的就解決了這個併發的問題。所以現在考慮一下,是不是挪到應用上,避免數據庫服務器也摻雜到業務上。就跟隨本站小編一起去了解下吧,想了解更多相關信息請持續關注我們應屆畢業生考試網!
Redis是一個比較高級的開源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中的隊列(分佈式)。
狀況場景:
現在的項目,都是部署在多個服務器,或者多個IP上,而且前台經由F5分發,所以用户的請求究竟落在那一台的服務器上,是無法確定的'。對於項目 中,有一秒殺設計,剛開始沒有考慮到這種部署,同時也是使用最容易處理的方式,直接給數據庫表鎖行記錄(Oracle上的)。可以説,對於不同的應用部 署,而只有一台數據庫服務器來説,很“輕鬆”的就解決了這個併發的問題。所以現在考慮一下,是不是挪到應用上,避免數據庫服務器也摻雜到業務上。
比如,現在有2台應用服務器,1台數據庫服務器。想法是,把Redis部署在數據庫服務器上,兩台服務器在操作併發緩存或者隊列時,先從Redis服務器上取得在兩台應用服務器的代理對象,再做入列出列的操作。
入隊操作代碼
<?php
$redis = new Redis();
$redis->connect('',6379);
while(True){
try{
$value = 'value_'('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('',6379);
while(True){
try{
echo $redis->LPOP('key1')."n";
}catch(Exception $e){
echo $e->getMessage()."n";
}
sleep(rand()%3);
}?>
入隊列操作文件 list_
<?php
$redis = getRedisInstance();//從Redis服務器拿到redis實例
$redis->connect('Redis服務器IP', 6379);
while (true) {
$redis->lPush('list1', 'A_'('Y-m-d H:i:s'));
sleep(rand()%3);
}
?>
執行# php list_ &
出隊列操作 list_文件
<?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.入隊列()
#!/usr/bin/env python
import time
from redis import Redis
redis = Redis(host='', port=6379)
while True:
now = time("%Y/%m/%d %H:%M:%S")
h('test_queue', now)
p(1)
2.出隊列()
#!/usr/bin/env python
import sys
from redis import Redis
redis = Redis(host='', port=6379)
while True:
res = ('test_queue')
if res == None:
pass
else:
print str(res)
在操作時,注意,要操作的是同一個list對象。
-
提高PHP執行效率的50個技巧
PHP是一種HTML內嵌式的語言,是一種在服務器端執行的嵌入HTML文檔的腳本語言,下面是小編為大家整理的提高PHP執行效率的50個技巧,歡迎參考~1、用單引號代替雙引號來包含字符串,這樣做會更快一些。因為PHP會在雙引號包圍的字符串中搜尋變量,單引號則不會,注意:只有echo...
-
ThinkPHP中自動驗證
學無止境,剛開始學習PHP會覺得簡單,但是越學會越難。下面是小編整理的關於ThinkPHP中自動驗證的知識,希望對大家有用,更多消息請關注應屆畢業生網。ThinkPHP中自動驗證:array(‘字段’,‘驗證規則’,‘錯誤提示’[,‘驗證條件&rsqu...
-
php計算兩個文件相對路徑的方法
文章主要介紹了php計算兩個文件相對路徑的方法,涉及php操作字符串的`技巧,具有一定參考借鑑價值,需要的朋友可以參考下.一、問題:寫一個php函數算出兩個文件的相對路徑。例如$a="/a/b/c/d/";$b="/a/b/12/34/",B相對於A的相對路徑是什麼?二、解決方法:?123456789101...
-
PHP 7.1中都有哪些重大更新
PHP7.1.0帶來了大量的改進和新功能:可空類型返回空類型可迭代的psuedo-type支持常量可見的類數組解構square框架和在list()中允許指定keys多異常類型捕獲,以下是小編為大家搜索整理的PHP7.1中都有哪些重大更新,希望能給大家帶來幫助!更多精彩內容請及時關注我們應...