Redis-Jedis客户端API
本文章几乎涵盖看Jedis对Redis中的各种数据结构如string、队列、栈、集合、map、地理位置、基数统计、位存储等数据结构的详细Api
连接Redis服务
依赖引入
在使用Jedis连接Redis客户端时，首先需要引入Jedis依赖
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.6.0</version>
</dependency>
单机连接
Jedis连接单机Redis使用起来是很简单的只需要使用Jedis的构造器即可获取一个jedis客户端
public class JedisTest {
public static void main(String[] args) {
Jedis jedis = new Jedis("localhost",6379);
System.out.println(jedis.set("test1", "123"));
System.out.println(jedis.set("test2", "123"));
System.out.println(jedis.get("test2"));
System.out.println(jedis.get("test2"));
}
}
集群连接
Jedis集群连接着需要使用JedisCluster对象的构造函数，并且需要传入Set集合的Redis集群所有服务的地址，最终得到客户端调用api的方式与单机版本无差别
public class JedisClusterTest {
public static void main(String[] args) throws IOException {
Set<HostAndPort> jedisClusterNode = new HashSet<>();
jedisClusterNode.add(new HostAndPort("192.168.100.101",8001));
jedisClusterNode.add(new HostAndPort("192.168.100.101",8002));
jedisClusterNode.add(new HostAndPort("192.168.100.102",8003));
jedisClusterNode.add(new HostAndPort("192.168.100.102",8004));
jedisClusterNode.add(new HostAndPort("192.168.100.103",8005));
jedisClusterNode.add(new HostAndPort("192.168.100.103",8006));
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(100);
config.setMaxIdle(10);
config.setTestOnBorrow(true);
JedisCluster jedisCluster = new JedisCluster(jedisClusterNode,
6000,
5000,
10,
"123456",
config);
System.out.println(jedisCluster.set("test1", "123"));
System.out.println(jedisCluster.set("test2", "123"));
System.out.println(jedisCluster.get("test2"));
System.out.println(jedisCluster.get("test2"));
jedisCluster.close();
}
}
常用API
以下代码执行命令前都调用了
Jedis jedis = new Jedis("localhost",6379);获取到客户端后才进行如下api操作的
基本指令
首先列举的是一些基本指令，也是使用的比较频繁的指令
System.out.println("清空当前数据："+jedis.flushDB());
System.out.println("判断某个键是否存在："+jedis.exists("username"));
System.out.println("新增<username,lzj>的键值对："+jedis.set("username","lzj"));
Set<String> keys = jedis.keys("*");
System.out.println("当前Redis下所有数据："+keys);
System.out.println("查看key所存储的值的类型："+jedis.type("username"));
System.out.println("删除key："+jedis.del("username"));
键值对操作
键值对操作即使
key,value操作也是redis中最常用的操作，以下列举了一些非常常用的API
jedis.flushDB();
System.out.println("新增1个键值对："+jedis.set("key1", "value1"));
System.out.println("在key1后面追加内容："+jedis.append("key1", "append"));
System.out.println("获取1个key的值："+jedis.get("key1"));
jedis.flushDB();
System.out.println("一次性设置多个键值对："+jedis.mset("key1","value1","key2","value2","key3","value3"));
System.out.println("一次性获取多个键值对："+jedis.mget("key1","key2","key3"));
System.out.println("一次性删除多个键值对："+jedis.del("key1","key2"));
System.out.println("一次性获取多个键值对："+jedis.mget("key1","key2","key3"));
jedis.flushDB();
System.out.println("=========新增并检查key，不存在新增，存在不操作=========");
System.out.println("新增1个键值对："+jedis.setnx("key4", "value4"));
System.out.println("尝试修改key4："+jedis.setnx("key4", "newValue4"));
System.out.println("获取key4的值："+jedis.get("key4"));
System.out.println("================获取原值，并传入新值================");
System.out.println("新增1个键值对："+jedis.set("key5", "value5"));
System.out.println("获取key5并且传入新值："+jedis.getSet("key5", "newValue5"));
System.out.println("获取key5的值："+jedis.get("key5"));
设置键过期操作
对某一个key指定过期时间，或查阅过期时间等操作
jedis.flushDB();
System.out.println("新增key并且设置60秒后过期："+jedis.setex("username",60L,"lzj"));
System.out.println("查看key过期倒计时（秒）："+jedis.ttl("username"));
System.out.println("查看key过期倒计时（毫秒）："+jedis.pttl("username"));
System.out.println("修改key10秒后过期："+jedis.expire("username",10L));
System.out.println("查看key过期倒计时（秒）："+jedis.ttl("username"));
分布式下原子性操作
对指定key进行原子++或–操作，通常由于分布式下的原子性操作
System.out.println("=========多客户端同时操作num进行原子性=========");
jedis.flushDB();
//创建一个Runnable循环对指定num进行原子性+1操作
class NumIncr implements Runnable{
//创建一个Jedis客户端
private final Jedis ThreadJedis = new Jedis("localhost",6379);
@Override
public void run() {
String name = Thread.currentThread().getName();
for (int i = 0; i < 5; i++) {
System.out.println(name + "原子性操作num+1："+ThreadJedis.incr("num"));
// System.out.println(name + "原子性操作num-1："+ThreadJedis.decr("num"));
}
}
}
Thread t1 = new Thread(new NumIncr(),"线程1");
Thread t2 = new Thread(new NumIncr(),"线程2");
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println("查看num的值："+jedis.get("num"));
List(数组)
List的基本操作以及，常用api
jedis.flushDB();
System.out.println("新增1个List："+jedis.rpush("list","3","6","2","7","1","2"));
System.out.println("查看List内容："+jedis.lrange("list",0,-1));
System.out.println("查看List长度："+jedis.llen("list"));
System.out.println("对List内容排序并返回："+jedis.sort("list"));
System.out.println("查看List内容："+jedis.lrange("list",0,-1));
System.out.println("获取下标0的值："+jedis.lindex("list",0));
System.out.println("替换下标0的值："+jedis.lset("list",0,"three"));
System.out.println("查看List内容："+jedis.lrange("list",0,-1));
System.out.println("在three前面插入值(before)："+jedis.linsert("list", ListPosition.BEFORE,"three","before"));
System.out.println("在three后面插入值(after)："+jedis.linsert("list", ListPosition.AFTER,"three","after"));
System.out.println("查看List内容："+jedis.lrange("list",0,-1));
System.out.println("保留下标0-2元素其余丢弃："+jedis.ltrim("list",0,2));
System.out.println("查看List内容："+jedis.lrange("list",0,-1));
List(队列)
List(队列)数据结构的api使用，特性先进先出
jedis.flushDB();
System.out.println("===============利用List完成队列入队操作===============");
System.out.println("从queue左侧插入元素："+jedis.lpush("queue","1"));
System.out.println("查看queue内容："+jedis.lrange("queue",0,-1));
System.out.println("从queue左侧插入元素："+jedis.lpush("queue","2"));
System.out.println("查看queue内容："+jedis.lrange("queue",0,-1));
System.out.println("从queue左侧插入元素："+jedis.lpush("queue","3"));
System.out.println("查看queue内容："+jedis.lrange("queue",0,-1));
System.out.println("===============利用List完成队列出队操作===============");
System.out.println("查看queue内容："+jedis.lrange("queue",0,-1));
System.out.println("从queue右侧获取元素："+jedis.rpop("queue"));
System.out.println("查看queue内容："+jedis.lrange("queue",0,-1));
System.out.println("从queue右侧获取元素："+jedis.rpop("queue"));
System.out.println("查看queue内容："+jedis.lrange("queue",0,-1));
System.out.println("从queue右侧获取元素："+jedis.rpop("queue"));
List(栈)
List(栈)数据结构的api使用，特性先进先出
jedis.flushDB();
System.out.println("===============利用List完成入栈操作===============");
System.out.println("从stack左侧插入元素："+jedis.lpush("stack","1"));
System.out.println("查看stack内容："+jedis.lrange("stack",0,-1));
System.out.println("从stack左侧插入元素："+jedis.lpush("stack","2"));
System.out.println("查看stack内容："+jedis.lrange("stack",0,-1));
System.out.println("从stack左侧插入元素："+jedis.lpush("stack","3"));
System.out.println("查看stack内容："+jedis.lrange("stack",0,-1));
System.out.println("===============利用List完成出栈操作===============");
System.out.println("查看stack内容："+jedis.lrange("stack",0,-1));
System.out.println("从stack左侧获取元素："+jedis.lpop("stack"));
System.out.println("查看stack内容："+jedis.lrange("stack",0,-1));
System.out.println("从stack左侧获取元素："+jedis.lpop("stack"));
System.out.println("查看queue内容："+jedis.lrange("stack",0,-1));
System.out.println("从stack左侧获取元素："+jedis.lpop("stack"));
Set(集合)
Set(集合)常用api
jedis.flushDB();
System.out.println("新增1个set："+jedis.sadd("set","s1","s2","s3","s4","s5","s6"));
System.out.println("查看set内容："+jedis.smembers("set"));
System.out.println("往set添加重复内容："+jedis.sadd("set","s1"));
System.out.println("往set添加重复内容："+jedis.sadd("set","s2"));
System.out.println("查看set内容："+jedis.smembers("set"));
System.out.println("删除s6元素："+jedis.srem("set","s6"));
System.out.println("查看set大小："+jedis.scard("set"));
System.out.println("查看set内容是否有s1元素："+jedis.sismember("set","s1"));
System.out.println("随机获取set中1个元素："+jedis.srandmember("set",1));
System.out.println("随机获取set中1个元素并且删除："+jedis.spop("set",1));
System.out.println("查看set大小："+jedis.scard("set"));
System.out.println("查看set内容："+jedis.smembers("set"));
System.out.println("====================集合运算====================");
System.out.println("新增1个set1："+jedis.sadd("set1","s1","s2","s3","s4","s5","s6"));
System.out.println("新增1个set2："+jedis.sadd("set2","s4","s5","s6","s7","s8","s9"));
System.out.println("查看set1内容："+jedis.smembers("set1"));
System.out.println("查看set2内容："+jedis.smembers("set2"));
System.out.println("set1和set2的交集："+jedis.sinter("set1","set2"));
System.out.println("set1和set2的并集："+jedis.sunion("set1","set2"));
System.out.println("set1和set2的差集："+jedis.sdiff("set1","set2"));
ZSet(有序集合)
ZSet(有序集合)常用api，与普通的set不同之处是该集合是有序的默认是从小到大排序
jedis.flushDB();
//以下map为一份成绩表
HashMap<String, Double> transcript = new HashMap<>();
transcript.put("zhangsan",60D);
transcript.put("lisi",30D);
transcript.put("wangwu",100D);
transcript.put("zhaoliu",85D);
System.out.println("新增1个ZSet："+jedis.zadd("transcript",transcript));
System.out.println("从小到大排序："+jedis.zrangeByScore("transcript",0,-1));
System.out.println("获取："+jedis.zrange("transcript",0,-1));
HasMap
<key,<key,value>>数据结构api
jedis.flushDB();
System.out.println("新增1个hasMap："+jedis.hset("map","key1","value1"));
HashMap<String, String> map = new HashMap<>();
map.put("key2","value2");
map.put("key3","value3");
System.out.println("对map一次性设置值："+jedis.hmset("map",map));
System.out.println("获取map所有键值对："+jedis.hgetAll("map"));
System.out.println("获取map所有键："+jedis.hkeys("map"));
System.out.println("获取map所有值："+jedis.hvals("map"));
System.out.println("获取map长度："+jedis.hlen("map"));
System.out.println("删除map的中值："+jedis.hdel("map","key1"));
System.out.println("获取map所有键值对："+jedis.hgetAll("map"));
System.out.println("查看map内容是否有key2："+jedis.hexists("map","key2"));
System.out.println("=========新增并检查key，不存在新增，存在不操作=========");
System.out.println("往map新增key4："+jedis.hsetnx("map","key4","value4"));
System.out.println("尝试修改key4值："+jedis.hsetnx("map","key4","newValue4"));
System.out.println("获取key4值："+jedis.hget("map","key4"));
Geospatial(地理位置)
地理位置api，可用于计算经纬度，查询附近人等
jedis.flushDB();
//以下map为一份城市经纬度表
HashMap<String, GeoCoordinate> cityMap = new HashMap<>();
cityMap.put("beijing", new GeoCoordinate(116.41667,39.91667));
cityMap.put("shanghai",new GeoCoordinate(121.43333,34.50000));
cityMap.put("guangzhou",new GeoCoordinate(113.23333,23.16667));
cityMap.put("shenzhen",new GeoCoordinate(114.06667,22.61667));
System.out.println("新增1个Geospatial："+jedis.geoadd("geospatial", cityMap));
System.out.println("查看所有城市信息："+jedis.zrange("geospatial",0,-1));
System.out.println("获取beijing的经纬度："+jedis.geopos("geospatial", "beijing"));
System.out.println("计算beijing到shanghai直线距离(km)："+jedis.geodist("geospatial", "beijing","shanghai", GeoUnit.KM));
System.out.println("========================获取经纬度(116,39)半径1000km的城市========================");
List<GeoRadiusResponse> list1 = jedis.georadius("geospatial", 116,39, 1000, GeoUnit.KM);
list1.forEach(g -> System.out.println(g.getMemberByString()));
System.out.println("========================获取guangzhou半径1000km的城市========================");
List<GeoRadiusResponse> list2 = jedis.georadiusByMember("geospatial", "guangzhou", 1000, GeoUnit.KM);
list2.forEach(g -> System.out.println(g.getMemberByString()));
System.out.println("删除指定城市："+jedis.zrem("geospatial","beijing"));
Hyperloglog(基数统计)
基数统计，即统计不重复元素的总数，以A={1,2,5,6,6,8}为例，基数=4 就是这给集合中不重复的数
jedis.flushDB();
System.out.println("新增1个Hyperloglog："+jedis.pfadd("hyperloglog","1","2","5","6","6","8"));
System.out.println("基数统计："+jedis.pfcount("hyperloglog"));
Bitmap(位存储)
位存储 为指定key的一个offset设置0/1，消耗内存最小
jedis.flushDB();
System.out.println("========================小明的考勤表========================");
jedis.setbit("xiaoming",1,true);
jedis.setbit("xiaoming",2,false);
jedis.setbit("xiaoming",3,false);
jedis.setbit("xiaoming",4,true);
jedis.setbit("xiaoming",5,true);
System.out.println("小明周一是否有上课："+jedis.getbit("xiaoming",1));
System.out.println("小明周二是否有上课："+jedis.getbit("xiaoming",2));
System.out.println("小明周三是否有上课："+jedis.getbit("xiaoming",3));
System.out.println("小明周四是否有上课："+jedis.getbit("xiaoming",4));
System.out.println("小明周五是否有上课："+jedis.getbit("xiaoming",5));
版权声明：本文为weixin_44642403原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。