R语言利剑之NoSQL系列:Redis(1)

R语言利剑之NoSQL系列:Redis(1)

Redis环境准备 rredis函数库 rredis基本使用操作 rredis使用案例

每一章节，都会分为”文字说明部分”和”代码部分”，保持文字说明与代码的连贯性。

第一章 Redis环境准备

文字说明部分：

首先环境准备，这里我选择了Linux Ubuntu操作系统12.04的64位服务器版本，大家可以根据自己的使用习惯选择顺手的Linux。

Redis安装过程跳过。sudo apt-get install redis-server

查看Redis服务器环境

使用/etc/init.d/redis-server命令，启动redis-server， 默认端口：port=6379

在服务器端，用telnet连接redis-server

用telnet插入数据，读取数据

R语言环境2.15.0，WinXP通过远程连接，访问Redis server。

代码部分：

查看操作系统 

~ uname -a      Linux AY121111030241cda8003 3.2.0-29-generic #46-Ubuntu SMP Fri Jul 27 17:03:23 UTC 2012 x86_64 x86_64 x86_64 GNU/Linux  ~ cat /etc/issue      Ubuntu 12.04.1 LTS \n \l  

启动redis 

~ /etc/init.d/redis-server start      Starting redis-server: redis-server.  

查看系统进程 

~ ps -aux|grep redis      redis    20128  0.0  0.0  10676  1428 ?        Ss   16:39   0:00 /usr/bin/redis-server /etc/redis/redis.conf  

查看启日志

~ cat  /var/log/redis/redis-server.log       
[20128] 14 Apr 16:39:43 * Server started, Redis version 2.2.12     
[20128] 14 Apr 16:39:43 # WARNING overcommit_memory is set to 0! Background save may fail under low memory condition. To fix this issue add 'vm.overcommit_memory = 1' to /etc/sysctl.conf and then reboot or run the command 'sysctl vm.overcommit_memory=1' for this to take effect.    
[20128] 14 Apr 16:39:43 * The server is now ready to accept connections on port 6379  

telnet连接redis-server

~ telnet localhost 6379      Trying 127.0.0.1...     Connected to localhost.     Escape character is '^]'.  

插入数据

rpush data 1     :1      rpush data 2     :2  

查询数据 

lrange data 0 -1     *2     $1     1     $1     2  

R语言开发环境2.15.0，WinXP

~ R R version 2.15.0 (2012-03-30) Copyright (C) 2012 The R Foundation for Statistical Computing ISBN 3-900051-07-0 Platform: i386-pc-mingw32/i386 (32-bit) 

第二章 rredis函数库

rredis提供了100函数，对应用redis的操作。虽然函数也不少，但是用法都是比较简单的，对R语言支持足够灵活，代码也比较简洁。

下面列出了所有rredis函数库，我只挑选一些常用的介绍。

文字说明部分：

建立连接，关闭连接

redisConnect() , redisClose()  

清空当前/所有数据库数据 

redisFlushDB() , redisFlushAll()  

列出所有KEY值，KEY的数量 

redisKeys(), redisDBSize()  

选择切换数据库:0是默认数据库 

redisSelect(0)      

插入string对象，批量插入 

redisSet('x',runif(5)), redisMSet(list(x=pi,y=runif(5),z=sqrt(2)))  

读取string对象，批量读取 

redisGet('x'), redisMGet(c('x','y','z'))  

删除对象 

redisDelete('x')  

左边插入数组对象,右边插入数组对象

redisLPush('a',1), redisRPush('a','A')  

左边弹出一个数组对象， 右边弹出一个数组对象， 

redisLPop('a'), redisRPop('a')  

从左边显示数组对象列表 

redisLRange('a',0,-1)  

插入set类型对象 

redisSAdd('A',runif(2))  

显示set对象有几个元素，列表显示set对象元素 

redisSCard('A'), redisSMembers('A')  

显示两个set对象的差集，交集，并集 

redisSDiff(c('A','B')),redisSInter(c('A','B')),redisSUnion(c('A','B'))  

