用PHP 写的基于 Memcache 的 Queue

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();  ?>
使用方法

							

								
								

									SmartB2B行业电子商务
									
SmartB2B 是一款基于PHP、MySQL、Smarty的B2B行业电子商务网站管理系统，系统提供了供求模型、企业模型、产品模型、人才招聘模型、资讯模型等模块，适用于想在行业里取得领先地位的企业快速假设B2B网站，可以运行于Linux与Windows等多重服务器环境，安装方便，使用灵活。 系统使用当前流行的PHP语言开发，以MySQL为数据库，采用B/S架构，MVC模式开发。融入了模型化、模板
								
								下载 
							
						
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);//取出一定数量的数据