文件
专题 ·
最新
首页
  • 我的主页卡化石
  • off中心
  • 基本设置
  • 文件上传

springboot整合redis数据库

硅谷探秘者 2414 0 0


安装redis数据库参考：http://www.jiajiajia.club/blog/artical/166


redis配置详解参考：http://www.jiajiajia.club/blog/artical/210


安装完数据库以后如果不是本地连接记得修改密码 requirepass。默认是没有密码 

需要后台运行 修改 daemonize yes 默认是no 


yml配置文件

spring:
  redis: 
    host: 192.168.145.128
    # Redis服务器连接端口
    port: 6379
    password: 123456
    jedis:
      pool:
        #连接池最大连接数（使用负值表示没有限制）
        max-active: 100
        # 连接池中的最小空闲连接
        max-idle: 10
        # 连接池最大阻塞等待时间（使用负值表示没有限制）
        max-wait: 100000
    # 连接超时时间（毫秒）
    timeout: 5000
    #默认是索引为0的数据库
    database: 0


redis配置文件


import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;

@EnableCaching  
@Configuration
public class RedisCacheConfig {
	/**
     * redisTemplate 序列化使用的jdkSerializeable, 存储二进制字节码, 所以自定义序列化类
     * @param redisConnectionFactory
     * @return
     */
    @SuppressWarnings("unchecked")
	@Bean
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
 
        // 使用Jackson2JsonRedisSerialize 替换默认序列化
        @SuppressWarnings("rawtypes")
		Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
 
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
 
        jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
 
        // 设置value的序列化规则和 key的序列化规则
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }
}


redis工具类

import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
/***
 * Redis工具类
 * @author jiajia
 *
 */
