finish spring redis application

Author: benweizhu

Diff for: README.md

@@ -1 +1,9 @@
-# spring-redis-docker-example
+# spring-redis-docker-example
+
+```
+./gradlew clean build
+
+docker-compose build
+
+docker-compose up
+```

Diff for: build.gradle

@@ -21,10 +21,8 @@ repositories {
 
 dependencies {
     compile 'com.google.guava:guava:21.0'
-    compile("org.springframework.boot:spring-boot-starter-web") {
-        exclude module: "spring-boot-starter-tomcat"
-    }
-    compile("org.springframework.boot:spring-boot-starter-jetty")
+    compile("org.springframework.boot:spring-boot-starter-web")
+    compile("org.springframework.boot:spring-boot-starter-data-redis")
     compile("org.springframework.boot:spring-boot-starter-actuator")
     testCompile("junit:junit")
 }

Diff for: redis/README.md

@@ -0,0 +1 @@
+This docker-compose.yml is for just docker up redis when doing development.

Diff for: redis/docker-compose.yml

@@ -0,0 +1,7 @@
+version: '2'
+services:
+  db:
+    image: "redis:alpine"
+    hostname: redis
+    ports:
+     - "6379:6379"

Diff for: src/main/java/me/zeph/controller/UserController.java

@@ -1,14 +1,33 @@
 package me.zeph.controller;
 
 import me.zeph.model.User;
+import me.zeph.service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import static org.springframework.http.HttpStatus.CREATED;
+import static org.springframework.http.MediaType.APPLICATION_JSON_VALUE;
+import static org.springframework.web.bind.annotation.RequestMethod.GET;
+import static org.springframework.web.bind.annotation.RequestMethod.POST;
+
 @RestController
 public class UserController {
-    @RequestMapping(value = "/user/{id}")
-    public User findUserById(@PathVariable("id") String id) {
-        return new User("1234567890");
+
+    @Autowired
+    private UserService userService;
+
+    @RequestMapping(value = "/user/{phoneNumber}", method = GET, produces = APPLICATION_JSON_VALUE)
+    public User findUserByPhoneNumber(@PathVariable("phoneNumber") String phoneNumber) {
+        return userService.findUserByPhoneNumber(phoneNumber);
+    }
+
+    @RequestMapping(value = "/user", method = POST, consumes = APPLICATION_JSON_VALUE, produces = APPLICATION_JSON_VALUE)
+    public ResponseEntity saveUser(@RequestBody User user) {
+        userService.saveUser(user);
+        return new ResponseEntity(CREATED);
     }
 }

Diff for: src/main/java/me/zeph/converter/BytesToUserConverter.java

@@ -0,0 +1,25 @@
+package me.zeph.converter;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import me.zeph.model.User;
+import org.springframework.core.convert.converter.Converter;
+import org.springframework.data.convert.ReadingConverter;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.stereotype.Component;
+
+@Component
+@ReadingConverter
+public class BytesToUserConverter implements Converter<byte[], User> {
+
+    private final Jackson2JsonRedisSerializer<User> serializer;
+
+    public BytesToUserConverter() {
+        serializer = new Jackson2JsonRedisSerializer<>(User.class);
+        serializer.setObjectMapper(new ObjectMapper());
+    }
+
+    @Override
+    public User convert(byte[] value) {
+        return serializer.deserialize(value);
+    }
+}

Diff for: src/main/java/me/zeph/converter/UserToBytesConverter.java

@@ -0,0 +1,25 @@
+package me.zeph.converter;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import me.zeph.model.User;
+import org.springframework.core.convert.converter.Converter;
+import org.springframework.data.convert.WritingConverter;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.stereotype.Component;
+
+@Component
+@WritingConverter
+public class UserToBytesConverter implements Converter<User, byte[]> {
+
+    private final Jackson2JsonRedisSerializer<User> serializer;
+
+    public UserToBytesConverter() {
+        serializer = new Jackson2JsonRedisSerializer<>(User.class);
+        serializer.setObjectMapper(new ObjectMapper());
+    }
+
+    @Override
+    public byte[] convert(User value) {
+        return serializer.serialize(value);
+    }
+}

Diff for: src/main/java/me/zeph/service/UserService.java

@@ -0,0 +1,33 @@
+package me.zeph.service;
+
+import me.zeph.converter.BytesToUserConverter;
+import me.zeph.converter.UserToBytesConverter;
+import me.zeph.model.User;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.HashOperations;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+
+@Service
+public class UserService {
+
+    @Autowired
+    private RedisTemplate redisTemplate;
+
+    @Autowired
+    private UserToBytesConverter userToBytesConverter;
+
+    @Autowired
+    private BytesToUserConverter bytesToUserConverter;
+
+    public void saveUser(User user) {
+        HashOperations hashOperations = redisTemplate.opsForHash();
+        hashOperations.put("user", user.getPhoneNumber(), userToBytesConverter.convert(user));
+    }
+
+    public User findUserByPhoneNumber(String phoneNumber) {
+        HashOperations hashOperations = redisTemplate.opsForHash();
+        return bytesToUserConverter.convert((byte[]) hashOperations.get("user", phoneNumber));
+    }
+
+}

Diff for: src/main/resources/application-dev.properties

@@ -0,0 +1 @@
+spring.redis.host=localhost

Diff for: src/main/resources/application.properties

@@ -0,0 +1 @@
+spring.redis.host=redis