类org.springframework.data.redis.core.ValueOperations源码实例Demo

下面列出了怎么用org.springframework.data.redis.core.ValueOperations的API类实例代码及写法,或者点击链接到github查看源代码。

/**
 * 判断手机验证码正确否
 * @param code 验证码
 * @param key redis中的key 前缀+手机号
 * @return
 */
protected MessageResult checkCode(String code, String key){
    ValueOperations valueOperations = redisTemplate.opsForValue();
    Object value = valueOperations.get(key);
    if(value==null) {
        return error(msService.getMessage("CODE_NOT_EXIST_RESEND"));
    }
    if(!value.toString().equals(code)) {
        return  error(msService.getMessage("CODE_ERROR"));
    }
    valueOperations.getOperations().delete(key);
    /**
     * 十分钟之内无需再次验证
     */
    valueOperations.set(key+"_PASS",true,10, TimeUnit.MINUTES);
    return success(msService.getMessage("CODE_CORRECT"));
}
 
/**
 * 删除信息
 * @param id
 * @return
 * @throws Exception
 */
@RequiresPermissions("exchange:init-plate:delete")
@GetMapping("delete/{id}")
public MessageResult deleteExchangeInitPlate(@PathVariable("id")long id)throws Exception{
    MessageResult mr = new MessageResult();
    try {
        InitPlate initPlate = initPlateService.findByInitPlateId(id);
        if(initPlate==null){
            mr.setCode(500);
            mr.setMessage("不存在该记录");
            return mr;
        }
        initPlateService.delete(id);
        ValueOperations valueOperations = redisTemplate.opsForValue();
        String key = SysConstant.EXCHANGE_INIT_PLATE_SYMBOL_KEY+initPlate.getSymbol();
        valueOperations.getOperations().delete(key);
        mr.setCode(0);
        mr.setMessage("success");
    }catch (Exception e){
        log.info(">>>>deleteExchangeInitPlate Error={}",e);
        e.printStackTrace();
        throw new Exception(e);
    }

    return  mr ;
}
 
源代码3 项目: mysiteforme   文件: SystemTask.java
/**
 * 同步文章点击量
 * @param params
 */
public void  synchronizationArticleView(String params){
    ValueOperations<String, Object> operations=redisTemplate.opsForValue();
    EntityWrapper<BlogArticle> wrapper = new EntityWrapper<>();
    wrapper.eq("del_flag",false);
    List<BlogArticle> list = blogArticleService.selectList(wrapper);
    for (BlogArticle article : list){
        String key = "article_click_id_"+article.getId();
        if(redisTemplate.hasKey(key)){
            Integer count = (Integer)operations.get(key);
            if(count > 0){
                article.setClick(blogArticleService.getArticleClick(article.getId()));
                if(StringUtils.isNotBlank(params)){
                    article.setUpdateId(Long.valueOf(params));
                }
                blogArticleService.updateById(article);
            }
        }
    }
}
 
/**
 * 重置资金密码
 *
 * @param newPassword
 * @param code
 * @param user
 * @return
 * @throws Exception
 */
@RequestMapping("/reset/transaction/password")
@Transactional(rollbackFor = Exception.class)
public MessageResult resetTransaction(String newPassword, String code, @SessionAttribute(SESSION_MEMBER) AuthMember user) throws Exception {
    hasText(newPassword, msService.getMessage("MISSING_NEW_JY_PASSWORD"));
    isTrue(newPassword.length() >= 6 && newPassword.length() <= 20, msService.getMessage("JY_PASSWORD_LENGTH_ILLEGAL"));
    ValueOperations valueOperations = redisTemplate.opsForValue();
    Object cache = valueOperations.get(SysConstant.PHONE_RESET_TRANS_CODE_PREFIX + user.getMobilePhone());
    notNull(cache, msService.getMessage("NO_GET_VERIFICATION_CODE"));
    hasText(code, msService.getMessage("MISSING_VERIFICATION_CODE"));
    if (!code.equals(cache.toString())) {
        return MessageResult.error(msService.getMessage("VERIFICATION_CODE_INCORRECT"));
    } else {
        valueOperations.getOperations().delete(SysConstant.PHONE_RESET_TRANS_CODE_PREFIX + user.getMobilePhone());
    }
    Member member = memberService.findOne(user.getId());
    member.setJyPassword(Md5.md5Digest(newPassword + member.getSalt()).toLowerCase());
    return MessageResult.success(msService.getMessage("SETTING_JY_PASSWORD"));
}
 
