数据库 java Jedis、RedisTemplate、Redisson 详解和实例

Jedis 是 Redis 官方推荐的面向 Java 的操作Redis 的客户端，通过jedis我们可以实现连接Redis，以及操作 Redis 。

一、Jedis 需要注意的点

   在redis3.2之后，redis增加了protected-mode，在这个模式下，即使注释掉了bind 127.0.0.1，再访问redisd时候还是报错查看redis.confy文件，如果protected-mode 是 yes 那么需要设置用户密码

1、Jedis类

Jedis父类BinaryJedis所依赖的接口：

BasicCommands:

提供基础的查询命令,如ping,quit,flushdb

BinaryJedisCommands:

提供了针对redis数据结构的CURD等操作,其中参数(K-V)必须以byte数组形式提供

MultiKeyBinaryCommands:

提供了针对redis数据结构的CURD等批量操作,其中参数(K-V)必须以byte数组形式提供

AdvancedBinaryJedisCommands:

提供高级操作redis的命令,如config相关,slowlog,client等命令,其中参数(K-V)必须以byte数组形式提供

BinaryScriptingCommands:

提供Lua脚本运行命令,命令必须以byte数组形式提供。

Jedis所依赖的接口：

JedisCommands:

提供了针对redis数据结构的CURD等操作,其中参数(K-V)必须以String形式提供

MultiKeyCommands:

提供了针对redis数据结构的CURD等批量操作,其中参数(K-V)必须以String数组形式提供

AdvancedJedisCommands:

提供高级操作redis的命令,如config相关,slowlog,client等命令,其中参数(K-V)必须以String形式提供

ScriptingCommands:

提供Lua脚本运行命令,命令必须以String形式提供。

BasicCommands:

提供如ping,quit,flushDb运维类命令

ClusterCommands:

提供集群状态查看,集群操作的命令

SentinelCommands:

提供哨兵操作命令

ModuleCommands:

提供redis模块加载和卸载命令

引入pom:

redis.clients

jedis

2.9.0

jar

compile

 yml文件配置：

redis:

host: 127.21.55.48

port: 6398

password: 88888

jedis:

pool:

#最大连接数

max-active: 8

#最大阻塞等待时间(负数表示没限制)

max-wait: -1

#最大空闲

max-idle: 8

#最小空闲

min-idle: 0

#连接超时时间

timeout: 10000

2、基本用法示例

2.1 在多线程环境中使用 Jedis

您不应该使用来自不同线程的同一实例，因为会出现奇怪的错误。有时创建大量Jedis实例还不够好，因为这意味着大量的套接字和连接，这也会导致奇怪的错误。单个Jedis实例不是线程安全的！为了避免这些问题，您应该使用JedisPool，这是一个线程安全的网络连接池。如果完成后将Jedis实例返回到池中，则可以使用池可靠地创建多个Jedis示例。通过这种方式，您可以克服这些奇怪的错误并获得出色的性能。

要使用它，请初始化池：

JedisPool pool = new JedisPool(new JedisPoolConfig(), "localhost");

您可以将池静态存储在某个位置，它是线程安全的。

JedisPoolConfig 包括许多有用的 Redis 特定连接池默认值。JedisPool基于Commons Pool 2，所以你可能想看看Commons Pool的配置。

您可以通过以下方式使用它：

/// Jedis implements Closeable. Hence, the jedis instance will be auto-closed after the last statement.

try (Jedis jedis = pool.getResource()) {

/// ... do stuff here ... for example

jedis.set("foo", "bar");

String foobar = jedis.get("foo");

jedis.zadd("sose", 0, "car"); jedis.zadd("sose", 0, "bike");

Set sose = jedis.zrange("sose", 0, -1);

}

/// ... when closing your application:

pool.close();

如果您不能在资源中使用try，您仍然可以使用Jedis.close（）。

Jedis jedis = null;

