Redis消息通知系统的实现

connect('/tmp/redis.sock');
$redis->lPush('usr',);
while ($usr = $redis->rPop('usr')) {
    var_dump($usr);
}
?>

zsetPop($zset, self::POSITION_FIRST);
    }
    public function zRevPop($zset)
    {
        return $this->zsetPop($zset, self::POSITION_LAST);
    }
    private function zsetPop($zset, $position)
    {
        $this->watch($zset);
        $element = $this->zRange($zset, $position, $position);
        if (!isset($element[0])) {
            return false;
        }
        if ($this->multi()->zRem($zset, $element[0])->exec()) {
            return $element[0];
        }
        return $this->zsetPop($zset, $position);
    }
}
?>

connect('/tmp/redis.sock');
$redis->zAdd('msg',,);
while ($msg = $redis->zRevPop('msg')) {
    var_dump($msg);
}
?>

<?php
for ($msgid = 1; $msgid sAdd(&#39;usr::msg&#39;, $msgid);
}
?>

<?php
for ($i = 1; $i multi(Redis::PIPELINE);
    for ($j = 1; $j sAdd(&#39;usr::msg&#39;, $msgid);
    }
    $redis->exec();
}
?>

redis> HMSET msg:1 title title1 content content1
redis> HMSET msg:2 title title2 content content2
redis> HMSET msg:3 title title3 content content3

redis> SADD usr:123:msg 1
redis> SADD usr:123:msg 2
redis> SADD usr:123:msg 3

redis> SMEMBERS usr:123:msg
1) "1"
2) "2"
3) "3"

redis> SORT usr:123:msg GET msg:*->title
1) "title1"
2) "title2"
3) "title3"
redis> SORT usr:123:msg GET msg:*->content
1) "content1"
2) "content2"
3) "content3"

redis> SORT usr:123:msg GET msg:*->title GET msg:*->content
1) "title1"
2) "content1"
3) "title2"
4) "content2"
5) "title3"
6) "content3"