基于Spring Boot2.x中的配置与使用Redis(Lettuce)详细教程---redis数据类型（String） (三)
作者：互联网
string是redis最基本的类型，一个key对应一个value。string类型是Redis最基本的数据类型，一个键最大能存储512MB。
3.1 应用场景
String通常用于保存单个字符串或JSON字符串数据,常用的场景有：统计网站访问数量、当前在线人数、微博数、粉丝数等，全局递增ID等 。
3.2 代码示例
代码：com.javablog.redis.demo.service.impl.KeyValueCacheServiceImpl
package com.javablog.redis.demo.service.impl;
import com.javablog.redis.demo.service.KeyValueCacheService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
@Service("keyValueCacheService")
public class KeyValueCacheServiceImpl implements KeyValueCacheService {
private final static Logger log = LoggerFactory.getLogger(KeyValueCacheServiceImpl.class);
@Autowired
private RedisTemplate<String, Object> redisTemplate;
@Autowired
private StringRedisTemplate stringRedisTemplate;
/**
* 普通缓存放入
* @param key 键
* @param value 值
* @param expireTime 超时时间(秒)
* @return true成功 false失败
*/
@Override
public Boolean set(String key, Object value, int expireTime) {
try {
redisTemplate.opsForValue().set(key, value, expireTime, TimeUnit.SECONDS);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 普通缓存放入
* @param key 键
* @param value 值
* @param expireTime 超时时间(秒)
* @return true成功 false失败
*/
@Override
public Boolean set(String key, String value, int expireTime) {
try {
stringRedisTemplate.opsForValue().set(key, value, expireTime, TimeUnit.SECONDS);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 普通缓存放入
* @param key 键
* @param value 值
* @return true成功 false失败
*/
@Override
public Boolean set(String key, Object value) {
try {
redisTemplate.opsForValue().set(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 普通缓存放入
* @param key 键
* @param value 值
* @return true成功 false失败
*/
@Override
public Boolean set(String key, String value) {
try {
redisTemplate.opsForValue().set(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 普通缓存获取
* @param key 键
* @return 值
*/
@Override
public String get(String key) {
return key == null ? null : (String) stringRedisTemplate.opsForValue().get(key);
}
/**
* 在原有的值基础上新增字符串到末尾。
* @param key 键
* @param value 追加的值
* @return true成功 false失败
*/
@Override
public void append(String key, String value) {
stringRedisTemplate.opsForValue().append(key,value);
}
/**
* 截取key键对应值得字符串，从开始下标位置开始到结束下标的位置(包含结束下标)的字符串。
* @param key 键
* @param start 开始位置
* @param end 结束位置
* @return
*/
@Override
public String get(String key, long start, long end) {
return stringRedisTemplate.opsForValue().get(key,start,end);
}
/**
* 获取原来key键对应的值并重新赋新值。
* @param key 键
* @param value 值
* @return 原来旧值
*/
@Override
public Object getAndSet(String key, String value) {
return stringRedisTemplate.opsForValue().getAndSet(key,value);
}
/**
* 覆盖从指定位置开始的值。
* @param key 键
* @param value 值
* @param offset 位置
*/
@Override
public void set(String key, String value, long offset) {
redisTemplate.opsForValue().set(key,value,offset);
}
/**
* 普通缓存获取
* @param key 键
* @return 值
*/
@Override
public Object getObject(String key) {
return key == null ? null : redisTemplate.opsForValue().get(key);
}
/**
* 获取指定字符串的长度。
* @param key
* @return 长度
*/
@Override
public long size(String key) {
return stringRedisTemplate.opsForValue().size(key);
}
/**
* 如果键不存在则新增,存在则不改变已经有的值
* @param key
* @param value
* @return true成功 false失败
*/
@Override
public boolean setIfAbsent(String key, String value){
return stringRedisTemplate.opsForValue().setIfAbsent(key,value);
}
/**
* 删除指定KEY的缓存
* @param keys
*/
@Override
public void del(String... keys) {
if (keys != null && keys.length > 0) {
if (keys.length == 1) {
redisTemplate.delete(keys[0]);
} else {
redisTemplate.delete(CollectionUtils.arrayToList(keys));
}
}
}
/**
* 根据key设置过期时间
* @param key 键
* @param seconds 超时时间(秒)
* @return true成功 false失败
*/
@Override
public boolean expire(String key, long seconds) {
return redisTemplate.expire(key,seconds,TimeUnit.SECONDS);
}
/**
* 根据key获取过期时间
* @param key 键 不能为null
* @return 时间(秒) 返回0代表为永久有效
*/
@Override
public long getExpire(String key) {
return redisTemplate.getExpire(key, TimeUnit.SECONDS);
}
/**
* 递增
* @param key 键
* @param delta 要增加几(大于0)
* @return 返回增加后的值
*/
public long incr(String key, long delta) {
if (delta < 0) {
throw new RuntimeException("递增因子必须大于0");
}
return stringRedisTemplate.opsForValue().increment(key, delta);
}
/**
* 递减
* @param key 键
* @param delta 要减少几(小于0)
* @return 返回减少后的值
*/
public long decr(String key, long delta) {
if (delta < 0) {
throw new RuntimeException("递减因子必须大于0");
}
return stringRedisTemplate.opsForValue().increment(key, -delta);
}
/**
* 设置map集合到redis。
* @param map
*/
@Override
public void multiSet(Map map) {
stringRedisTemplate.opsForValue().multiSet(map);
}
/**
* 根据集合取出对应的value值。
* @param list
* @return
*/
@Override
public List multiGet(List list) {
return stringRedisTemplate.opsForValue().multiGet(list);
}
}
3.3 测试用例
代码：com.qianfeng.redis.demo.KeyValueCacheServiceImplTest
package com.javablog.redis.demo;
import com.javablog.redis.demo.service.KeyValueCacheService;
import junit.framework.TestCase;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.test.context.web.WebAppConfiguration;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = CacheServiceApplication.class)
@WebAppConfiguration
public class KeyValueCacheServiceImplTest {
private final static Logger log = LoggerFactory.getLogger(KeyValueCacheServiceImplTest.class);
@Autowired
private KeyValueCacheService redisService;
//普通缓存测试
@Test
public void testSetGetString(){
redisService.set("key","value",1000);
String str = redisService.get("key1");
System.out.println("查询结果:" + str);
//在原有的值基础上新增字符串到末尾。 redisTemplate读不出APPEND的值，stringRedisTemplate可以
redisService.append("key","add string");
str = redisService.get("key");
System.out.println("通过append(K key, String value)方法修改后的字符串:" + str);
//截取key键对应值得字符串，从开始下标位置开始到结束下标的位置(包含结束下标)的字符串。
String cutString = redisService.get("key",0,4);
System.out.println("通过get(K key, long start, long end)方法获取截取的字符串:"+cutString);
// 获取原来key键对应的值并重新赋新值。
String oldAndNewStringValue = (String)redisService.getAndSet("key","new value");
System.out.print("通过getAndSet(K key, V value)方法获取原来的" + oldAndNewStringValue + ",");
String newStringValue = redisService.get("key");
System.out.println("修改过后的值:"+newStringValue);
//获取指定字符串的长度。
Long stringValueLength = redisService.size("key");
System.out.println("通过size(K key)方法获取字符串的长度:"+stringValueLength);
//如果键不存在则新增,存在则不改变已经有的值。
boolean absentBoolean = redisService.setIfAbsent("absentKey","fff");
System.out.println("通过setIfAbsent(K key, V value)方法判断变量值absentValue是否存在:" + absentBoolean);
if(absentBoolean) {
String absentValue = redisService.get("absentKey") + "";
System.out.print(",不存在，则新增后的值是:" + absentValue);
boolean existBoolean = redisService.setIfAbsent("absentKey", "eee");
System.out.println(",再次调用setIfAbsent(K key, V value)判断absentValue是否存在并重新赋值:" + existBoolean);
if (!existBoolean) {
absentValue = redisService.get("absentKey") + "";
System.out.println("如果存在,则重新赋值后的absentValue变量的值是:" + absentValue);
}
}
redisService.del("key");
System.out.println("删除后再查结果:" + redisService.get("key"));
}
//集合功能测试
@Test
public void testmulti() {
Map valueMap = new HashMap();
valueMap.put("valueMap1", "map1");
valueMap.put("valueMap2", "map2");
valueMap.put("valueMap3", "map3");
redisService.multiSet(valueMap);
//根据集合取出对应的value值。
List paraList = new ArrayList();
paraList.add("valueMap1");
paraList.add("valueMap2");
paraList.add("valueMap3");
List<String> valueList = redisService.multiGet(paraList);
for (String value : valueList) {
System.out.println("通过multiGet(Collection<K> keys)方法获取map值:" + value);
}
}
//针对复杂的对象类型测试
@Test
public void testSetGetObject(){
User user =new User();
user.setAge(22);
user.setName("张三");
user.setUserId("1234567");
redisService.set("userid:1234567",user,1000);
User userEntity = (User) redisService.getObject("userid:1234567");
System.out.println("user info>>>>>>>>>>>>>>>>>:" + userEntity.toString());
TestCase.assertNotSame(user,userEntity);
}
// 过期测试
@Test
public void testSetKeyExpire() throws InterruptedException {
redisService.set("expirekey","值");
redisService.expire("expirekey" ,30);
System.out.println("超时前取值:" + redisService.get("expirekey"));
System.out.println("获取过期时间:" + redisService.getExpire("expirekey")+"秒") ;
Thread.sleep(5000);
String str = redisService.get("expirekey");
System.out.println("超时后取值:" + redisService.get("expirekey"));
}
// 计数测试
@Test
public void testIncrDecr() throws InterruptedException {
redisService.incr("count:pv",10000);
System.out.println("统计PV的数值:" + redisService.getObject("count:pv"));
redisService.decr("count:pv",5000);
Integer count = (Integer)redisService.getObject("count:pv");
System.out.println("统计decr后的PV的数值:" + count);
}
}
标签：return,String,redisService,数据类型,redis,param,value,key 来源： https://blog.csdn.net/jetty_welcome/article/details/104867253