Redis入门很简单之五【Jedis和Spring的整合】

Redis入门很简单之五【Jedis和Spring的整合】

博客分类：

• NoSQL/Redis/MongoDB

redisnosql缓存jedisspring

在上一篇文章中，简单介绍了Jedis的连接池使用方式。

如果和Spring进行整合的话，我们将获得更好的简洁性、灵活性，显然是一种更加优雅(graceful)的方式。

[一]. 搭建环境：
 1. 在之前版本的基础之上，添加如下的依赖：
   spring.jar
   commons-logging.jar
   log4j-1.2.15.jar
   同时添加日志配置文件：log4j.properties到classpath下面。
 2. 配置Spring文件：applicationContext.xml
  注意：连接池jedisPool的配置，这里使用了构造方式注入，这是和Jedis的API一致的；
   在注入port时，需要使用使用type = "int"指定注入的参数类型，否则出现异常。

Xml代码  

1. <beans xmlns="http://www.springframework.org/schema/beans"
2. xmlns:context="http://www.springframework.org/schema/context"
3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
5. http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd">
6. <!-- 加载redis配置文件 -->
7. <context:property-placeholder location="classpath:redis.properties"/>
8. <!-- redis连接池的配置 -->
9. <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
10. <property name="maxActive" value="${redis.pool.maxActive}"/>
11. <property name="maxIdle" value="${redis.pool.maxIdle}"/>
12. <property name="minIdle" value="${redis.pool.minIdle}"/>
13. <property name="maxWait" value="${redis.pool.maxWait}"/>
14. <property name="testOnBorrow" value="${redis.pool.testOnBorrow}"/>
15. <property name="testOnReturn" value="${redis.pool.testOnReturn}"/>
16. </bean>
17. <!-- redis的连接池pool，不是必选项：timeout/password  -->
18. <bean id = "jedisPool" class="redis.clients.jedis.JedisPool">
19. <constructor-arg index="0" ref="jedisPoolConfig"/>
20. <constructor-arg index="1" value="${redis.host}"/>
21. <constructor-arg index="2" value="${redis.port}" type="int"/>
22. <constructor-arg index="3" value="${redis.timeout}" type="int"/>
23. <constructor-arg index="4" value="${redis.password}"/>
24. </bean>
25. </beans>

[二]. 从SPring容器中获取JedisPool：

Java代码  

1. ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
2. JedisPool pool = (JedisPool) context.getBean("jedisPool");
3. Jedis jedis = pool.getResource();
4. ...
5. pool.returnResource(jedis);

[三]. 缓存JavaBean：
 上一篇文章中，已经有了对Jedis使用的基本说明。

当然很多时候我们都希望Redis能够对JavaBean进行缓存，这需要借助于JDK提供的序列化技术。
   1. 要求缓存实体实现了序列化Serializable接口：这里以Userinfo为例。
   2. 序列化工具类：Jedis对序列化的支持，是提供了字节数组byte[]作为参数；
  为此编写SerializingUtil工具类负责byte[]和JavaBean之间的相互转换。该方法的API如下所示：

Java代码  

1. public static byte[] serialize(Object source);
2. public static Object deserialize(byte[] source);

该工具类的具体实现：

Java代码  

1. /**
2. * 功能简述: 序列化工具类，负责byte[]和Object之间的相互转换.
3. * @author Nick Xu
4. * @version 1.0
5. */
6. public class SerializingUtil {
7. private static Log logger = LogFactory.getLog(SerializingUtil.class);
8. /**
9. * 功能简述: 对实体Bean进行序列化操作.
10. * @param source 待转换的实体
11. * @return 转换之后的字节数组
12. * @throws Exception
13. */
14. public static byte[] serialize(Object source) {
15. ByteArrayOutputStream byteOut = null;
16. ObjectOutputStream ObjOut = null;
17. try {
18. byteOut = new ByteArrayOutputStream();
19. ObjOut = new ObjectOutputStream(byteOut);
20. ObjOut.writeObject(source);
21. ObjOut.flush();
22. }
23. catch (IOException e) {
24. logger.error(source.getClass().getName()
25. + " serialized error !", e);
26. }
27. finally {
28. try {
29. if (null != ObjOut) {
30. ObjOut.close();
31. }
32. }
33. catch (IOException e) {
34. ObjOut = null;
35. }
36. }
37. return byteOut.toByteArray();
38. }
39. /**
40. * 功能简述: 将字节数组反序列化为实体Bean.
41. * @param source 需要进行反序列化的字节数组
42. * @return 反序列化后的实体Bean
43. * @throws Exception
44. */
45. public static Object deserialize(byte[] source) {
46. ObjectInputStream ObjIn = null;
47. Object retVal = null;
48. try {
49. ByteArrayInputStream byteIn = new ByteArrayInputStream(source);
50. ObjIn = new ObjectInputStream(byteIn);
51. retVal = ObjIn.readObject();
52. }
53. catch (Exception e) {
54. logger.error("deserialized error  !", e);
55. }
56. finally {
57. try {
58. if(null != ObjIn) {
59. ObjIn.close();
60. }
61. }
62. catch (IOException e) {
63. ObjIn = null;
64. }
65. }
66. return retVal;
67. }
68. }

3. 对JavaBean的存储和获取：
        定义实体：借助于Timestamp类，获取ms值。

Java代码  

1. Userinfo actual = new Userinfo(140520, "Nick Xu",
2. new Date(Timestamp.valueOf("1990-11-11 00:00:00").getTime()));

使用Jedis操作：key、value都需要转成byte[]字节数组。

Java代码  

1. String key = "user.userid." + actual.getUserId();
2. jedis.set(key.getBytes(), SerializingUtil.serialize(actual));
3. Userinfo expected = (Userinfo) SerializingUtil.deserialize(jedis.get(key.getBytes()));

对象的比较：需要覆写equals和hashCode方法。

Java代码  

1. assertEquals(expected, actual);

0 
顶

0 
踩

分享到：  

Redis入门很简单之六【Jedis常见操作】| Redis入门很简单之四【初识Jedis】

• 2014-06-07 19:17
• 浏览 9661
• 评论(5)
• 分类:互联网
• 相关推荐

参考知识库

Redis知识库4908  关注 | 738  收录

评论

5 楼 di1984HIT 2017-02-02

慢慢会完善很多。罗马不是一日建成

4 楼 alafqq 2016-05-20

希望楼主提供完整的代码~~哈哈jredis.properties

3 楼 19774279 2015-07-31

Hello_Nick_Xu 写道

yixiandave 写道

Spring不是有一个Spring-data-redis的项目吗？？

嗯，是的，稍后会对Spring Data Redis进行介绍，使用起来确实方便 ，不过带来的却是Redis特性的大量丢失 ，尤其是，不支持Sharding机制。

都丢失了什么，能例举一下吗？有文章吗？

2 楼 Hello_Nick_Xu 2014-06-08

yixiandave 写道

Spring不是有一个Spring-data-redis的项目吗？？

嗯，是的，稍后会对Spring Data Redis进行介绍，使用起来确实方便 ，不过带来的却是Redis特性的大量丢失 ，尤其是，不支持Sharding机制。