spring 结合 redis 例子 （转)

好了费话不多说了,介绍下spring 结合redis是怎么操作数据的 这里我用了maven管理,由于简单嘛,依赖下包就行了..不用单独去依赖包,成了我的习惯

好了,下面是pom的代码

[xml] view plaincopy

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<groupId>redis</groupId>

<artifactId>redis</artifactId>

<version>0.0.1-SNAPSHOT</version>

<build>

</build>

<dependencies>

<dependency>

<groupId>org.springframework.data</groupId>

<artifactId>spring-data-redis</artifactId>

<version>1.0.2.RELEASE</version>

</dependency>

</dependencies>

</project>

在pom里添加了redis spring客户端的依赖,那么所有的jar包都会帮你自动下载下来,是不是很方便啊,哈

下面是spring-context.xml代码

[xml] view plaincopy

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:util="http://www.springframework.org/schema/util" xmlns:mvc="http://www.springframework.org/schema/mvc"

xsi:schemaLocation="http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.1.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd
http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd">

<!--注解说明 -->

<context:annotation-config />

<!-- 把标记了@Controller注解的类转换为bean -->

<context:component-scan base-package="com.mkfree.**" />

<!-- redis工厂 -->

<bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"

p:host-name="192.168.9.140" p:port="6379" p:password="87980879" />

<!-- redis服务封装 -->

<bean id="redisService" class="com.mkfree.redis.test.RedisService">

</bean>

这里配置了一个跟spring 集成的redis客户端,ip port password自己定哦,这里我在redis配置文件了定义了需求密码认证,你们先不要用吧,为了简单起见

下面是RedisService,里面包含了对redis的方法,还有更多的方法没有去使用,这里当一个入门的小例子吧

[java] view plaincopy

package com.mkfree.redis.test;

import java.util.Set;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;

import redis.clients.jedis.Jedis;

/**

* 封装redis 缓存服务器服务接口

* @author hk

*

* 2012-12-16 上午3:09:18

*/

public class RedisService {

/**

* 通过key删除（字节）

* @param key

*/

public void del(byte [] key){

this.getJedis().del(key);

}

/**

* 通过key删除

* @param key

*/

public void del(String key){

this.getJedis().del(key);

}

/**

* 添加key value 并且设置存活时间(byte)

* @param key

* @param value

* @param liveTime

*/

public void set(byte [] key,byte [] value,int liveTime){

this.set(key, value);

this.getJedis().expire(key, liveTime);

}

/**

* 添加key value 并且设置存活时间

* @param key

* @param value

* @param liveTime

*/

public void set(String key,String value,int liveTime){

this.set(key, value);

this.getJedis().expire(key, liveTime);

}

/**

* 添加key value

* @param key

* @param value

*/

public void set(String key,String value){

this.getJedis().set(key, value);

}

/**添加key value (字节)(序列化)

* @param key

* @param value

*/

public void set(byte [] key,byte [] value){

this.getJedis().set(key, value);

}

/**

* 获取redis value (String)

* @param key

* @return

*/

public String get(String key){

String value = this.getJedis().get(key);

return value;

}

/**

* 获取redis value (byte [] )(反序列化)

* @param key

* @return

*/

public byte[] get(byte [] key){

return this.getJedis().get(key);

}

/**

* 通过正则匹配keys

* @param pattern

* @return

*/

public Set<String> keys(String pattern){

return this.getJedis().keys(pattern);

}

/**

* 检查key是否已经存在

* @param key

* @return

*/

public boolean exists(String key){

return this.getJedis().exists(key);

}

/**

* 清空redis 所有数据

* @return

*/

public String flushDB(){

return this.getJedis().flushDB();

}

/**

* 查看redis里有多少数据

*/

public long dbSize(){

return this.getJedis().dbSize();

}

/**

* 检查是否连接成功

* @return

*/

public String ping(){

return this.getJedis().ping();

}

/**

* 获取一个jedis 客户端

* @return

*/

private Jedis getJedis(){

if(jedis == null){

return jedisConnectionFactory.getShardInfo().createResource();

}

return jedis;

}

private RedisService (){

}

//操作redis客户端

private static Jedis jedis;

@Autowired

@Qualifier("jedisConnectionFactory")

private JedisConnectionFactory jedisConnectionFactory;

}

下面是测试代码TestRedis.java

[java] view plaincopy

package com.mkfree.redis.test;

import java.util.Set;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

/**

* redis spring 简单例子

* @author hk

*

* 2012-12-22 上午10:40:15

*/

public class TestRedis {

public static void main(String[] args) throws InterruptedException {

ApplicationContext app = new ClassPathXmlApplicationContext("classpath:spring-context.xml");

//这里已经配置好,属于一个redis的服务接口

RedisService redisService = (RedisService) app.getBean("redisService");

String ping = redisService.ping();//测试是否连接成功,连接成功输出PONG

System.out.println(ping);

//首先,我们看下redis服务里是否有数据

long dbSizeStart = redisService.dbSize();

System.out.println(dbSizeStart);

redisService.set("username", "oyhk");//设值(查看了源代码,默认存活时间30分钟)

String username = redisService.get("username");//取值

System.out.println(username);

redisService.set("username1", "oyhk1", 1);//设值,并且设置数据的存活时间(这里以秒为单位)

String username1 = redisService.get("username1");

System.out.println(username1);

Thread.sleep(2000);//我睡眠一会,再去取,这个时间超过了,他的存活时间

String liveUsername1 = redisService.get("username1");

System.out.println(liveUsername1);//输出null

//是否存在

boolean exist = redisService.exists("username");

System.out.println(exist);

//查看keys

Set<String> keys = redisService.keys("*");//这里查看所有的keys

System.out.println(keys);//只有username username1(已经清空了)

//删除

redisService.set("username2", "oyhk2");

String username2 = redisService.get("username2");

System.out.println(username2);

redisService.del("username2");

String username2_2 = redisService.get("username2");

System.out.println(username2_2);//如果为null,那么就是删除数据了

//dbsize

long dbSizeEnd = redisService.dbSize();

System.out.println(dbSizeEnd);

//清空reids所有数据

//redisService.flushDB();

}

}