Redis入门实战(4)-Jedis操作redis
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Redis入门实战(4)-Jedis操作redis，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含11276字，纯文字阅读大概需要17分钟。
内容图文
本文主要介绍redis命令行的使用，使用到的软件版本：Java 1.8.0_191、Redis 5.0.8、Jedis 3.3.0。
1、引入依赖
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.3.0</version>
</dependency>
2、基本操作
package com.inspur.demo.general.redis;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import redis.clients.jedis.Jedis;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 使用jedis来实现对redis的基本操作
*/
public class JedisBaseCase {
private Jedis jedis;
@Before
public void before() {
jedis = new Jedis("10.49.196.10");
jedis.auth("123456");
}
@After
public void after() {
jedis.close();
}
/***********************************Key begin*****************************/
/**
* 清空所有key
*/
@Test
public void flushAll() {
String status = jedis.flushAll();
System.out.println(status);
}
/**
* 重命名key
*/
@Test
public void rename() {
String status = jedis.rename("name", "name2");
System.out.println(status);
}
/**
* 重命名key,仅当新key不存在时才执行
* 返回值：
* 1：oldKey被重新命名
* 0：newKey已存在
*/
@Test
public void renamenx() {
long status = jedis.renamenx("name", "name3");
System.out.println(status);
}
/**
* 设置key的过期时间，以秒为单位
* 返回值：
* 1：成功设置了过期时间
* 0：key不存在
*/
@Test
public void expired() {
long status = jedis.expire("name", 100);
System.out.println(status);
}
/**
* 设置key的过期时间,它是距历元(即格林威治标准时间1970年1月1日00:00:00)的秒数。
* 返回值：
* 1：成功设置了过期时间
* 0：key不存在
*/
@Test
public void expiredAt() {
long status = jedis.expireAt("name", System.currentTimeMillis()/1000 + 100);
System.out.println(status);
}
/**
* 查询key的过期时间，单位秒
* 返回值：
* -1: 表示没有过期时间
* -2：表示key不存在
* 其他：key的过期时间
*/
@Test
public void ttl() {
long time = jedis.ttl("name");
System.out.println(time);
}
/**
* 持久化key
* 返回值：
* 1：成功持久化了
* 0：key不存在
*/
@Test
public void persist() {
long state = jedis.persist("name");
System.out.println(state);
}
/**
* 删除key
* 返回值：
* 成功删除的key的个数
* 0表示key都不存在
*/
@Test
public void del() {
long state = jedis.del("name", "name1");
System.out.println(state);
}
/***********************************Key end*******************************/
/***********************************String begin***************************/
@Test
public void set() {
String status = jedis.set("name", "mayun");
System.out.println(status);
}
/**
* 添加有过期时间的记录
*/
@Test
public void setex() {
String status = jedis.setex("name", 100, "mayun");
System.out.println(status);
}
/**
* 添加一条记录，仅当给定的key不存在时才插入
* 返回值：
* 1：成功设置了key
* 0：可以不存在
*/
@Test
public void setnx() {
long code = jedis.setnx("name", "mayun");
System.out.println(code);
}
@Test
public void mset() {
String status = jedis.mset("name", "mayun", "age", "50");
System.out.println(status);
}
@Test
public void get() {
String value = jedis.get("name");
System.out.println(value);
}
@Test
public void mget() {
List<String> value = jedis.mget("name", "age");
System.out.println(value);
}
/**
* 将key对应的value减去指定的值，只有value可以转为数字时该方法才可用
* 返回相减后的值
*/
@Test
public void decrBy() {
long value = jedis.decrBy("salary", 10);
System.out.println(value);
}
/**
* 将key对应的value加上指定的值，只有value可以转为数字时该方法才可用
* 返回相加后的值
*
* <b>可以作为获取唯一id的方法</b>
*/
@Test
public void incrBy() {
long value = jedis.incrBy("salary", 10);
System.out.println(value);
}
/**
* 设置Key的值并返回老的值
*/
@Test
public void getSet() {
String value = jedis.getSet("name", "马化腾");
System.out.println(value);
}
/***********************************String end***************************/
/***********************************list begin***************************/
/**
* 将一个或多个值插入到列表头部
* 返回插入队列的数据的个数
*/
@Test
public void lpush() {
Long num = jedis.lpush("list", "a", "b", "c");
System.out.println(num);
}
/**
* 将一个或多个值插入到列表尾部
* 返回插入队列的数据的个数
*/
@Test
public void rpush() {
Long num = jedis.rpush("list", "a", "b", "c");
System.out.println(num);
}
/**
* 将一个或多个值插入到已存在的列表头部
* 返回插入队列的数据的个数
*/
@Test
public void lpushx() {
Long num = jedis.lpushx("list", "1", "2", "3");
System.out.println(num);
}
/**
* 将一个或多个值插入到已存在的列表尾部
* 返回插入队列的数据的个数
*/
@Test
public void rpushx() {
Long num = jedis.rpushx("list", "1", "2", "3");
System.out.println(num);
}
/**
* 返回列表指定范围内的数据
*/
@Test
public void lrange() {
List<String> list = jedis.lrange("list", 0, 5);
System.out.println(list);
}
/***********************************list end***************************/
/***********************************hash begin***************************/
/**
* 返回值新增加的field的个数，如果field都已存在则更新并返回0
*/
@Test
public void hset() {
HashMap<String, String> values = new HashMap<>();
values.put("age", "50");
values.put("sex", "male");
long code = jedis.hset("mayun", values);
System.out.println(code);
code = jedis.hset("mayun", "address", "杭州");
System.out.println(code);
}
@Test
public void hgetAll() {
Map<String, String> value = jedis.hgetAll("mayun");
System.out.println(value);
}
/**
* 将field对应的value加上指定的值，只有value可以转为数字时该方法才可用
* 返回增加后的值
*/
@Test
public void hincrBy() {
long value = jedis.hincrBy("mayun", "age", 1);
System.out.println(value);
}
/***********************************hash begin***************************/
/***********************************set begin***************************/
/**
* 往set里增加元素
* 成功增加元素的个数，如果都已存在返回0
*/
@Test
public void sadd() {
long value = jedis.sadd("set", "a", "b");
System.out.println(value);
}
/**
* 移除set中的元素
* 1：成功移除
* 0：元素不存在
*/
@Test
public void srem() {
long value = jedis.srem("set", "a");
System.out.println(value);
}
/**
* 获取set里的所有元素
*/
@Test
public void smembers() {
Set<String> value = jedis.smembers("set");
System.out.println(value);
}
/***********************************set begin***************************/
/***********************************sorted set begin***************************/
/**
* 往sorted set里增加元素
* 1: 成功增加
* 0: 元素已存在
*/
@Test
public void zadd() {
long value = jedis.zadd("sortedset", 1, "a");
System.out.println(value);
value = jedis.zadd("sortedset", 2, "b");
System.out.println(value);
}
/**
* 移除sorted set中的元素
* 1：成功移除
* 0：元素不存在
*/
@Test
public void zrem() {
long value = jedis.zrem("sortedset", "a");
System.out.println(value);
}
/**
* 获取set里的所有元素
*/
@Test
public void zrange() {
Set<String> value = jedis.zrange("sortedkey", 0, 5);
System.out.println(value);
}
/***********************************sorted set end***************************/
/***********************************hyper begin***************************/
/**
* 添加指定元素到HyperLogLog中
* 返回成功天的个数，如果元素都已存在则返回0
*/
@Test
public void pfadd() {
long code = jedis.pfadd("hyper", "a", "b", "d");
System.out.println(code);
}
/**
* 返回给定HyperLogLog的基数估算值
*/
@Test
public void pfcount() {
long value = jedis.pfcount("hyper");
System.out.println(value);
}
/***********************************hyper end***************************/
}
3、高级操作
package com.inspur.demo.general.redis;
import org.junit.Before;
import org.junit.Test;
import redis.clients.jedis.*;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Set;
/**
* 高级操作
*/
public class JedisAdvancedCase {
private JedisPoolConfig config;
@Before
public void before() {
config = new JedisPoolConfig();
config.setMaxWaitMillis(1000 * 30);//当连接池内的连接耗尽时，最大的等待时间
config.setMaxTotal(20);//资源池的最大连接数
config.setMaxIdle(10);//资源池的最大空闲连接数
config.setMinIdle(5);//资源池的最小空闲连接数
config.setTestOnBorrow(true);//获取连接实例时，是否进行测试，默认false
config.setTestWhileIdle(true);//是否开启空闲资源检测, 默认false
config.setTimeBetweenEvictionRunsMillis(1000 * 10);//空闲资源的检测周期
}
/**
* 连接池操作
*/
@Test
public void jedisPool() {
JedisPool pool = new JedisPool(config, "10.49.196.10", 6379, 1000 * 10, "123456");
//获取Jedis实列
Jedis jedis = pool.getResource();
System.out.println(jedis.get("name"));
jedis.close();
pool.close();
}
/**
* 哨兵模式
*/
@Test
public void jedisSentinelPool() {
Set<String> sentinels = new HashSet<>();
sentinels.add("10.49.196.20:26379");
sentinels.add("10.49.196.21:26379");
sentinels.add("10.49.196.22:26379");
JedisSentinelPool pool = new JedisSentinelPool("mymaster", sentinels, config, 1000 * 5, "123456");
//获取Jedis实列
Jedis jedis = pool.getResource();
System.out.println(jedis.get("name"));
jedis.close();
pool.close();
}
/**
* 集群模式
*/
@Test
public void jedisCluster() {
Set<HostAndPort> set = new HashSet<HostAndPort>();
set.add(new HostAndPort("10.49.196.20", 7000));
set.add(new HostAndPort("10.49.196.20", 7001));
set.add(new HostAndPort("10.49.196.21", 7000));
set.add(new HostAndPort("10.49.196.21", 7001));
set.add(new HostAndPort("10.49.196.22", 7000));
set.add(new HostAndPort("10.49.196.22", 7001));
JedisCluster cluster = new JedisCluster(set, 1000 * 5, 1000 * 5, 5, "123456", config);
//JedisCluster的基础操作和Jedis很类似
//key
System.out.println("判断key是否存在：" + cluster.exists("name"));
System.out.println("查询key的过期时间：" + cluster.ttl("name"));
//String
System.out.println("设置键值对：" + cluster.set("name", "mahuateng"));
System.out.println("获取key对应的值：" + cluster.get("name"));
//List
System.out.println("将一个或多个值插入到列表头部：" + cluster.lpush("list", "a", "b", "c"));
System.out.println("返回列表指定范围内的数据：" + cluster.lrange("list", 0, 5));
//Hash
HashMap<String, String> values = new HashMap<>();
values.put("age", "50");
values.put("sex", "male");
System.out.println("在hash中设置field及value：" + cluster.hset("mayun", values));
System.out.println("在hash中所有属性及值：" + cluster.hgetAll("mayun"));
//set
System.out.println("往set里增加元素：" + cluster.sadd("set", "a", "b"));
System.out.println("取set里的所有元素：" + cluster.smembers("set"));
//sorted set
System.out.println("往sorted set里增加元素1：" + cluster.zadd("sortedset", 1, "a"));
System.out.println("往sorted set里增加元素2：" + cluster.zadd("sortedset", 2, "b"));
System.out.println("获取sorted set里的所有元素：" + cluster.zrange("sortedset",0, 5));
//集群信息
System.out.println("集群节点信息：" + cluster.getClusterNodes());
cluster.close();
}
}
4、JedisPoolConfig参数说明
JedisPoolConfig用来设置连接池的相关属性，具体参数如下：
| 参数名称 | 说明 | 默认值 | 建议 |
| maxTotal | 资源池中的最大连接数 | 8 | |
| maxIdle | 资源池中的最大空闲连接数 | 8 | |
| minIdle | 资源池中的最少空闲连接数 | 0 | |
| blockWhenExhausted | 当资源池用尽后，调用者是否要等待。只有当值为true时，下面的maxWaitMillis才会生效。 | true | 建议使用默认值 |
| maxWaitMillis | 当资源池连接用尽后，调用者的最大等待时间（单位为毫秒）。 | -1（表示永不超时） | 不建议使用默认值 |
| testOnBorrow | 向资源池借用连接时是否做连接有效性检测（ping）。检测到的无效连接将会被移除。 | false | 业务量很大时候建议设置为false，减少一次ping的开销。 |
| testOnReturn | 向资源池归还连接时是否做连接有效性检测（ping）。检测到无效连接将会被移除。 | false | 业务量很大时候建议设置为false，减少一次ping的开销。 |
| jmxEnabled | 是否开启JMX监控 | true | 建议开启，注意应用本身也需要开启。 |
| testWhileIdle | 是否开启空闲资源检测 | false | 建议开启 |
| timeBetweenEvictionRunsMillis | 空闲资源的检测周期（单位为毫秒） | -1（不检测） | 建议设置 |
| minEvictableIdleTimeMillis | 资源池中资源的最小空闲时间（单位为毫秒），达到此值后空闲资源将被移除。 | 1800000（即30分钟） | 可根据自身业务决定，一般默认值即可 |
| numTestsPerEvictionRun | 做空闲资源检测时，每次检测资源的个数。 | 3 | 可根据自身应用连接数进行微调，如果设置为 -1，就是对所有连接做空闲监测。 |
内容总结
以上是互联网集市为您收集整理的Redis入门实战(4)-Jedis操作redis全部内容，希望文章能够帮你解决Redis入门实战(4)-Jedis操作redis所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】