Redis学习记录之Java中的初步使用

1.关于Redis

[html] view plain copy





redis下载地址：<span style="font-family: Arial, Helvetica, sans-serif;">http://download.csdn.net/detail/he90227/8569855</span>

[html] view plain copy





Redis是什么？两句话可以做下概括：

1. 是一个完全开源免费的key-value内存数据库

2. 通常被认为是一个数据结构服务器，主要是因为其有着丰富的数据结构 strings、map、 list、sets、 sorted sets

它通过提供多种键值数据类型来适应不同场景下的存储需求，并借助许多高层级的接口使其可以胜任如缓存、队列系统等不同的角色

和Memcached类似，但是解决了断电后数据完全丢失的情况，而且她支持更多无化的value类型，除了和string外，

还支持lists（链表）、sets（集合）和zsets（有序集合）几种数据类型。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的

2.支持的数据类型

字符串类型 string

散列类型 Hash

链表表类型 lists

集合类型 sets

有序集合类型 zsets

说明：

string是最简单的类型，你可以理解成与Memcached一模一个的类型，一个key对应一个value，其上支持的操作与Memcached的操作类似。但它的功能更丰富。

list是一个链表结构，主要功能是push、pop、获取一个范围的所有值等等。操作中key理解为链表的名字。

set是集合，和我们数学中的集合概念相似，对集合的操作有添加删除元素，有对多个集合求交并差等操作。操作中key理解为集合的名字。

zset是set的一个升级版本，他在set的基础上增加了一个顺序属性，这一属性在添加修改元素的时候可以指定，每次指定后，zset会自动重新按新的值调整顺序。可以理解了有两列的mysql表，一列存value，一列存顺序。操作中key理解为zset的名字。

Hash数据类型允许用户用Redis存储对象类型,Hash数据类型的一个重要优点是,当你存储的数据对象只有很少几个key值时,数据存储的内存消耗会很小.

3.内存存储于持久化

Redis数据库中的所有数据都存储在内存中，同时提供了对持久化的支持，即：可以将内存中的数据异步写入硬盘中，同时不会影响继续提供服务

redis主从配置

redis支持master-slave的主从配置，配置方法是在从机的配置文件中指定slaveof参数为主机的ip和port即可

4. Redis VS Memcached

1.都可以做为缓存系统使用

2.性能上Redis是单线程模型，Memcached支持多线程，所有在多核服务器上后者的性能更高一些

3.Redis支持高级的数据类型和持久化等功能

4.存储方式方面：Memcached只支持简单的key-value存储，不支持枚举，不支持持久化和复制等功能

5.安装Redis -- Redis官方仅支持 Linux、Unix和OS X，不支持Windows

Linux下安装： wget或拷贝到指定目录下 --- 解压后在src目录下使用macke命令完成编译

wget http://download.redis.io/redis-stable.tar.gz
tar xzf redis-stable.tar.gz

cd redis-stable

make

需要说明的事，redis的安装非常简单，已经有现成的Makefile文件，直接运行make命令即可。

make

make install

Redis 由四个可执行文件：redis-benchmark、redis-cli、redis-server、redis-stat 这四个文件，加上一个redis.conf就构成了整个redis的最终可用包。它们的作用如下：

redis-server：Redis服务器的daemon启动程序

redis-cli：Redis命令行操作工具。当然，你也可以用telnet根据其纯文本协议来操作

redis-benchmark：Redis性能测试工具，测试Redis在你的系统及你的配置下的读写性能

redis-stat：Redis状态检测工具，可以检测Redis当前状态参数及延迟状况

6.启动和停止Redis

编译后生成的可执行文件

redis-server ---- Redis 服务器

redis-cli ---- Redis命令行客户端

redis-server 是Redis的服务器，启动Redis即运行redis-server

redis-cli 是Redis自带的Redis命令行客户端，学习Redis的重要工具

启动Redis

1.直接启动 -- 运行redis-server即可启动redis

注意：

Redis服务器默认会使用6379端口，通过--port参数可以自定义使用的端口号

eg:

redis-server --port 6380

停止Redis

