Merge remote-tracking branch 'origin/develop'

Author: dunwu

README.md

@@ -61,6 +61,7 @@
 - [Spring 之事务](docs/01.Java/13.框架/01.Spring/02.Spring数据/03.Spring之事务.md)
 - [Spring 之 JPA](docs/01.Java/13.框架/01.Spring/02.Spring数据/04.Spring之JPA.md)
 - [Spring 集成 Mybatis](docs/01.Java/13.框架/01.Spring/02.Spring数据/10.Spring集成Mybatis.md)
+- [Spring 访问 Redis](docs/01.Java/13.框架/01.Spring/02.Spring数据/21.Spring访问Redis.md)
 - [Spring 访问 MongoDB](docs/01.Java/13.框架/01.Spring/02.Spring数据/22.Spring访问MongoDB.md)
 - [SpringBoot 之 Elasticsearch](docs/01.Java/13.框架/01.Spring/02.Spring数据/24.SpringBoot之Elasticsearch.md)
 

codes/data/nosql/redis/pom.xml

@@ -18,7 +18,11 @@
   <dependencies>
     <dependency>
       <groupId>org.springframework.boot</groupId>
-      <artifactId>spring-boot-starter-data-redis</artifactId>
+      <artifactId>spring-boot-starter-data-redis-reactive</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-webflux</artifactId>
     </dependency>
     <dependency>
       <groupId>org.springframework.boot</groupId>
@@ -37,6 +41,11 @@
       <groupId>io.github.dunwu.tool</groupId>
       <artifactId>dunwu-tool-data</artifactId>
     </dependency>
+    <dependency>
+      <groupId>io.projectreactor</groupId>
+      <artifactId>reactor-test</artifactId>
+      <scope>test</scope>
+    </dependency>
   </dependencies>
 
   <dependencyManagement>

codes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/DataRedisApplication.java

@@ -0,0 +1,10 @@
+package example.spring.data.nosql.redis.quickstart;
+
+public enum Location {
+    Nanjing,
+    Beijing,
+    Shanghai,
+    Hangzhou,
+    Guangzhou,
+    Shenzhen
+}

codes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/User.java

@@ -1,42 +1,26 @@
-package example.spring.data.nosql.redis;
+package example.spring.data.nosql.redis.quickstart;
 
 import com.fasterxml.jackson.annotation.JsonAutoDetect;
 import com.fasterxml.jackson.annotation.PropertyAccessor;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Primary;
 import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.core.HashOperations;
-import org.springframework.data.redis.core.ListOperations;
 import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.core.SetOperations;
-import org.springframework.data.redis.core.ValueOperations;
-import org.springframework.data.redis.core.ZSetOperations;
 import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
 
-/**
- * @author <a href="mailto:[email protected]">Zhang Peng</a>
- * @since 2019-10-14
- */
-@Configuration
-public class RedisAutoConfiguration {
+@Slf4j
+@SpringBootApplication
+public class RedisQuickstartApplication {
 
     @Autowired
     private ObjectMapper objectMapper;
 
-    @Bean
-    public HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) {
-        return redisTemplate.opsForHash();
-    }
-
-    @Bean
-    public ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) {
-        return redisTemplate.opsForList();
-    }
-
     @Bean
     @Primary
     public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
@@ -66,19 +50,8 @@ public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factor
         return template;
     }
 
-    @Bean
-    public SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) {
-        return redisTemplate.opsForSet();
-    }
-
-    @Bean
-    public ValueOperations<String, Object> valueOperations(RedisTemplate<String, Object> redisTemplate) {
-        return redisTemplate.opsForValue();
-    }
-
-    @Bean
-    public ZSetOperations<String, Object> zsetOperations(RedisTemplate<String, Object> redisTemplate) {
-        return redisTemplate.opsForZSet();
+    public static void main(String[] args) {
+        SpringApplication.run(RedisQuickstartApplication.class, args);
     }
 
 }

codes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/quickstart/Location.java

@@ -0,0 +1,24 @@
+package example.spring.data.nosql.redis.quickstart;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+
+import java.io.Serializable;
+
+@Data
+@ToString
+@NoArgsConstructor
+@AllArgsConstructor
+public class User implements Serializable {
+
+    private static final long serialVersionUID = 4142994984277644695L;
+
+    private Long id;
+    private String name;
+    private Integer age;
+    private String address;
+    private String email;
+
+}

…/nosql/redis/RedisAutoConfiguration.java …ickstart/RedisQuickstartApplication.javacodes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/RedisAutoConfiguration.java renamed to codes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/quickstart/RedisQuickstartApplication.java codes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/RedisAutoConfiguration.java renamed to codes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/quickstart/RedisQuickstartApplication.java

@@ -1,17 +1,21 @@
-package example.spring.data.nosql.redis;
+package example.spring.data.nosql.redis.quickstart;
 
 import java.util.Map;
 
 /**
+ * 用户服务
+ *
  * @author <a href="mailto:[email protected]">Zhang Peng</a>
  * @since 2019-10-14
  */
 public interface UserService {
 
+    void batchSetUsers(Map<String, User> users);
+
+    long count();
+
     User getUser(Long id);
 
     void setUser(User user);
 
-    void batchSetUsers(Map<String, User> users);
-
 }

codes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/quickstart/User.java

@@ -1,4 +1,4 @@
-package example.spring.data.nosql.redis;
+package example.spring.data.nosql.redis.quickstart;
 
 import cn.hutool.core.bean.BeanUtil;
 import org.springframework.data.redis.core.RedisTemplate;
@@ -7,20 +7,32 @@
 import java.util.Map;
 
 /**
+ * 用户服务实现
+ *
  * @author <a href="mailto:[email protected]">Zhang Peng</a>
  * @since 2019-10-14
  */
 @Service
 public class UserServiceImpl implements UserService {
 
-    public static final String DEFAULT_KEY = "spring-boot:user";
+    public static final String DEFAULT_KEY = "spring:tutorial:user";
 
     private final RedisTemplate<String, Object> redisTemplate;
 
     public UserServiceImpl(RedisTemplate<String, Object> redisTemplate) {
         this.redisTemplate = redisTemplate;
     }
 
+    @Override
+    public void batchSetUsers(Map<String, User> users) {
+        redisTemplate.opsForHash().putAll(DEFAULT_KEY, users);
+    }
+
+    @Override
+    public long count() {
+        return redisTemplate.opsForHash().size(DEFAULT_KEY);
+    }
+
     @Override
     public User getUser(Long id) {
         Object obj = redisTemplate.opsForHash().get(DEFAULT_KEY, id.toString());
@@ -32,9 +44,4 @@ public void setUser(User user) {
         redisTemplate.opsForHash().put(DEFAULT_KEY, user.getId().toString(), user);
     }
 
-    @Override
-    public void batchSetUsers(Map<String, User> users) {
-        redisTemplate.opsForHash().putAll(DEFAULT_KEY, users);
-    }
-
 }

…spring/data/nosql/redis/UserService.java …/nosql/redis/quickstart/UserService.javacodes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/UserService.java renamed to codes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/quickstart/UserService.java codes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/UserService.java renamed to codes/data/nosql/redis/src/main/java/example/spring/data/nosql/redis/quickstart/UserService.java

@@ -0,0 +1,15 @@
+package example.spring.data.nosql.redis.reactive;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class Coffee {
+
+    private String id;
+    private String name;
+
+}