Spring-data-redis使用心得
上个星期用redis,protobuf实现了一个轻量级的mq。过程中尝试用了spring-data-redis,目前是1.0.0.2.M2-SNAPSHOT版本,貌似之前已经release了一个版本。
?
优点
1.目前redis java客户端有多个:如jredis,jedis。用adapter的方式屏蔽了底层实现。让我们可以随意切换redis实现
?
2.将各种操作分类存放,不用在一个类中看到满篇的方法调用。ListOps,SetOps,功能职责进一步分离,方便调用方。
?
3.序列化,反序列化方式做了插件式,我们可以选择使用自己的序列化方式,我选择了protobuf。默认使用的是蛋疼的JDK默认方式。
?
4.提供模板模式,省去了很多connection打开,关闭的操作代码
?
5.对底层的connection进行了抽象工厂,以供依赖注入
?
6.集成了spring的transaction manager。
?
?
但是使用时bug一堆,用了的童鞋请注意。
1. 方法 V rightPop(K key, long timeout, TimeUnit unit);
?? ?TimeUnit没做校验,我可以传入MILLISECOND,但此时如果小于1s,它会按照0来处理,如果pop操作的话就会永久hold住。我们再使用时TimeUnit需要大于SECOND,因为reds的bl(r)pop是按秒计算的。spring应该做校验
?
2. 方法 ???V leftPop(K key, long timeout, TimeUnit unit)?
Jedis blpop的返回值是list,第一个值是key,第二个值才是value,spring把key当value返回给了调用者。这么明显的错你哥哥都发现不了吗?
?
3.接口,RedisCallback, T doInRedis(RedisConnection connection) throws DataAccessException;
由redis template调用,我们提供给redistemplate我们定义好的序列化,反序列化实现,在callback时获取不到。其序列化反序列化最好封装在callback中,这样用户自定callback时可以使用到自己设置的序列化,反序列化方式。作为存储实现来说,序列化,反序列化是很重要的一步。
?
4.方法 RedisSerializer<?> getDefaultSerializer()
靠,返回给我一个带问号的泛型,你让我们调用者到底用不用泛型呢?
?
5. ?
?
?
public <T> T execute(RedisCallback<T> action, boolean exposeConnection, boolean pipeline, RedisSerializer<?> returnSerializer) {Assert.notNull(action, "Callback object must not be null");RedisConnectionFactory factory = getConnectionFactory();RedisConnection conn = RedisConnectionUtils.getConnection(factory);boolean existingConnection = TransactionSynchronizationManager.hasResource(factory);preProcessConnection(conn, existingConnection);boolean pipelineStatus = conn.isPipelined();if (pipeline && !pipelineStatus) {conn.openPipeline();}try {RedisConnection connToExpose = (exposeConnection ? conn : createRedisConnectionProxy(conn));T result = action.doInRedis(connToExpose);// TODO: should do flush?return postProcessResult(result, conn, existingConnection);} finally {try {if (pipeline && !pipelineStatus) {conn.closePipeline();}} finally {RedisConnectionUtils.releaseConnection(conn, factory);}}}?
既然让我们用了pipeline,为什么不给我们返回值呢。pipleline的返回值是在conn.closePipeline();时候返回的,使用pipeline得到的返回值都是null,pipeline只能用于没有返回值的操作。
?
?
个人希望spring可以好好设计封装一下。