/**
 * 绑定邮箱
 *
 * @param request
 * @param password
 * @param code
 * @param email
 * @param user
 * @return
 */
@RequestMapping("/bind/email")
@Transactional(rollbackFor = Exception.class)
public MessageResult bindEmail(HttpServletRequest request, String password, String code, String email, @SessionAttribute(SESSION_MEMBER) AuthMember user) throws Exception {
    hasText(password, msService.getMessage("MISSING_LOGIN_PASSWORD"));
    hasText(code, msService.getMessage("MISSING_VERIFICATION_CODE"));
    hasText(email, msService.getMessage("MISSING_EMAIL"));
    isTrue(ValidateUtil.isEmail(email), msService.getMessage("EMAIL_FORMAT_ERROR"));
    ValueOperations valueOperations = redisTemplate.opsForValue();
    Object cache = valueOperations.get(SysConstant.EMAIL_BIND_CODE_PREFIX + email);
    notNull(cache, msService.getMessage("NO_GET_VERIFICATION_CODE"));
    isTrue(code.equals(cache.toString()), msService.getMessage("VERIFICATION_CODE_INCORRECT"));
    Member member = memberService.findOne(user.getId());
    isTrue(member.getEmail() == null, msService.getMessage("REPEAT_EMAIL_REQUEST"));
    if (!Md5.md5Digest(password + member.getSalt()).toLowerCase().equals(member.getPassword())) {
        request.removeAttribute(SysConstant.SESSION_MEMBER);
        return MessageResult.error(msService.getMessage("PASSWORD_ERROR"));
    } else {
        member.setEmail(email);
        return MessageResult.success(msService.getMessage("SETTING_SUCCESS"));
    }
}
 
源代码6 项目: ZTuoExchange_framework   文件: AideController.java
/**
 * 获取该分类(二级页面)
 * @param pageNo
 * @param pageSize
 * @param cate
 * @return
 */
@RequestMapping(value = "more/help/page",method = RequestMethod.POST)
public MessageResult sysHelpCate(@RequestParam(value = "pageNo",defaultValue = "1")int pageNo,
                                @RequestParam(value = "pageSize",defaultValue = "10")int pageSize,
                                @RequestParam(value = "cate")SysHelpClassification cate){
    ValueOperations valueOperations = redisTemplate.opsForValue();
    JSONObject result = (JSONObject) valueOperations.get(SysConstant.SYS_HELP_CATE+cate);
    if (result != null){
        return success(result);
    }else {
        JSONObject jsonObject = new JSONObject();
        Page<SysHelp> sysHelpPage = sysHelpService.findByCondition(pageNo,pageSize,cate);
        jsonObject.put("content",sysHelpPage.getContent());
        jsonObject.put("totalPage",sysHelpPage.getTotalPages());
        jsonObject.put("totalElements",sysHelpPage.getTotalElements());
        valueOperations.set(SysConstant.SYS_HELP_CATE+cate,jsonObject,SysConstant.SYS_HELP_CATE_EXPIRE_TIME, TimeUnit.SECONDS);
        return success(jsonObject);

    }

}
 
/**
 * 根据ID获取当前公告及上一条和下一条
 * @param id
 * @return
 */
@RequestMapping(value = "more",method = RequestMethod.POST)
public MessageResult moreDetail(@RequestParam("id")Long id ){
    ValueOperations redisOperations = redisTemplate.opsForValue();
    JSONObject result  = (JSONObject) redisOperations.get(SysConstant.NOTICE_DETAIL+id);
    if ( result != null){
        return success(result);
    }else {
        JSONObject resultObj = new JSONObject();
        Announcement announcement = announcementService.findById(id);
        Assert.notNull(announcement, "validate id!");
        resultObj.put("info",announcement);
        resultObj.put("back",announcementService.getBack(id));
        resultObj.put("next",announcementService.getNext(id));
        redisOperations.set(SysConstant.NOTICE_DETAIL+id,resultObj,SysConstant.NOTICE_DETAIL_EXPIRE_TIME, TimeUnit.SECONDS);
        return success(resultObj);
    }
}
 
