PHP로 작성된 Memcache 기반의 Memcache 대기열 구현 코드

php类代码:

复主代码 代码如下:

클래스 MQ{
공개 정적 $클라이언트;
비공개 정적 $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) || 비어 있음(self::$m_real)) {
self::$real= 0;
}
if (!isset(self::$m_front) || 비어 있음(self::$m_front)) {
self::$m_front = 0;
}
return 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;
}
}
return $result;
}
공용 정적 함수 get($key, $count) {
$num = 0;
for ($i=self::$m_front;$iif ($dataTmp = memcache_get(self::$client, $key.$i )) {
self::$m_data[] = $dataTmp;
memcache_delete(self::$client, $key.$i);
$번호 ;
}
}
if ($num>0) {
self::mqFrontChange($num);
}
return 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);
}
공용 정적 함수 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) ;//출판 수량 제한 

                
                
                

                    Memcache ache php 写的基于 memcache 的 대기열 实现代码, 包括了 memcache 方面的内容, 希望对 php 教程有兴趣的朋友有所帮助。