springboot-15-redis(完)

Author: clown-coding

springboot-15-redis/doc/README.md

@@ -0,0 +1,64 @@
+# ***SpringBoot-RedisCache***
+
+**[Redis中文网](http://www.redis.cn/)**
+
+## **1.引入依赖**
+```pom
+<dependencies>
+    <!-- Data-Redis -->
+    <dependency>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-data-redis</artifactId>
+    </dependency>
+
+    <!-- mybatis依赖-->
+    <dependency>
+        <groupId>org.mybatis.spring.boot</groupId>
+        <artifactId>mybatis-spring-boot-starter</artifactId>
+        <version>1.3.1</version>
+    </dependency>
+
+    <!-- mysql驱动 -->
+    <dependency>
+        <groupId>mysql</groupId>
+        <artifactId>mysql-connector-java</artifactId>
+        <scope>runtime</scope>
+    </dependency>
+</dependencies>
+```
+## **2.编写配置文件*
+```yml
+spring:
+  datasource:
+    driver-class-name: com.mysql.cj.jdbc.Driver
+    url: jdbc:mysql://localhost:3306/springboot-redis?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8
+    username: root
+    password: '123456'
+    schema:
+    - classpath:sql/springboot-redis.sql
+    initialization-mode: always
+#redis配置
+  redis:
+    host: 192.168.25.145
+    port: 6379
+#mybatis配置
+mybatis:
+  configuration:
+    map-underscore-to-camel-case: true
+  type-aliases-package: com.clown.redis.model
+  mapper-locations: classpath:mybatis/mapper/*.xml
+#logging配置
+logging:
+  level:
+    com.clown.redis.mapper: debug
+```
+
+# **Redis数据操作**
+ * Redis常见5大数据类型
+    * String(字符串). list(列表). Set(集合). Hash(散列 ). ZSet(有序集合)
+ * 5大数据操作
+    *  操作字符串:  stringRedisTemplate.opsForValue()
+    *  操作Hash:   stringRedisTemplate.opsForHash()
+    *  操作list:   stringRedisTemplate.opsForList()
+    *  操作Set:    stringRedisTemplate.opsForSet()
+    *  操作ZSet:   stringRedisTemplate.opsForZSet()

springboot-15-redis/pom.xml

@@ -0,0 +1,34 @@
+<?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">
+    <parent>
+        <artifactId>SpringBootLearn</artifactId>
+        <groupId>com.clown</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>springboot-15-redis</artifactId>
+
+    <dependencies>
+        <!-- Data-Redis -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+
+        <!-- mybatis依赖-->
+        <dependency>
+            <groupId>org.mybatis.spring.boot</groupId>
+            <artifactId>mybatis-spring-boot-starter</artifactId>
+            <version>1.3.1</version>
+        </dependency>
+
+        <!-- mysql驱动 -->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <scope>runtime</scope>
+        </dependency>
+    </dependencies>
+</project>

springboot-15-redis/src/main/java/com/clown/redis/RedisApplication.java

@@ -0,0 +1,17 @@
+package com.clown.redis;
+
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @author: Richard·Ackerman
+ * @create: 2019/1/22
+ **/
+@SpringBootApplication
+@MapperScan("com.clown.redis.mapper")
+public class RedisApplication {
+    public static void main(String[] args){
+        SpringApplication.run(RedisApplication.class);
+    }
+}

springboot-15-redis/src/main/java/com/clown/redis/config/MyRedisConfig.java

@@ -0,0 +1,86 @@
+package com.clown.redis.config;
+
+import com.clown.redis.model.Department;
+import com.clown.redis.model.Employee;
+import com.clown.redis.model.User;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.cache.RedisCacheConfiguration;
+import org.springframework.data.redis.cache.RedisCacheManager;
+import org.springframework.data.redis.cache.RedisCacheWriter;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.RedisSerializationContext;
+import org.springframework.data.redis.serializer.RedisSerializer;
+
+import java.net.UnknownHostException;
+import java.time.Duration;
+
+/**
+ * @author: Richard·Ackerman
+ * @create: 2019/1/22
+ *
+ * redis默认使用JDK的序列化器,一般都会将其配置为json序列化器
+ *
+ **/
+@Configuration
+public class MyRedisConfig {
+
+    //将数据进行序列化
+    @Bean
+    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
+        RedisTemplate<Object, Object> template = new RedisTemplate<>();
+        template.setConnectionFactory(redisConnectionFactory);
+        Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(Object.class);
+        template.setDefaultSerializer(serializer);
+        return template;
+    }
+
+    //将redis序列化器进行转换,并且该模板的返回值是employee
+    @Bean
+    public RedisTemplate<Object, Employee> employeeRedisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
+        RedisTemplate<Object, Employee> template = new RedisTemplate<>();
+        template.setConnectionFactory(redisConnectionFactory);
+        Jackson2JsonRedisSerializer<Employee> serializer = new Jackson2JsonRedisSerializer<>(Employee.class);
+        template.setDefaultSerializer(serializer);
+        return template;
+    }
+
+    //将redis序列化器进行转换,并且该模板的返回值是department
+    @Bean
+    public RedisTemplate<String, Department> departmentRedisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
+        RedisTemplate<String, Department> template = new RedisTemplate<>();
+        template.setConnectionFactory(redisConnectionFactory);
+        Jackson2JsonRedisSerializer<Department> serializer = new Jackson2JsonRedisSerializer<>(Department.class);
+        template.setDefaultSerializer(serializer);
+        return template;
+    }
+
+    //将redis序列化器进行转换,并且该模板的返回值是user
+    @Bean
+    public RedisTemplate<Object, User> userRedisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
+        RedisTemplate<Object, User> template = new RedisTemplate<>();
+        template.setConnectionFactory(redisConnectionFactory);
+        Jackson2JsonRedisSerializer<User> serializer = new Jackson2JsonRedisSerializer<>(User.class);
+        template.setDefaultSerializer(serializer);
+        return template;
+    }
+
+    //定制缓存规则
+    @Bean
+    public RedisCacheManager userRedisCacheManager(RedisConnectionFactory connectionFactory){
+        //创建一个redisCacheWriter
+        RedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(connectionFactory);
+        RedisSerializer<Object> jsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
+        RedisSerializationContext.SerializationPair<Object> pair = RedisSerializationContext.SerializationPair.fromSerializer(jsonRedisSerializer);
+        RedisCacheConfiguration defaultCacheConfig=RedisCacheConfiguration.defaultCacheConfig().serializeValuesWith(pair);
+        //设置默认过期时间是30秒
+        defaultCacheConfig.entryTtl(Duration.ofSeconds(30));
+        //初始化RedisCacheManager
+        return new RedisCacheManager(redisCacheWriter, defaultCacheConfig);
+    }
+
+
+}

