自定义springboot-starter封装lua脚本调用redis实现库存扣减

自定义springboot-starter封装redis库存扣减

  • 第一步：创建starter工程stock-spring-boot-starter并配置pom.xml文件
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
                             http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.2.RELEASE</version>
        <relativePath/>
    </parent>
    <groupId>com.lhs</groupId>
    <artifactId>stock-spring-boot-starter</artifactId>
    <version>1.1-SNAPSHOT</version>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-autoconfigure</artifactId>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.16.18</version>
        </dependency>

        <dependency>
            <groupId>com.google.code.gson</groupId>
            <artifactId>gson</artifactId>
            <version>2.8.0</version>
        </dependency>

        <!--redisson-->
        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson</artifactId>
            <version>3.6.0</version>
        </dependency>

        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>22.0</version>
        </dependency>
    </dependencies>
</project>
  • 第二步：创建配置属性类StockRedisClientProperties
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
package com.lhs.config;

import org.springframework.boot.context.properties.ConfigurationProperties;

/**
 * StockRedisClientProperties
 *
 * @author longhuashen
 * @since 2024/06/01
 */
@ConfigurationProperties(prefix = "stock.redis")
public class StockRedisClientProperties {

    /** 节点地址，redis://host:port的格式 */
    private String address;

    /** 连接超时，单位：毫秒 */
    private int connectTimeout;

    /** 响应超时，单位：毫秒 */
    private int timeout;

    /** 最小空闲连接数 */
    private int minIdlePoolSize;

    /** 连接池最大容量 */
    private int maxPoolSize;

    public String getAddress() {
        return address;
    }

    public void setAddress(String address) {
        this.address = address;
    }

    public int getConnectTimeout() {
        return connectTimeout;
    }

    public void setConnectTimeout(int connectTimeout) {
        this.connectTimeout = connectTimeout;
    }

    public int getTimeout() {
        return timeout;
    }

    public void setTimeout(int timeout) {
        this.timeout = timeout;
    }

    public int getMinIdlePoolSize() {
        return minIdlePoolSize;
    }

    public void setMinIdlePoolSize(int minIdlePoolSize) {
        this.minIdlePoolSize = minIdlePoolSize;
    }

    public int getMaxPoolSize() {
        return maxPoolSize;
    }

    public void setMaxPoolSize(int maxPoolSize) {
        this.maxPoolSize = maxPoolSize;
    }

    @Override
    public String toString() {
        return "StockRedisClientProperties{" +
                "address='" + address + '\'' +
                ", connectTimeout=" + connectTimeout +
                ", timeout=" + timeout +
                ", minIdlePoolSize=" + minIdlePoolSize +
                ", maxPoolSize=" + maxPoolSize +
                '}';
    }
}
  • 第三步：创建服务类StockReduceService
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
package com.lhs.service;

import com.lhs.model.StockReduceFlow;
import com.lhs.model.StockReduceResult;

/**
 * 库存扣减服务
 */
public interface StockReduceService {

    /**
     * 扣库存(同步调用)
     */
    StockReduceResult reduce(StockReduceFlow flow);

    /**
     * 回库存
     */
    StockReduceResult cancelReduce(StockReduceFlow flow);

}
  • 第四步：创建自动配置类StockReduceAutoConfiguration StockRedisClientAutoConfiguration
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
package com.lhs.config;

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.client.codec.StringCodec;
import org.redisson.config.Config;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * StockRedisClientAutoConfiguration
 *
 * @author longhuashen
 * @since 2024/06/01
 */
@Configuration
@EnableConfigurationProperties(StockRedisClientProperties.class)
public class StockRedisClientAutoConfiguration {

    private StockRedisClientProperties stockRedisClientProperties;

    public StockRedisClientAutoConfiguration(StockRedisClientProperties stockRedisClientProperties) {
        this.stockRedisClientProperties = stockRedisClientProperties;
    }

    @Bean(destroyMethod = "shutdown")
    @ConditionalOnClass(Config.class)
    @ConditionalOnMissingBean(RedissonClient.class)
    public RedissonClient stockRedissonClient() {
        Config config = new Config();
        config.setCodec(StringCodec.INSTANCE);
        config.useSingleServer()
                .setAddress(stockRedisClientProperties.getAddress())
                .setConnectTimeout(stockRedisClientProperties.getConnectTimeout())
                .setTimeout(stockRedisClientProperties.getTimeout())
                .setConnectionMinimumIdleSize(stockRedisClientProperties.getMinIdlePoolSize())
                .setConnectionPoolSize(stockRedisClientProperties.getMaxPoolSize());
        return Redisson.create(config);
    }

}
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
27
package com.lhs.config;

/**
 * StockReduceAutoConfiguration
 *
 * @author longhuashen
 * @since 2024/06/01
 */

import com.lhs.service.StockReduceService;
import com.lhs.service.impl.StockReduceServiceImpl;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 库存扣减服务配置类
 */
@Configuration
public class StockReduceAutoConfiguration {

    @Bean
    @ConditionalOnMissingBean
    public StockReduceService stockReduceService() {
        return new StockReduceServiceImpl();
    }
}

  • 第五步：在resources目录下创建META-INF/spring.factories

    1
    2
    3
    org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
    com.lhs.config.StockRedisClientAutoConfiguration,\
    com.lhs.config.StockReduceAutoConfiguration

  • 项目结构

上层app使用该starter

定义好使用的redis

引用服务

测试成功