【Redis】redis的setnx使用

た入场券 2022-03-09 08:38 387阅读 0赞

业务需求是这样的：扫车牌，添加一个车牌号，推送消息到一体机，小程序，若该对应用户的会员卡有余额不足的情况，推送到极光服务。  
添加车牌号需要判断今日车辆是否进场，如果已经进场过，直接返回提示，否则添加入库，执行逻辑。

**问题：**  
推送逻辑不能影响主逻辑，所以将推送逻辑放在了finally。但是若重复进场，我不能重复极光推送，try里执行完入库操作，在finally的逻辑里如果再次判断是否进场，就会报已进场，这样肯定不行的。

**解决办法：**  
当日同门店下同一车牌号，不能多次推送，所以我们选择将推送逻辑加锁。

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
    String currentDate = sdf.format(new Date());
    if(jedisPythonUtil.setnx("getLicencePlateList:" + addRequestModel.getStoreId() + ":" + currentDate + ":" + addRequestModel.getCarNum(),  "0", 86400) > 0) {
        //极光推送逻辑
    }

我们再看setnx的方法：

private JedisPool jedisPoolPython;
        
    	/**
         * set if not exists，若key已存在，则setnx不做任何操作
         *
         * @param key
         * @param value key已存在，1：key赋值成功
         * @param expire 过期时间，单位：秒
         * @return
         * @author jqlin
         */
        public  long setnx(String key, String value, int expire) {
            long result = -1;
            Jedis jedis = getJedis();
            try {
                if(null != jedis) {
                    result = jedis.setnx(key, value);
                    jedis.expire(key, expire);
                }
            } catch (Exception e) {
                log.error("设置值失败：" + e.getMessage(), e);
    
            } finally {
                returnResource(jedis);
            }
    
            return result;
        }
        
        /**
         * 同步获取Jedis实例
         *
         * @return Jedis
         */
        public  Jedis getJedis() {
            if (jedisPoolPython == null) {
                poolInit();
            }
            Jedis jedis = null;
            try {
                if (jedisPoolPython != null) {
                    jedis = jedisPoolPython.getResource();
                }
            } catch (Exception e) {
                log.error("同步获取Jedis实例失败" + e.getMessage(), e);
                returnResource(jedis);
            }
            return jedis;
        }
        
        /**
         * 释放jedis资源
         * @param jedis
         */
        public static void returnResource(Jedis jedis) {
            if (jedis != null) {
                jedis.close();
            }
        }

**总结：**  
不要照搬代码，理解意思，自己的需求再下手。