spring结合Redis例子,简单入门例子

pom.xml

<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 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的方法,还有更多的方法没有去使用,这里当一个入门的小例子吧

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

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(); } }

好了入门例子就先这么多了...如果有什么疑问,可以加我QQ 1109349806 联系我,交流学习方法

项目源代码 redis.rar
http://blog.mkfree.com/posts/12

  1. da shang
    donate-alipay
               donate-weixin weixinpay

发表评论↓↓