@Component
public final class RedisUtil {
  @Autowired
  private RedisTemplate<Object,Object> redisTemplate;
  // =============================common============================
  /**
   * 指定缓存失效时间
   * @param key 键
   * @param time 时间(秒)
   * @return
   */
  public boolean expire(String key, long time) {
      try {
          if (time > 0) {
              redisTemplate.expire(key, time, TimeUnit.SECONDS);
          }
          return true;
      } catch (Exception e) {
          e.printStackTrace();
          return false;
      }
  }
  /**
   * 根据key 获取过期时间
   * @param key 键 不能为null
   * @return 时间(秒) 返回0代表为永久有效
   */
  public long getExpire(String key) {
      return redisTemplate.getExpire(key, TimeUnit.SECONDS);
  }
  /**
   * 判断key是否存在
   * @param key 键
   * @return true 存在 false不存在
   */
  public boolean hasKey(String key) {
      try {
          return redisTemplate.hasKey(key);
      } catch (Exception e) {
          e.printStackTrace();
          return false;
      }
  }
  /**
   * 删除缓存
   * @param key 可以传一个值 或多个
   */
  @SuppressWarnings("unchecked")
  public void del(String... key) {
      if (key != null && key.length > 0) {
          if (key.length == 1) {
              redisTemplate.delete(key[0]);
          } else {
              redisTemplate.delete(CollectionUtils.arrayToList(key));
          }
      }
  }
  // ============================String=============================
  /**
   * 普通缓存获取
   * @param key 键
   * @return 值
   */
  public Object get(String key) {
      return key == null ? null : redisTemplate.opsForValue().get(key);
  }
  /**
   * 普通缓存放入
   * @param key 键
   * @param value 值
   * @return true成功 false失败
   */
  public boolean set(String key, Object value) {
      try {
            redisTemplate.opsForValue().set(key, value);
         return true;
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * 普通缓存放入并设置时间
  * @param key 键
  * @param value 值
  * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
  * @return true成功 false 失败
  */
 public boolean set(String key, Object value, long time) {
     try {
         if (time > 0) {
             redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
         } else {
             set(key, value);
         }
         return true;
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * 递增
  * @param key 键
  * @param delta 要增加几(大于0)
  * @return
  */
 public long incr(String key, long delta) {
     if (delta < 0) {
         throw new RuntimeException("递增因子必须大于0");
     }
     return redisTemplate.opsForValue().increment(key, delta);
 }
 /**
  * 递减
  * @param key 键
  * @param delta 要减少几(小于0)
  * @return
  */
 public long decr(String key, long delta) {
     if (delta < 0) {
         throw new RuntimeException("递减因子必须大于0");
     }
     return redisTemplate.opsForValue().increment(key, -delta);
 }
 // ================================Map=================================
 /**
  * HashGet
  * @param key 键 不能为null
  * @param item 项 不能为null
  * @return 值
  */
 public Object hget(String key, String item) {
     return redisTemplate.opsForHash().get(key, item);
 }
 /**
  * 获取hashKey对应的所有键值
  * @param key 键
  * @return 对应的多个键值
  */
 public Map<Object, Object> hmget(String key) {
     return redisTemplate.opsForHash().entries(key);
 }
 /**
  * HashSet
  * @param key 键
  * @param map 对应多个键值
  * @return true 成功 false 失败
  */
 public boolean hmset(String key, Map<String, Object> map) {
     try {
         redisTemplate.opsForHash().putAll(key, map);
         return true;
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * HashSet 并设置时间
  * @param key 键
  * @param map 对应多个键值
  * @param time 时间(秒)
  * @return true成功 false失败
  */
 public boolean hmset(String key, Map<String, Object> map, long time) {
     try {
         redisTemplate.opsForHash().putAll(key, map);
         if (time > 0) {
             expire(key, time);
         }
         return true;
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * 向一张hash表中放入数据,如果不存在将创建
  * @param key 键
  * @param item 项
  * @param value 值
  * @return true 成功 false失败
  */
 public boolean hset(String key, String item, Object value) {
     try {
         redisTemplate.opsForHash().put(key, item, value);
         return true;
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * 向一张hash表中放入数据,如果不存在将创建
  * @param key 键
  * @param item 项
  * @param value 值
  * @param time 时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
  * @return true 成功 false失败
  */
 public boolean hset(String key, String item, Object value, long time) {
     try {
         redisTemplate.opsForHash().put(key, item, value);
         if (time > 0) {
             expire(key, time);
         }
         return true;
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * 删除hash表中的值
  * @param key 键 不能为null
  * @param item 项 可以使多个 不能为null
  */
 public void hdel(String key, Object... item) {
     redisTemplate.opsForHash().delete(key, item);
 }
 /**
  * 判断hash表中是否有该项的值
  * @param key 键 不能为null
  * @param item 项 不能为null
  * @return true 存在 false不存在
  */
 public boolean hHasKey(String key, String item) {
     return redisTemplate.opsForHash().hasKey(key, item);
 }
 /**
  * hash递增 如果不存在,就会创建一个 并把新增后的值返回
  * @param key 键
  * @param item 项
  * @param by 要增加几(大于0)
  * @return
  */
 public double hincr(String key, String item, double by) {
     return redisTemplate.opsForHash().increment(key, item, by);
 }
 /**
  * hash递减
  * @param key 键
  * @param item 项
  * @param by 要减少记(小于0)
  * @return
  */
 public double hdecr(String key, String item, double by) {
     return redisTemplate.opsForHash().increment(key, item, -by);
 }
 // ============================set=============================
 /**
  * 根据key获取Set中的所有值
  * @param key 键
  * @return
  */
 public Set<Object> sGet(String key) {
     try {
         return redisTemplate.opsForSet().members(key);
     } catch (Exception e) {
         e.printStackTrace();
         return null;
     }
 }
 /**
  * 根据value从一个set中查询,是否存在
  * @param key 键
  * @param value 值
  * @return true 存在 false不存在
  */
 public boolean sHasKey(String key, Object value) {
     try {
         return redisTemplate.opsForSet().isMember(key, value);
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * 将数据放入set缓存
  * @param key 键
  * @param values 值 可以是多个
  * @return 成功个数
  */
 public long sSet(String key, Object... values) {
     try {
         return redisTemplate.opsForSet().add(key, values);
     } catch (Exception e) {
         e.printStackTrace();
         return 0;
     }
 }
 /**
  * 将set数据放入缓存
  * @param key 键
  * @param time 时间(秒)
  * @param values 值 可以是多个
  * @return 成功个数
  */
 public long sSetAndTime(String key, long time, Object... values) {
     try {
         Long count = redisTemplate.opsForSet().add(key, values);
         if (time > 0)
             expire(key, time);
         return count;
     } catch (Exception e) {
         e.printStackTrace();
         return 0;
     }
 }
 /**
  * 获取set缓存的长度
  * @param key 键
  * @return
  */
 public long sGetSetSize(String key) {
     try {
         return redisTemplate.opsForSet().size(key);
     } catch (Exception e) {
         e.printStackTrace();
         return 0;
     }
 }
 /**
  * 移除值为value的
  * @param key 键
  * @param values 值 可以是多个
  * @return 移除的个数
  */
 public long setRemove(String key, Object... values) {
     try {
         Long count = redisTemplate.opsForSet().remove(key, values);
         return count;
     } catch (Exception e) {
         e.printStackTrace();
         return 0;
     }
 }
 // ===============================list=================================
 /**
  * 获取list缓存的内容
  * @param key 键
  * @param start 开始
  * @param end 结束 0 到 -1代表所有值
  * @return
  */
 public List<Object> lGet(String key, long start, long end) {
     try {
         return redisTemplate.opsForList().range(key, start, end);
     } catch (Exception e) {
         e.printStackTrace();
         return null;
     }
 }
 /**
  * 获取list缓存的长度
  * @param key 键
  * @return
  */
 public long lGetListSize(String key) {
     try {
         return redisTemplate.opsForList().size(key);
     } catch (Exception e) {
         e.printStackTrace();
         return 0;
     }
 }
 /**
  * 通过索引 获取list中的值
  * @param key 键
  * @param index 索引 index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推
  * @return
  */
 public Object lGetIndex(String key, long index) {
     try {
         return redisTemplate.opsForList().index(key, index);
     } catch (Exception e) {
         e.printStackTrace();
         return null;
     }
 }
 /**
  * 将list放入缓存
  * @param key 键
  * @param value 值
  * @param time 时间(秒)
  * @return
  */
 public boolean lSet(String key, Object value) {
     try {
         redisTemplate.opsForList().rightPush(key, value);
         return true;
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * 将list放入缓存
  * @param key 键
  * @param value 值
  * @param time 时间(秒)
  * @return
  */
 public boolean lSet(String key, Object value, long time) {
     try {
         redisTemplate.opsForList().rightPush(key, value);
         if (time > 0)
             expire(key, time);
         return true;
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * 将list放入缓存
  * @param key 键
  * @param value 值
  * @param time 时间(秒)
  * @return
  */
 public boolean lSet(String key, List<Object> value) {
     try {
         redisTemplate.opsForList().rightPushAll(key, value);
         return true;
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * 将list放入缓存
  * 
  * @param key 键
  * @param value 值
  * @param time 时间(秒)
  * @return
  */
 public boolean lSet(String key, List<Object> value, long time) {
     try {
         redisTemplate.opsForList().rightPushAll(key, value);
         if (time > 0)
             expire(key, time);
         return true;
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * 根据索引修改list中的某条数据
  * @param key 键
  * @param index 索引
  * @param value 值
  * @return
  */
 public boolean lUpdateIndex(String key, long index, Object value) {
     try {
         redisTemplate.opsForList().set(key, index, value);
         return true;
     } catch (Exception e) {
         e.printStackTrace();
         return false;
     }
 }
 /**
  * 移除N个值为value
  * @param key 键
  * @param count 移除多少个
  * @param value 值
  * @return 移除的个数
  */
 public long lRemove(String key, long count, Object value) {
     try {
         Long remove = redisTemplate.opsForList().remove(key, count, value);
         return remove;
     } catch (Exception e) {
         e.printStackTrace();
         return 0;
     }
 }
}


测试：

import java.util.HashMap;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import RedisUtil;
import User;
/**
 * redis测试
 * @author jiajia
 *
 */
@RestController
public class ControllerTest {

	@Autowired
    private RedisUtil redisUtil;
	
	@RequestMapping("/getObj")
    public Object getObj(){
		Map<String,Object> map=new HashMap<String,Object>();
		map.put("id",1);
		map.put("user",new User("jiajia",12));
		redisUtil.set("map",map);
		Object obj=redisUtil.get("map");
		System.out.println(obj);
		return obj;
    }
	@RequestMapping("/getObj2")
    public Object getObj2(){
		redisUtil.set("user",new User("wangshuai",12));
		Object obj=redisUtil.get("user");
		System.out.println(obj);
		return obj;
    }

}


QQ截图20190518172224.png


评论区
请写下您的评论...
暂无评论...
猜你喜欢
linux系统 3935 linux下安装redis数据库到官网下载对应的tar.gz包https://redis.io/解压我是直接解压到了/opt文件夹下进入redis-5.0.4文件夹下，执行#cdredis
框架 2563 springboot整合mybatis1.创建maven项目2.sql文件SETNAMESutf8mb4;SETFOREIGN_KEY_CHECKS=0
redis,springboot 1067 一、springboot集成redis一般配置pomdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot
official 662 [TOC]一、pom文件?xmlversion="1.0"encoding="UTF-8"?projectxmlns="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
框架 2671 1.配置springboot支持websocketpackagecom.example.demo.websocket
weblog 1031 pomparent groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-parent/artifactId version2.1.3.RELEASE/version /parentdependencies dependency groupIdorg.springframework.boot/group
java框架 1378 springboot整合elasticsearch框架实现全文索引demo配置说明参考：http://www.jiajiajia.club/blog/artical/Ja4t7X/378
java 数据库 2609 java项目-数据库之间定时进行数据交换服务（右上方下载）压缩包内附sql脚本，本项目为springboot+mybatis框架，导入项目即可启动测试。目的，实现两个数据库定时自动进行数据同步，定时
最新发表
归档
2018-11  12 2018-12  33 2019-01  28 2019-02  28 2019-03  32 2019-04  27 2019-05  33 2019-06  6 2019-07  12 2019-08  12 2019-09  21 2019-10  8 2019-11  15 2019-12  25 2020-01  9 2020-02  5 2020-03  16 2020-04  4 2020-06  1 2020-07  7 2020-08  13 2020-09  9 2020-10  5 2020-12  3 2021-01  1 2021-02  5 2021-03  7 2021-04  4 2021-05  4 2021-06  1 2021-07  7 2021-08  2 2021-09  8 2021-10  9 2021-11  16 2021-12  14 2022-01  7 2022-05  1 2022-08  3 2022-09  2 2022-10  2 2022-12  5 2023-01  3 2023-02  1 2023-03  4 2023-04  2 2023-06  3 2023-07  4 2023-08  1 2023-10  1 2024-02  1 2024-03  1 2024-04  1
标签
算法基础 linux 前端 c++ 数据结构 框架 数据库 计算机基础 储备知识 java基础 ASM 其他 深入理解java虚拟机 nginx git 消息中间件 搜索 maven redis docker dubbo vue 导入导出 软件使用 idea插件 协议 无聊的知识 jenkins springboot mqtt协议 keepalived minio mysql ensp 网络基础 xxl-job rabbitmq haproxy srs 音视频 webrtc javascript
目录
没有一个冬天不可逾越，没有一个春天不会来临。最慢的步伐不是跬步，而是徘徊，最快的脚步不是冲刺，而是坚持。