写点什么

立即可用的实战源码 (springboot+redis+mybatis+restTemplate)

作者:程序员欣宸
  • 2022-10-28
    广东
  • 本文字数:16967 字

    阅读完需:约 56 分钟

立即可用的实战源码(springboot+redis+mybatis+restTemplate)

欢迎访问我的 GitHub

这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos

关于这个 demo 工程

  • 开发 springboot 应用的时候,经常用到 redis、mybatis、restTemplate 这些技术,在此将常用代码和配置都整理出来,以后有需要就能直接拿来用了;

demo 的功能简介

  • 此 demo 是个父子结构的 maven 工程,两个子工程特点如下:



  • 整个服务如下图所示:

  • 写操作:用户通过浏览器向 service-a 发起请求,通过 service-a 将数据写入 mysql,然后 service-a 会调用 service-b 的接口,将数据写入 redis;

  • 读操作:用户通过浏览器向 service-a 发起请求,service-a 会调用 service-b 的接口从 redis 中取数据,如果取到了就返回给浏览器,如果取不到,就从 mysql 中取,如果从 mysql 中能取到,就先通过 service-b 写入 redis,再返回给浏览器,如果 mysql 中也没有,就返回无数据;

版本信息参考

  1. 操作系统:CentOS Linux release 7.7.1908

  2. docker:Community 19.03.2

  3. springboot:2.0.5.RELEASE

  4. mysql:5.7.27

  5. redis:5.0.6

demo 源码下载

  • 如果您不想编码,可以直接从 GitHub 下载完整的 demo 工程源码,地址和链接信息如下表所示:



  • 这个 git 项目中有多个文件夹,本章的应用在 pinpoint185demo 文件夹下,如下图红框所示:

快速部署 mysql

  • 为了快速准备好 mysql 服务用来测试,我这里是用 docker 来完成的,一行命令即可:


docker run --name mysql -p 3306:3306 -e MYSQL_ROOT_PASSWORD=888888 -idt mysql:5.7.27
复制代码


  • 创建数据库 demo 和表 student,表结构非常简单:


CREATE DATABASE demo;USE demo;CREATE TABLE student (id INT(11), name VARCHAR(128));
复制代码

快速部署 redis

  • 为了快速准备好 redis 服务用来测试,我这里是用 docker 来完成的,一行命令即可:


docker run --name redis -p 6379:6379 -idt redis:5.0.6 redis-server --appendonly yes
复制代码

父工程

  • 首先创建名为 pinpoint185demo 的 maven 工程,pom.xml 内容如下:


<?xml version="1.0" encoding="UTF-8"?><project xmlns="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 http://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0</modelVersion>    <modules>        <module>service-a</module>        <module>service-b</module>    </modules>    <parent>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-parent</artifactId>        <version>2.0.5.RELEASE</version>        <relativePath/> <!-- lookup parent from repository -->    </parent>    <groupId>com.bolingcavalry</groupId>    <artifactId>pinpoint185demo</artifactId>    <version>1.0-SNAPSHOT</version>    <packaging>pom</packaging>    <properties>        <java.version>1.8</java.version>        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>        <java.version>1.8</java.version>        <spring.boot.version>2.0.5.RELEASE</spring.boot.version>    </properties>    <!--编译管理 jdk版本和字符集编码-->    <build>        <plugins>            <plugin>                <groupId>org.apache.maven.plugins</groupId>                <artifactId>maven-compiler-plugin</artifactId>                <configuration>                    <source>${java.version}</source>                    <target>${java.version}</target>                    <encoding>${project.build.sourceEncoding}</encoding>                </configuration>            </plugin>        </plugins>    </build></project>
复制代码

子工程 service-a 编码

  • 在此工程下创建子工程 service-a ,其 pom.xml 内容如下:


<?xml version="1.0" encoding="UTF-8"?><project xmlns="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 https://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0</modelVersion>    <parent>        <groupId>com.bolingcavalry</groupId>        <artifactId>pinpoint185demo</artifactId>        <version>1.0-SNAPSHOT</version>    </parent>    <artifactId>service-a</artifactId>    <name>service-a</name>    <description>服务a</description>    <properties>        <java.version>1.8</java.version>    </properties>    <dependencies>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>        </dependency>        <dependency>            <groupId>org.mybatis.spring.boot</groupId>            <artifactId>mybatis-spring-boot-starter</artifactId>            <version>1.3.2</version>        </dependency>
<dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency>
<dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.28</version> </dependency>
<dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <version>3.9</version> </dependency> </dependencies>
<build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build></project>
复制代码


  • 以上内容有几点需要注意:a. 要提供 web 服务,所以依赖了 spring-boot-starter-web;b. 要使用 mybaits,所以依赖了 mybatis-spring-boot-starter;c. 要连接 mysql,所以依赖了 mysql-connector-java;d. commons-lang3、fastjson 作为工具类,在代码中会用到它们的 API;

  • service-a 的系统配置 application.yml 内容如下,注意数据库和 mybaits 的配置:


