package com.redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import java.util.Set;
/**
* @author 陈浮生
*/
public class RedisClient {
/**
* 非切片连接
*/
private Jedisjedis;
/**
* 非切片连接池
*/
private JedisPooljedisPool;
/**
* 生成对象时就对其初始化
*/
public RedisClient(){
initialPool();
jedis =jedisPool.getResource();
}
/**
* 初始化连接池
*/
public void initialPool(){
JedisPoolConfig config =new JedisPoolConfig();
config.setMaxActive(20);
config.setMaxIdle(20);
config.setMaxWait(1000L);
config.setTestOnBorrow(false);
jedisPool =new JedisPool(config, "localhost", 6379);
}
/**
* 键值的操作
*/
public void keyOperate() {
System.out.println("====================keyOperate====================");
System.out.println("清空redis:" +jedis.flushDB());
System.out.println("设置键的操作:" +jedis.set("key01", "value01"));
System.out.println("设置键的操作:" +jedis.set("key02", "value02"));
System.out.println("设置键的操作:" +jedis.set("key03", "value03"));
System.out.println("设置键的操作:" +jedis.set("key04", "value04"));
System.out.println("设置键的操作:" +jedis.set("key05", "value05"));
System.out.println("查询操作:" +jedis.get("key01"));
jedis.expire("key01", 100);
System.out.println("查看key01的剩余生命时间"+jedis.ttl("key01"));
System.out.println("查看所有的key:");
Set keys =jedis.keys("*");
for (String key : keys) {
System.out.println(jedis.get(key));
}
}
public void sortSetOperate(){
System.out.println("清空数据:" +jedis.flushDB());
System.out.println("增加数据(set)集合的方式:" +jedis.zadd("zset", 5.0, "value5"));
System.out.println("增加数据(set)集合的方式:" +jedis.zadd("zset", 4.0, "value4"));
System.out.println("增加数据(set)集合的方式:" +jedis.zadd("zset", 3.0, "value3"));
System.out.println("增加数据(set)集合的方式:" +jedis.zadd("zset", 2.0, "value2"));
System.out.println("增加数据(set)集合的方式:" +jedis.zadd("zset", 1.0, "value1"));
System.out.println("查看所有set集合中所有数据:" +jedis.zrange("zset", 0, -1));
System.out.println("集合中数据的个数" +jedis.zcard("zset"));
System.out.println("权重范围内数据的个数:" +jedis.zcount("zset", 1.0, 2.0));
System.out.println("查看集合中数据的权重:" +jedis.zscore("zset", "value1"));
System.out.println("查看下标范围内的数据:" +jedis.zrange("zset", 0, 2));
}
public void hashOperate(){
System.out.println("清数据:" +jedis.flushDB());
System.out.println("新增数据:" +jedis.hset("hash", "key1", "value1"));
System.out.println("新增数据:" +jedis.hset("hash", "key2", "value2"));
System.out.println("新增数据:" +jedis.hset("hash", "key3", "value3"));
System.out.println("新增数据:" +jedis.hset("hash", "key4", "value4"));
System.out.println("新增数据:" +jedis.hset("hash", "key5", "value5"));
System.out.println("新增一个整型的键值对:" +jedis.hincrBy("hash", "key6", 4L));
System.out.println("查看所有值:" +jedis.hvals("hash"));
System.out.println("增加值:" +jedis.hincrBy("hash", "key6", 100L));
System.out.println("判断是否存:" +jedis.hexists("hash", "key1"));
System.out.println("获取批量值:" +jedis.hmget("hash", "key1", "key2"));
System.out.println("获取所有的key:" +jedis.hkeys("hash"));
System.out.println("获取所有的key:" +jedis.hvals("hash"));
}
public static void main(String[] args) {
RedisClient redisClient =new RedisClient();
//redisClient.keyOperate();
//redisClient.sortSetOperate();
redisClient.hashOperate();
}
}
网友评论