SpringBoot 集成Jedis操作set

源码资源网

SpringBoot 集成Jedis操作set

题外话：

Redis是个有趣的东西，相信搞java的或多或少都会用到，面试时也总离不开问Redis，之前觉得redis只是用做缓存，飞快！也因为最初在封装底层的时候，使用Redisson，所以大部分都只用到了String这种类型，不管相应的value是List还是Map，最多也就以json格式存储，慢慢的用多了，才发现在业务中错过了许多优化的地方；

其中Set类型是一个不错的选择，举个例子，我们实际业务中存在粉丝订阅关系，同时，因为采用Spring Cloud分布式架构，加上各个微服务之间做了分库，导致许多地方在查询时需要feign调用订阅关系去做其他逻辑，用Set存储可以解决粉丝关注，粉丝数统计，我关注的人也关注了谁等等问题；

1、pom.xml

1. <!-- jedis -->
   
2. <dependency>
   
3. <groupId>redis.clients</groupId>
   
4. <artifactId>jedis</artifactId>
   
5. <version>2.8.2</version>
   
6. </dependency>

复制代码

2、注入bean

1. @Bean
   
2. public JedisPool redisPoolFactory(
   
3. @Value("${spring.redis.host}") String redisHost,
   
4. @Value("${spring.redis.port}") int redisPort,
   
5. @Value("${spring.redis.password}") String redisPassword,
   
6. @Value("${spring.redis.database}") int database ,
   
7. @Value("${spring.redis.jedis.pool.max-wait}") int maxWaitMillis,
   
8. @Value("${spring.redis.jedis.pool.max-idle}") int maxIdle,
   
9. @Value("${spring.redis.jedis.pool.max-active}") int maxActive
   
10.         ){
    
11.         JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
    
12.         jedisPoolConfig.setMaxIdle(maxIdle);
    
13.         jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);
    
14.         jedisPoolConfig.setMaxTotal(maxActive);
    
15.         jedisPoolConfig.setMinIdle(0);
    
16.         jedisPoolConfig.setMaxIdle(maxIdle);
    
17.         JedisPool jedisPool = new JedisPool(jedisPoolConfig,redisHost,redisPort,0,redisPassword);
    
18.         return jedisPool;
    
19.         }
    
20. @Bean
    
21. public JedisUtils jedisUtils (JedisPool jedisPool ){
    
22.         return new JedisUtils(jedisPool);
    
23.         }

复制代码

3、JedisUtils操作set

1. package com.cookie.util;
   
2. import org.slf4j.Logger;
   
3. import org.slf4j.LoggerFactory;
   
4. import org.springframework.beans.factory.annotation.Autowired;
   
5. import org.springframework.stereotype.Component;
   
6. import redis.clients.jedis.Jedis;
   
7. import redis.clients.jedis.JedisPool;
   
8. import java.util.Set;
   
9. /**
   
10. * author : cxq
    
11. * Date : 2019/7/11
    
12. */
    
13. //@Component
    
14. public class JedisUtils {
    
15.     private final static Logger logger = LoggerFactory.getLogger(JedisUtils.class);
    
16.     // @Autowired
    
17.     private JedisPool jedisPool ;
    
18.     public JedisUtils(JedisPool jedisPool) {
    
19.         this.jedisPool = jedisPool;
    
20.     }
    
21.     /**
    
22.      * 查询set集合数据
    
23.      * @param key
    
24.      * @return
    
25.      */
    
26.     public Set<String> getSet(String key ){
    
27.         Jedis jedis = null ;
    
28.         Set<String> set = null ;
    
29.         try {
    
30.             jedis = jedisPool.getResource();
    
31.             set = jedis.smembers(key);
    
32.         }catch (Exception e ){
    
33.             logger.error(" get set error : "+e.getMessage());
    
34.         }
    
35.         return set ;
    
36.     }
    
37.     /**
    
38.      * 往set中添加数据
    
39.      * @param key
    
40.      * @param values
    
41.      * @return
    
42.      */
    
43.     public Long addSet(String key , String... values ){
    
44.         Jedis jedis = null ;
    
45.         try {
    
46.             jedis = jedisPool.getResource();
    
47.             return jedis.sadd(key,values);
    
48.         }catch (Exception e ){
    
49.             logger.error(" get set error : "+e.getMessage());
    
50.         }
    
51.         return 0L ;
    
52.     }
    
53.     /**
    
54.      * 删除数据
    
55.      * @param key
    
56.      * @param values
    
57.      * @return
    
58.      */
    
59.     public Long delSet(String key , String... values ){
    
60.         Jedis jedis = null ;
    
61.         try {
    
62.             jedis = jedisPool.getResource();
    
63.             return jedis.srem(key,values);
    
64.         }catch (Exception e ){
    
65.             logger.error(" del set error : "+e.getMessage());
    
66.         }
    
67.         return 0L ;
    
68.     }
    
69.     /**
    
70.      * 求第一个key与其他key不同的部分
    
71.      * @param keys
    
72.      * @return
    
73.      */
    
74.     public Set<String> getDiffSet(String... keys){
    
75.         Jedis jedis = null ;
    
76.         try {
    
77.             jedis = jedisPool.getResource();
    
78.             return jedis.sdiff(keys);
    
79.         }catch (Exception e ){
    
80.             logger.error(" get diff set error : "+e.getMessage());
    
81.         }
    
82.         return null ;
    
83.     }
    
84.     /**
    
85.      * 求key的合集
    
86.      * @param keys
    
87.      * @return
    
88.      */
    
89.     public Set<String> getUnionSet(String... keys){
    
90.         Jedis jedis = null ;
    
91.         try {
    
92.             jedis = jedisPool.getResource();
    
93.             return jedis.sunion(keys);
    
94.         }catch (Exception e ){
    
95.             logger.error(" get union set error : "+e.getMessage());
    
96.         }
    
97.         return null ;
    
98.     }
    
99.     /**
    
100.      * 求key的交集
     
101.      * @param keys
     
102.      * @return
     
103.      */
     
104.     public Set<String> getInterSet(String... keys){
     
105.         Jedis jedis = null ;
     
106.         try {
     
107.             jedis = jedisPool.getResource();
     
108.             return jedis.sinter(keys);
     
109.         }catch (Exception e ){
     
110.             logger.error(" get inter set error : "+e.getMessage());
     
111.         }
     
112.         return null ;
     
113.     }
     
114.     /**
     
115.      * 获取key的长度
     
116.      * @param key
     
117.      * @return
     
118.      */
     
119.     public Long getSetCount(String key ){
     
120.         Jedis jedis = null ;
     
121.         try {
     
122.             jedis = jedisPool.getResource();
     
123.             return jedis.scard(key);
     
124.         }catch (Exception e ){
     
125.             logger.error(" get set count error : "+e.getMessage());
     
126.         }
     
127.         return 0L ;
     
128.     }
     
129.     /**
     
130.      * 判断值是否存在
     
131.      * @param key
     
132.      * @param value
     
133.      * @return
     
134.      */
     
135.     public boolean checkValueIsInSet(String key , String value ){
     
136.         Jedis jedis = null ;
     
137.         try {
     
138.             jedis = jedisPool.getResource();
     
139.             return jedis.sismember(key,value);
     
140.         }catch (Exception e ){
     
141.             logger.error(" check member is in set error : "+e.getMessage());
     
142.         }
     
143.         return false ;
     
144.     }
     
145. }

复制代码