/**
 * 发送绑定邮箱验证码
 *
 * @param email
 * @param user
 * @return
 */
@RequestMapping("/bind/email/code")
@ResponseBody
@Transactional(rollbackFor = Exception.class)
public MessageResult sendBindEmail(String email, @SessionAttribute(SESSION_MEMBER) AuthMember user) {
    Assert.isTrue(ValidateUtil.isEmail(email), localeMessageSourceService.getMessage("WRONG_EMAIL"));
    Member member = memberService.findOne(user.getId());
    Assert.isNull(member.getEmail(), localeMessageSourceService.getMessage("BIND_EMAIL_REPEAT"));
    Assert.isTrue(!memberService.emailIsExist(email), localeMessageSourceService.getMessage("EMAIL_ALREADY_BOUND"));
    String code = String.valueOf(GeneratorUtil.getRandomNumber(100000, 999999));
    ValueOperations valueOperations = redisTemplate.opsForValue();
    if (valueOperations.get(EMAIL_BIND_CODE_PREFIX + email) != null) {
        return error(localeMessageSourceService.getMessage("EMAIL_ALREADY_SEND"));
    }
    try {
        sentEmailCode(valueOperations, email, code);
    } catch (Exception e) {
        e.printStackTrace();
        return error(localeMessageSourceService.getMessage("SEND_FAILED"));
    }
    return success(localeMessageSourceService.getMessage("SENT_SUCCESS_TEN"));
}
 
/**
 * 忘记密码后重置密码
 *
 * @param mode     0为手机验证,1为邮箱验证
 * @param account  手机或邮箱
 * @param code     验证码
 * @param password 新密码
 * @return
 */
@RequestMapping(value = "/reset/login/password", method = RequestMethod.POST)
@ResponseBody
@Transactional(rollbackFor = Exception.class)
public MessageResult forgetPassword(int mode, String account, String code, String password) throws Exception {
    Member member = null;
    ValueOperations valueOperations = redisTemplate.opsForValue();
    Object redisCode = valueOperations.get(SysConstant.RESET_PASSWORD_CODE_PREFIX + account);
    notNull(redisCode, localeMessageSourceService.getMessage("VERIFICATION_CODE_NOT_EXISTS"));
    if (mode == 0) {
        member = memberService.findByPhone(account);
    } else if (mode == 1) {
        member = memberService.findByEmail(account);
    }
    isTrue(password.length() >= 6 && password.length() <= 20, localeMessageSourceService.getMessage("PASSWORD_LENGTH_ILLEGAL"));
    notNull(member, localeMessageSourceService.getMessage("MEMBER_NOT_EXISTS"));
    if (!code.equals(redisCode.toString())) {
        return error(localeMessageSourceService.getMessage("VERIFICATION_CODE_INCORRECT"));
    } else {
        valueOperations.getOperations().delete(SysConstant.RESET_PASSWORD_CODE_PREFIX + account);
    }
    //生成密码
    String newPassword = Md5.md5Digest(password + member.getSalt()).toLowerCase();
    member.setPassword(newPassword);
    return success();
}
 
源代码10 项目: ZTuoExchange_framework   文件: SmsController.java
/**
 * 重置交易密码验证码
 *
 * @param user
 * @return
 */
