init

.gitignore

@@ -0,0 +1,4 @@
+/target/
+.settings/
+.classpath
+.project

pom.xml

@@ -0,0 +1,48 @@
+<?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>
+	
+	<groupId>com.yaozhitech</groupId>
+	<artifactId>spring5</artifactId>
+	<packaging>jar</packaging>
+	<version>0.1.0</version>
+	
+	<name>${project.artifactId}</name>
+    <description>spring5 demo</description>
+	
+	<!-- Spring Boot 启动父依赖 -->
+	<parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.2.1.RELEASE</version>
+        <relativePath />
+    </parent>
+
+	<properties>
+		<maven.compiler.source>1.8</maven.compiler.source>
+		<maven.compiler.target>1.8</maven.compiler.target>
+		<maven-jar-plugin.version>3.1.1</maven-jar-plugin.version>
+	</properties>
+
+	<dependencies>
+		<!-- Spring Boot Web Flux 依赖 -->
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-webflux</artifactId>
+		</dependency>
+	
+		<!-- Spring Boot 响应式 Redis 依赖 -->
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-redis-reactive</artifactId>
+		</dependency>
+		
+		<!-- lombok依赖包 -->
+		<dependency>
+			<groupId>org.projectlombok</groupId>
+			<artifactId>lombok</artifactId>
+		</dependency>
+		
+	</dependencies>
+</project>

src/main/java/com/yaozhitech/spring5/App.java

@@ -0,0 +1,13 @@
+package com.yaozhitech.spring5;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class App {
+
+	public static void main(String[] args) {
+        // 程序启动入口
+        SpringApplication.run(App.class,args);
+    }
+}

src/main/java/com/yaozhitech/spring5/config/RedisConfig.java

@@ -0,0 +1,54 @@
+package com.yaozhitech.spring5.config;
+
+
+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.RedisTemplate;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+/**
+ * redis 配置
+ *
+ * @author yinzy
+ */
+@Configuration
+@EnableCaching
+public class RedisConfig extends CachingConfigurerSupport {
+	public static String cachePrefix = "bbc:";
+	
+    @Bean
+    public StringRedisSerializer stringRedisSerializer() {
+        return new StringRedisSerializer();
+    }
+
+    @Bean
+    public GenericJackson2JsonRedisSerializer genericJackson2JsonRedisSerializer() {
+        return new GenericJackson2JsonRedisSerializer();
+    }
+    
+    @Bean
+    public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory){
+        StringRedisTemplate template = new StringRedisTemplate();
+        template.setConnectionFactory(redisConnectionFactory);
+        return template;
+    }
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory,
+                                                       StringRedisSerializer stringRedisSerializer,
+                                                       GenericJackson2JsonRedisSerializer genericJackson2JsonRedisSerializer) {
+        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
+        redisTemplate.setConnectionFactory(redisConnectionFactory);
+        redisTemplate.setKeySerializer(stringRedisSerializer);
+        redisTemplate.setValueSerializer(genericJackson2JsonRedisSerializer);
+        redisTemplate.setHashKeySerializer(stringRedisSerializer);
+        redisTemplate.setHashValueSerializer(genericJackson2JsonRedisSerializer);
+        return redisTemplate;
+    }
+    
+}

src/main/java/com/yaozhitech/spring5/controller/CityWebFluxController.java

@@ -0,0 +1,58 @@
+package com.yaozhitech.spring5.controller;
+
+import java.util.concurrent.TimeUnit;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.ValueOperations;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.yaozhitech.spring5.domain.City;
+
+import reactor.core.publisher.Mono;
+
+@RestController
+@RequestMapping(value = "/city")
+public class CityWebFluxController {
+
+	@Autowired
+	private RedisTemplate<String, Object> redisTemplate;
+
+	@GetMapping(value = "/{id}")
+	public Mono<City> findCityById(@PathVariable("id") Long id) {
+		String key = "city_" + id;
+		ValueOperations<String, Object> operations = redisTemplate.opsForValue();
+		boolean hasKey = redisTemplate.hasKey(key);
+		City city = (City) operations.get(key);
+
+		if (!hasKey) {
+			return Mono.create(monoSink -> monoSink.success(null));
+		}
+		return Mono.create(monoSink -> monoSink.success(city));
+	}
+
+	@PostMapping()
+	public Mono<City> saveCity(@RequestBody City city) {
+		String key = "city_" + city.getId();
+		ValueOperations<String, Object> operations = redisTemplate.opsForValue();
+		operations.set(key, city, 160, TimeUnit.SECONDS);
+
+		return Mono.create(monoSink -> monoSink.success(city));
+	}
+
+	@DeleteMapping(value = "/{id}")
+	public Mono<Long> deleteCity(@PathVariable("id") Long id) {
+		String key = "city_" + id;
+		boolean hasKey = redisTemplate.hasKey(key);
+		if (hasKey) {
+			redisTemplate.delete(key);
+		}
+		return Mono.create(monoSink -> monoSink.success(id));
+	}
+}

src/main/java/com/yaozhitech/spring5/domain/City.java

@@ -0,0 +1,27 @@
+package com.yaozhitech.spring5.domain;
+
+import org.springframework.data.annotation.Id;
+
+import lombok.Data;
+
+@Data
+public class City {
+
+	@Id
+    private Long id;
+
+    /**
+     * 省份编号
+     */
+    private Long pid;
+
+    /**
+     * 城市名称
+     */
+    private String cityName;
+
+    /**
+     * 描述
+     */
+    private String desc;
+}

src/main/resources/application.properties

@@ -0,0 +1,9 @@
+## Redis 配置
+## Redis服务器地址
+spring.redis.host=127.0.0.1
+## Redis服务器连接端口
+spring.redis.port=6279
+## Redis服务器连接密码（默认为空）
+spring.redis.password=bbztx123456
+# 连接超时时间（毫秒）
+spring.redis.timeout=5000