springboot-15-redis/src/main/java/com/clown/redis/controller/DepartmentController.java

@@ -0,0 +1,50 @@
+package com.clown.redis.controller;
+
+import com.clown.redis.model.Department;
+import com.clown.redis.service.DepartmentService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * @author: Richard·Ackerman
+ * @create: 2019/1/20
+ **/
+@RestController
+@RequestMapping("/department")
+public class DepartmentController {
+
+    @Autowired
+    private DepartmentService departmentService;
+
+    @GetMapping
+    public List<Department> findAll(){
+        return departmentService.findAll();
+    }
+
+    @GetMapping("/{id}")
+    public Department findById(@PathVariable("id") Integer id){
+        return departmentService.findById(id);
+    }
+
+    @GetMapping("/findByDepartmentName/{departmentName}")
+    public Department findByDepartmentName(@PathVariable("departmentName") String departmentName){
+        return departmentService.findByDepartmentName(departmentName);
+    }
+
+    @PostMapping
+    public String add(@RequestBody Department department){
+        return departmentService.add(department);
+    }
+
+    @PutMapping
+    public String update(@RequestBody Department department){
+        return  departmentService.update(department);
+    }
+
+    @DeleteMapping("/{id}")
+    public String deleteById(@PathVariable("id") Integer id){
+        return departmentService.deleteById(id);
+    }
+}