@RequestMapping(value = "/transaction/code", method = RequestMethod.POST)
public MessageResult sendResetTransactionCode(@SessionAttribute(SESSION_MEMBER) AuthMember user) throws Exception {
    Member member = memberService.findOne(user.getId());
    Assert.hasText(member.getMobilePhone(), localeMessageSourceService.getMessage("NOT_BIND_PHONE"));
    String randomCode = String.valueOf(GeneratorUtil.getRandomNumber(100000, 999999));
    MessageResult result;
    if ("86".equals(member.getCountry().getAreaCode())) {
        result = smsProvider.sendVerifyMessage(member.getMobilePhone(), randomCode);
    } else {
        result = smsProvider.sendInternationalMessage(randomCode, member.getCountry().getAreaCode() + member.getMobilePhone());
    }
    if (result.getCode() == 0) {
        ValueOperations valueOperations = redisTemplate.opsForValue();
        String key = SysConstant.PHONE_RESET_TRANS_CODE_PREFIX + member.getMobilePhone();
        valueOperations.getOperations().delete(key);
        // 缓存验证码
        valueOperations.set(key, randomCode, 10, TimeUnit.MINUTES);
        return success(localeMessageSourceService.getMessage("SEND_SMS_SUCCESS"));
    } else {
        return error(localeMessageSourceService.getMessage("SEND_SMS_FAILED"));
    }
}
 
源代码11 项目: ZTuoExchange_framework   文件: SmsController.java
/**
 * 忘记密码验证码
 */
@RequestMapping(value = "/reset/code", method = RequestMethod.POST)
public MessageResult resetPasswordCode(String account) throws Exception {
    Member member = memberService.findByPhone(account);
    Assert.notNull(member, localeMessageSourceService.getMessage("MEMBER_NOT_EXISTS"));
    MessageResult result;
    String randomCode = String.valueOf(GeneratorUtil.getRandomNumber(100000, 999999));
    if ("86".equals(member.getCountry().getAreaCode())) {
        result = smsProvider.sendVerifyMessage(member.getMobilePhone(), randomCode);
    } else {
        result = smsProvider.sendInternationalMessage(randomCode, member.getCountry().getAreaCode() + member.getMobilePhone());
    }
    if (result.getCode() == 0) {
        ValueOperations valueOperations = redisTemplate.opsForValue();
        String key = SysConstant.RESET_PASSWORD_CODE_PREFIX + member.getMobilePhone();
        valueOperations.getOperations().delete(key);
        // 缓存验证码
        valueOperations.set(key, randomCode, 10, TimeUnit.MINUTES);
        return success(localeMessageSourceService.getMessage("SEND_SMS_SUCCESS"));
    } else {
        return error(localeMessageSourceService.getMessage("SEND_SMS_FAILED"));
    }
}
 
源代码12 项目: SuperBoot   文件: Pub_RedisUtils.java
/**
 * 根据来源平台与版本获取TOKEN
 *
 * @param pkUser   用户主键
 * @param platform 来源平台
 * @param version  来源版本
 * @return
 */
public String getTokenAllow(long pkUser, String platform, String version) {
    ValueOperations<String, HashMap> operations = redisTemplate.opsForValue();
    boolean exists = redisTemplate.hasKey(BaseConstants.USER_TOKEN + "-" + pkUser);
    if (exists) {
        HashMap<String, Object> tokenMap = operations.get(BaseConstants.USER_TOKEN + "-" + pkUser);
        //循环处理TOKEN白名单里失效的TOKEN
        for (String key : tokenMap.keySet()) {
            //判断对象是TOKEN
            if (key.startsWith("Bearer")) {
                //如果TOKEN已经不存在了
                if (!redisTemplate.hasKey(key)) {
                    //清理失效TOKEN信息
                    cleanTokenAllow(pkUser, key);
                }
            }
        }
        if (tokenMap.containsKey(platform + "-" + version)) {
            return "" + tokenMap.get(platform + "-" + version);
        }
    }
    return null;
}
 
