ホームページ >バックエンド開発 >PHPチュートリアル >PHP_PHP チュートリアルで記述された Memcache に基づくキュー実装コード
PHP_PHP チュートリアルで記述された Memcache に基づくキュー実装コード
- WBOYオリジナル
- 2016-07-21 15:23:11891ブラウズ
php类代码:
复制代码代码如下:
class MQ{
public static $client;
プライベート静的$m_real;
プライベート静的 $m_front;
プライベート静的 $m_data = array();
const QUEUE_MAX_NUM = 100000000;
const QUEUE_FRONT_KEY = '_queue_item_front';
const QUEUE_REAL_KEY = '_queue_item_real';
パブリック静的関数 setupMq($conf) {
self::$client = memcache_pconnect($conf);
self::$m_real = memcache_get(self::$client, self::QUEUE_REAL_KEY);
self::$m_front = memcache_get(self::$client, self::QUEUE_FRONT_KEY);
if (!isset(self::$m_real) || emptyempty(self::$m_real)) {
self::$real= 0;
}
if (!isset(self::$m_front) || emptyempty(self::$m_front)) {
self::$m_front = 0;
}
self::$client を返します。
}
パブリック静的関数 add($queue, $data) {
$result = false;
if (self::$m_real < self::QUEUE_MAX_NUM) {
if (memcache_add(self::$client, $queue.self::$m_real, $data)) {
self::mqRealChange();
$結果 = true;
}
}
$result を返します。
}
パブリック静的関数 get($key, $count) {
$num = 0;
for ($i=self::$m_front;$i
self::$m_data[] = $dataTmp;
memcache_delete(self::$client, $key.$i);
$num++;
}
}
if ($num>0) {
self::mqFrontChange($num);
}
self::$m_data を返します。
}
プライベート静的関数 mqRealChange() {
memcache_add(self::$client, self::QUEUE_REAL_KEY, 0);
self::$m_real = memcache_increment(self::$client, self::QUEUE_REAL_KEY, 1);
}
プライベート静的関数 mqFrontChange($num) {
memcache_add(self::$client, self::QUEUE_FRONT_KEY, 0);
self::$m_front = memcache_increment(self::$client, self::QUEUE_FRONT_KEY, $num);
}
パブリック静的関数 mflush($memcache_obj) {
memcache_flush($memcache_obj);
}
public static function Debug() {
echo 'real:'.self::$m_real."
/r/n";
echo 'front:'.self::$m_front."
/r/n";
echo 'プロセスデータを待ちます:'.intval(self::$m_real - self::$m_front);
echo "
/r/n";
echo '
';
print_r(self::$m_data);
echo '';
}
}
define('FLUSH_MQ',0);//すべてのデータを消去
define('IS_ADD',0);//データを設定
$mobj = MQ::setupMq('127.0.0.1','11211 ');
if (FLUSH_MQ) {
MQ::mflush($mobj);
} else {
if (IS_ADD) {
MQ::add('user_sync', '1test');
MQ::add('user_sync', '2test');
MQ::add('user_sync', '3test');
MQ::add('user_sync', '4test');
MQ::add('user_sync', '5test');
MQ::add('user_sync', '6test');
} else {
MQ::get('user_sync', 10);
}
}
MQ::Debug();
?>
使用メソッド
复制代码代码如下:
MQ::setupMq('127.0.0.1','11211');//接続
MQ::add($key, $value) ;// 队列にデータを追加
MQ::add($key, $value);// 队列にデータを追加
MQ::add($key, $value);// 队列にデータを追加
MQ::add ($key, $value);// 队列にデータを追加
MQ::add($key, $value);// 队列にデータを追加
MQ::add($key, $value);// データを追加到队列
MQ:get($key, 10);//一定量のデータを取り出す
声明：
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。