php类代码:
复制代码 代码如下:
0) {
self::mqfrontchange($num);
}
return self::$m_data;
}
private static function mqrealchange() {
memcache_add(self::$client, self::queue_real_key, 0);
self::$m_real = memcache_increment(self::$client, self::queue_real_key, 1);
}
private static function mqfrontchange($num) {
memcache_add(self::$client, self::queue_front_key, 0);
self::$m_front = memcache_increment(self::$client, self::queue_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::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 用php写的基于memcache的queue实现代码，包括了memcache方面的内容，希望对php教程有兴趣的朋友有所帮助。