redisson整合spring

package com.basic.common.utils.redis;  

1. import java.util.Map;  
2. import org.redisson.api.RAtomicLong;  
3. import org.redisson.api.RBucket;  
4. import org.redisson.api.RCountDownLatch;  
5. import org.redisson.api.RDeque;  
6. import org.redisson.api.RList;  
7. import org.redisson.api.RLock;  
8. import org.redisson.api.RMap;  
9. import org.redisson.api.RQueue;  
10. import org.redisson.api.RSet;  
11. import org.redisson.api.RSortedSet;  
12. import org.redisson.api.RTopic;  
13. import org.redisson.api.RedissonClient;  
14. import org.springframework.stereotype.Service;  
15. import com.basic.common.utils.generator.CollectionObjectConvert;  
16. @Service  
17. public class RedissonUtils{  
18. /**  
19.      * 获取字符串对象  
20.      * @param redisson  
21.      * @param t  
22.      * @param objectName  
23.      * @return  
24.      */    
25. public static <T> RBucket<T> getRBucket(RedissonClient redissonClient,String objectName){    
26.         RBucket<T> bucket=redissonClient.getBucket(objectName);    
27. return bucket;    
28.     }    
29. /**  
30.      * 获取Map对象  
31.      * @param redisson  
32.      * @param objectName  
33.      * @return  
34.      */    
35. public static <K,V> RMap<K, V> getRMap(RedissonClient redissonClient,String objectName){    
36.         RMap<K, V> map=redissonClient.getMap(objectName);    
37. return map;    
38.     }    
39. /**  
40.      * 获取有序集合  
41.      * @param redisson  
42.      * @param objectName  
43.      * @return  
44.      */    
45. public static <V> RSortedSet<V> getRSortedSet(RedissonClient redissonClient,String objectName){    
46.         RSortedSet<V> sortedSet=redissonClient.getSortedSet(objectName);    
47. return sortedSet;    
48.     }    
49. /**  
50.      * 获取集合  
51.      * @param redisson  
52.      * @param objectName  
53.      * @return  
54.      */    
55. public static <V> RSet<V> getRSet(RedissonClient redissonClient,String objectName){    
56.         RSet<V> rSet=redissonClient.getSet(objectName);    
57. return rSet;    
58.     }    
59. /**  
60.      * 获取列表  
61.      * @param redisson  
62.      * @param objectName  
63.      * @return  
64.      */    
65. public static <V> RList<V> getRList(RedissonClient redissonClient,String objectName){    
66.         RList<V> rList=redissonClient.getList(objectName);    
67. return rList;    
68.     }    
69. /**  
70.      * 获取队列  
71.      * @param redisson  
72.      * @param objectName  
73.      * @return  
74.      */    
75. public static <V> RQueue<V> getRQueue(RedissonClient redissonClient,String objectName){    
76.         RQueue<V> rQueue=redissonClient.getQueue(objectName);    
77. return rQueue;    
78.     }    
79. /**  
80.      * 获取双端队列  
81.      * @param redisson  
82.      * @param objectName  
83.      * @return  
84.      */    
85. public static <V> RDeque<V> getRDeque(RedissonClient redissonClient,String objectName){    
86.         RDeque<V> rDeque=redissonClient.getDeque(objectName);    
87. return rDeque;    
88.     }    
89. /**  
90.      * 此方法不可用在Redisson 1.2 中   
91.      * 在1.2.2版本中 可用  
92.      * @param redisson  
93.      * @param objectName  
94.      * @return  
95.      */    
96. /**  
97.     public <V> RBlockingQueue<V> getRBlockingQueue(Redisson redisson,String objectName){  
98.         RBlockingQueue rb=redisson.getBlockingQueue(objectName);  
99.         return rb;  
100.     }*/    
101. /**  
102.      * 获取锁  
103.      * @param redisson  
104.      * @param objectName  
105.      * @return  
106.      */    
107. public static RLock getRLock(RedissonClient redissonClient,String objectName){    
108.         RLock rLock=redissonClient.getLock(objectName);    
109. return rLock;    
110.     }    
111. /**  
112.      * 获取原子数  
113.      * @param redisson  
114.      * @param objectName  
115.      * @return  
116.      */    
117. public static RAtomicLong getRAtomicLong(RedissonClient redissonClient,String objectName){    
118.         RAtomicLong rAtomicLong=redissonClient.getAtomicLong(objectName);    
119. return rAtomicLong;    
120.     }    
121. /**  
122.      * 获取记数锁  
123.      * @param redisson  
124.      * @param objectName  
125.      * @return  
126.      */    
127. public static RCountDownLatch getRCountDownLatch(RedissonClient redissonClient,String objectName){    
128.         RCountDownLatch rCountDownLatch=redissonClient.getCountDownLatch(objectName);    
129. return rCountDownLatch;    
130.     }    
131. /**  
132.      * 获取消息的Topic  
133.      * @param redisson  
134.      * @param objectName  
135.      * @return  
136.      */    
137. public static <M> RTopic<M> getRTopic(RedissonClient redissonClient,String objectName){    
138.          RTopic<M> rTopic=redissonClient.getTopic(objectName);    
139. return rTopic;    
140.     }    
141. }  
142.