try {

jedis = pool.getResource();

/// ... do stuff here ... for example

jedis.set("foo", "bar");

String foobar = jedis.get("foo");

jedis.zadd("sose", 0, "car"); jedis.zadd("sose", 0, "bike");

Set sose = jedis.zrange("sose", 0, -1);

} finally {

// You have to close jedis object. If you don't close then

// it doesn't release back to pool and you can't get a new

// resource from pool.

if (jedis != null) {

jedis.close();

}

}

/// ... when closing your application:

pool.close();

若Jedis是从池中借用的，那个么它将使用正确的方法返回到池中，因为它已经确定发生了JedisConnectionException。若Jedis不是从池中借来的，它将被断开并关闭。

2.1 设置主/从分配

启用复制

Redis 主要用于主/从分发。这意味着写入请求必须显式发送到主服务器（redis 服务器），后者将更改复制到从服务器（也是 redis 服务器）。然后，读取请求可以（但不一定）发送给从站，从而减轻了主站的负担。

您可以使用主控形状，如上所示。为了启用复制，有两种方法可以告诉从站它将是给定主服务器的“slaveOf”：

在 Redis 服务器的 Redis 配置文件的相应部分中指定它 在给定的 jedis 实例上（见上文），调用 slaveOf 方法并将 IP（或“localhost”）和端口作为参数传递：

jedis.slaveof("localhost", 6379); // if the master is on the same PC which runs your code

jedis.slaveof("192.168.1.35", 6379);

注意：由于默认情况下Redis 2.6从设备是只读的，因此对它们的写入请求将导致错误。 如果您更改该设置，它们的行为将与正常的redis服务器一样，并接受写入请求而不会出错，但这些更改不会被复制，因此，如果您混淆了jedis实例，这些更改可能会被默默覆盖。

禁用复制/主服务器出现故障时，升级从属服务器

万一你的主人倒下了，你可能想提拔一个奴隶成为新的主人。您应该首先（尝试）首先禁用脱机主服务器的复制，然后，如果您有多个从站，请启用剩余从站到新主站的复制：

slave1jedis.slaveofNoOne();

slave2jedis.slaveof("192.168.1.36", 6379);

详细请参阅：Jedis 使用详解（官方原版）

二、RedisTemplate使用

RedisTemplate方式是SpringBoot集成Redis的客户端方式 ,SpringDataRedis 中对JedisAp i的高度封装。SpringDataRedis 相对于 Jedis 来说可以方便地更换 Redis 的 Java客户端，比 Jedis 多了自动管理连接池的特性，方便与其他 Spring 框架进行搭配使用如：SpringCache

官网：Spring Boot Reference Guide

接口：RedisTemplate (Spring Data Redis 3.0.2 API)

引入pom:

org.projectlombok

lombok

true

org.springframework.boot

spring-boot-starter-data-redis

com.alibaba

fastjson

1.2.3

yml文件配置：

redis:

host: 192.168.159.133

port: 6379

database: 0

jedis:

pool:

max-active: 10

max-idle: 5

min-idle: 0

max-wait: 60000

redisTemplate.opsForValue();//操作字符串 redisTemplate.opsForHash();//操作hash redisTemplate.opsForList();//操作list redisTemplate.opsForSet();//操作set redisTemplate.opsForZSet();//操作有序set  //向redis里存入数据和设置缓存时间 //参数1：是key 键 //参数2：是值 是存入redis里的值 //参数3：时间，类型为long //参数4：时间类型， 如：TimeUnit.MILLISECONDS 代表分钟   RedisTemplate.opsForValue().set("baike", "100", 60 * 10, TimeUnit.SECONDS); //根据key获取缓存中的val   RedisTemplate.opsForValue().get("baike") //根据key获取过期时间并指定返回形式   RedisTemplate.opsForValue().getOperations.getExpire("baike",TimeUnit.HOURS); //根据key获取过期时间并换算成指定单位 RedisTemplate.getExpire("baike",TimeUnit.SECONDS); //根据key删除缓存   RedisTemplate.delete("baike"); //检查key是否存在，返回boolean值   RedisTemplate.hasKey("baike"); //向指定key中存放set集合   RedisTemplate.opsForSet().add("baike", "1","2","3"); //设置过期时间   RedisTemplate.expire("baike",1000 , TimeUnit.MILLISECONDS); //根据key查看集合中是否存在指定数据  

