从RedisTemplate中获得Jedis实例

阳光穿透心脏的1/2处 2024-04-07 15:43 45阅读 0赞

在很多时候，我们也许需要使用一些更为高级的缓存服务器的 API，如 Redis 的流水线、事务和 Lua 语言等，所以也许会使用到 RedisTemplate 本身。

这里再多给几个实例帮助大家加深对 RedisTemplate 使用的理解。首先，定义 RedisTemplateService 的接口，代码如下所示。

> 1.  `package com.service;`
> 2.  `public interface RedisTemplateService {`
> 3.  `/**`
> 4.  `* 执行多个命令`
> 5.  `*/`
> 6.  `public void execMultiCommand();`
> 7.  `/**`
> 8.  `* 执行Redis事务`
> 9.  `*/`
> 10. `public void execTransaction();`
> 11. `/**`
> 12. `* 执行Redis流水线`
> 13. `*/`
> 14. `public void execPipeline();`
> 15. `}`

这样就可以提供一个实现类来展示如何使用这些方法了，代码如下所示。

> 1.  `package com.service.impl;`
> 2.  `import java.util.List;`
> 3.  `import org.springframework.beans.factory.annotation.Autowired;`
> 4.  `import org.springframework.dao.DataAccessException;`
> 5.  `import org.springframework.data.redis.core.RedisOperations;`
> 6.  `import org.springframework.data.redis.core.RedisTemplate;`
> 7.  `import org.springframework.data.redis.core.SessionCallback;`
> 8.  `import org.springframework.stereotype.Service;`
> 9.  `import com.service.RedisTemplateService;`
> 10. `@Service`
> 11. `public class RedisTemplateServiceImpl implements RedisTemplateService {`
> 12. `@Autowired`
> 13. `private RedisTemplate redisTemplate = null;`
> 14. `/**`
> 15. `* 使用Sessioncallback接口实现多个命令在一个Redis连接中执行`
> 16. `*/`
> 17. `@Override`
> 18. `public void execMultiCommand() {`
> 19. `// 使用Java 8 lambda表达式`
> 20. `Object obj = redisTemplate.execute((RedisOperations ops) -> {`
> 21. `ops.boundValueOps("key1").set("abc");`
> 22. `ops.boundHashOps("hash").put("hash-key-1", "hash-value-1");`
> 23. `return ops.boundValueOps("key1").get();`
> 24. `});`
> 25. `System.err.println(obj);`
> 26. `}`
> 27. `/**`
> 28. `* 使用SessionCallback接口实现事务在一个Redis连接中执行`
> 29. `*/`
> 30. `@Override`
> 31. `public void execTransaction() {`
> 32. `List list = (List) redisTemplate.execute((RedisOperations ops) -> {`
> 33. `// 监控`
> 34. `ops.watch("key1");`
> 35. `// 开启事务`
> 36. `ops.multi();`
> 37. `// 注意，命令都不会被马上执行，只会放到Redis的队列屮，只会返回为null`
> 38. `ops.boundValueOps("key1").set("abc");`
> 39. `ops.boundHashOps("hash").put("hash-key-1", "hash-value-1");`
> 40. `ops.opsForValue().get("key1");`
> 41. `// 执行exec方法后会触发事务执行，返回结果，存放到list屮`
> 42. `List result = ops.exec();`
> 43. `return result;`
> 44. `});`
> 45. `System.err.println(list);`
> 46. `}`
> 47. `/**`
> 48. `* 执行流水线，将多个命令一次性发送给Redis服务器`
> 49. `*/`
> 50. `@Override`
> 51. `public void execPipeline() {`
> 52. `// 使用匿名类实现`
> 53. `List list = redisTemplate.executePipelined(new SessionCallback() {`
> 54. `@Override`
> 55. `public Object execute(RedisOperations ops) throws DataAccessException {`
> 56. `// 在流水线下，命令不会马上返回结果，结果是一次性执行后返回的`
> 57. `ops.opsForValue().set("key1", "value1");`
> 58. `ops.opsForHash().put("hash", "key-hash-1", "value-hash-1");`
> 59. `ops.opsForValue().get("key1");`
> 60. `return null;`
> 61. `};`
> 62. `});`
> 63. `System.err.println(list);`
> 64. `}`
> 65. `}`

执行多个命令都会用到 SessionCallback 接口，这里可以使用 Java 8 的 Lambda 表达式或者 SessionCallback 接口的匿名类，而事实上也可以使用 RedisCallback 接口，但是它会涉及底层的 API，使用起来比较困难。

因此在大多数情况下，笔者建议优先使用 SessionCallback 接口进行操作，它会提供高级 API，简化编程。

因为对于 RedisTemplate 每执行一个方法，就意味着从 Redis 连接池中获取一条连接，使用 SessionCallBack 接口后，就意味着所有的操作都来自同一条 Redis 连接，而避免了命令在不同连接上执行。

因为事务或者流水线执行命令都是先缓存到一个队列里，所以执行方法后并不会马上返回结果，结果是通过最后的一次性执行才会返回的，这点在使用的时候要注意。

在需要保证数据一致性的情况下，要使用事务。在需要执行多个命令时，可以使用流水线，它让命令缓存到一个队列，然后一次性发给 Redis 服务器执行，从而提高性能。