spring boot 2.0 整合redis 完整程式碼
阿新 • • 發佈：2019-02-14
1.建立maven專案：
2.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> <groupId>com.anwensheng</groupId> <artifactId>springboot_redis</artifactId> <version>1.0-SNAPSHOT</version> <packaging>jar</packaging> <name>springboot_redis</name> <!-- FIXME change it to the project's website --> <url>http://www.example.com</url> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <maven.compiler.source>1.7</maven.compiler.source> <maven.compiler.target>1.7</maven.compiler.target> </properties> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.1.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <configuration> <includeSystemScope>true</includeSystemScope> </configuration> </plugin> </plugins> </build> </project>
3.編寫application.yml檔案：
server: port: 8090 servlet: context-path: /redis #redis配置 spring: redis: database: 0 host: 127.0.0.1 port: 6379 timeout: 3000 password: laoan2000 #密碼 jedis: pool: min-idle: 200 max-idle: 200 max-active: 2000 max-wait: 10000
4.編寫工具類：
package com.anwensheng.utils; import java.io.Serializable; /** * 後端相應包裝類 * 狀態碼200 返回成功 * 500 響應有問題 */ public class JsonData implements Serializable { private Integer code;//狀態碼 private Object data;//返回資料 private String message;//返回資訊描述 public Integer getCode() { return code; } public void setCode(Integer code) { this.code = code; } public Object getData() { return data; } public void setData(Object data) { this.data = data; } public String getMessage() { return message; } public void setMessage(String message) { this.message = message; } public JsonData(Integer code, Object data, String message) { this.code = code; this.data = data; this.message = message; } public JsonData() { } // 成功，只返回成功狀態碼 public static JsonData buildSucceful() { return new JsonData(200, null, null); } // 成功，傳入狀態碼和資料 public static JsonData ok(Object data) { return new JsonData(200, data, null); } // 失敗，傳入描述資訊,狀態碼 public static JsonData buildError(String message){ return new JsonData(500,null,message); } // 失敗，傳入描述資訊,狀態碼 public static JsonData buildError(Integer code,String message){ return new JsonData(code,null,message); } // 成功，傳入資料,及描述資訊 public static JsonData buildSuccesful(Object data,String message){ return new JsonData(200,data,message); } // 成功，傳入資料,及狀態碼 public static JsonData buildSuccesful(Object data,Integer code){ return new JsonData(code,data,null); } }
package com.anwensheng.utils; import com.fasterxml.jackson.databind.ObjectMapper; public class JsonUtils { private static ObjectMapper mapper = new ObjectMapper(); //物件轉化成字串 public static <T> String objToString(T object) { if (object == null) { return null; } ; try { return object instanceof String ? (String) object : mapper.writeValueAsString(object); } catch (Exception e) { e.getStackTrace(); return null; } } //字串轉化成物件 public static <T> T str2Object(String str, Class<T> clazz) { if (str == null || clazz == null) { return null; } try { return clazz.equals(String.class) ? (T) str : mapper.readValue(str, clazz); } catch (Exception e) { e.printStackTrace(); return null; } } }
package com.anwensheng.utils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Component; /** * redis包裝工具類 * 對於redisTpl.opsForValue().set(key, value)進行了一次封裝，不然每次都要這樣儲存值 * 而封裝後只需：new RedisClient().set(key,value); */ @Component public class RedisClient { @Autowired private StringRedisTemplate redisTemplate; /** * 儲存值到快取裡面 * @param key * @param value * @return */ public boolean setkey_Value(String key, String value) { try { redisTemplate.opsForValue().set(key, value); return true; } catch (Exception e) { e.getStackTrace(); return false; } } /** * 通過key獲取快取裡對應的value * @param key * @return */ public String getValue(String key){ return redisTemplate.opsForValue().get(key); } }
5.編寫控制層：
package com.anwensheng.controller; import com.anwensheng.pojo.User; import com.anwensheng.utils.JsonData; import com.anwensheng.utils.JsonUtils; import com.anwensheng.utils.RedisClient; import io.lettuce.core.dynamic.annotation.Param; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("/api") public class RedisController { @Autowired private RedisClient redisClient; @RequestMapping("/addKey") public JsonData addKey(@Param("key") String key,@Param("value") String value) { boolean b = redisClient.setkey_Value(key, value); if(b){ return JsonData.buildSucceful(); } return JsonData.buildError("新增失敗！"); } @RequestMapping("/getKey") public JsonData getKey(@Param("key") String key) { String value = redisClient.getValue(key); if (value != null) { return JsonData.buildSuccesful(value, "獲取成功！"); } return JsonData.buildError("獲取失敗！"); } @RequestMapping("/addUser") public JsonData addUser(){ User user = new User(); user.setName("李四"); user.setPassword("90lai"); String s = JsonUtils.objToString(user); if(s!=null){ boolean flag = redisClient.setkey_Value("user1", s); if(flag){ return JsonData.buildSuccesful(null,"success"); } } return JsonData.buildError("fail"); } @RequestMapping("/getUser") public JsonData getUser(){ String str = redisClient.getValue("user1"); User user = JsonUtils.str2Object(str, User.class); if(user!=null){ return JsonData.buildSuccesful(user,"success"); } return JsonData.buildError("未獲取到相關值！"); } }
6.實體類：（測試用）
package com.anwensheng.pojo; public class User { private Integer uId; private String name; private String password; public Integer getuId() { return uId; } public void setuId(Integer uId) { this.uId = uId; } public String getName() { return name; } public void setName(String name) { this.name = name == null ? null : name.trim(); } public String getPassword() { return password; } public void setPassword(String password) { this.password = password == null ? null : password.trim(); } }
7.啟動類
package com.anwensheng; 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); } }
8.開啟redis伺服器和客戶端：
9，開啟應用程式服務
測試結果：
