版本说明

本示例基于华为云分布式缓存服务Redis基础版 5.0开发。

简介

Redis实现（电商网站）秒杀抢购示例（Java版本）

电商网站的商品类目、推荐系统以及秒杀抢购活动，适宜使用Redis缓存数据库。

例如秒杀抢购活动，并发高，对于传统关系型数据库来说访问压力大，需要较高的硬件配置（如磁盘IO）支撑。Redis数据库，单节点QPS支撑能达到10万，轻松应对秒杀并发。实现秒杀和数据加锁的命令简单，使用SET、GET、DEL、RPUSH等命令即可。对分布式应用加锁，能够避免出现库存超卖及无序访问等现象。本实践介绍如何使用Redis对分布式应用加锁。

开发前准备

• 注册华为云账号，详细操作请参见如何注册华为云管理控制台的用户？，并完成实名认证。
• 已购买具有公网IP的ECS，详细操作请参见购买并登录Linux弹性云服务器。
• 已购买DCS缓存实例，详细操作请参见购买缓存实例，且需保证DCS实例与已购买具的ECS在同一虚拟私有云、子网内，并在已购买具的ECS上配置公网访问Redis，详细操作请参见使用Nginx实现公网访问Redis 4.0/5.0的单机/主备/Proxy集群实例。

安装SDK

您可以通过Maven方式获取和安装SDK，首先需要在您的操作系统中下载并安装Maven ，安装完成后您只需要在Java项目的pom.xml文件中加入相应的依赖项即可。

                    
                    Copied!
                
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.9.0</version>
</dependency>

开始使用

导入依赖模块

                    
                    Copied!
                
// 通用唯一识别码类
import java.util.UUID;
// Redis客户端Jedis类
import redis.clients.jedis.Jedis;

加锁

示例代码

                    
                    Copied!
                
    /*
     * @param lockName      锁名
     * @param timeout       获取锁的超时时间
     * @param lockTimeout   锁的有效时间
     * @return              锁的标识
     */
    public String getLockWithTimeout(String lockName, long timeout, long lockTimeout) {
        String ret = null;
        Jedis jedisClient = new Jedis(HOST, PORT);

        try {
            String authMsg = jedisClient.auth("YOUR PASSWORD");
            if (!SUCCESS.equals(authMsg)) {
                System.out.println("AUTH FAILED: " + authMsg);
            }

            String identifier = UUID.randomUUID().toString();
            String lockKey = "DLock:" + lockName;
            long end = System.currentTimeMillis() + timeout;

            while (System.currentTimeMillis() < end) {
                String result = jedisClient.set(lockKey, identifier, SET_IF_NOT_EXIST, EXPIRE_TIME, lockTimeout);
                if (SUCCESS.equals(result)) {
                    ret = identifier;
                    break;
                }

                try {
                    Thread.sleep(2);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            }
        } catch (Exception e) {

        } finally {
            jedisClient.quit();
            jedisClient.close();
        }

        return ret;
    }

释放锁

示例代码

                    
                    Copied!
                
    /*
     * @param lockName        锁名
     * @param identifier    锁的标识
     */
    public void releaseLock(String lockName, String identifier) {
        Jedis jedisClient = new Jedis(HOST, PORT);

        try {
            String authMsg = jedisClient.auth("YOUR PASSWORD");
            if (!SUCCESS.equals(authMsg)) {
                System.out.println("AUTH FAILED: " + authMsg);
            }

            String lockKey = "DLock:" + lockName;
            if (identifier.equals(jedisClient.get(lockKey))) {
                jedisClient.del(lockKey);
            }
        } catch (Exception e) {

        } finally {
            jedisClient.quit();
            jedisClient.close();
        }
    }

模拟手机秒杀抢购

示例代码

                    
                    Copied!
                
    public void handleOder() {
        String userName = UUID.randomUUID().toString().substring(0, 8) + Thread.currentThread().getName();
        String identifier = DLock.getLockWithTimeout("Huawei Mate 10", 10000, 2000);
        System.out.println("正在为用户：" + userName + " 处理订单");
        if (n > 0) {
            int num = MAX - n + 1;
            System.out.println("用户：" + userName + "购买第" + num + "台，剩余" + (--n) + "台");
        } else {
            System.out.println("用户：" + userName + "无法购买，已售罄！");
        }
        DLock.releaseLock("Huawei Mate 10", identifier);
    }

FAQ

暂无

参考

更多信息请参考 分布式缓存服务文档。

修订记录