private MessageResult sendCode(String phone, String prefix) {
    Assert.notNull(phone, msService.getMessage("NO_CELL_PHONE_NUMBER"));
    MessageResult result;
    String randomCode = String.valueOf(GeneratorUtil.getRandomNumber(100000, 999999));
    try {
        ValueOperations valueOperations = redisTemplate.opsForValue();
        String key = prefix + phone;
        long expire = valueOperations.getOperations().getExpire(key, TimeUnit.SECONDS);
        if (expire < 600 && expire > 540) {
            return error(msService.getMessage("SEND_CODE_FAILURE_ONE"));
        }
             result = smsProvider.sendVerifyMessage(phone, randomCode);
        if (result.getCode() == 0) {
            logger.info("短信验证码:{}", randomCode);
            valueOperations.set(key, randomCode, 10, TimeUnit.MINUTES);
            return success(msService.getMessage("SEND_CODE_SUCCESS") + phone);
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
    return error(msService.getMessage("REQUEST_FAILED"));
}
 
/**
 * 增加提币地址验证码
 *
 * @param user
 * @return
 */
@RequestMapping("/add/address/code")
@ResponseBody
@Transactional(rollbackFor = Exception.class)
public MessageResult sendAddAddress(@SessionAttribute(SESSION_MEMBER) AuthMember user) {
    String code = String.valueOf(GeneratorUtil.getRandomNumber(100000, 999999));
    ValueOperations valueOperations = redisTemplate.opsForValue();
    Member member = memberService.findOne(user.getId());
    String email = member.getEmail();
    if (email == null) {
        return error(localeMessageSourceService.getMessage("NOT_BIND_EMAIL"));
    }
    if (valueOperations.get(ADD_ADDRESS_CODE_PREFIX + email) != null) {
        return error(localeMessageSourceService.getMessage("EMAIL_ALREADY_SEND"));
    }
    try {
        sentEmailAddCode(valueOperations, email, code);
    } catch (Exception e) {
        e.printStackTrace();
        return error(localeMessageSourceService.getMessage("SEND_FAILED"));
    }
    return success(localeMessageSourceService.getMessage("SENT_SUCCESS_TEN"));
}
 
源代码15 项目: SuperBoot   文件: Pub_RedisUtils.java
/**
 * 获取用户菜单
 *
 * @param userId 用户ID
 * @return
 */
public List getUserMenu(long userId) {
    ValueOperations<String, String> operations = redisTemplate.opsForValue();
    boolean exists = redisTemplate.hasKey(USER_MENU + userId);
    if (exists) {

        Object list = operations.get(USER_MENU + userId);
        if (list instanceof List) {
            return (List<UserMenuDTO>) list;
        }

        Object o = JSON.parse(operations.get(USER_MENU + userId));

        List<UserMenuDTO> rList = new ArrayList<>();

        List data = JSON.toJavaObject((JSON) o, List.class);

        for (int i = 0; i < data.size(); i++) {
            UserMenuDTO item = ((JSONObject) data.get(i)).toJavaObject(UserMenuDTO.class);
            rList.add(item);

        }
        return rList;
    }
    return null;
}
 
/**
 * 忘记密码后重置密码
 *
 * @param mode     0为手机验证,1为邮箱验证
 * @param account  手机或邮箱
 * @param code     验证码
 * @param password 新密码
 * @return
 */
@RequestMapping(value = "/reset/login/password", method = RequestMethod.POST)
@ResponseBody
@Transactional(rollbackFor = Exception.class)
public MessageResult forgetPassword(int mode, String account, String code, String password) throws Exception {
    Member member = null;
    ValueOperations valueOperations = redisTemplate.opsForValue();
    Object redisCode = valueOperations.get(SysConstant.RESET_PASSWORD_CODE_PREFIX + account);
    notNull(redisCode, localeMessageSourceService.getMessage("VERIFICATION_CODE_NOT_EXISTS"));
    if (mode == 0) {
        member = memberService.findByPhone(account);
    } else if (mode == 1) {
        member = memberService.findByEmail(account);
    }
    isTrue(password.length() >= 6 && password.length() <= 20, localeMessageSourceService.getMessage("PASSWORD_LENGTH_ILLEGAL"));
    notNull(member, localeMessageSourceService.getMessage("MEMBER_NOT_EXISTS"));
    if (!code.equals(redisCode.toString())) {
        return error(localeMessageSourceService.getMessage("VERIFICATION_CODE_INCORRECT"));
    } else {
        valueOperations.getOperations().delete(SysConstant.RESET_PASSWORD_CODE_PREFIX + account);
    }
    //生成密码
    String newPassword = Md5.md5Digest(password + member.getSalt()).toLowerCase();
    member.setPassword(newPassword);
    return success();
}
 
源代码17 项目: ZTuoExchange_framework   文件: SmsController.java
@RequestMapping(value = "/add/address/code", method = RequestMethod.POST)
public MessageResult addAddressCode(@SessionAttribute(SESSION_MEMBER) AuthMember user) throws Exception {
    Member member = memberService.findOne(user.getId());
    Assert.hasText(member.getMobilePhone(), localeMessageSourceService.getMessage("NOT_BIND_PHONE"));
    MessageResult result;
    String randomCode = String.valueOf(GeneratorUtil.getRandomNumber(100000, 999999));
    if ("86".equals(member.getCountry().getAreaCode())) {
        result = smsProvider.sendVerifyMessage(member.getMobilePhone(), randomCode);
    } else {
        result = smsProvider.sendInternationalMessage(randomCode, member.getCountry().getAreaCode() + member.getMobilePhone());
    }
    if (result.getCode() == 0) {
        ValueOperations valueOperations = redisTemplate.opsForValue();
        String key = SysConstant.PHONE_ADD_ADDRESS_PREFIX + member.getMobilePhone();
        valueOperations.getOperations().delete(key);
        // 缓存验证码
        valueOperations.set(key, randomCode, 10, TimeUnit.MINUTES);
        return success(localeMessageSourceService.getMessage("SEND_SMS_SUCCESS"));
    } else {
        return error(localeMessageSourceService.getMessage("SEND_SMS_FAILED"));
    }
}
 
源代码18 项目: ZTuoExchange_framework   文件: SmsController.java
@RequestMapping(value = "/withdraw/code", method = RequestMethod.POST)
public MessageResult withdrawCode(@SessionAttribute(SESSION_MEMBER) AuthMember user) throws Exception {
    Member member = memberService.findOne(user.getId());
    Assert.hasText(member.getMobilePhone(), localeMessageSourceService.getMessage("NOT_BIND_PHONE"));
    MessageResult result;
    log.info("===提币验证码发送===mobile:"+member.getMobilePhone());
    String randomCode = String.valueOf(GeneratorUtil.getRandomNumber(100000, 999999));
    if ("86".equals(member.getCountry().getAreaCode())) {
        result = smsProvider.sendVerifyMessage(member.getMobilePhone(), randomCode);
    } else {
        result = smsProvider.sendInternationalMessage(randomCode, member.getCountry().getAreaCode() + member.getMobilePhone());
    }
    if (result.getCode() == 0) {
        ValueOperations valueOperations = redisTemplate.opsForValue();
        String key = SysConstant.PHONE_WITHDRAW_MONEY_CODE_PREFIX + member.getMobilePhone();
        valueOperations.getOperations().delete(key);
        // 缓存验证码
        valueOperations.set(key, randomCode, 10, TimeUnit.MINUTES);
        return success(localeMessageSourceService.getMessage("SEND_SMS_SUCCESS"));
    } else {
        return error(localeMessageSourceService.getMessage("SEND_SMS_FAILED"));
    }
}
 
源代码19 项目: ZTuoExchange_framework   文件: SmsController.java
/**
 * 更改手机验证码
 */
@RequestMapping(value = "/change/code", method = RequestMethod.POST)
public MessageResult resetPhoneCode(@SessionAttribute(SESSION_MEMBER) AuthMember user) throws Exception {
    Member member = memberService.findOne(user.getId());
    Assert.hasText(member.getMobilePhone(), localeMessageSourceService.getMessage("NOT_BIND_PHONE"));
    MessageResult result;
    String randomCode = String.valueOf(GeneratorUtil.getRandomNumber(100000, 999999));
    if ("86".equals(member.getCountry().getAreaCode())) {
        result = smsProvider.sendVerifyMessage(member.getMobilePhone(), randomCode);
    } else {
        result = smsProvider.sendInternationalMessage(randomCode, member.getCountry().getAreaCode() + member.getMobilePhone());
    }
    if (result.getCode() == 0) {
        ValueOperations valueOperations = redisTemplate.opsForValue();
        String key = SysConstant.PHONE_CHANGE_CODE_PREFIX + member.getMobilePhone();
        valueOperations.getOperations().delete(key);
        // 缓存验证码
        valueOperations.set(key, randomCode, 10, TimeUnit.MINUTES);
        return success(localeMessageSourceService.getMessage("SEND_SMS_SUCCESS"));
    } else {
        return error(localeMessageSourceService.getMessage("SEND_SMS_FAILED"));
    }
}
 
源代码20 项目: spring-boot-demo   文件: TestRedis1.java
@Test
public void testObj() throws Exception {
    User user = new User("[email protected]", "aa", "aa123456", "aa", "123");
    ValueOperations<String, User> operations = redisTemplate.opsForValue();
    operations.set("easy.demo", user);
    User userRedis = (User) redisTemplate.opsForValue().get("easy.demo");
    log.info(String.format("easy.demo值是:%s", userRedis.toString()));
}
 
源代码21 项目: dbys   文件: RedisCache.java
/**
 * Get cached query result from redis
 *
 * @param key
 * @return
 */
@Override
public Object getObject(Object key) {
    try {
        RedisTemplate redisTemplate = getRedisTemplate();
        ValueOperations opsForValue = redisTemplate.opsForValue();
        logger.debug("Get cached query result from redis");
        return opsForValue.get(key.toString());
    } catch (Throwable t) {
        logger.error("Redis get failed, fail over to db", t);
        return null;
    }
}
 
源代码22 项目: spring-boot-demo   文件: TestRedis1.java
@Test
public void testObj() throws Exception {
    User user = new User("[email protected]", "aa", "aa123456", "aa", "123");
    ValueOperations<String, User> operations = redisTemplate.opsForValue();
    operations.set("easy.demo", user);
    User userRedis = (User) redisTemplate.opsForValue().get("easy.demo");
    log.info(String.format("easy.demo值是:%s", userRedis.toString()));
}
 
源代码23 项目: spring-boot-demo   文件: TestRedis2.java
@Test
public void test() {
    ValueOperations<String, String> ops = this.template.opsForValue();
    String key = "DemoRedisApplication";
    if (!this.template.hasKey(key)) {
        ops.set(key, "easy-web");
    }
    log.info("找到key=" + key + ", 值=" + ops.get(key));
}
 
源代码24 项目: yfshop   文件: RedisCache.java
/**
 * Put query result to redis
 *
 * @param key
 * @param value
 */
@Override
public void putObject(Object key, Object value) {
    try {
        RedisTemplate redisTemplate = getRedisTemplate();
        ValueOperations opsForValue = redisTemplate.opsForValue();
        opsForValue.set(key, value, EXPIRE_TIME_IN_MINUTES, TimeUnit.MINUTES);
        logger.debug("Put query result to redis");
    } catch (Throwable t) {
        logger.error("Redis put failed", t);
    }
}
 
源代码25 项目: springboot-learn   文件: RedisUtils.java
/**
 * 写入缓存
 *
 * @param key
 * @param value
 * @return
 */
@SuppressWarnings("unchecked")
public boolean set(final String key, Object value, Long expireTime) {
    boolean result = false;
    try {
        ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
        operations.set(key, value);
        redisTemplate.expire(key, expireTime, TimeUnit.SECONDS);
        result = true;
    } catch (Exception e) {
        e.printStackTrace();
    }
    return result;
}
 
源代码26 项目: ZTuoExchange_framework   文件: ApproveController.java
/**
 * 绑定手机号
 *
 * @param password
 * @param phone
 * @param code
 * @param user
 * @return
 */
@RequestMapping("/bind/phone")
@Transactional(rollbackFor = Exception.class)
public MessageResult bindPhone(HttpServletRequest request, String password, String phone, String code, @SessionAttribute(SESSION_MEMBER) AuthMember user) throws Exception {
    hasText(password, msService.getMessage("MISSING_LOGIN_PASSWORD"));
    hasText(phone, msService.getMessage("MISSING_PHONE"));
    hasText(code, msService.getMessage("MISSING_VERIFICATION_CODE"));
    if ("中国".equals(user.getLocation().getCountry())) {
        if (!ValidateUtil.isMobilePhone(phone.trim())) {
            return MessageResult.error(msService.getMessage("PHONE_FORMAT_ERROR"));
        }
    }
    ValueOperations valueOperations = redisTemplate.opsForValue();
    Object cache = valueOperations.get(SysConstant.PHONE_BIND_CODE_PREFIX + phone);
    notNull(cache, msService.getMessage("NO_GET_VERIFICATION_CODE"));
    Member member1 = memberService.findByPhone(phone);
    isTrue(member1 == null, msService.getMessage("PHONE_ALREADY_BOUND"));
    if (!code.equals(cache.toString())) {
        return MessageResult.error(msService.getMessage("VERIFICATION_CODE_INCORRECT"));
    } else {
        valueOperations.getOperations().delete(SysConstant.PHONE_BIND_CODE_PREFIX + phone);
    }
    Member member = memberService.findOne(user.getId());
    isTrue(member.getMobilePhone() == null, msService.getMessage("REPEAT_PHONE_REQUEST"));
    if (member.getPassword().equals(Md5.md5Digest(password + member.getSalt()).toLowerCase())) {
        member.setMobilePhone(phone);
        return MessageResult.success(msService.getMessage("SETTING_SUCCESS"));
    } else {
        request.removeAttribute(SysConstant.SESSION_MEMBER);
        return MessageResult.error(msService.getMessage("PASSWORD_ERROR"));
    }
}
 
源代码27 项目: pcc-like   文件: LikeServiceImpl.java
@Override
public long likeUserCount(Long feedId) {
	if (feedId == null) {
		return -1;
	}
	ValueOperations<String, String> feedCount = this.template.opsForValue();
	String result = feedCount.get(KEY_FEED_LIKE_COUNT + feedId);
	if (StringUtils.isEmpty(result)) {
		return -1;
	}
	return Long.parseLong(result);
}
 
源代码28 项目: ZTuoExchange_framework   文件: CoinController.java
@GetMapping("get-no-check-key")
public MessageResult getKey(String phone) {
    String key = SysConstant.ADMIN_COIN_TRANSFER_COLD_PREFIX + phone + "_PASS";
    ValueOperations valueOperations = redisTemplate.opsForValue();
    Object object = valueOperations.get(key);
    if (object == null) {
        return error(messageSource.getMessage("NEED_CODE"));
    }
    return success(messageSource.getMessage("NO_NEED_CODE"), object);
}
 
源代码29 项目: SuperBoot   文件: Pub_RedisUtils.java
/**
 * 根据来源平台+版本清理TOKEN白名单
 *
 * @param pkUser   用户主键
 * @param platform 来源平台
 * @param version  来源版本
 */
public void cleanTokenAllow(long pkUser, String platform, String version) {
    ValueOperations<String, HashMap> operations = redisTemplate.opsForValue();
    boolean exists = redisTemplate.hasKey(BaseConstants.USER_TOKEN + "-" + pkUser);
    if (exists) {
        HashMap<String, Object> tokenMap = operations.get(BaseConstants.USER_TOKEN + "-" + pkUser);
        String token = "" + tokenMap.get(platform + "-" + version);
        tokenMap.remove(token);
        tokenMap.remove(platform + "-" + version);
        //重新设置以便刷新最后失效时间
        operations.set(BaseConstants.USER_TOKEN + "-" + pkUser, tokenMap, TOKEN_EXPIRED_DAY, TimeUnit.DAYS);
    }
}
 
源代码30 项目: ZTuoExchange_framework   文件: AideController.java
/**
 * 获取该分类的置顶文章
 * @param cate
 * @return
 */
@RequestMapping(value = "more/help/page/top", method = RequestMethod.POST)
public MessageResult sysHelpTop(@RequestParam(value = "cate")String cate){
    ValueOperations valueOperations = redisTemplate.opsForValue();
    List<SysHelp> result = (List<SysHelp>) valueOperations.get(SysConstant.SYS_HELP_TOP+cate);
    if ( result != null && !result.isEmpty()){
        return success(result);
    }else {
        List<SysHelp> sysHelps = sysHelpService.getgetCateTops(cate);
        valueOperations.set(SysConstant.SYS_HELP_TOP+cate,sysHelps,SysConstant.SYS_HELP_TOP_EXPIRE_TIME,TimeUnit.SECONDS);
        return success(sysHelps);
    }
}
 
 类方法
 同包方法