Construyendo aplicaciones web con PHP, LUA y REDIS

$ git clone https://github.com/gchacaltana/phpredis.git

$ sudo apt-get install php5-dev
$ sudo phpize
$ ./configure
$ sudo make && make install

$ sudo cp /path/redis.so /etc/php5/conf.d/

$ sudo service apache2 restart

$ sudo service nginx restart

$ sudo service redis_6379 start

$ redis-cli
Redis 127.0.0.1:6379> zadd usersonline 1394326080 jaimito.
Redis 127.0.0.1:6379> zadd usersonline 1394326089 pepito.
Redis 127.0.0.1:6379> zadd usersonline 1394326099 gchacaltana.

/**
 * Connecting Redis Server
 */
function connectRedis()
{
    (string) $serverRedis = "127.0.0.1"; //localhost
    (int) $portRedis = "6379"; //default port
    try {
        if (!class_exists('Redis')) {
            throw new Exception("Redis Library not found.");
        }
        $connection = new Redis();
        $connection->connect($serverRedis, $portRedis);
    } catch (Exception $e) {
        throw new Exception("There was a problem connecting to redis server.");
    }
 
    //validate redis connection
    if (isset($connection->socket)) {
        return $connection;
    } else {
        throw new Exception("The redis server is turned off.");
    }
}

/**
 * Insert element Sorted Set Redis Server.
 * @param string $set, nombre de la lista ordenada en redis.
 * @param string $key, llave con que ordenaremos nuestra lista, 
 * en este caso sera el datetime de la fecha de ingreso del usuario.
 * @param string $value, será el nombre de usuario.
 */
function setSortedSetRedis($set, $key, $value)
{
    //conectamos a redis
    $redis = connectRedis();
 
    //El metodo zAdd agrega un elemento a una lista ordenada de Redis
    $redis->zadd($set, $key, $value);
 
    //cerramos la conexion a Redis.
    $redis->close();
    return true;
}

/**
 * Get Records SortedSet redis server
 * @param string $set nombre del sorted set de redis.
 * @param string $order_by indica si el listado lo devuelve en forma
 * descendente o ascendente.
 */
function getElementsSortedSetRedis($set, $order_by = "desc")
{
    //conectado a Redis
    $redis = connectRedis();
    $records = array();
 
    if ($order_by == "desc") {
        //zRevRangeByScore: metodo que retorna los elementos de un
        //sorted set en forma descendente.
        $records = $redis->zRevRangeByScore($set, '+inf', '-inf');
    } else if ($order_by == "asc") {
        //zRangeByScore: metodo que retorna los elementos de un
        //lista en forma ascendente.
        $records = $redis->zRangeByScore($set, '-inf', '+inf');
    }
    //cerramos conexion a redis.
    $redis->close();
 
    //devolvemos listado
    return $records;
}

/**
 * Get Count Set Order Redis Server
 * @param string $set, nombre de la lista ordenada en redis.
 * @return int cantidad total de registros de una lista.
 */
function getCountSortedSetRedis($set)
{
    //conectamos con redis
    $redis = connectRedis();
 
    //zCount: metodo que devuelve la cantidad de registros de una lista.
    (int) $value = $redis->zCount($set, '-inf', '+inf');
 
    //cerramos conexion
    $redis->close();
 
    //devolvemos el numero de registros de la lista.
    return $value;
}

--[[
LUA Script to delete items from list REDIS.
KEYS[1] = list name sent as a parameter.
KEYS[2] = datetime up to where you want to remove from the list.
--]]
local set = KEYS[1]
local maxValue = KEYS[2]
 
-- delete records sorted set redis.
local deleted = redis.call('zremrangebyscore',set,'-inf',maxValue)
-- return records deleted.
return deleted

/**
 * Delete elements sorted set from LUA Script
 * @param string $set lista name REDIS.
 * @param int $maxValue datetime up to where you want to remove from the list.
 */
function delElementsSortedSetRedisFromLua($set, $maxValue)
{
    //indicamos la ruta del script .lua
    (string) $filename = "/path/script.lua";
    //verificamos si existe el archivo .lua
    if (!file_exists($filename)) {
        throw new Exception('file procedure script not found.');
    }
    //cargamos el contenido del script.lua en una variable php.
    $luaScript = file_get_contents($filename, FILE_USE_INCLUDE_PATH);
    //declaramos los parametros que recibira nuestro script.lua
    $params = array($set, $maxValue);
    //cantidad de parametros a enviar al script.lua
    (int) $paramCount = count($params);
    //abrimos conexion a redis
    $redis = connectRedis();
    //usamos el metodo eval de redis para ejecutar script.lua
    (int) $deleted = $redis->eval($luaScript, $params, $paramCount);
    //cerramos conexion a redis.
    $redis->close();
    //devolvemos el numero de elementos eliminados que devuelve script.lua
    return $deleted;
}