用PHP写的基于Memcache的Queue实现代码

            php类代码:
[U]复制代码[/U] 代码如下:
0) {
self::mqFrontChange($num);
}
return self:m_data;
}
private static function mqRealChange() {
memcache_add(self:client, self:UEUE_REAL_KEY, 0);
self:m_real = memcache_increment(self:client, self:UEUE_REAL_KEY, 1);
}
private static function mqFrontChange($num) {
memcache_add(self:client, self:UEUE_FRONT_KEY, 0);
self:m_front = memcache_increment(self:client, self:UEUE_FRONT_KEY, $num);
}
public static function 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 'wait for process data:'.intval(self:m_real - self::$m_front);
echo "
/r/n";
echo '';
print_r(self::$m_data);
echo '';
}
}
define('FLUSH_MQ',0);//CLEAN ALL DATA
define('IS_ADD',0);//SET DATA
$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:ebug();
?>

使用方法
[U]复制代码[/U] 代码如下:
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);//取出一定数量的数据
            
            
您可能感兴趣的文章:

php Memcache 中实现消息队列

PHP Memcached应用实现代码

Memcache 在PHP中的使用技巧

PHP操作Memcache实例介绍

php之Memcache学习笔记

php的memcache类分享(memcache队列)

PHP中的Memcache详解

PHP+memcache实现消息队列案例分享