server:  port: 8080spring:  datasource:    username: root    password: 888888    url: jdbc:mysql://192.168.121.143:3306/demo?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC    driver-class-name: com.mysql.jdbc.Driver
mybatis: mapper-locations: classpath:mapping/*Mapping.xml type-aliases-package: com.bolingcavalry.servicea.entity
logging: level: com: bolingcavalry: servicea: debug
# service-b的服务urlserviceb: baseurl: http://localhost:8081/
复制代码


  • mybatis 的 mapping 文件在 src\main\resources\mapping 目录,名为 StudentMapping.xml,对应 student 表的定义和操作:


<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.bolingcavalry.servicea.mapper.StudentMapper">    <resultMap id="BaseResultMap" type="com.bolingcavalry.servicea.entity.Student">        <result column="id" jdbcType="INTEGER" property="id" />        <result column="name" jdbcType="VARCHAR" property="name" />    </resultMap>    <select id="getById" resultType="com.bolingcavalry.servicea.entity.Student">        select * from student where id = #{id}    </select>    <insert id="insert" parameterType="com.bolingcavalry.servicea.entity.Student" >        insert into student (id, name) values (#{id,jdbcType=INTEGER}, #{name,jdbcType=VARCHAR})    </insert></mapper>
复制代码


  • student 表对应的实体类:


package com.bolingcavalry.servicea.entity;
/** * @Description: student entity * @author: willzhao E-mail: zq2599@gmail.com * @date: 2019/10/3 9:55 */public class Student {
private Integer id;
private String name;
public Integer getId() { return id; }
public void setId(Integer id) { this.id = id; }
public String getName() { return name; }
public void setName(String name) { this.name = name; }}
复制代码


  • student 对应的 mapper 接口:


package com.bolingcavalry.servicea.mapper;
import com.bolingcavalry.servicea.entity.Student;import org.springframework.stereotype.Repository;
/** * @Description: mybatis mapper * @author: willzhao E-mail: zq2599@gmail.com * @date: 2019/10/3 9:58 */@Repositorypublic interface StudentMapper {
Student getById(Integer id);
void insert(Student student);}
复制代码


  • 由于要用到 restTemplate 访问 service-b,因此要增加对应的配置类:


package com.bolingcavalry.servicea.config;
import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.http.client.ClientHttpRequestFactory;import org.springframework.http.client.SimpleClientHttpRequestFactory;import org.springframework.web.client.RestTemplate;
/** * @Description: 远程请求的配置 * @author: willzhao E-mail: zq2599@gmail.com * @date: 2019/10/3 11:45 */@Configurationpublic class RestTemplateConfig {
@Bean public RestTemplate restTemplate(ClientHttpRequestFactory factory){ return new RestTemplate(factory); }
@Bean public ClientHttpRequestFactory simpleClientHttpRequestFactory(){ SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory(); factory.setConnectTimeout(15000); factory.setReadTimeout(5000); return factory; }}
复制代码


  • 接下来是提供 web 服务的 controller:


