1、创建java程序,通过程序实现存取操作
(1)导入jar包:
(2)程序:
import redis.clients.jedis.Jedis;
public class JedisDemo {
public void test(){
Jedis jedis=new Jedis("192.168.204.128",6379);
jedis.set("河南","郑州");
String add=jedis.get("河南");
System.out.println(add);
}
public static void main(String[]args){
JedisDemo jedisDemo=new JedisDemo();
jedisDemo.test();
}
}
(3)运行结果:
2、连接池的方式
(1)代码实现:
import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; public class JedisDemo { public void test(){ //对连接池进行配置 JedisPoolConfig jedisPoolConfig=new JedisPoolConfig(); jedisPoolConfig.setMaxIdle(30);//最大闲置个数 jedisPoolConfig.setMinIdle(10);//最小闲置个数 jedisPoolConfig.setMaxTotal(50);//最大连接数 //创建一个redis连接池 JedisPool jedisPool=new JedisPool(jedisPoolConfig,"192.168.204.128",6379); //从连接池中获取redis的连接资源 Jedis jedis=jedisPool.getResource(); //对数据库进行存取操作 jedis.set("河南","郑州"); System.out.println(jedis.get("河南")); //释放资源 jedis.close(); jedisPool.close(); } public static void main(String[]args){ JedisDemo jedisDemo=new JedisDemo(); jedisDemo.test(); } }
(2)运行结果:
3、连接池工具类:
import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; public class JedisDemo { private static JedisPool jedisPool= null; static{ //对连接池进行配置 JedisPoolConfig jedisPoolConfig=new JedisPoolConfig(); jedisPoolConfig.setMaxIdle(30);//最大闲置个数 jedisPoolConfig.setMinIdle(10);//最小闲置个数 jedisPoolConfig.setMaxTotal(50);//最大连接数 //创建一个redis连接池 jedisPool=new JedisPool(jedisPoolConfig,"192.168.204.128",6379); } public static Jedis getJedis(){//从连接池中获取redis的连接资源 return jedisPool.getResource(); } public static void main(String[] args){ Jedis jedis=getJedis(); String add=jedis.get("河南"); System.out.println(add); } }
4、添加配置文件的工具类:
(1)配置文件:
redis.maxIdle=30 redis.minIdle=10 redis.maxTotal=50 redis.url=192.168.204.128 redis.port=6379
(2)工具类:
import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; import java.io.IOException; import java.io.InputStream; import java.util.Properties; public class JedisDemo { private static JedisPool jedisPool= null; static{ //读取配置文件 InputStream inputStream=JedisDemo.class.getClassLoader().getResourceAsStream("redis.properties"); Properties properties=new Properties(); try { properties.load(inputStream); } catch (IOException e) { e.printStackTrace(); } //对连接池进行配置 JedisPoolConfig jedisPoolConfig=new JedisPoolConfig(); jedisPoolConfig.setMaxIdle(Integer.parseInt(properties.get("redis.maxIdle").toString()));//最大闲置个数 jedisPoolConfig.setMinIdle(Integer.parseInt(properties.get("redis.minIdle").toString()));//最小闲置个数 jedisPoolConfig.setMaxTotal(Integer.parseInt(properties.get("redis.maxTotal").toString()));//最大连接数 //创建一个redis连接池 jedisPool=new JedisPool(jedisPoolConfig,properties.getProperty("redis.url"),Integer.parseInt(properties.get("redis.port").toString())); } public static Jedis getJedis(){//从连接池中获取redis的连接资源 return jedisPool.getResource(); } public static void main(String[] args){ Jedis jedis=getJedis(); String add=jedis.get("河南"); System.out.println(add); } }
读取配置文件中的信息,在有关的参数改变时,只需要改变配置文件即可。