要在Java程序中操作Redis可以使用Jedis开源工具。
一、jedis的下载
如果使用Maven项目,可以把以下内容添加到pom中
<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>4.3.1</version>
</dependency>
也可以在maven仓库中下载需要的jar文件,除了jedis.jar以外,还要下载对应的依赖包
1、jedis下载地址:
https://mvnrepository.com/artifact/redis.clients/jedis/4.3.1
2、依赖下载
在下载页面的下方有依赖项的列表,在对应的链接上右键,选择”在新的标签中打开链接“,如果对应的页面不有jar的链接,可以点击”View All“,进入到子页面中去下载。
gson是必须的依赖,用于内部json数据的操作
如果要使用JedisPoolConfig,则必须添加commons-pool2和slf4j-api,没有commons-pool2无法配置池的参数,而没有slf4j-api在运行时会抛异常。
下载后把五个Jar包添加到项目中去
二、jedis使用
说明:本示例全部使用junit4
1、redis的连接和关闭
//连接redis
Jedis j = new Jedis("localhost", 6379);
//密码
j.auth("123456");
//切换到数据库9
j.select(8);//关闭连接
j.close();
从以下示例可以看出,jedis操作redis时方法的名称与redis的命令一致。因此对于掌握了redis操作的人员jedis会很容易上手
2、添加一个字符串的值
//连接redis
Jedis j = new Jedis("localhost", 6379);
//密码
j.auth("123456");
//切换到数据库9
j.select(8);
//清空当前数据库中的数据
j.flushDB() ;
//添加字符串的值
j.set("key1".getBytes("utf-8"), "value1".getBytes("utf-8"));
//关闭连接
j.close();
redis的默认编码为utf-8,但应用程序的编码不一定一致,如果直接使用字符串进行操作,可以在多个系统中访问时由于编码不一致而出现乱码,因此建议key和值都以utf-8编码转换成字节数组进行添加
3、获取字符串的值
Jedis j = new Jedis("localhost", 6379);
j.auth("123456");
j.select(8);
//根据key获取值
byte[] bys = j.get("key1".getBytes("utf-8"));
//输出结果
System.out.println(new String(bys,"utf-8"));j.close();
取出时按存入时的编码还原成字符串即可
4、事务处理
Jedis j = new Jedis("localhost", 6379);
j.auth("123456");
j.select(8);
//监听
j.watch("str2".getBytes("utf-8"),"value2".getBytes("utf-8"));
//开启事务
Transaction t = j.multi();
//添加多条数据
t.set("str2".getBytes("utf-8"),"value2".getBytes("utf-8"));
t.set("str3".getBytes("utf-8"),"value3".getBytes("utf-8"));
//执行事务
t.exec();j.close();
6、list查询的执行
当在事务中执行查询时,会反回一个Response对象,此对象的操作必须在事务结束后执行。
示例
Transaction t = j.multi();
//在事务中必须使用事务对象执行相关方法
t.lpush(toBys("lkey1"),
toBys("val1"),toBys("val2"));Response<List<byte[]>> res = t.lrange(toBys("lkey1"), 0 ,-1);
t.exec();//执行事务
//从响应中获取查询结果,必须在事务完成之后执行
List<byte[]> list = res.get();
for (byte[] bytes : list) {
System.out.println(new String(bytes,"utf-8"));
}
//关闭连接
j.close();
6、使用默认连接池创建连接
//使用默认配置创建连接池
JedisPool pool = new JedisPool("localhost", 6379);
//从池中取出连接
Jedis j = pool.getResource();//把连接交还给池
j.close();//关闭池,释放所有连接
pool.close();
7、使用连接池配置创建连接池JedisPoolConfig conf = new JedisPoolConfig();
//最大空闲连接数
conf.setMaxIdle(10);
//最大连接数
conf.setMaxTotal(100);
//最小空闲数
conf.setMinIdle(2);//使用配置对象创建连接池
JedisPool pool = new JedisPool(conf,"localhost", 6379);
常用的配置如下
1)maxActive
控制一个pool可分配多少个jedis实例,通过pool.getResource()来获取;如果赋值为-1,则表示不限制;如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted。
2)maxIdle
控制一个pool最多有多少个状态为idle(空闲)的jedis实例;
3)whenExhaustedAction
表示当pool中的jedis实例都被allocated完时,pool要采取的操作;默认有三种。
WHEN_EXHAUSTED_FAIL –> 表示无jedis实例时,直接抛出NoSuchElementException;
WHEN_EXHAUSTED_BLOCK –> 则表示阻塞住,或者达到maxWait时抛出JedisConnectionException;
WHEN_EXHAUSTED_GROW –> 则表示新建一个jedis实例,也就说设置的maxActive无用;
4)maxWait
表示当borrow一个jedis实例时,最大的等待时间,如果超过等待时间,则直接抛JedisConnectionException;
5)testOnBorrow
获得一个jedis实例的时候是否检查连接可用性(ping());如果为true,则得到的jedis实例均是可用的;
6)testOnReturn
return 一个jedis实例给pool时,是否检查连接可用性(ping());
7)testWhileIdle
如果为true,表示有一个idle object evitor线程对idle object进行扫描,如果validate失败,此object会被从pool中drop掉;这一项只有在timeBetweenEvictionRunsMillis大于0时才有意义;
8)timeBetweenEvictionRunsMillis
表示idle object evitor两次扫描之间要sleep的毫秒数;
9)numTestsPerEvictionRun
表示idle object evitor每次扫描的最多的对象数;
10)minEvictableIdleTimeMillis
表示一个对象至少停留在idle状态的最短时间,然后才能被idle object evitor扫描并驱逐;这一项只有在timeBetweenEvictionRunsMillis大于0时才有意义;
11)softMinEvictableIdleTimeMillis
在minEvictableIdleTimeMillis基础上,加入了至少minIdle个对象已经在pool里面了。如果为-1,evicted不会根据idle time驱逐任何对象。如果minEvictableIdleTimeMillis>0,则此项设置无意义,且只有在timeBetweenEvictionRunsMillis大于0时才有意义;
12)lifo
borrowObject返回对象时,是采用DEFAULT_LIFO(last in first out,即类似cache的最频繁使用队列),如果为False,则表示FIFO队列;
8、使用属性配置文件配置池参数
在项目的根下面添加属性配置文件redis.properties
max-total=10
max-idle=4
min-idle=0
在java中读取配置文件并添加到配置对象中
//创建属性配置文件解析对象
Properties pro = new Properties();
//解析属性配置文件
pro.load(Class.class.getResourceAsStream("/redis.properties"));//创建连接池配置对象
JedisPoolConfig conf = new JedisPoolConfig();
//注入配置参数
conf.setMaxTotal(Integer.parseInt(pro.getProperty("max-total")));
conf.setMaxIdle(Integer.parseInt(pro.getProperty("max-idle")));
conf.setMinIdle(Integer.parseInt(pro.getProperty("min-idle")));
文章来源于哔站《使用Java操作Redis》
更多学习视频和专栏文章请到哔站个人空间: 布道师学院的个人空间-布道师学院个人主页-哔哩哔哩视频
更多资源和项目下载请到:”开源吧(找实战项目和毕设项目的好网站)“ :开源吧