SpringBoot使用Redisson实现分布式锁（秒杀系统）_redisson 适配springboot1.4版本

1

2

3

4

5

<dependency>

 <groupId>org.redisson</groupId>

 <artifactId>redisson-spring-boot-starter</artifactId>

 <version>3.10.6</version>

</dependency>

1

2

3

4

5

<dependency>

 <groupId>org.redisson</groupId>

 <artifactId>redisson</artifactId>

 <version>3.6.1</version>

</dependency>

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

<dependency>

 <groupId>io.netty</groupId>

 <artifactId>netty-all</artifactId>

 <version>4.1.25.Final</version>

</dependency>

<dependency>

 <groupId>com.fasterxml.jackson.core</groupId>

 <artifactId>jackson-core</artifactId>

 <version>2.9.0</version>

</dependency>

<dependency>

 <groupId>com.fasterxml.jackson.core</groupId>

 <artifactId>jackson-databind</artifactId>

 <version>2.9.0</version>

</dependency>

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

singleServerConfig:

 idleConnectionTimeout: 10000

 pingTimeout: 1000

 connectTimeout: 10000

 timeout: 3000

 retryAttempts: 3

 retryInterval: 1500

 reconnectionTimeout: 3000

 failedAttempts: 3

 password: null

 subscriptionsPerConnection: 5

 clientName: null

 address: "redis://127.0.0.1:6379"

 subscriptionConnectionMinimumIdleSize: 1

 subscriptionConnectionPoolSize: 50

 connectionMinimumIdleSize: 32

 connectionPoolSize: 64

 database: 0

 #在最新版本中dns的检查操作会直接报错 所以我直接注释掉了

 #dnsMonitoring: false

 dnsMonitoringInterval: 5000

threads: 0

nettyThreads: 0

codec: !<org.redisson.codec.JsonJacksonCodec> {}

transportMode : "NIO"

1

2

3

4

5

6

7

8

9

10

11

12

13

14

/**

* @Description //TODO

* @Date $ $

* @Author huangwb

**/

@Configuration

public class RedssonConfig {

 @Bean(destroyMethod="shutdown")

 public RedissonClient redisson() throws IOException {

  RedissonClient redisson = Redisson.create(

    Config.fromYAML(new ClassPathResource("redisson-single.yml").getInputStream()));

  return redisson;

 }

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

@Autowired

private RedissonClient redissonClient;

@Override

public boolean decrementProductStore(Long productId, Integer productQuantity) {

 String key = "dec_store_lock_" + productId;

 RLock lock = redissonClient.getLock(key);

 try {

  //加锁 操作很类似Java的ReentrantLock机制

  lock.lock();

  ProductInfo productInfo = productInfoMapper.selectByPrimaryKey(productId);

  //如果库存为空

  if (productInfo.getProductStock() == 0) {

   return false;

  }

  //简单减库存操作 没有重新写其他接口了

  productInfo.setProductStock(productInfo.getProductStock() - 1);

  productInfoMapper.updateByPrimaryKey(productInfo);

 } catch (Exception e) {

  System.out.println(e.getMessage());

 } finally {

  //解锁

  lock.unlock();

 }

 return true;

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

@GetMapping("test")

public String createOrderTest() {

 if (!productInfoService.decrementProductStore(1L, 1)) {

  return "库存不足";

 }

 OrderMaster orderMaster = new OrderMaster();

 //未支付

 orderMaster.setOrderStatus(0);

 //未支付

 orderMaster.setPayStatus(0);

 orderMaster.setBuyerName(name);

 orderMaster.setBuyerAddress("湖南长沙");

 orderMaster.setBuyerPhone("18692794847");

 orderMaster.setOrderAmount(BigDecimal.ZERO);

 orderMaster.setCreateTime(DateUtils.getCurrentDate());

 orderMaster.setOrderId(UUID.randomUUID().toString().replaceAll("-", ""));

 orderMasterService.insert(orderMaster);

 return "创建订单成功";

}