redis-cli shutdown

Redis有可能正在将内存中的数据同步到硬盘中，强行终止Redis进程可能会导致数据丢失，正确的做法是向Redis发送shutdown命令

当Redis收到shutdown命令后，会先断开所有客户端连接，然后根据配置执行持久化，最后完成退出

2.Redis配置和常用命令

[html] view plain copy





1.Redis配置

[html] view plain copy





redis.conf配置文件：

引用

#是否作为守护进程运行

daemonize yes

#配置pid的存放路径及文件名，默认为当前路径下

pidfile redis.pid

#Redis默认监听端口

port 6379

#客户端闲置多少秒后，断开连接

timeout 300

#日志显示级别

loglevel verbose

#指定日志输出的文件名，也可指定到标准输出端口

logfile stdout

#设置数据库的数量，默认连接的数据库是0，可以通过select N来连接不同的数据库

databases 16

#保存数据到disk的策略

#当有一条Keys数据被改变是，900秒刷新到disk一次

save 900 1

#当有10条Keys数据被改变时，300秒刷新到disk一次

save 300 10

#当有1w条keys数据被改变时，60秒刷新到disk一次

save 60 10000

#当dump .rdb数据库的时候是否压缩数据对象

rdbcompression yes

#dump数据库的数据保存的文件名

dbfilename dump.rdb

#Redis的工作目录

dir /home/falcon/redis-2.0.0/

########### Replication #####################

#Redis的复制配置

# slaveof <masterip> <masterport>

# masterauth <master-password>

############## SECURITY ###########

# requirepass foobared

############### LIMITS ##############

#最大客户端连接数

# maxclients 128

#最大内存使用率

# maxmemory <bytes>

########## APPEND ONLY MODE #########

#是否开启日志功能

appendonly no

# 刷新日志到disk的规则

# appendfsync always

appendfsync everysec

# appendfsync no

################ VIRTUAL MEMORY ###########

#是否开启VM功能

vm-enabled no

# vm-enabled yes

vm-swap-file logs/redis.swap

vm-max-memory 0

vm-page-size 32

vm-pages 134217728

vm-max-threads 4

############# ADVANCED CONFIG ###############

glueoutputbuf yes

hash-max-zipmap-entries 64

hash-max-zipmap-value 512

#是否重置Hash表

activerehashing yes

[html] view plain copy





常规操作命令

01 exits key //测试指定key是否存在，返回1表示存在，0不存在

02 del key1 key2 ....keyN //删除给定key,返回删除key的数目，0表示给定key都不存在

03 type key //返回给定key的value类型。返回 none 表示不存在key,string字符类型，list 链表类型 set 无序集合类型...

04 keys pattern //返回匹配指定模式的所有key,下面给个例子

05 randomkey //返回从当前数据库中随机选择的一个key,如果当前数据库是空的，返回空串

06 rename oldkey newkey //原子的重命名一个key,如果newkey存在，将会被覆盖，返回1表示成功，0失败。可能是oldkey不存在或者和newkey相同

07 renamenx oldkey newkey //同上，但是如果newkey存在返回失败

08 dbsize //返回当前数据库的key数量

09 expire key seconds //为key指定过期时间，单位是秒。返回1成功，0表示key已经设置过过期时间或者不存在

10 ttl key //返回设置过过期时间的key的剩余过期秒数 -1表示key不存在或者没有设置过过期时间

11 select db-index //通过索引选择数据库，默认连接的数据库所有是0,默认数据库数是16个。返回1表示成功，0失败

12 move key db-index //将key从当前数据库移动到指定数据库。返回1成功。0 如果key不存在，或者已经在指定数据库中

13 flushdb //删除当前数据库中所有key,此方法不会失败。慎用

14 flushall //删除所有数据库中的所有key，此方法不会失败。更加慎用

string 类型数据操作命令

01 set key value //设置key对应的值为string类型的value,返回1表示成功，0失败

02 setnx key value //同上，如果key已经存在，返回0 。nx 是not exist的意思

03 get key //获取key对应的string值,如果key不存在返回nil

