我要评论package redis.redis;
import redis.clients.jedis.jedis;
import redis.clients.jedis.jedispool;
/**
* 描述:jedis连接池工具类
* 【时间 2019-05-20 15:13:34 作者 陶攀峰】
*/
public class jedispoolutil
{
private static volatile jedispool jedispool=null;
private jedispoolutil() {}
/**
* 描述:获取
* 【时间 2019-05-21 11:02:24 作者 陶攀峰】
*/
public static jedispool getjeidpoolinstance()
{
if (jedispool==null)
{
synchronized (jedispoolutil.class)
{
if (jedispool==null)
{
jedispool=new jedispool("192.168.37.160",6379);
}
}
}
return jedispool;
}
/**
* 描述:关闭
* 【时间 2019-05-21 11:02:13 作者 陶攀峰】
*/
public static void close(jedispool jedispool,jedis jedis)
{
if (jedis!=null)
{
jedispool.returnresourceobject(jedis);
}
}
}
package redis.redis;
import redis.clients.jedis.binaryclient.list_position;
import java.util.hashmap;
import java.util.map;
import redis.clients.jedis.jedis;
import redis.clients.jedis.jedispool;
import redis.clients.jedis.transaction;
/**
* 描述:操作数据库
* 【时间 2019-05-20 15:28:46 作者 陶攀峰】
*/
public class redis_test {
public static void main(string[] args) {
jedispool jedispool=jedispoolutil.getjeidpoolinstance();
jedis jedis=null;
try {
jedis=jedispool.getresource();//获取
system.out.println("连接:"+jedis.ping());//测试连接性 正常返回pong
transaction(jedis);//事务
basics(jedis);//基础操作
} catch (exception e) {
e.printstacktrace();
}finally {//关闭
jedispoolutil.close(jedispool, jedis);
}
}
/**
* 描述:redis事务
* 【时间 2019-05-20 15:33:59 作者 陶攀峰】
*/
public static void transaction(jedis jedis){
int k3=10;
jedis.watch("k1");
//thread.sleep(7000);
if (integer.parseint(jedis.get("k1"))<k3) {
jedis.unwatch();
system.out.println("---modify---");
}else {
transaction transaction=jedis.multi();
transaction.decrby("k1", k3);
transaction.incrby("k2", k3);
transaction.exec();
system.out.println("---"+jedis.get("k1")+"---"+jedis.get("k2"));
}
}
/**
* 描述:redis基础
* 【时间 2019-05-21 08:07:33 作者 陶攀峰】
*/
public static void basics(jedis jedis) {
jedis.set("k1", "v1");
jedis.set("k2", "v2");
system.out.println("当前数据库记录："+jedis.dbsize());
system.out.println("jedis.keys(\"*\"):"+jedis.keys("*"));//获取所有key
jedis.select(1);//切换数据库 下标从0开始 到 15 ，共16个数据库
system.out.println(jedis.keys("*"));
system.out.println(jedis.dbsize());//当前库的数据大小 key的数量
system.out.println(jedis.randomkey());//随机出一个key
jedis.flushdb();//清空当前数据库
jedis.flushall();//清空全部数据库
//-------------------string--------------------
jedis.set("k1", "v1");
system.out.println(jedis.get("k1"));
jedis.del("k1");
jedis.append("k1", "556677");//追加
system.out.println(jedis.get("k1"));
system.out.println(jedis.strlen("k1"));//得到长度
jedis.set("k2", "2");
jedis.incr("k2");//增加1
jedis.decr("k2");//减少1
jedis.incrby("k2", 5);//增加5
jedis.decrby("k2", 20);//减少20
system.out.println(jedis.get("k2"));
jedis.flushall();//清空全部数据库
jedis.set("k3", "tpf951101");
system.out.println(jedis.getrange("k3", 2, 3));//从0开始包括2和3
system.out.println(jedis.setrange("k3", 2, "pf"));//从下标2开始 包括2 开始替换两个字符pf
system.out.println(jedis.get("k3"));
jedis.setex("k3", 10, "v3");//10为过期时间 单位秒
system.out.println(jedis.get("k3"));
system.out.println(jedis.ttl("k3"));//返回还有多少秒到期，到期自动删除，-2已过期
jedis.setnx("k4", "v4");//不存在k4才能设值成功
system.out.println(jedis.get("k4"));
jedis.flushall();
jedis.mset("k1","v11","k2","v22");
system.out.println(jedis.mget("k1","k2"));
system.out.println(jedis.keys("*"));
jedis.set("k5", "v5");
jedis.del("k5");
jedis.msetnx("k4","v44","k5","v55");//全部不存在才能成功
system.out.println(jedis.mget("k4","k5"));
system.out.println(jedis.getset("k1", "19951101"));//先返回设值前内容再设值
//-------------------list--------------------
jedis.lpush("l1", "1","2","3","4","5");
jedis.rpush("l2", "11","22","33","44","55");
system.out.println(jedis.lrange("l1", 0, -1));//0 -1 查询全部
system.out.println(jedis.lrange("l2", 0, -1));
system.out.println(jedis.lpop("l1"));//删除表头、返回删除的内容
system.out.println(jedis.lpop("l2"));
system.out.println(jedis.rpop("l1"));//删除表尾、返回删除的内容
system.out.println(jedis.rpop("l2"));
system.out.println(jedis.lindex("l1", 1));//返回下标1的内容
system.out.println(jedis.llen("l1"));//相当于list.size()
jedis.ltrim("l1", 2, 3);//截取2-3 包括2和3替换之前的内容
system.out.println(jedis.lrem("l1", 1, "33"));;//第一个为key 第二个为1 第三个为要删除的value 返回删除的条数
jedis.rpoplpush("l1", "l2");//把l1的尾添加到l2的头
jedis.lset("l2", 0, "333");//把下标为0的值 改为333
jedis.linsert("l2", list_position.before, "3", "a3");
jedis.linsert("l2", list_position.after, "4", "a4");
system.out.println(jedis.lrange("l1", 0, -1));
system.out.println(jedis.lrange("l2", 0, -1));
//-------------------set--------------------
jedis.sadd("s1", "1","2","3","4","5");
system.out.println(jedis.sismember("s1", "6"));//s1中是否存在6 存在true 不存在false
system.out.println(jedis.scard("s1"));//相当于list.size()
system.out.println(jedis.srem("s1", "5"));//删除s1中的5 成功返回1 失败返回0
system.out.println(jedis.srandmember("s1"));//随机出一条记录
system.out.println(jedis.srandmember("s1",3));//随机出三条记录
system.out.println(jedis.srandmember("s1",9));//如果大于等于记录数 就等于查询全部
system.out.println(jedis.spop("s1"));//随机删除一条数据
system.out.println(jedis.smove("s1", "s2", "3"));//把s1中的3移到s2的头
system.out.println(jedis.sdiff("s1","s2"));//s1有 s2没有
system.out.println(jedis.sinter("s1","s2"));//s1 s2 都有
system.out.println(jedis.sunion("s1","s2"));//s1 s2合集
system.out.println(jedis.smembers("s1"));
//-------------------hash--------------------
jedis.hset("stu", "id", "7");
system.out.println(jedis.hget("stu", "id"));
map<string, string> map=new hashmap<>();
map.put("id","13");
map.put("name", "daniu");
map.put("sex", "nan");
jedis.hmset("stu", map);
system.out.println(jedis.hmget("stu", "id","name","sex"));
system.out.println(jedis.hgetall("stu"));
system.out.println(jedis.hdel("stu", "id","sex2"));//返回删除的数量
system.out.println(jedis.hlen("stu"));
system.out.println(jedis.hexists("stu", "name"));//存在true 不存在false
system.out.println(jedis.hkeys("stu"));
system.out.println(jedis.hvals("stu"));
system.out.println(jedis.hincrby("stu", "id", 2));//每次增加2 返回增加后的数值
system.out.println(jedis.hincrbyfloat("stu", "id", 3.4));//每次增加3.4 返回增加后的数值
system.out.println(jedis.hsetnx("stu", "id1", "99"));//插入成功返回1 失败返回0
//-------------------zset--------------------
jedis.zadd("zs1", 60, "v1");
jedis.zadd("zs1", 70, "v2");
jedis.zadd("zs1", 80, "v3");
jedis.zadd("zs1", 90, "v4");
jedis.zadd("zs1", 100, "v5");
system.out.println(jedis.zrange("zs1", 0, -1));
system.out.println(jedis.zrangebyscore("zs1", 60, 90));//60<=score<=90的value值
system.out.println(jedis.zrem("zs1", "v5","v6"));//返回删除记录数
system.out.println(jedis.zcard("zs1"));//返回数量
system.out.println(jedis.zcount("zs1", 60, 80));//60<=score<=80的数量
system.out.println(jedis.zrank("zs1", "v4"));//返回所在位置下标
system.out.println(jedis.zscore("zs1", "v1"));//返回v1的score
//zre表示把原本的数据逆转顺序之后，再读取，不改变原有数据
system.out.println(jedis.zrevrank("zs1", "v4"));
system.out.println(jedis.zrevrange("zs1", 0, -1));
}
}
如对本文有疑问， 点击进行留言回复！！
修复 Mac brew 安装 mongodb 报 Error: No available formula with the name ‘mongodb’ 问题详解
MongoDB中数据的替换方法实现类Replace()函数功能详解
网友评论