redis事务模拟信用卡交易

绝地灬酷狼 2022-01-23 04:23 194阅读 0赞

本次用redis模拟用户信用卡交易：

用maven导入jar包：

<dependency>
          <groupId>redis.clients</groupId>
          <artifactId>jedis</artifactId>
          <version>3.0.1</version>
        </dependency>

开启redis的服务端后，开始测试。

package cn.mesmile.redis;
    
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.Transaction;
    
    import java.util.List;
    
    /**
     * @Created with IDEA
     * @author: Super Zheng
     * @Description: java类作用描述
     * @Date:2019/6/2
     * @Time:11:08
     */
    public class RedisTransaction {
    
        private  static Jedis jedis =null;
    
        static {
            jedis = new Jedis("192.168.0.108",6381);
            // 模拟每个月的初始可用余额
            jedis.set("balance", "1000");
            // 模拟下个月需要还的钱
            jedis.set("debate", "0");
        }
    
        /**
         *
         * @param turnover 实时交易额
         * @return 交易是否成功
         */
        public static boolean moneyTransaction(long turnover)  {
            // OK
            String balance1 = jedis.watch("balance");
            // 模拟开始监控后，修改数据，出错。
           // jedis.set("balance", "300");
    
            String balance = jedis.get("balance");
            // 判断本次交易额是否超过可用余额
            if(Long.valueOf(balance)<turnover){
                // OK
                String unwatch = jedis.unwatch();
                System.out.println("操作失败，可用余额不足！");
                return false;
            }else {
                try {
                    // 开启事务
                    Transaction transaction = jedis.multi();
                    
                    // 模拟出错后回滚数据
                    //jedis.set("balance", "300");
    
                    transaction.decrBy("balance", turnover);
                    transaction.incrBy("debate", turnover);
                    // 提交事务
                    List<Object> exec = transaction.exec();
                    
                    if(exec==null){
                        System.out.println("本次交易失败");
                        return false;
                    }
                    // [800, 200]
                    System.out.println(exec);
                } catch (Exception e){
                    System.out.println("本次交易失败！");
                    return false;
                }
                return true;
            }
    
        }
    
        public static void main(String[] args) {
            boolean result = moneyTransaction(200);
            System.out.println("交易结果："+result);
        }
    }