package com.bolingcavalry.servicea.controller;
import com.alibaba.fastjson.JSON;import com.bolingcavalry.servicea.entity.Student;import com.bolingcavalry.servicea.mapper.StudentMapper;import org.apache.commons.lang3.StringUtils;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Value;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RequestMethod;import org.springframework.web.bind.annotation.RestController;import org.springframework.web.client.RestTemplate;
/** * @Description: 提供学生服务相关的web接口 * @author: willzhao E-mail: zq2599@gmail.com * @date: 2019/10/3 8:51 */@RestControllerpublic class StudentController {
@Autowired StudentMapper studentMapper;
@Autowired private RestTemplate restTemplate;
@Value("${serviceb.baseurl}") private String baseUrl;
@RequestMapping(value = "/get/{id}", method = RequestMethod.GET) public String get(@PathVariable("id") Integer id) {
String rlt = restTemplate.getForObject(baseUrl + "get/" + id,String.class);
if(StringUtils.isNotBlank(rlt)){ return "From redis :" + rlt; }
//redis中查不到,就去数据库里面查 Student student = studentMapper.getById(id); //mysql里面也没有就报错 if(null==student) { return "student with id["+id+"] not exist"; } //调用service-b的接口,写入redis restTemplate.getForObject(baseUrl + "set/"+id+"/"+student.getName(),String.class);
return "From mysql :"+JSON.toJSONString(student); }
@RequestMapping(value = "/add/{id}/{name}", method = RequestMethod.GET) public String add(@PathVariable("id") Integer id, @PathVariable("name") String name) { Student student = new Student(); student.setId(id); student.setName(name); //写入数据库 studentMapper.insert(student); //调用service-b的接口,写入redis restTemplate.getForObject(baseUrl + "set/"+id+"/"+name,String.class); return "insert success"; }}
复制代码


  • 整个应用的启动类,增加了 MapperScan 注解:


package com.bolingcavalry.servicea;
import org.mybatis.spring.annotation.MapperScan;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication@MapperScan("com.bolingcavalry.servicea.mapper")public class ServiceAApplication {
public static void main(String[] args) { SpringApplication.run(ServiceAApplication.class, args); }}
复制代码


  • 以上就是 service-a 的全部源码了,包括 mybatis 和 restTmeplate 操作;

service-b 源码

  • 创建名为 service-b 的子工程,pom.xml 如下,要注意的是依赖了 spring-boot-starter-data-redis 和 commons-pool2:


<?xml version="1.0" encoding="UTF-8"?><project xmlns="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 https://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0</modelVersion>    <parent>        <groupId>com.bolingcavalry</groupId>        <artifactId>pinpoint185demo</artifactId>        <version>1.0-SNAPSHOT</version>    </parent>    <artifactId>service-b</artifactId>    <name>service-b</name>    <description>服务b</description>    <dependencies>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-data-redis</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>        </dependency>        <dependency>            <groupId>com.alibaba</groupId>            <artifactId>fastjson</artifactId>            <version>1.2.28</version>        </dependency>        <dependency>            <groupId>org.apache.commons</groupId>            <artifactId>commons-pool2</artifactId>            <version>2.0</version>        </dependency>    </dependencies>    <build>        <plugins>            <plugin>                <groupId>org.springframework.boot</groupId>                <artifactId>spring-boot-maven-plugin</artifactId>            </plugin>        </plugins>    </build></project>
复制代码


  • 应用的配置文件 application.properties 内容如下:


server.port=8081#redisspring.redis.host=192.168.121.144spring.redis.port=6379# 数据库连接超时时间,2.0 中该参数的类型为Duration,这里在配置的时候需要指明单位spring.redis.timeout=60s# 连接池配置,2.0中直接使用jedis或者lettuce配置连接池# 最大活跃连接数,负数为不限制spring.redis.lettuce.pool.max-active=50# 等待可用连接的最大时间,负数为不限制spring.redis.lettuce.pool.max-wait=-1ms# 最大空闲连接数spring.redis.lettuce.pool.max-idle=10# 最小空闲连接数spring.redis.lettuce.pool.min-idle=2
复制代码


  1. redis 的配置类:


package com.example.serviceb.config;
import com.fasterxml.jackson.annotation.JsonAutoDetect;import com.fasterxml.jackson.annotation.PropertyAccessor;import com.fasterxml.jackson.databind.ObjectMapper;import org.springframework.cache.annotation.CachingConfigurerSupport;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.*;import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;import org.springframework.data.redis.serializer.StringRedisSerializer;
/** * @Description: (这里用一句话描述这个类的作用) * @author: willzhao E-mail: zq2599@gmail.com * @date: 2019/10/3 11:06 */@Configuration@EnableCachingpublic class RedisConfig extends CachingConfigurerSupport {
/** * retemplate相关配置 * @param factory * @return */ @Bean public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
RedisTemplate<String, Object> template = new RedisTemplate<>(); // 配置连接工厂 template.setConnectionFactory(factory);
//使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值(默认使用JDK的序列化方式) Jackson2JsonRedisSerializer jacksonSeial = new Jackson2JsonRedisSerializer(Object.class);
ObjectMapper om = new ObjectMapper(); // 指定要序列化的域,field,get和set,以及修饰符范围,ANY是都有包括private和public om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); // 指定序列化输入的类型,类必须是非final修饰的,final修饰的类,比如String,Integer等会跑出异常 om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jacksonSeial.setObjectMapper(om);
// 值采用json序列化 template.setValueSerializer(jacksonSeial); //使用StringRedisSerializer来序列化和反序列化redis的key值 template.setKeySerializer(new StringRedisSerializer());
// 设置hash key 和value序列化模式 template.setHashKeySerializer(new StringRedisSerializer()); template.setHashValueSerializer(jacksonSeial); template.afterPropertiesSet();
return template; }
/** * 对hash类型的数据操作 * * @param redisTemplate * @return */ @Bean public HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) { return redisTemplate.opsForHash(); }
/** * 对redis字符串类型数据操作 * * @param redisTemplate * @return */ @Bean public ValueOperations<String, Object> valueOperations(RedisTemplate<String, Object> redisTemplate) { return redisTemplate.opsForValue(); }
/** * 对链表类型的数据操作 * * @param redisTemplate * @return */ @Bean public ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) { return redisTemplate.opsForList(); }
/** * 对无序集合类型的数据操作 * * @param redisTemplate * @return */ @Bean public SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) { return redisTemplate.opsForSet(); }
/** * 对有序集合类型的数据操作 * * @param redisTemplate * @return */ @Bean public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) { return redisTemplate.opsForZSet(); }}
复制代码


  • redis 的工具类:


