redis在java中的使用(实例讲解)

redis在java中的使用(实例讲解)

1、首先下载jar包放到你的工程中

2、练习

package com.jianyuan.redisTest;

import java.util.Iterator;

import java.util.List;

import java.util.Set;

import redis.clients.jedis.Jedis;

public class RedisTest {

public static void main(String[] args) {

//连接本地的Redis服务

Jedis jedis = new Jedis("127.0.0.1",6379);

//权限认证

jedis.auth("wenhongyu66");

jedis.select(0);

System.out.println("连接成功");

//查看服务是否运行

System.out.println(jedis.ping());

//设置 redis 字符串数据

jedis.set("runoobkey", "runoob.com");

// 获取存储的数据并输出

System.out.println("redis 存储的字符串为: "+ jedis.get("runoobkey"));

//存储数据到列表中

jedis.lpush("site-list", "Runoob");

jedis.lpush("site-list", "Google");

jedis.lpush("site-list", "Taobao");

System.out.println(jedis.llen("site-list"));

// 获取存储的数据并输出

List list = jedis.lrange("site-list", 0 ,jedis.llen("site-list"));

for(int i=0; i

System.out.println("列表项为: "+list.get(i));

}

// 获取数据并输出

Set keys = jedis.keys("*");

Iterator it=keys.iterator() ;

while(it.hasNext()){

String key = it.next();

System.out.println(key);

}

}

}

总结：自己可以封装一些工具类方便使用，包括连接池的配置，jedis参数的配置等。

private static JedisPool jedisPool = null;

private static Jedis jedis;

static {

jedis = getJedisPool().getResource();

}

/**

* 构建redis连接池

*/

public static JedisPool getJedisPool() {

if (jedisPool == null) {

JedisPoolConfig config = new JedisPoolConfig();

config.setMaxTotal(1024); // 可用连接实例的最大数目,如果赋值为-1,表示不限制.

config.setMaxIdle(5); // 控制一个Pool最多有多少个状态为idle(空闲的)jedis实例,默认值也是8

config.setMaxWaitMillis(1000 * 100); // 等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时/如果超过等待时间,则直接抛出异常

config.setTestOnBorrow(true); // 在borrow一个jedis实例时,是否提前进行validate操作,如果为true,则得到的jedis实例均是可用的

jedisPool = new JedisPool(config, "127.0.0.1", 6379http://);

}

return jedisPool;

}

/**

* 释放jedis资源

*/

public static void returnResource(Jedis jedis) {

if (jedis != null) {

jedis.close();

}

}

public static String get(String key) {

String value = null;

Jedis jedis = null;

try {

JedisPool pool = getJedisPool();

jedis = pool.getResource();

value = jedis.get(key);

}

catcBsFyXch (Exception e) {

returnResource(jedis);

e.printStackTrace();

}

finally {

returnResource(jedis);

}

return value;

}

RedisTemplate封装了从JedisPool中取jedis以及返回池中

public class RedisTemplate {

private JedisPool jedisPool;

public RedisTemplate(JedisPool jedisPool) {

this.jedisPool = jedisPool;

}

public T execute(RedisCallback callback) {

Jedis jedis = jedisPool.getResource();

try {

return callback.handle(jedis);

}

catch (Exception e) {

// throw your exception

throw e;

}

finally {

returnResource(jedis);

}

}

private void returnResource(Jedis jedis) {

if (jedis != null) {

jedis.close();

}

}

}

public interface RedisCallback {

public T handle(Jedis jedis);

}

System.out.println("列表项为: "+list.get(i));

}

// 获取数据并输出

Set keys = jedis.keys("*");

Iterator it=keys.iterator() ;

while(it.hasNext()){

String key = it.next();

System.out.println(key);

}

}

}

总结：自己可以封装一些工具类方便使用，包括连接池的配置，jedis参数的配置等。

private static JedisPool jedisPool = null;

private static Jedis jedis;

static {

jedis = getJedisPool().getResource();

}

/**

* 构建redis连接池

*/

public static JedisPool getJedisPool() {

if (jedisPool == null) {

JedisPoolConfig config = new JedisPoolConfig();

config.setMaxTotal(1024); // 可用连接实例的最大数目,如果赋值为-1,表示不限制.

config.setMaxIdle(5); // 控制一个Pool最多有多少个状态为idle(空闲的)jedis实例,默认值也是8

config.setMaxWaitMillis(1000 * 100); // 等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时/如果超过等待时间,则直接抛出异常

config.setTestOnBorrow(true); // 在borrow一个jedis实例时,是否提前进行validate操作,如果为true,则得到的jedis实例均是可用的

jedisPool = new JedisPool(config, "127.0.0.1", 6379http://);

}

return jedisPool;

}

/**

* 释放jedis资源

*/

public static void returnResource(Jedis jedis) {

if (jedis != null) {

jedis.close();

}

}

public static String get(String key) {

String value = null;

Jedis jedis = null;

try {

JedisPool pool = getJedisPool();

jedis = pool.getResource();

value = jedis.get(key);

}

catcBsFyXch (Exception e) {

returnResource(jedis);

e.printStackTrace();

}

finally {

returnResource(jedis);

}

return value;

}

RedisTemplate封装了从JedisPool中取jedis以及返回池中

public class RedisTemplate {

private JedisPool jedisPool;

public RedisTemplate(JedisPool jedisPool) {

this.jedisPool = jedisPool;

}

public T execute(RedisCallback callback) {

Jedis jedis = jedisPool.getResource();

try {

return callback.handle(jedis);

}

catch (Exception e) {

// throw your exception

throw e;

}

finally {

returnResource(jedis);

}

}

private void returnResource(Jedis jedis) {

if (jedis != null) {

jedis.close();

}

}

}

public interface RedisCallback {

public T handle(Jedis jedis);

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。