PHP网站制作之PHP memcache完成动静行列实例 - 仓酷云

classMemcache_Queue{private$memcache;private$name;private$prefix;function__construct($maxSize,$name,$memcache,$prefix="__memcache_queue__"){if($memcache==null){thrownewException("memcacheobjectisnull,newtheobjectfirst.");}$this->memcache=$memcache;$this->name=$name;$this->prefix=$prefix;$this->maxSize=$maxSize;$this->front=0;$this->real=0;$this->size=0;}function__get($name){return$this->get($name);}function__set($name,$value){$this->add($name,$value);return$this;}functionisEmpty(){return$this->size==0;}functionisFull(){return$this->size==$this->maxSize;}functionenQueue($data){if($this->isFull()){thrownewException("QueueisFull");}$this->increment("size");$this->set($this->real,$data);$this->set("real",($this->real+1)%$this->maxSize);return$this;}functiondeQueue(){if($this->isEmpty()){thrownewException("QueueisEmpty");}$this->decrement("size");$this->delete($this->front);$this->set("front",($this->front+1)%$this->maxSize);return$this;}functiongetTop(){return$this->get($this->front);}functiongetAll(){return$this->getPage();}functiongetPage($offset=0,$limit=0){if($this->isEmpty()$this->size<$offset){returnnull;}$keys[]=$this->getKeyByPos(($this->front+$offset)%$this->maxSize);$num=1;for($pos=($this->front+$offset+1)%$this->maxSize;$pos!=$this->real;$pos=($pos+1)%$this->maxSize){$keys[]=$this->getKeyByPos($pos);$num++;if($limit>0&&$limit==$num){break;}}returnarray_values($this->memcache->get($keys));}functionmakeEmpty(){$keys=$this->getAllKeys();foreach($keysas$value){$this->delete($value);}$this->delete("real");$this->delete("front");$this->delete("size");$this->delete("maxSize");}privatefunctiongetAllKeys(){if($this->isEmpty()){returnarray();}$keys[]=$this->getKeyByPos($this->front);for($pos=($this->front+1)%$this->maxSize;$pos!=$this->real;$pos=($pos+1)%$this->maxSize){$keys[]=$this->getKeyByPos($pos);}return$keys;}privatefunctionadd($pos,$data){$this->memcache->add($this->getKeyByPos($pos),$data);return$this;}privatefunctionincrement($pos){return$this->memcache->increment($this->getKeyByPos($pos));}privatefunctiondecrement($pos){$this->memcache->decrement($this->getKeyByPos($pos));}privatefunctionset($pos,$data){$this->memcache->set($this->getKeyByPos($pos),$data);return$this;}privatefunctionget($pos){return$this->memcache->get($this->getKeyByPos($pos));}privatefunctiondelete($pos){return$this->memcache->delete($this->getKeyByPos($pos));}privatefunctiongetKeyByPos($pos){return$this->prefix.$this->name.$pos;}}

复制代码