package com.example.serviceb.util;
/** * @Description: (这里用一句话描述这个类的作用) * @author: willzhao E-mail: zq2599@gmail.com * @date: 2019/10/3 11:09 */import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.stereotype.Component;import org.springframework.util.CollectionUtils;
import java.util.List;import java.util.Map;import java.util.Set;import java.util.concurrent.TimeUnit;
/** * redisTemplate封装 */@Componentpublic class RedisUtil {
@Autowired private RedisTemplate<String, Object> redisTemplate;
public RedisUtil(RedisTemplate<String, Object> redisTemplate) { this.redisTemplate = redisTemplate; }
/** * 指定缓存失效时间 * @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 值 * @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 值 * @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; } }
}
复制代码


  • 保存 student 数据的实体类:


package com.example.serviceb.entity;
import java.io.Serializable;
/** * @Description: (这里用一句话描述这个类的作用) * @author: willzhao E-mail: zq2599@gmail.com * @date: 2019/10/3 11:11 */public class Student implements Serializable { private Integer id; private String name;
public Integer getId() { return id; }
public void setId(Integer id) { this.id = id; }
public String getName() { return name; }
public void setName(String name) { this.name = name; }}
复制代码


  • 提供 http 服务的 controller 类:


package com.example.serviceb.controller;
import com.alibaba.fastjson.JSON;import com.example.serviceb.entity.Student;import com.example.serviceb.util.RedisUtil;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RequestMethod;import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
/** * @Description: redis服务 * @author: willzhao E-mail: zq2599@gmail.com * @date: 2019/10/3 11:13 */@RestControllerpublic class StudentRedisController {
@Resource private RedisUtil redisUtil;
@RequestMapping(value = "/set/{id}/{name}", method = RequestMethod.GET) public String set(@PathVariable("id") Integer id, @PathVariable("name") String name) { Student student = new Student(); student.setId(id); student.setName(name); //写入redis,有效期是30秒 redisUtil.set("student:"+id, student, 30); return "set successful, id ["+id+"], name ["+name+"]"; }
@RequestMapping(value = "/get/{id}", method = RequestMethod.GET) public String get(@PathVariable("id") Integer id) { Object object = redisUtil.get("student:"+id); return null==object ? "" : JSON.toJSONString(object); }}
复制代码


  • 最后是应用启动类:


package com.example.serviceb;
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplicationpublic class ServiceBApplication {
public static void main(String[] args) { SpringApplication.run(ServiceBApplication.class, args); }}
复制代码


  • 以上就是整个 demo 的所有代码,接下来验证服务

验证


mysql> select * from student;+------+------+| id   | name |+------+------+|    1 | tom  |+------+------+1 row in set (0.00 sec)
复制代码


  • 检查 redis,写入成功(注意:千万不要在生产环境使用 keys 命令!!!):


127.0.0.1:6379> keys *1) "student:1"127.0.0.1:6379> get "student:1""[\"com.example.serviceb.entity.Student\",{\"id\":1,\"name\":\"tom\"}]"
复制代码


  • 等待超过 30 秒,调用读接口试试:http://localhost:8080/get/1 ,由于 redis 中的数据只有 30 秒有效期,所以此时页面提示数据来自 mysql


  • 立即再调用读接口,由于前面的一次读接口会将数据写入 redis,所以此时页面提示数据来自 redis:


  • 至此,整个 demo 已经完成开发和验证,希望你在着手开发一个数据、缓存相关的 springboot 应用时,此 demo 能给你提供一些参考。

参考并致谢

欢迎关注 InfoQ:程序员欣宸

学习路上,你不孤单,欣宸原创一路相伴...


发布于: 刚刚阅读数: 5
用户头像

搜索"程序员欣宸",一起畅游Java宇宙 2018-04-19 加入

前腾讯、前阿里员工,从事Java后台工作,对Docker和Kubernetes充满热爱,所有文章均为作者原创,个人Github:https://github.com/zq2599/blog_demos

评论

发布
暂无评论
立即可用的实战源码(springboot+redis+mybatis+restTemplate)_Java_程序员欣宸_InfoQ写作社区