Rhiredis

Rhiredis is a wrapper of hiredis, which is a minimalistic C client library for the Redis database.

Rhiredis is much faster than rredis. However, it internally converts every objects to character and send them to redis server. The user could still save R objects completely into redis server with base::serialize and base64enc::base64encode. Please read the benchmark of objects for example.

Dependencies

• boost shared_ptr
• git
• R packages
  • Rcpp
  • bit64

Install

git clone https://github.com/wush978/Rhiredis.git
cd Rhiredis
git submodule init 
git submodule update --recursive
R CMD INSTALL .

Getting Start

library(Rhiredis)

con <- redisConnect()
redisSET("a", "b") # "OK"
redisGET("a")

The name pattern of functions is redis<Command name>. Please read http://redis.io/commands for more details about commands of redis.

Benchmark

Character

The following example compares the time of inserting strings to redis server between Rhiredis and rredis.

suppressPackageStartupMessages(library(Rhiredis))
suppressPackageStartupMessages(library(base64enc))
suppressPackageStartupMessages(library(rredis))
suppressPackageStartupMessages(library(rbenchmark))

con <- Rhiredis::redisConnect()
rredis::redisConnect()

benchmark(Rhiredis::redisSET("a1", "b1"), rredis::redisSet("a2", "b2"))

##                             test replications elapsed relative user.self
## 1 Rhiredis::redisSET("a1", "b1")          100   0.017      1.0     0.016
## 2   rredis::redisSet("a2", "b2")          100   4.002    235.4     0.228
##   sys.self user.child sys.child
## 1    0.000          0         0
## 2    0.004          0         0

Rhiredis::redisGET("a1")

## [1] "b1"

rredis::redisGet("a2")

## [1] "b2"

Object

The following example compares the time of inserting R object into redis server between Rhiredis and rredis.

suppressPackageStartupMessages(library(Rhiredis))
suppressPackageStartupMessages(library(base64enc))
suppressPackageStartupMessages(library(rredis))
suppressPackageStartupMessages(library(rbenchmark))

con <- Rhiredis::redisConnect()
rredis::redisConnect()

benchmark(Rhiredis::redisSET("a1", base64encode(serialize(iris, NULL))), rredis::redisSet("a2", 
    iris))

## Warning: closing unused connection 5 (->localhost:6379)

##                                                            test
## 1 Rhiredis::redisSET("a1", base64encode(serialize(iris, NULL)))
## 2                                  rredis::redisSet("a2", iris)
##   replications elapsed relative user.self sys.self user.child sys.child
## 1          100   0.026      1.0     0.016    0.004          0         0
## 2          100   4.000    153.8     0.224    0.008          0         0

all.equal(unserialize(base64decode(Rhiredis::redisGET("a1"))), iris)

## [1] TRUE

all.equal(rredis::redisGet("a2"), iris)

## [1] TRUE

License

GNU GENERAL PUBLIC LICENSE Version 3, 29 June 2007