设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

详解java之redis篇(spring-data-redis整合)

2017-3-7 12:51| 发布者: zhangjf| 查看: 1247| 评论: 0

摘要: 1，利用spring-data-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 ...

1，利用spring-data-redis整合

项目使用的pom.xml：

  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4. <modelVersion>4.0.0</modelVersion>
  6. <groupId>com.x.redis</groupId>
  7. <artifactId>Spring_redis</artifactId>
  8. <version>1.0-SNAPSHOT</version>
  9. <packaging>jar</packaging>
  11. <name>Spring_redis</name>
  12. <url>http://maven.apache.org</url>
  14. <properties>
  15. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  16. </properties>
  18. <dependencies>
  19. <dependency>
  20. <groupId>org.springframework.data</groupId>
  21. <artifactId>spring-data-redis</artifactId>
  22. <version>1.0.2.RELEASE</version>
  23. </dependency>
  24. <dependency>
  25. <groupId>org.springframework</groupId>
  26. <artifactId>spring-core</artifactId>
  27. <version>3.1.2.RELEASE</version>
  28. </dependency>
  31. <dependency>
  32. <groupId>redis.clients</groupId>
  33. <artifactId>jedis</artifactId>
  34. <version>2.1.0</version>
  35. </dependency>
  37. <dependency>
  38. <groupId>junit</groupId>
  39. <artifactId>junit</artifactId>
  40. <version>4.8.2</version>
  41. <scope>test</scope>
  42. </dependency>
  43. <dependency>
  44. <groupId>org.slf4j</groupId>
  45. <artifactId>slf4j-api</artifactId>
  46. <version>1.6.1</version>
  47. </dependency>
  48. <!-- 将现有的jakarta commons logging的调用转换成lsf4j的调用。 -->
  49. <dependency>
  50. <groupId>org.slf4j</groupId>
  51. <artifactId>jcl-over-slf4j</artifactId>
  52. <version>1.6.1</version>
  53. </dependency>
  54. <!-- Hack：确保commons-logging的jar包不被引入，否则将和jcl-over-slf4j冲突 -->
  55. <dependency>
  56. <groupId>commons-logging</groupId>
  57. <artifactId>commons-logging</artifactId>
  58. <version>1.1.1</version>
  59. <scope>provided</scope>
  60. </dependency>
  61. <!-- slf4j的实现：logback，用来取代log4j。更快、更强！ -->
  62. <dependency>
  63. <groupId>ch.qos.logback</groupId>
  64. <artifactId>logback-classic</artifactId>
  65. <version>0.9.24</version>
  66. <scope>runtime</scope>
  67. </dependency>
  68. </dependencies>
  69. </project>
复制代码

除了log部分，只有一个spring core 和 spring-data-redis了

项目文件目录结构：

applicationContext.xml：

1，context:property-placeholder 标签用来导入properties文件。从而替换${redis.maxIdle}这样的变量。

2，context:component-scan 是为了在com.x.redis.dao报下的类能够实用spring的注解注入的方式。

3，事实上我们只需要把JedisPoolConfig配数来就好了，接下来就是spring的封装了。所以直接看UserDAOImpl的实现就明白了。

  2. <?xml version="1.0" encoding="UTF-8"?>
  3. <beans xmlns="http://www.springframework.org/schema/beans"
  4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
  5. xmlns:context="http://www.springframework.org/schema/context"
  6. xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
  7. xmlns:aop="http://www.springframework.org/schema/aop"
  8. xsi:schemaLocation="
  9. http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
  10. http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
  12. <context:property-placeholder location="classpath:redis.properties" />
  13. <context:component-scan base-package="com.x.redis.dao">
  14. </context:component-scan>
  15. <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
  16. <property name="maxIdle" value="${redis.maxIdle}" />
  17. <property name="maxActive" value="${redis.maxActive}" />
  18. <property name="maxWait" value="${redis.maxWait}" />
  19. <property name="testOnBorrow" value="${redis.testOnBorrow}" />
  20. </bean>
  22. <bean id="connectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
  23. p:host-name="${redis.host}" p:port="${redis.port}" p:password="${redis.pass}" p:pool-config-ref="poolConfig"/>
  25. <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
  26. <property name="connectionFactory" ref="connectionFactory" />
  27. </bean>
  29. <bean id="userDAO" class="com.x.redis.dao.impl.UserDAOImpl" />
  30. </beans>
