Java操作redis
2023-09-14 09:01:03 时间
Jedis jedis = null;
jedis = new Jedis(FinalCollention.IP, 6379); //redis服务器的ip和端口
jedis.auth(FinalCollention.PASSWORD); //连接redis的密码
return jedis;
}
public void test(){
Jedis jedis = null;
try{
jedis = getJedis();
jedis.incr("test");
long dbsize = jedis.dbSize();
System.out.println("数据库大小:"+dbsize);
System.out.println("测试test的值:"+jedis.get("test"));
}catch(Exception e){
e.printStackTrace();
}finally{
if(jedis != null){
jedis.disconnect();
}
}
}
public static void main(String[] args) {
RedisDemo demo = new RedisDemo();
demo.test();
}
# Accept connections on the specified port, default is 6379. # If port 0 is specified Redis will not listen on a TCP socket. port 6379 # If you want you can bind a single interface, if the bind option is not # specified all the interfaces will listen for incoming connections. # bind 127.0.0.1 "redis.conf" 597L, 25667C written
Jedis jedis = null; jedis = new Jedis(FinalCollention.IP, 6379); //redis服务器的ip和端口 jedis.auth(FinalCollention.PASSWORD); //连接redis的密码 return jedis; } /** * * @title demoKey * @description 测试Key * @author hadoop */ public void demoKey(){ Jedis jedis = RedisDataTypeDemo.getJedis(); System.out.println("查看键为aa的是否存在:"+jedis.exists("aa")); System.out.println("查看键为aa的类型:"+jedis.type("aa")); System.out.println("随机获得一个key:"+jedis.randomKey()); System.out.println("将aa重命名为bb:"+jedis.rename("aa", "bb")); System.out.println("删除bb:"+jedis.del("bb")); //从上面的方法可以看出,redis提供的接口方法名和redis-cli客户端提供的方法名是一样的,所以,只要对redis客户端的命令熟悉,那么Java操作redis就不是问题 } /** * * @title demoString * @description 测试String * @author hadoop */ public void demoString(){ Jedis jedis = RedisDataTypeDemo.getJedis(); System.out.println("设置name:"+jedis.set("name", "小花")); System.out.println("设置name1:"+jedis.set("name1", "小花1")); System.out.println("设置那么2:"+jedis.set("name2", "小花2")); System.out.println("设置name,如果存在返回0:"+jedis.setnx("name", "小花哈哈")); System.out.println("获取key为name和name1的value值:"+jedis.mget("name","name1")); System.out.println("自增1:"+jedis.incr("index")); System.out.println("自增1:"+jedis.incr("index")); System.out.println("自增2:"+jedis.incrBy("count", 2)); System.out.println("自增2:"+jedis.incrBy("count", 2)); System.out.println("递减1:"+jedis.decr("count")); System.out.println("递减2:"+jedis.decrBy("index",2)); System.out.println("在name后面添加String:"+jedis.append("name", ",我爱你")); System.out.println("获取key为name的值:"+jedis.get("name")); } /** * * @title demoList * @description 测试list数据类型 * @author hadoop */ public void demoList(){ Jedis jedis = RedisDataTypeDemo.getJedis(); //在头添加 jedis.lpush("list", "hadoop","hbase","hive","pig","zookeeper"); //在末尾添加 jedis.rpush("list", "java","struts"); //返回长度 jedis.llen("list"); //取值 List String list = jedis.lrange("list", 0, -1); for (String string : list) { System.out.println(string); } } /** * * @title demoSet * @description 测试set数据类型 * @author hadoop */ public void demoSet(){ Jedis jedis = RedisDataTypeDemo.getJedis(); jedis.sadd("city", "北京","上海","重启","武汉"); System.out.println("取出最上面的:"+jedis.spop("city")); System.out.println("随机取出一个值"+jedis.srandmember("city")); jedis.sadd("city2", "北京","武汉","河北","张家界","辽林"); System.out.println("交集:"+jedis.sinter("city","city1")); System.out.println("并集:"+jedis.sunion("city","city1")); System.out.println("差集:"+jedis.sdiff("city","city1")); } /** * * @title demoMap * @description 测试map数据类型 * @author hadoop */ public void demoMap(){ Jedis jedis = RedisDataTypeDemo.getJedis(); jedis.hset("Mcity", "c1", "北京"); System.out.println("取值:"+jedis.hget("city", "c1")); Map String,String mcity = new HashMap String, String mcity.put("c1", "桂林"); mcity.put("c2", "天津"); mcity.put("c3", "合肥"); jedis.hmset("Mcity2", mcity); List String list = jedis.hmget("Mcity2", "c1","c2","c3"); for (String string : list) { System.out.println(string); } System.out.println(jedis.hlen("Mcity2")); } //测试 public static void main(String[] args) { RedisDataTypeDemo rdr = new RedisDataTypeDemo(); rdr.demoKey(); rdr.demoList(); rdr.demoMap(); rdr.demoSet(); rdr.demoString(); }
Jedis jedis = null; jedis = new Jedis(FinalCollention.IP, 6379); //redis服务器的ip和端口 jedis.auth(FinalCollention.PASSWORD); //连接redis的密码 return jedis; } public void hasPipeline(){ Jedis jedis = RedisPipelineDemo.getJedis(); System.out.println("开始:"+System.currentTimeMillis()); Pipeline pl = jedis.pipelined(); for(int i = 0 ; i 1000 ; i++){ pl.incr("testPL"); } pl.sync(); System.out.println("开始:"+System.currentTimeMillis()); } public void noPipeline(){ Jedis jedis = RedisPipelineDemo.getJedis(); System.out.println("开始:"+System.currentTimeMillis()); for(int i = 0 ; i 1000 ; i++){ jedis.incr("testPL"); } System.out.println("开始:"+System.currentTimeMillis()); }
Jedis jedis = null; jedis = new Jedis(FinalCollention.IP, 6379); //redis服务器的ip和端口 jedis.auth(FinalCollention.PASSWORD); //连接redis的密码 return jedis; } /** * * @title txDemo * @description 没有异常的事务 * @author hadoop */ public void txDemo(){ Jedis jedis = getJedis(); //开启事务 Transaction tx = jedis.multi(); tx.set("txcity", "beijin"); tx.sadd("hi", "abc"); tx.get("txcity"); List Object objs = tx.exec(); for (Object object : objs) { System.out.println(object.toString()); } } /** * * @title txHasExDemo * @description 含有异常的事务 * @author hadoop */ public void txHasExDemo(){ Jedis jedis = getJedis(); //开启事务 Transaction tx = jedis.multi(); tx.set("txcity1", "beijin"); tx.sadd("hi1", "abc"); int i = 1/0; tx.get("txcity1"); List Object objs = tx.exec(); for (Object object : objs) { System.out.println(object.toString()); } } public static void main(String[] args) { RedisTXDemo redisTXDemo = new RedisTXDemo(); redisTXDemo.txDemo(); redisTXDemo.txHasExDemo(); }
Redis(三十)- Redis集群操作和故障恢复&集群的Jedis开发 上一篇文章我们介绍了集群的基本概念,以及如何搭建一个简单的Redis集群。Redis(二十九)- Redis集群的介绍以及搭建,这篇文章我们接着来学习Redis集群。
Redis(二十五)-持久化操作之RDB 我们都知道Redis是纯内存的操作,数据首先被保存到内存中,但是内存中的数据是非持久化数据,即当服务器宕机,或者断电之后,内存中的数据就会丢失。所以数据只有保存到硬盘中才能持久化。Redis中默认的持久化方式是RDB的方式。
如果出现Java无法连接redis的异常,主要有三个方面的问题:
1.Java运行的主机ping一下redis服务器所在主机,看能否ping通
2.关闭redis服务器所在主机的防火墙
3.打开redis安装目录下的redis.conf文件。注释掉:bind 127.0.0.1这句话
# Accept connections on the specified port, default is 6379. # If port 0 is specified Redis will not listen on a TCP socket. port 6379 # If you want you can bind a single interface, if the bind option is not # specified all the interfaces will listen for incoming connections. # bind 127.0.0.1 "redis.conf" 597L, 25667C written
特别说明:后面的实例,我就不使用try--catch了,但是自己写时一定要记着关闭连接
2.Java操作redis的各种数据结构Jedis jedis = null; jedis = new Jedis(FinalCollention.IP, 6379); //redis服务器的ip和端口 jedis.auth(FinalCollention.PASSWORD); //连接redis的密码 return jedis; } /** * * @title demoKey * @description 测试Key * @author hadoop */ public void demoKey(){ Jedis jedis = RedisDataTypeDemo.getJedis(); System.out.println("查看键为aa的是否存在:"+jedis.exists("aa")); System.out.println("查看键为aa的类型:"+jedis.type("aa")); System.out.println("随机获得一个key:"+jedis.randomKey()); System.out.println("将aa重命名为bb:"+jedis.rename("aa", "bb")); System.out.println("删除bb:"+jedis.del("bb")); //从上面的方法可以看出,redis提供的接口方法名和redis-cli客户端提供的方法名是一样的,所以,只要对redis客户端的命令熟悉,那么Java操作redis就不是问题 } /** * * @title demoString * @description 测试String * @author hadoop */ public void demoString(){ Jedis jedis = RedisDataTypeDemo.getJedis(); System.out.println("设置name:"+jedis.set("name", "小花")); System.out.println("设置name1:"+jedis.set("name1", "小花1")); System.out.println("设置那么2:"+jedis.set("name2", "小花2")); System.out.println("设置name,如果存在返回0:"+jedis.setnx("name", "小花哈哈")); System.out.println("获取key为name和name1的value值:"+jedis.mget("name","name1")); System.out.println("自增1:"+jedis.incr("index")); System.out.println("自增1:"+jedis.incr("index")); System.out.println("自增2:"+jedis.incrBy("count", 2)); System.out.println("自增2:"+jedis.incrBy("count", 2)); System.out.println("递减1:"+jedis.decr("count")); System.out.println("递减2:"+jedis.decrBy("index",2)); System.out.println("在name后面添加String:"+jedis.append("name", ",我爱你")); System.out.println("获取key为name的值:"+jedis.get("name")); } /** * * @title demoList * @description 测试list数据类型 * @author hadoop */ public void demoList(){ Jedis jedis = RedisDataTypeDemo.getJedis(); //在头添加 jedis.lpush("list", "hadoop","hbase","hive","pig","zookeeper"); //在末尾添加 jedis.rpush("list", "java","struts"); //返回长度 jedis.llen("list"); //取值 List String list = jedis.lrange("list", 0, -1); for (String string : list) { System.out.println(string); } } /** * * @title demoSet * @description 测试set数据类型 * @author hadoop */ public void demoSet(){ Jedis jedis = RedisDataTypeDemo.getJedis(); jedis.sadd("city", "北京","上海","重启","武汉"); System.out.println("取出最上面的:"+jedis.spop("city")); System.out.println("随机取出一个值"+jedis.srandmember("city")); jedis.sadd("city2", "北京","武汉","河北","张家界","辽林"); System.out.println("交集:"+jedis.sinter("city","city1")); System.out.println("并集:"+jedis.sunion("city","city1")); System.out.println("差集:"+jedis.sdiff("city","city1")); } /** * * @title demoMap * @description 测试map数据类型 * @author hadoop */ public void demoMap(){ Jedis jedis = RedisDataTypeDemo.getJedis(); jedis.hset("Mcity", "c1", "北京"); System.out.println("取值:"+jedis.hget("city", "c1")); Map String,String mcity = new HashMap String, String mcity.put("c1", "桂林"); mcity.put("c2", "天津"); mcity.put("c3", "合肥"); jedis.hmset("Mcity2", mcity); List String list = jedis.hmget("Mcity2", "c1","c2","c3"); for (String string : list) { System.out.println(string); } System.out.println(jedis.hlen("Mcity2")); } //测试 public static void main(String[] args) { RedisDataTypeDemo rdr = new RedisDataTypeDemo(); rdr.demoKey(); rdr.demoList(); rdr.demoMap(); rdr.demoSet(); rdr.demoString(); }
Jedis jedis = null; jedis = new Jedis(FinalCollention.IP, 6379); //redis服务器的ip和端口 jedis.auth(FinalCollention.PASSWORD); //连接redis的密码 return jedis; } public void hasPipeline(){ Jedis jedis = RedisPipelineDemo.getJedis(); System.out.println("开始:"+System.currentTimeMillis()); Pipeline pl = jedis.pipelined(); for(int i = 0 ; i 1000 ; i++){ pl.incr("testPL"); } pl.sync(); System.out.println("开始:"+System.currentTimeMillis()); } public void noPipeline(){ Jedis jedis = RedisPipelineDemo.getJedis(); System.out.println("开始:"+System.currentTimeMillis()); for(int i = 0 ; i 1000 ; i++){ jedis.incr("testPL"); } System.out.println("开始:"+System.currentTimeMillis()); }
Jedis jedis = null; jedis = new Jedis(FinalCollention.IP, 6379); //redis服务器的ip和端口 jedis.auth(FinalCollention.PASSWORD); //连接redis的密码 return jedis; } /** * * @title txDemo * @description 没有异常的事务 * @author hadoop */ public void txDemo(){ Jedis jedis = getJedis(); //开启事务 Transaction tx = jedis.multi(); tx.set("txcity", "beijin"); tx.sadd("hi", "abc"); tx.get("txcity"); List Object objs = tx.exec(); for (Object object : objs) { System.out.println(object.toString()); } } /** * * @title txHasExDemo * @description 含有异常的事务 * @author hadoop */ public void txHasExDemo(){ Jedis jedis = getJedis(); //开启事务 Transaction tx = jedis.multi(); tx.set("txcity1", "beijin"); tx.sadd("hi1", "abc"); int i = 1/0; tx.get("txcity1"); List Object objs = tx.exec(); for (Object object : objs) { System.out.println(object.toString()); } } public static void main(String[] args) { RedisTXDemo redisTXDemo = new RedisTXDemo(); redisTXDemo.txDemo(); redisTXDemo.txHasExDemo(); }
Redis(三十)- Redis集群操作和故障恢复&集群的Jedis开发 上一篇文章我们介绍了集群的基本概念,以及如何搭建一个简单的Redis集群。Redis(二十九)- Redis集群的介绍以及搭建,这篇文章我们接着来学习Redis集群。
Redis(二十五)-持久化操作之RDB 我们都知道Redis是纯内存的操作,数据首先被保存到内存中,但是内存中的数据是非持久化数据,即当服务器宕机,或者断电之后,内存中的数据就会丢失。所以数据只有保存到硬盘中才能持久化。Redis中默认的持久化方式是RDB的方式。
相关文章
- java 大数据处理之内存溢出解决办法(一)
- Java实现 蓝桥杯 算法训练 天数计算
- Java实现高效便捷还容易懂的排序算法
- Java实现 洛谷 P1009 阶乘之和
- java实现第四届蓝桥杯买不到的数目
- Java实现冗余路径Redundant Paths
- Java实现 蓝桥杯VIP 基础练习 报时助手
- Java实现蓝桥杯历届试题分考场
- Redis学习(5)-Jedis(Java操作redis数据库技术)
- Redis Java 常用客户端
- 【刷题】java会不会内存泄漏
- java web开发 高并发处理
- java实现redis数据库访问
- 【Java案例】-Jedis操作redis教程
- Java案例-用户注册邮箱验证将邮箱激活码存入redis功能实现
- Atitit.Java exe bat 作为windows系统服务程序运行
- java 操作redis
- Java实现Redis持久化到数据库的关键方法
- java操作redis
- 华为OD机试 - 没有回文串(Java & JS & Python)
- spring-java项目中连接redis数据库
- 蓝桥杯2013省赛——打印十字图(Java实现)
- java编程:jedis连接redis数据库实例
- 编程实践精华总结集锦系列1: SpringBoot/Maven/IDEA/Java/Kotlin/Redis等等
- java 不寻常的问题 No bean named 'sessionFactory' is defined 和 initialize a collection of role
- Java操作Redis的方式
- ES failed to notify ClusterStateListener java.lang.IllegalStateException: environment is not locked
- Java面试——Redis系列总结