springboot-15-redis/src/main/java/com/clown/redis/controller/EmployeeController.java

@@ -0,0 +1,59 @@
+package com.clown.redis.controller;
+
+import com.clown.redis.model.Employee;
+import com.clown.redis.service.EmployeeService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * @author: Richard·Ackerman
+ * @create: 2019/1/20
+ **/
+@RestController
+@RequestMapping("/employee")
+public class EmployeeController {
+
+    @Autowired
+    private EmployeeService employeeService;
+
+    @GetMapping
+    public List<Employee> findAll(){
+        return employeeService.findAll();
+    }
+
+    @GetMapping("/{id}")
+    public Employee findById(@PathVariable("id") Integer id){
+        return employeeService.findById(id);
+    }
+
+    @GetMapping("/findByDId/{dId}")
+    public List<Employee> findByDId(@PathVariable("dId") Integer dId){
+        return employeeService.findByDId(dId);
+    }
+
+    @GetMapping("/findByLastName")
+    public Employee findByLastName(@RequestParam("lastName") String lastName){
+        return employeeService.findByLastName(lastName);
+    }
+
+    @PostMapping
+    public String add(@RequestBody Employee employee){
+        return employeeService.add(employee);
+    }
+
+    @PutMapping
+    public String update(@RequestBody Employee employee){
+        Employee update = employeeService.update(employee);
+        if (null==update) {
+            return "更新失败";
+        }
+        return "更新成功";
+    }
+
+    @DeleteMapping("/{id}")
+    public String deleteById(@PathVariable("id") Integer id){
+        return employeeService.deleteById(id);
+    }
+}

springboot-15-redis/src/main/java/com/clown/redis/controller/UserController.java

@@ -0,0 +1,45 @@
+package com.clown.redis.controller;
+
+import com.clown.redis.model.User;
+import com.clown.redis.service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * @author: Richard·Ackerman
+ * @create: 2019/1/22
+ **/
+@RestController
+@RequestMapping("/user")
+public class UserController {
+
+    @Autowired
+    private UserService userService;
+
+    @GetMapping
+    public List<User> findAll(){
+        return userService.findAll();
+    }
+
+    @GetMapping("/{id}")
+    public User findById(@PathVariable("id") Integer id){
+       return userService.findById(id);
+    }
+
+    @PostMapping
+    public String add(@RequestBody User user){
+        return userService.add(user);
+    }
+
+    @PutMapping
+    public String update(@RequestBody User user){
+        return userService.update(user);
+    }
+
+    @DeleteMapping("/{id}")
+    public String deleteById(@PathVariable("id") Integer id){
+        return userService.deleteById(id);
+    }
+}

springboot-15-redis/src/main/java/com/clown/redis/mapper/DepartmentMapper.java

@@ -0,0 +1,31 @@
+package com.clown.redis.mapper;
+
+import com.clown.redis.model.Department;
+import org.apache.ibatis.annotations.*;
+
+import java.util.List;
+
+//@Mapper
+public interface DepartmentMapper {
+
+    @Select("SELECT * FROM department")
+    List<Department> findAll();
+
+    @Select("SELECT * FROM department WHERE id = #{id}")
+    Department findById(Integer id);
+
+    @Select("SELECT * FROM department WHERE department_name = #{departmentName}")
+    Department findByDepartmentName(String departmentName);
+
+    @Options(useGeneratedKeys = true,keyProperty = "id",keyColumn = "id")
+    @Insert("INSERT INTO department(department_name) VALUES(#{departmentName})")
+    int add(Department department);
+
+    @Update("UPDATE department SET department_name = #{departmentName} WHERE id = #{id}")
+    int update(Department department);
+
+    @Delete("DELETE FROM department WHERE id = #{id}")
+    int deleteById(Integer id);
+
+
+}