复制代码

redis.properties：

  2. # Redis settings
  3. #redis.host=192.168.20.101
  4. #redis.port=6380
  5. #redis.pass=foobared
  6. redis.host=127.0.0.1
  7. redis.port=6379
  8. redis.pass=
  10. redis.maxIdle=300
  11. redis.maxActive=600
  12. redis.maxWait=1000
  13. redis.testOnBorrow=true
复制代码

UserDAOImpl：

1，spring对dao层的封装很多用了类似于下面代码的模板方式。

2，RedisTemplate就是spring对redis的一个封装而已。

  2. public class UserDAOImpl implements UserDAO {
  4. @Autowired
  5. protected RedisTemplate<Serializable, Serializable> redisTemplate;
  7. public void saveUser(final User user) {
  8. redisTemplate.execute(new RedisCallback<Object>() {
  10. @Override
  11. public Object doInRedis(RedisConnection connection) throws DataAccessException {
  12. connection.set(redisTemplate.getStringSerializer().serialize("user.uid." + user.getId()),
  13. redisTemplate.getStringSerializer().serialize(user.getName()));
  14. return null;
  15. }
  16. });
  17. }
  19. @Override
  20. public User getUser(final long id) {
  21. return redisTemplate.execute(new RedisCallback<User>() {
  22. @Override
  23. public User doInRedis(RedisConnection connection) throws DataAccessException {
  24. byte[] key = redisTemplate.getStringSerializer().serialize("user.uid." + id);
  25. if (connection.exists(key)) {
  26. byte[] value = connection.get(key);
  27. String name = redisTemplate.getStringSerializer().deserialize(value);
  28. User user = new User();
  29. user.setName(name);
  30. user.setId(id);
  31. return user;
  32. }
  33. return null;
  34. }
  35. });
  36. }
  39. }
复制代码

其他：

User：

  2. public class User {
  4. private long id;
  5. private String name;
  7. public long getId() {
  8. return id;
  9. }
  11. public void setId(long id) {
  12. this.id = id;
  13. }
  15. public String getName() {
  16. return name;
  17. }
  19. public void setName(String name) {
  20. this.name = name;
  21. }
  22. }
复制代码

测试代码：

  2. public static void main(String[] args) {
  3. ApplicationContext ac = new ClassPathXmlApplicationContext("classpath:/applicationContext.xml");
  4. UserDAO userDAO = (UserDAO)ac.getBean("userDAO");
  5. User user1 = new User();
  6. user1.setId(1);
  7. user1.setName("obama");
  8. userDAO.saveUser(user1);
  9. User user2 = userDAO.getUser(1);
  10. System.out.println(user2.getName());
  11. }
复制代码

2，不利用spring-data-redis整合

个人觉得这样整合灵活度更大，能够更加明了的完成任务。