代码部分：

共有100个函数

redisAuth redisBgRewriteAOF redisBgSave redisBLPop redisBRPop redisBRPopLPush redisClose redisCmd redisConnect redisDBSize 
redisDecr redisDecrBy redisDelete redisDiscard redisEval redisExec redisExists redisExpire redisExpireAt redisFlushAll redisFlushDB 
redisGet redisGetContext redisGetResponse redisGetSet redisHDel redisHExists redisHFields redisHGet redisHGetAll redisHIncrBy redisHKeys 
redisHLen redisHMGet redisHMSet redisHSet redisHVals redisIncr redisIncrBy redisInfo redisKeys redisLIndex redisLLen redisLPop redisLPush 
redisLRange redisLRem redisLSet redisLTrim redisMGet redisMonitorChannels redisMove redisMSet redisMulti redisPublish redisRandomKey 
redisRename redisRPop redisRPopLPush redisRPush redisSAdd redisSave redisSCard redisSDiff redisSDiffStore redisSelect redisSet
 redisSetBlocking redisSetContext redisShutdown redisSInter redisSInterStore redisSIsMember redisSlaveOf redisSMembers redisSMove
 redisSort redisSPop redisSRandMember redisSRem redisSubscribe redisSUnion redisSUnionStore redisTTL redisType redisUnsubscribe 
redisUnwatch redisWatch redisZAdd redisZCard redisZIncrBy redisZInterStore redisZRange redisZRangeByScore redisZRank redisZRem 
redisZRemRangeByRank redisZRemRangeByScore redisZScore redisZUnionStore 

第三章 rredis基本使用操作

文字说明部分：

首先，要安装rredis类库，加载类库。

redisConnect(host=“192.168.1.101”,port=6379)

然后，通过redisConnect()函数，建立与Redis Server的连接。如果是本地连接redisConnect()不要参数，下面例子使用远程连接，增加host参数配置IP地址。redisConnect(host=“192.168.1.101”,port=6379)

redis的基本操作：建议链接，切换数据库，列表显示所有KEY值，清空当前数据库数据，清空所有数据库数据，关闭链接，

string类型操作：插入，读取，删除，插入并设置过期时间，批量操作

list类型操作：插入，读取，弹出

set类型操作：插入，读取，交集，差集，并集

rredis与redis-cli的交互操作

代码部分：

redis的基本操作：

#安装rredis 
install.packages(rredis) 
 
#加载rredis类库 
library(rredis) 
 
#远程连接redis server 
redisConnect(host="192.168.1.101",port=6379) 
 
#列出所有的keys 
redisKeys() 
    [1] "x"    "data" 
 
#显示有多少个key 
redisDBSize() 
    [1] 2 
 
#切换数据库1 
redisSelect(1) 
    [1] "OK" 
redisKeys() 
    NULL 
 
#切换数据库0 
redisSelect(0) 
    [1] "OK" 
redisKeys() 
    [1] "x"    "data" 
 
#清空当前数据库数据 
redisFlushDB() 
    [1] "OK" 
 
#清空所有数据库数据 
redisFlushAll() 
    [1] "OK" 
 
#关闭链接 
redisClose() 

string类型操作:

#插入对象 
redisSet('x',runif(5)) 
    1] "OK" 
 
#读取对象 
redisGet('x') 
    [1] 0.67616159 0.06358643 0.07478021 0.32129140 0.16264615 
 
#设置数据过期时间 
redisExpire('x',1) 
Sys.sleep(1) 
redisGet('x') 
    NULL 
 
#批量插入 
redisMSet(list(x=pi,y=runif(5),z=sqrt(2))) 
    [1] TRUE 
 
#批量读取 
redisMGet(c('x','y','z')) 
    $x 
    [1] 3.141593 
    $y 
    [1] 0.9249501 0.3444994 0.6477250 0.1681421 0.2646853 
    $z 
    [1] 1.414214 
 
#删除数据     
redisDelete('x') 
    [1] 1 
redisGet('x') 
    NULL