使用java连接Redis,Maven管理操作

2023-07-20 17:30:03 478

pom配置



4.0.0
redis
redis
1.0-SNAPSHOT


5.0.2.RELEASE
1.8
1.8




redis.clients
jedis
2.8.0


junit
junit
4.9



commons-pool
commons-pool
1.6



org.springframework.data
spring-data-redis
2.0.3.RELEASE

创建db.properties文件

redis.host=bigdata-hpsk01.huadian.com
redis.port=6379
redis.maxIdle=10
redis.minIdle=10
redis.maxTotal=50

书写工具类

packagecom.huadian.redisUntil;

importredis.clients.jedis.Jedis;
importredis.clients.jedis.JedisPool;
importredis.clients.jedis.JedisPoolConfig;

publicfinalclassJedisPoolUntil{
privatestaticStringADDR="192.168.59.160";
//Redis的端口号
privatestaticintPORT=6379;

/*//可用连接实例的最大数目，默认值为8；
//如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。
privatestaticintMAX_ACTIVE=1024;

//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。
privatestaticintMAX_IDLE=200;

//等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；
privatestaticintMAX_WAIT=10000;

privatestaticintTIMEOUT=10000;*//*

//在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
privatestaticbooleanTEST_ON_BORROW=true;*/

privatestaticintMAXTOTAL=20;
privatestaticintMINIDLE=10;
privatestaticintMAXIDLE=15;
privatestaticJedisPooljedisPool=null;
/**
*初始化Redis连接池
*/
static{
try{
JedisPoolConfigconfig=newJedisPoolConfig();
config.setMaxTotal(MAXTOTAL);
config.setMaxIdle(MINIDLE);
config.setMinIdle(MAXIDLE);

jedisPool=newJedisPool(config,ADDR,PORT);
}catch(Exceptione){
e.printStackTrace();
}
}

/**
*获取Jedis实例
*@return
*/
publicsynchronizedstaticJedisgetJedis(){
try{
if(jedisPool!=null){
Jedisresource=jedisPool.getResource();
returnresource;
}else{
returnnull;
}
}catch(Exceptione){
e.printStackTrace();
returnnull;
}
}

/**
*释放jedis资源
*@paramjedis
*/
publicstaticvoidreturnResource(finalJedisjedis){
if(jedis!=null){
jedisPool.returnResource(jedis);
}
}
}

书写测试类

packagecom.huadian.jedis;

importcom.huadian.redisUntil.JedisPoolUntil;
importorg.junit.Test;
importredis.clients.jedis.Jedis;
importredis.clients.jedis.JedisPool;
importredis.clients.jedis.JedisPoolConfig;

publicclassJedisDemo{
privateJedisjedis=null;

/**
*单连接
*/
@Test
publicvoidjedisSingleConn(){
Stringhost="192.168.59.160";
intport=6379;
Jedisjedis=newJedis(host,port);
jedis.set("name","张三");
jedis.set("age","18");
Strings=jedis.get("name");
Strings1=jedis.get("age");
System.out.println(s);
System.out.println(s1);
}
/**
*连接池连接
*/
@Test
publicvoidjedisPoolConn(){
JedisPoolConfigjedisPoolConfig=newJedisPoolConfig();
jedisPoolConfig.setMaxTotal(20);
jedisPoolConfig.setMinIdle(10);
jedisPoolConfig.setMaxIdle(15);
JedisPooljedisPool=newJedisPool(jedisPoolConfig,"192.168.59.160",6379);
Jedisjedis=jedisPool.getResource();
//取数据
Strings=jedis.get("name");
Strings1=jedis.get("age");
System.out.println(s);
System.out.println(s1);
}
/**
*连接池连接
*工具类
*/
@Test
publicvoidjedisPoolConn1(){
Jedisjedis1=JedisPoolUntil.getJedis();
//取数据
Strings=jedis1.get("name");
Strings1=jedis1.get("age");
System.out.println(s);
System.out.println(s1);
}
}

补充知识：JAVA使用Redis所需的MAVEN的POM文件

redis不仅可以通过命令行进行操作，同时redis也可以通过javaAPI进行操作,这是操作redis所需的依赖



redis.clients
jedis
2.9.0


junit
junit
4.12
test


org.testng
testng
6.14.3
test





org.apache.maven.plugins
maven-compiler-plugin
3.0

1.8
1.8
UTF-8

以上这篇使用java连接Redis,Maven管理操作就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。

使用java连接Redis,Maven管理操作

热门推荐

随机推荐