pom.xml:

  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4. <modelVersion>4.0.0</modelVersion>
  6. <groupId>com.d.work</groupId>
  7. <artifactId>Redis_Templete</artifactId>
  8. <version>1.0-SNAPSHOT</version>
  9. <packaging>jar</packaging>
  11. <name>Redis_Templete</name>
  12. <url>http://maven.apache.org</url>
  14. <properties>
  15. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  16. </properties>
  18. <dependencies>
  19. <dependency>
  20. <groupId>junit</groupId>
  21. <artifactId>junit</artifactId>
  22. <version>3.8.1</version>
  23. <scope>test</scope>
  24. </dependency>
  25. <dependency>
  26. <groupId>redis.clients</groupId>
  27. <artifactId>jedis</artifactId>
  28. <version>2.1.0</version>
  29. </dependency>
  30. <dependency>
  31. <groupId>org.springframework</groupId>
  32. <artifactId>spring-core</artifactId>
  33. <version>3.1.2.RELEASE</version>
  34. </dependency>
  35. <dependency>
  36. <groupId>org.springframework</groupId>
  37. <artifactId>spring-beans</artifactId>
  38. <version>3.1.2.RELEASE</version>
  39. </dependency>
  40. <dependency>
  41. <groupId>org.springframework</groupId>
  42. <artifactId>spring-context</artifactId>
  43. <version>3.1.2.RELEASE</version>
  44. </dependency>
  45. <dependency>
  46. <groupId>org.slf4j</groupId>
  47. <artifactId>slf4j-api</artifactId>
  48. <version>1.6.1</version>
  49. </dependency>
  50. <!-- 将现有的jakarta commons logging的调用转换成lsf4j的调用。 -->
  51. <dependency>
  52. <groupId>org.slf4j</groupId>
  53. <artifactId>jcl-over-slf4j</artifactId>
  54. <version>1.6.1</version>
  55. </dependency>
  56. <!-- Hack：确保commons-logging的jar包不被引入，否则将和jcl-over-slf4j冲突 -->
  57. <dependency>
  58. <groupId>commons-logging</groupId>
  59. <artifactId>commons-logging</artifactId>
  60. <version>1.1.1</version>
  61. <scope>provided</scope>
  62. </dependency>
  63. <!-- slf4j的实现：logback，用来取代log4j。更快、更强！ -->
  64. <dependency>
  65. <groupId>ch.qos.logback</groupId>
  66. <artifactId>logback-classic</artifactId>
  67. <version>0.9.24</version>
  68. <scope>runtime</scope>
  69. </dependency>
  70. </dependencies>
  71. </project>
复制代码

目录结构：

data-source.xml

1，context:property-placeholder 和 context:component-scan 前面解释过啦。

2，配置了一个ShardedJedisPool，在jdeis里 还有个JedisPool。这两个的区别:

一个是分片形式，可以连接有主备的redis服务端，一个是单个的。详细后续学习

3，因为不使用spring-data-redis的封装，所以自己要自己封装一个

  2. <?xml version="1.0" encoding="UTF-8"?>
  3. <beans xmlns="http://www.springframework.org/schema/beans"
  4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
  5. xmlns:context="http://www.springframework.org/schema/context"
  6. xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
  7. xmlns:aop="http://www.springframework.org/schema/aop"
  8. xsi:schemaLocation="
  9. http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
  10. http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
  12. <context:property-placeholder location="classpath:redis.properties" />
  13. <context:component-scan base-package="com.d.work.main">
  14. </context:component-scan>
  15. <context:component-scan base-package="com.d.work.redis">
  16. </context:component-scan>
  17. <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
  18. <property name="maxActive" value="50" />
  19. <property name="maxIdle" value="8" />
  20. <property name="maxWait" value="1000" />
  21. <property name="testOnBorrow" value="true"/>
  22. <property name="testOnReturn" value="true"/>
  23. <!-- <property name="testWhileIdle" value="true"/> -->
  24. </bean>
  26. <bean id="shardedJedisPool" class="redis.clients.jedis.ShardedJedisPool" scope="singleton">
  27. <constructor-arg index="0" ref="jedisPoolConfig" />
  28. <constructor-arg index="1">
  29. <list>
  30. <bean class="redis.clients.jedis.JedisShardInfo">
  31. <constructor-arg name="host" value="${redis.host}" />
  32. <constructor-arg name="port" value="${redis.port}" />
  33. <constructor-arg name="timeout" value="${redis.timeout}" />
  34. <constructor-arg name="weight" value="1" />
  35. </bean>
  36. </list>
  37. </constructor-arg>
  38. </bean>
  39. </beans>
复制代码

RedisDataSource:定义三个方法

  2. public interface RedisDataSource {
  3. public abstract ShardedJedis getRedisClient();
  4. public void returnResource(ShardedJedis shardedJedis);
  5. public void returnResource(ShardedJedis shardedJedis,boolean broken);
  6. }
复制代码

实现redisDataSource:

1, 注入配置好的ShardedJedisPool，这三个方法的作用：

  • getRedisClient() ： 取得redis的客户端，可以执行命令了。
  • returnResource(ShardedJedis shardedJedis) ： 将资源返还给pool
  • returnResource(ShardedJedis shardedJedis, boolean broken) : 出现异常后，将资源返还给pool （其实不需要第二个方法）
  2. @Repository("redisDataSource")
  3. public class RedisDataSourceImpl implements RedisDataSource {
  5. private static final Logger log = LoggerFactory.getLogger(RedisDataSourceImpl.class);
  7. @Autowired
  8. private ShardedJedisPool shardedJedisPool;
  10. public ShardedJedis getRedisClient() {
  11. try {
  12. ShardedJedis shardJedis = shardedJedisPool.getResource();
  13. return shardJedis;
  14. } catch (Exception e) {
  15. log.error("getRedisClent error", e);
  16. }
  17. return null;
  18. }
  20. public void returnResource(ShardedJedis shardedJedis) {
  21. shardedJedisPool.returnResource(shardedJedis);
  22. }
  24. public void returnResource(ShardedJedis shardedJedis, boolean broken) {
  25. if (broken) {
  26. shardedJedisPool.returnBrokenResource(shardedJedis);
  27. } else {
  28. shardedJedisPool.returnResource(shardedJedis);
  29. }
  30. }
  31. }
复制代码

第二层的封装：RedisClientTemplate，例子实现了放值和取值。最后代码提供了全部命令的实现。

代码就是映射性质的又一次调用jedis的方法而已，用了个broken来做标示符，决定返还资源的方式。

这一层的目的主要也是让再上层的调用不需要关心pool中链接的取得和返还问题了。

  2. @Repository("redisClientTemplate")
  3. public class RedisClientTemplate {
  5. private static final Logger log = LoggerFactory.getLogger(RedisClientTemplate.class);
  7. @Autowired
  8. private RedisDataSource redisDataSource;
  10. public void disconnect() {
  11. ShardedJedis shardedJedis = redisDataSource.getRedisClient();
  12. shardedJedis.disconnect();
  13. }
  15. /**
  16. * 设置单个值
  17. *
  18. * @param key
  19. * @param value
  20. * @return
  21. */
  22. public String set(String key, String value) {
  23. String result = null;
  25. ShardedJedis shardedJedis = redisDataSource.getRedisClient();
  26. if (shardedJedis == null) {
  27. return result;
  28. }
  29. boolean broken = false;
  30. try {
  31. result = shardedJedis.set(key, value);
  32. } catch (Exception e) {
  33. log.error(e.getMessage(), e);
  34. broken = true;
  35. } finally {
  36. redisDataSource.returnResource(shardedJedis, broken);
  37. }
  38. return result;
  39. }
  41. /**
  42. * 获取单个值
  43. *
  44. * @param key
  45. * @return
  46. */
  47. public String get(String key) {
  48. String result = null;
  49. ShardedJedis shardedJedis = redisDataSource.getRedisClient();
  50. if (shardedJedis == null) {
  51. return result;
  52. }
  54. boolean broken = false;
  55. try {
  56. result = shardedJedis.get(key);
  58. } catch (Exception e) {
  59. log.error(e.getMessage(), e);
  60. broken = true;
  61. } finally {
  62. redisDataSource.returnResource(shardedJedis, broken);
  63. }
  64. return result;
  65. }
  66. }
复制代码

测试代码：

  2. public static void main(String[] args) {
  3. ApplicationContext ac = new ClassPathXmlApplicationContext("classpath:/data-source.xml");
  4. RedisClientTemplate redisClient = (RedisClientTemplate)ac.getBean("redisClientTemplate");
  5. redisClient.set("a", "abc");
  6. System.out.println(redisClient.get("a"));
  7. }
复制代码

附上RedisClientTemplate全部实现：

RedisClientTemplate代码太多，附上下载地址：http://xiazai.jb51.net/201701/yuanma/RedisClientTemplate_jb51.rar

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持程序员之家。

收藏 邀请
上一篇：java 中cookie的详解及简单实例下一篇：图片验证码概述及实现步骤

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-5-4 02:20

Copyright 2015-2025 djqfx

返回顶部