示例代码：

@Autowired

RedisTemplate redisTemplate;

/**

* 指定key的失效时间

*/

@GetMapping("expire")

public void expire(String key, long time) {

//参数一：key

//参数二：睡眠时间

//参数三：睡眠时间单位 TimeUnit.DAYS 天 TimeUnit.HOURS 小时 。。。

redisTemplate.expire(key, time, TimeUnit.MINUTES);

}

/**

* 根据key获取过期时间

*/

@GetMapping("getexpire")

public long getExpire(String key) {

Long expire = redisTemplate.getExpire(key);

return expire;

}

/**

* 判断key是否存在

*/

@GetMapping("haskey")

public boolean hasKey(String key) {

return redisTemplate.hasKey(key);

}

/**

* 根据key删除reids中缓存数据

*/

@GetMapping("delredisbykey")

public void delete(String key) {

redisTemplate.delete(key);

}

/**

* 保存和读取String

*/

@GetMapping("stringredisdemo")

public String stringredisdemo() {

//设置过期时间为1分钟

redisTemplate.opsForValue().set("key1", "value1", 1, TimeUnit.MINUTES);

redisTemplate.opsForValue().set("key2", "value2");

redisTemplate.opsForValue().set("key3", "value3");

//读取redis数据

String result1 = redisTemplate.opsForValue().get("key1").toString();

String result2 = redisTemplate.opsForValue().get("key2").toString();

String result3 = redisTemplate.opsForValue().get("key3").toString();

System.out.println("缓存结果为：result：" + result1 + " " + result2 + " " + result3);

return "缓存结果为：result：" + result1 + " " + result2 + " " + result3;

}

/**

* 保存和读取list

*/

@GetMapping("listredisdemo")

public String listredisdemo() {

List list1 = new ArrayList<>();

list1.add("a1");

list1.add("a2");

list1.add("a3");

List list2 = new ArrayList<>();

list2.add("b1");

list2.add("b2");

list2.add("b3");

redisTemplate.opsForList().leftPush("listkey1", list1);

redisTemplate.opsForList().rightPush("listkey2", list2);

List resultList1 = (List) redisTemplate.opsForList().leftPop("listkey1");

List resultList2 = (List) redisTemplate.opsForList().rightPop("listkey2");

System.out.println("resultList1:" + resultList1);

System.out.println("resultList2:" + resultList2);

return "成功";

}

/**

* Hash结构，保存和读取map

*/

@GetMapping("mapredisdemo")

public String mapredisdemo() {

Map map = new HashMap<>();

map.put("key1", "value1");

map.put("key2", "value2");

map.put("key3", "value3");

redisTemplate.opsForHash().putAll("map1", map);

Map resultMap = redisTemplate.opsForHash().entries("map1");

List reslutMapList = redisTemplate.opsForHash().values("map1");

Set resultMapSet = redisTemplate.opsForHash().keys("map1");

String value = (String) redisTemplate.opsForHash().get("map1", "key1");

System.out.println("value:" + value);

System.out.println("resultMapSet:" + resultMapSet);

System.out.println("resultMap:" + resultMap);

System.out.println("resulreslutMapListtMap:" + reslutMapList);

return "成功";

}

/**

* 保存和读取Set

*/

@GetMapping("setredisdemo")

public String getredisdemo() {

SetOperations set = redisTemplate.opsForSet();

set.add("key1", "value1");

set.add("key1", "value2");

set.add("key1", "value3");

Set resultSet = redisTemplate.opsForSet().members("key1");

System.out.println("resultSet:" + resultSet);

return "resultSet:" + resultSet;

}

/**

* 保存和读取zset

*/

@GetMapping("zsetredisdemo")

public String zsetredisdemo() {

ZSetOperations.TypedTuple