04 getset key value //原子的设置key的值，并返回key的旧值。如果key不存在返回nil

05 mget key1 key2 ... keyN //一次获取多个key的值，如果对应key不存在，则对应返回nil。下面是个实验,首先清空当前数据库，然后设置k1,k2.获取时k3对应返回nil

06 mset key1 value1 ... keyN valueN //一次设置多个key的值，成功返回1表示所有的值都设置了，失败返回0表示没有任何值被设置

07 msetnx key1 value1 ... keyN valueN //同上，但是不会覆盖已经存在的key

08 incr key //对key的值做加加操作,并返回新的值。注意incr一个不是int的value会返回错误，incr一个不存在的key，则设置key为1

09 decr key //同上，但是做的是减减操作，decr一个不存在key，则设置key为-1

10 incrby key integer //同incr，加指定值 ，key不存在时候会设置key，并认为原来的value是 0

11 decrby key integer //同decr，减指定值。decrby完全是为了可读性，我们完全可以通过incrby一个负值来实现同样效果，反之一样。

12 append key value //给指定key的字符串值追加value,返回新字符串值的长度。下面给个例子

13 substr key start end //返回截取过的key的字符串值,注意并不修改key的值。下标是从0开始的，接着上面例子

list 类型数据操作命令

01 lpush key string //在key对应list的头部添加字符串元素，返回1表示成功，0表示key存在且不是list类型

02 rpush key string //同上，在尾部添加

03 llen key //返回key对应list的长度，key不存在返回0,如果key对应类型不是list返回错误

04 lrange key start end //返回指定区间内的元素，下标从0开始，负值表示从后面计算，-1表示倒数第一个元素 ，key不存在返回空列表

05 ltrim key start end //截取list，保留指定区间内元素，成功返回1，key不存在返回错误

06 lset key index value //设置list中指定下标的元素值，成功返回1，key或者下标不存在返回错误

07 lrem key count value //从key对应list中删除count个和value相同的元素。count为0时候删除全部

08 lpop key //从list的头部删除元素，并返回删除元素。如果key对应list不存在或者是空返回nil，如果key对应值不是list返回错误

09 rpop //同上，但是从尾部删除

10 blpop key1...keyN timeout //从左到右扫描返回对第一个非空list进行lpop操作并返回，比如blpop list1 list2 list3 0 ,如果list不存在list2,list3都是非空则对list2做lpop并返回从list2中删除的元素。如果所有的list都是空或不存在，则会阻塞timeout秒，timeout为0表示一直阻塞。当阻塞时，如果有client对key1...keyN中的任意key进行push操作，则第一在这个key上被阻塞的client会立即返回。如果超时发生，则返回nil。有点像unix的select或者poll

11 brpop //同blpop，一个是从头部删除一个是从尾部删除

12 rpoplpush srckey destkey //从srckey对应list的尾部移除元素并添加到destkey对应list的头部,最后返回被移除的元素值，整个操作是原子的.如果srckey是空或者不存在返回nil

set 类型数据操作命令

01 sadd key member //添加一个string元素到,key对应的set集合中，成功返回1,如果元素以及在集合中返回0,key对应的set不存在返回错误

02 srem key member //从key对应set中移除给定元素，成功返回1，如果member在集合中不存在或者key不存在返回0，如果key对应的不是set类型的值返回错误

03 spop key //删除并返回key对应set中随机的一个元素,如果set是空或者key不存在返回nil

04 srandmember key //同spop，随机取set中的一个元素，但是不删除元素

05 smove srckey dstkey member //从srckey对应set中移除member并添加到dstkey对应set中，整个操作是原子的。成功返回1,如果member在srckey中不存在返回0，如果key不是set类型返回错误

06 scard key //返回set的元素个数，如果set是空或者key不存在返回0

07 sismember key member //判断member是否在set中，存在返回1，0表示不存在或者key不存在

08 sinter key1 key2...keyN //返回所有给定key的交集

09 sinterstore dstkey key1...keyN //同sinter，但是会同时将交集存到dstkey下

10 sunion key1 key2...keyN //返回所有给定key的并集

