springboot 整合redisson

Posted 2020-11-19 otherCoding

整合代码已经过测试

1、pom

1 <!-- redisson -->
2 <dependency>
3     <groupId>org.redisson</groupId>
4     <artifactId>redisson</artifactId>
5     <version>3.5.7</version>
6 </dependency>

2、properties

# redis
spring.redis.host=
spring.redis.port=
spring.redis.password=
spring.redis.jedis.pool.max-active=500
spring.redis.jedis.pool.max-idle=1000
spring.redis.jedis.pool.max-wait=6000ms
spring.redis.jedis.pool.min-idle=4

 

3、添加redisson配置类、这里是单机模式

　

 1 package com.example.common.config;
 2 
 3 import org.redisson.Redisson;
 4 import org.redisson.api.RedissonClient;
 5 import org.redisson.config.Config;
 6 import org.springframework.beans.factory.annotation.Value;
 7 import org.springframework.context.annotation.Bean;
 8 import org.springframework.context.annotation.Configuration;
 9 
10 /**
11  * redisson 配置类
12  * Created on 2018/6/19
13  */
14 @Configuration
15 public class RedissonConfig {
16 
17     @Value("${spring.redis.host}")
18     private String host;
19 
20     @Value("${spring.redis.port}")
21     private String port;
22 
23     @Value("${spring.redis.password}")
24     private String password;
25 
26     @Bean
27     public RedissonClient getRedisson(){
28 
29         Config config = new Config();
30         config.useSingleServer().setAddress("redis://" + host + ":" + port).setPassword(password);
31         //添加主从配置
32 //        config.useMasterSlaveServers().setMasterAddress("").setPassword("").addSlaveAddress(new String[]{"",""});
33 
34         return Redisson.create(config);
35     }
36 
37 }

4、加入redisson 操作类（redissonService）

  1 package com.example.common.base;
  2 
  3 import org.redisson.api.*;
  4 import org.redisson.config.Config;
  5 import org.springframework.beans.factory.annotation.Autowired;
  6 import org.springframework.stereotype.Service;
  7 
  8 import java.io.IOException;
  9 
 10 /**
 11  * redisson操作类
 12  */
 13 @Service("redissonService")
 14 public class RedissonService {
 15 
 16     @Autowired
 17     private RedissonClient redissonClient;
 18 
 19     public void getRedissonClient() throws IOException {
 20         Config config = redissonClient.getConfig();
 21         System.out.println(config.toJSON().toString());
 22     }
 23 
 24     /**`
 25      * 获取字符串对象
 26      *
 27      * @param objectName
 28      * @return
 29      */
 30     public <T> RBucket<T> getRBucket(String objectName) {
 31         RBucket<T> bucket = redissonClient.getBucket(objectName);
 32         return bucket;
 33     }
 34 
 35     /**
 36      * 获取Map对象
 37      *
 38      * @param objectName
 39      * @return
 40      */
 41     public <K, V> RMap<K, V> getRMap(String objectName) {
 42         RMap<K, V> map = redissonClient.getMap(objectName);
 43         return map;
 44     }
 45 
 46     /**
 47      * 获取有序集合
 48      *
 49      * @param objectName
 50      * @return
 51      */
 52     public <V> RSortedSet<V> getRSortedSet(String objectName) {
 53         RSortedSet<V> sortedSet = redissonClient.getSortedSet(objectName);
 54         return sortedSet;
 55     }
 56 
 57     /**
 58      * 获取集合
 59      *
 60      * @param objectName
 61      * @return
 62      */
 63     public <V> RSet<V> getRSet(String objectName) {
 64         RSet<V> rSet = redissonClient.getSet(objectName);
 65         return rSet;
 66     }
 67 
 68     /**
 69      * 获取列表
 70      *
 71      * @param objectName
 72      * @return
 73      */
 74     public <V> RList<V> getRList(String objectName) {
 75         RList<V> rList = redissonClient.getList(objectName);
 76         return rList;
 77     }
 78 
 79     /**
 80      * 获取队列
 81      *
 82      * @param objectName
 83      * @return
 84      */
 85     public <V> RQueue<V> getRQueue(String objectName) {
 86         RQueue<V> rQueue = redissonClient.getQueue(objectName);
 87         return rQueue;
 88     }
 89 
 90     /**
 91      * 获取双端队列
 92      *
 93      * @param objectName
 94      * @return
 95      */
 96     public <V> RDeque<V> getRDeque(String objectName) {
 97         RDeque<V> rDeque = redissonClient.getDeque(objectName);
 98         return rDeque;
 99     }
100 
101 
102     /**
103      * 获取锁
104      *
105      * @param objectName
106      * @return
107      */
108     public RLock getRLock(String objectName) {
109         RLock rLock = redissonClient.getLock(objectName);
110         return rLock;
111     }
112 
113     /**
114      * 获取读取锁
115      *
116      * @param objectName
117      * @return
118      */
119     public RReadWriteLock getRWLock(String objectName) {
120         RReadWriteLock rwlock = redissonClient.getReadWriteLock(objectName);
121         return rwlock;
122     }
123 
124     /**
125      * 获取原子数
126      *
127      * @param objectName
128      * @return
129      */
130     public RAtomicLong getRAtomicLong(String objectName) {
131         RAtomicLong rAtomicLong = redissonClient.getAtomicLong(objectName);
132         return rAtomicLong;
133     }
134 
135     /**
136      * 获取记数锁
137      *
138      * @param objectName
139      * @return
140      */
141     public RCountDownLatch getRCountDownLatch(String objectName) {
142         RCountDownLatch rCountDownLatch = redissonClient.getCountDownLatch(objectName);
143         return rCountDownLatch;
144     }
145 
146     /**
147      * 获取消息的Topic
148      *
149      * @param objectName
150      * @return
151      */
152     public <M> RTopic<M> getRTopic(String objectName) {
153         RTopic<M> rTopic = redissonClient.getTopic(objectName);
154         return rTopic;
155     }
156 }

View Code

5.、测试代码

package com.example.test;

import com.example.common.base.RedissonService;
import org.redisson.api.RLock;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import java.util.concurrent.TimeUnit;

@Controller
@RequestMapping("test")
public class TestService {

    private static final Logger log = LoggerFactory.getLogger(TestService.class);

    @Autowired
    private RedissonService redissonService;

    @RequestMapping(value = "/test")
    @ResponseBody
    public void test(String recordId) {

        RLock lock = redissonService.getRLock(recordId);
        try {
            boolean bs = lock.tryLock(5, 6, TimeUnit.SECONDS);
            if (bs) {
                // 业务代码
                log.info("进入业务代码: " + recordId);

                lock.unlock();
            } else {
                Thread.sleep(300);
            }
        } catch (Exception e) {
            log.error("", e);
            lock.unlock();
        }
    }

}