parent
9715b3a916
commit
fbb4484c37
|
@ -0,0 +1,99 @@
|
|||
package com.len.redis;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Value;
|
||||
import org.springframework.data.redis.core.RedisTemplate;
|
||||
import org.springframework.data.redis.core.StringRedisTemplate;
|
||||
import org.springframework.data.redis.core.ValueOperations;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
/**
|
||||
* @author zhuxiaomeng
|
||||
* @date 2018/11/24.
|
||||
* @email 154040976@qq.com
|
||||
*/
|
||||
@Service
|
||||
public class RedisService {
|
||||
|
||||
@Autowired
|
||||
private StringRedisTemplate stringRedisTemplate;
|
||||
|
||||
@Autowired
|
||||
private RedisTemplate<Object, Object> redisTemplate;
|
||||
|
||||
@Resource(name = "stringRedisTemplate")
|
||||
private ValueOperations<String, String> valueOps;
|
||||
|
||||
@Resource(name = "redisTemplate")
|
||||
private ValueOperations<Object, Object> valOpsObj;
|
||||
|
||||
@Value("${redis.prefix}")
|
||||
private String prefix;
|
||||
|
||||
/**
|
||||
* 获取缓存字符串 根据key
|
||||
*
|
||||
* @param key 字符串key
|
||||
* @return value
|
||||
*/
|
||||
public String get(String key) {
|
||||
key = prefix + key;
|
||||
return valueOps.get(key);
|
||||
}
|
||||
|
||||
/**
|
||||
* set value and cache timeout by str key
|
||||
*
|
||||
* @param key 字符串key
|
||||
* @param value 字符串value
|
||||
* @param second 过期时间 单位 秒
|
||||
*/
|
||||
public void set(String key, String value, Long second) {
|
||||
key = prefix + key;
|
||||
valueOps.set(key, value, second,TimeUnit.SECONDS);
|
||||
}
|
||||
|
||||
/**
|
||||
* get object value by key
|
||||
*
|
||||
* @param key obj key
|
||||
* @return obj value
|
||||
*/
|
||||
public Object getObj(Object key) {
|
||||
key = prefix + key.toString();
|
||||
return valOpsObj.get(key);
|
||||
}
|
||||
|
||||
/**
|
||||
* set value by key
|
||||
*
|
||||
* @param key obj key
|
||||
* @param value obj value
|
||||
* @param second 过期时间 单位户 秒
|
||||
*/
|
||||
public void setObj(Object key, Object value, Long second) {
|
||||
key = prefix + key.toString();
|
||||
valOpsObj.set(key, value, second,TimeUnit.SECONDS);
|
||||
}
|
||||
|
||||
/**
|
||||
* delete by key
|
||||
*
|
||||
* @param key key
|
||||
*/
|
||||
public void del(String key) {
|
||||
stringRedisTemplate.delete(prefix + key);
|
||||
}
|
||||
|
||||
/**
|
||||
* delete by key
|
||||
*
|
||||
* @param key obj key
|
||||
*/
|
||||
public void delObj(Object key) {
|
||||
redisTemplate.delete(prefix + key.toString());
|
||||
}
|
||||
}
|
|
@ -2,6 +2,7 @@ package test;
|
|||
|
||||
import com.len.Application;
|
||||
import com.len.entity.SysUser;
|
||||
import com.len.redis.RedisService;
|
||||
import com.len.service.SysUserService;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
|
@ -20,14 +21,27 @@ import org.springframework.test.context.web.WebAppConfiguration;
|
|||
@WebAppConfiguration
|
||||
public class BootTest {
|
||||
|
||||
@Autowired
|
||||
SysUserService userService;
|
||||
@Autowired
|
||||
SysUserService userService;
|
||||
|
||||
@Test
|
||||
public void testStartJob() throws Exception {
|
||||
//12
|
||||
SysUser user=userService.selectByPrimaryKey("2211fec3e17c11e795ed201a068c6482");
|
||||
System.out.println(user.getUsername());
|
||||
}
|
||||
@Autowired
|
||||
RedisService redisService;
|
||||
|
||||
@Test
|
||||
public void testStartJob() throws Exception {
|
||||
//12
|
||||
SysUser user = userService.selectByPrimaryKey("2211fec3e17c11e795ed201a068c6482");
|
||||
System.out.println(user.getUsername());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void redisTest() throws InterruptedException {
|
||||
redisService.set("str", "你好 世界", 10L);
|
||||
String str = redisService.get("str");
|
||||
System.out.println("value:" + str);
|
||||
Thread.sleep(1000 * 10L);
|
||||
System.out.println("value:" + redisService.get("str"));
|
||||
|
||||
}
|
||||
|
||||
}
|
|
@ -32,6 +32,9 @@ spring:
|
|||
client:
|
||||
prefer-ip: true
|
||||
url: http://localhost:8082
|
||||
redis:
|
||||
host: 127.0.0.1
|
||||
port: 6379
|
||||
|
||||
mybatis:
|
||||
type-aliases-package: com.len.entity
|
||||
|
@ -64,4 +67,7 @@ logging:
|
|||
level:
|
||||
com.len.mapper: debug
|
||||
|
||||
dataType: mysql
|
||||
dataType: mysql
|
||||
|
||||
redis:
|
||||
prefix: len_
|
|
@ -31,6 +31,9 @@ spring:
|
|||
client:
|
||||
prefer-ip: true
|
||||
url: http://localhost:8082
|
||||
redis:
|
||||
host: 127.0.0.1
|
||||
port: 6379
|
||||
|
||||
mybatis:
|
||||
type-aliases-package: com.len.entity
|
||||
|
@ -57,4 +60,7 @@ logging:
|
|||
|
||||
filePath: ./file/
|
||||
|
||||
imagePath: ./image/
|
||||
imagePath: ./image/
|
||||
|
||||
redis:
|
||||
prefix: len_
|
5
pom.xml
5
pom.xml
|
@ -93,6 +93,11 @@
|
|||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-logging</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-data-redis</artifactId>
|
||||
<version>2.0.1.RELEASE</version>
|
||||
</dependency>
|
||||
|
||||
<!-- <dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
|
|
Loading…
Reference in New Issue