11 sunionstore dstkey key1...keyN //同sunion，并同时保存并集到dstkey下

12 sdiff key1 key2...keyN //返回所有给定key的差集

13 sdiffstore dstkey key1...keyN //同sdiff，并同时保存差集到dstkey下

14 smembers key //返回key对应set的所有元素，结果是无序的

sorted set 类型数据操作命令

01 zadd key score member //添加元素到集合，元素在集合中存在则更新对应score

02 zrem key member //删除指定元素，1表示成功，如果元素不存在返回0

03 zincrby key incr member //增加对应member的score值，然后移动元素并保持skip list保持有序。返回更新后的score值

04 zrank key member //返回指定元素在集合中的排名（下标）,集合中元素是按score从小到大排序的

05 zrevrank key member //同上,但是集合中元素是按score从大到小排序

06 zrange key start end //类似lrange操作从集合中去指定区间的元素。返回的是有序结果

07 zrevrange key start end //同上，返回结果是按score逆序的

08 zrangebyscore key min max //返回集合中score在给定区间的元素

09 zcount key min max //返回集合中score在给定区间的数量

10 zcard key //返回集合中元素个数

11 zscore key element //返回给定元素对应的score

12 zremrangebyrank key min max //删除集合中排名在给定区间的元素

13 zremrangebyscore key min max //删除集合中score在给定区间的元素

hash 类型数据操作命令

01 hset key field value //设置hash field为指定值，如果key不存在，则先创建

02 hget key field //获取指定的hash field

03 hmget key filed1....fieldN //获取全部指定的hash filed

04 hmset key filed1 value1 ... filedN valueN //同时设置hash的多个field

05 hincrby key field integer //将指定的hash filed 加上给定值

06 hexists key field //测试指定field是否存在

07 hdel key field //删除指定的hash field

08 hlen key //返回指定hash的field数量

09 hkeys key //返回hash的所有field

10 hvals key //返回hash的所有value

11 hgetall //返回hash的所有filed和value

3.redis在Java中的使用

1.maven依赖：

[html] view plain copy





<!-- Redis依赖 -->

<dependency>

<groupId>redis.clients</groupId>

<artifactId>jedis</artifactId>

<version>2.7.0</version>

</dependency>

<!-- Spring整合Redis依赖 -->

<dependency>

<groupId>org.springframework.data</groupId>

<artifactId>spring-data-redis</artifactId>

<version>1.5.0.RELEASE</version>

</dependency>

2.客户端实例

[html] view plain copy





properties文件基本配置

redis.pool.maxActive=100

redis.pool.maxIdle=20

redis.pool.maxWait=3000

redis.ip=localhost

redis.port=6379

[html] view plain copy





import java.util.ResourceBundle;

import com.alibaba.fastjson.JSON;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

import redis.clients.jedis.ShardedJedis;

import redis.clients.jedis.ShardedJedisPool;

