Redisキューの操作例(php)_PHPチュートリアル-PHPチュートリアル-php.cn

Redisキューの操作例(php)_PHPチュートリアル

WBOY

リリース： 2016-07-21 15:19:10

オリジナル

894 人が閲覧しました

入力操作

コードをコピーコードは次のとおりです:

 
$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); )% 3); 
echo $value."n"; 
}catch(Exception $e){ 
} 
} 
デキュー操作 

コードをコピーします

コードは次のとおりです:

$redis = new Redis(); $redis->pconnect('127.0.0.1',6379); (True){

try{

echo $redis->LPOP('key1')."n"; 
}catch(Exception $e){ 
echo $e->getMessage()."n"; } 
sleep( rand()%3); 
}?> 

 

キュー操作に Redis を使用する方法 
 Reids は、ANSI C で実装された比較的高度なオープンソースのキー値ストレージ システムです。これは memcached に似ていますが、永続的なデータ ストレージをサポートし、value は文字列 (memcached の値と同じ)、リスト、セット (Set)、順序付きセット (OrderSet)、およびハッシュの複数の型をサポートします。すべての値の型は、リストへの要素の追加とポップ、コレクションへの要素の挿入と削除などのアトミック操作をサポートしています。 Rdid のデータのほとんどはメモリ上に配置され、読み取りおよび書き込み効率が非常に高くなります。AOF (操作記録ファイルの追加) と DUMP (定期的なデータ バックアップ) の 2 つの永続化方法が提供されます。 Redis はカスタマイズされた VM (仮想メモリ) メカニズムをサポートしており、データ容量がメモリを超える場合、値の一部をファイルに保存できます。同時に、Redis はデータ レプリケーションを実行できるマスター/スレーブ メカニズムをサポートします。 
Redisのリスト構造をキューとして利用できます 
上記のRedisのシナリオと機能から、現在の開発活動において、「こんな良いものを進化させるのではなく、どのシナリオでRedisを導入できるでしょうか？」 Redis、「Redis」の悲惨な状況はどうですか？もちろん、特定の問題を詳細に分析することは非常に重要です。 
キャッシング?分散キャッシュ？ 

キュー?分散キュー?もちろん、一部のシステムアプリケーション (電気通信、銀行、大規模なインターネットアプリケーションなど) はこれを使用します。しかし、ある面から見ると、memcache にはその 2 つが含まれるのでしょうか。もっとうまくできるはずです（実際には応用できないので、ただ捨てるだけです）。しかし、Redis を見ると、Redis ではキューとキャッシュの両方を含めることができ、Redis の操作はすべてアトミックな操作であるため、同時実行環境でも問題が発生しないことがわかります。
どちらが良いか悪いかについてコメントする必要はありません、存在が理由であり、自分に合ったものを選択するのが最善です。 Redis でキュー (分散) デザイン YY を試してみましょう。アドバイスをお願いします。 状況シナリオ:
現在、プロジェクトは複数のサーバーまたは複数の IP にデプロイされており、フロントエンドは F5 を通じて分散されているため、ユーザーのリクエストがどのサーバーに該当するかを判断することは不可能です。このプロジェクトでは、この種の展開は当初は考慮されていませんでしたが、同時に、(Oracle 上で) データベーステーブルの行レコードを直接ロックすることが最も簡単な方法でもありました。。さまざまなアプリケーションをデプロイし、データベースサーバーが 1 つだけの場合、この同時実行の問題は「簡単に」解決できると言えます。そこで、データベースサーバーが業務に関与しないように、アプリケーションに移行するかどうかを検討します。
たとえば、現在 2 つのアプリケーションサーバーと 1 つのデータベースサーバーがあります。このアイデアは、データベースサーバーに Redis をデプロイすることです。2 つのサーバーが同時にキャッシュまたはキューを操作する場合、最初に 2 つのアプリケーションサーバー上のプロキシオブジェクトを Redis サーバーから取得し、次に列をリストする操作を実行します。
コード実装を見てください (PHP)
キュー操作ファイル list_push.php

コードをコピー

コードは次のとおりです:

$redis = getRedisInstance();// Redis を取得しますRedis サーバーからのインスタンス

$redis->connect('Redis サーバー IP', 6379); while (true) { $redis->lPush('list1', 'A_'.date('Y-m-d H: i:s') ; $redis = getRedisInstance();//Redis サーバーから Redis インスタンスを取得します $redis->pconnect('Redis サーバー IP', 6379); { try {

var_export( $redis->blPop('list1', 10) );
} catch(Exception $e) {
//echo $e
}

実装方法(Python)
1. キュー(write.py)

コードをコピーコードは以下の通りです:

 
#!/usr/bin/env python 
インポート時間 
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」、今) 
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) 

操作する際は、同じリストオブジェクトを操作していることに注意してください。
はは、現在の主なアイデアはほぼ次のとおりですが、実際のシーンでは違いがあるでしょう。

)