public class RedisClient {

public static JedisPool jedisPool; // 池化管理jedis链接池

static {

//读取相关的配置

ResourceBundle resourceBundle = ResourceBundle.getBundle("redis");

int maxActive = Integer.parseInt(resourceBundle.getString("redis.pool.maxActive"));

int maxIdle = Integer.parseInt(resourceBundle.getString("redis.pool.maxIdle"));

int maxWait = Integer.parseInt(resourceBundle.getString("redis.pool.maxWait"));

String ip = resourceBundle.getString("redis.ip");

int port = Integer.parseInt(resourceBundle.getString("redis.port"));

JedisPoolConfig config = new JedisPoolConfig();

//设置最大连接数

config.setMaxTotal(maxActive);

//设置最大空闲数

config.setMaxIdle(maxIdle);

//设置超时时间

config.setMaxWaitMillis(maxWait);

//初始化连接池

jedisPool = new JedisPool(config, ip, port);

}

/**

* 向缓存中设置字符串内容

* @param key key

* @param value value

* @return

* @throws Exception

*/

public static boolean set(String key,String value) throws Exception{

Jedis jedis = null;

try {

jedis = jedisPool.getResource();

jedis.set(key, value);

return true;

} catch (Exception e) {

e.printStackTrace();

return false;

}finally{

jedisPool.returnResource(jedis);

}

}

/**

* 向缓存中设置对象

* @param key

* @param value

* @return

*/

public static boolean set(String key,Object value){

Jedis jedis = null;

try {

String objectJson = JSON.toJSONString(value);

jedis = jedisPool.getResource();

jedis.set(key, objectJson);

return true;

} catch (Exception e) {

e.printStackTrace();

return false;

}finally{

jedisPool.returnResource(jedis);

}

}

/**

* 删除缓存中得对象，根据key

* @param key

* @return

*/

public static boolean del(String key){

Jedis jedis = null;

try {

jedis = jedisPool.getResource();

jedis.del(key);

return true;

} catch (Exception e) {

e.printStackTrace();

return false;

}finally{

jedisPool.returnResource(jedis);

}

}

/**

* 根据key 获取内容

* @param key

* @return

*/

public static Object get(String key){

Jedis jedis = null;

try {

jedis = jedisPool.getResource();

Object value = jedis.get(key);

return value;

} catch (Exception e) {

e.printStackTrace();

return false;

}finally{

jedisPool.returnResource(jedis);

}

}

/**

* 根据key 获取对象

* @param key

* @return

*/

public static <T> T get(String key,Class<T> clazz){

Jedis jedis = null;

try {

jedis = jedisPool.getResource();

String value = jedis.get(key);

return JSON.parseObject(value, clazz);

} catch (Exception e) {

e.printStackTrace();

return null;

}finally{

jedisPool.returnResource(jedis);

}

}

// private Jedis jedis; //非切片的客户端连接

// private JedisPool jedisPool; //非切片连接池

// private ShardedJedis shardedJedis; //切片的数据库连接

// private ShardedJedisPool shardedJedisPool; // 切片连接池

//

// public RedisClient() {

// initialPool();

// initialShardedPool();

// shardedJedis = shardedJedisPool.getResource();

// jedis = jedisPool.getResource();

// }

//

// /*

// * 初始化非切片池

// */

// private void initialPool() {

// //池基本配置

// JedisPoolConfig config = new JedisPoolConfig();

// config.setMaxIdle(5);

// config.set

// }

//

// private void initialShardedPool() {

// shardedJedisPool

//

// }

}

[html] view plain copy





测试代码

package com.jay.demo6.redis.test;

import org.junit.Test;

public class RedisDemoTest {

/*

* 向Redis中添加需要缓存的数据

*/

@Test

public void setUserCache() {

// 向缓冲中添加保存对象

UserDO user1 = new UserDO();

user1.setId(1111);

user1.setSex(true);

user1.setPhone("1783797435");

user1.setEmail("gfdsgjg@163.com");

// 调用方法处理

boolean resultCache = RedisClient.set("user1", user1);

if (resultCache) {

System.out.println("向缓存中保存对象成功。");

} else {

System.out.println("向缓存中保存对象失败。");

}

}

/*

*从Reids中获取缓存的数据

*/

@Test

public void getUserCahce(){

UserDO user1 = RedisClient.get("user1",UserDO.class);

if(user1!=null){

System.out.println(user1.toString());

}

}

}

[html] view plain copy





</pre><pre code_snippet_id="637583" snippet_file_name="blog_20150407_12_3514709" name="code" class="html">package com.jay.demo6.redis.test;

public class UserDO {

private int id;

private boolean sex;

private String name;

private String phone;

private String email;

public UserDO() {

super();

}

public int getId() {

return id;

}

public void setId(int id) {

this.id = id;

}

public boolean isSex() {

return sex;

}

public void setSex(boolean sex) {

this.sex = sex;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

public String getPhone() {

return phone;

}

public void setPhone(String phone) {

this.phone = phone;

}

public String getEmail() {

return email;

}

public void setEmail(String email) {

this.email = email;

}

@Override

public String toString() {

return "UserDO [id=" + id + ", sex=" + (sex?"男":"女") + ", name=" + name

+ ", phone=" + phone + ", email=" + email + "]";

}

}