redis是如何存储对象和集合的

本文涉及的产品
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
云原生内存数据库 Tair,内存型 2GB
云数据库 Redis 版,经济版 1GB 1个月
简介: 在项目中,缓存以及mq消息队列可以说是不可或缺的2个重要技术。前者主要是为了减轻数据库压力,大幅度提升性能。后者主要是为了提高用户的体验度,我理解的是再后端做的一个ajax请求(异步),并且像ribbmitmq等消息队列有重试机制等功能。

在项目中,缓存以及mq消息队列可以说是不可或缺的2个重要技术。前者主要是为了减轻数据库压力,大幅度提升性能。后者主要是为了提高用户的体验度,我理解的是再后端做的一个ajax请求(异步),并且像ribbmitmq等消息队列有重试机制等功能。
这里主要讲redis如何把对象,集合存入,并且取出.

1.在启动类上加入如下代码

private Jedis jedis;

private JedisPoolConfig config;

private JedisShardInfo sharInfo;
@Bean
public Jedis jedis(){
//连接redis服务器,192.168.0.100:6379
// jedis = new Jedis("192.168.0.100", 6379);
// //权限认证
// jedis.auth("123456");
// 操作单独的文本串
config = new JedisPoolConfig();
config.setMaxIdle(1000);//最大空闲时间
config.setMaxWaitMillis(1000); //最大等待时间
config.setMaxTotal(500); //redis池中最大对象个数
sharInfo = new JedisShardInfo("192.168.0.100", 6379);
sharInfo.setPassword("123456");
sharInfo.setConnectionTimeout(5000);//链接超时时间
jedis = new Jedis(sharInfo);
return jedis;
}

2.在application.yml当中加入redis配置

spring:
  redis:
    database: 0
    host: 101.132.191.77
    port: 6379
    password: 123456
    pool:
      max-idle: 8 #连接池最大连接数(使用负值表示没有限制)
      min-idle: 0 # 连接池中的最小空闲连接
      max-active: 8 # 连接池最大阻塞等待时间(使用负值表示没有限制)
      max-wait: -1 # 连接池中的最大空闲连接
     timeout: 5000 # 连接超时时间(毫秒)

3..新建SerializeUtil类,这个类主要是为了将对象序列化redis当中

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;

/**
* @author Administrator
*
*/
public class SerializeUtil {
public static byte[] serialize(Object object) {
ObjectOutputStream oos = null;
ByteArrayOutputStream baos = null;
try {
// 序列化
baos = new ByteArrayOutputStream();
oos = new ObjectOutputStream(baos);
oos.writeObject(object);
byte[] bytes = baos.toByteArray();
return bytes;
} catch (Exception e) {

}
return null;
}

public static Object unserialize( byte[] bytes) {
ByteArrayInputStream bais = null;
try {
// 反序列化
bais = new ByteArrayInputStream(bytes);
ObjectInputStream ois = new ObjectInputStream(bais);
return ois.readObject();
} catch (Exception e) {

}
return null;
}
}

4.我封装了一个RedisServiceImpl类,主要是用对redis设值和取值

redisServiceImpl.set主要是传object,setStr主要设置string

import com.ys.util.redis.SerializeUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import redis.clients.jedis.Jedis;

import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;

@Service
public class RedisServiceImpl {
@Autowired
private StringRedisTemplate stringRedisTemplate;


@Autowired
private Jedis jedis;

public void setStr(String key, String value) {
setStr(key, value, null);
}



public void setStr(String key, Object value, Long time) {
if(value == null){
return;
}
if(value instanceof String){
String obj = (String) value;
stringRedisTemplate.opsForValue().set(key, obj);
}else if(value instanceof List){
List obj = (List) value;
stringRedisTemplate.opsForList().leftPushAll(key,obj);
}else if(value instanceof Map){
Map obj = (Map) value;
stringRedisTemplate.opsForHash().putAll(key,obj);
}
if (time != null)
stringRedisTemplate.expire(key, time, TimeUnit.SECONDS);
}

public Object getKey(String key) {
return stringRedisTemplate.opsForValue().get(key);
}

public void delKey(String key) {
stringRedisTemplate.delete(key);
}





/**set Object*/
public String set(String key,Object object)
{
return jedis.set(key.getBytes(), SerializeUtil.serialize(object));
}

/**get Object*/
public Object get(String key)
{
byte[] value = jedis.get(key.getBytes());
return SerializeUtil. unserialize(value);
}

/**delete a key**/
public boolean del(String key)
{
return jedis.del(key.getBytes())>0;
}
}

5.测试redis是否ok,编写redisController类

import com.ys.service.impl.RedisServiceImpl;
import com.ys.vo.IqProduct;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

@RestController
public class RedisServiceController {
@Autowired
private RedisServiceImpl redisService;

@RequestMapping(value = "/setredis")
public String setredis(String keyredis){
redisService.setStr(keyredis,"2018年1月26日");
return "保存成功,请访问getredis查询redis";
}

@RequestMapping(value = "/setObj")
public String setObj(String keyredis){
IqProduct iqProduct = new IqProduct();
iqProduct.setSort(1);
iqProduct.setTimestamp(new Date().getTime());
iqProduct.setProductName("productname");
// list.add(iqProduct);
redisService.set(keyredis, iqProduct);
return "保存成功,请访问getredis查询redis";
}

@RequestMapping(value = "/getObj")
public Object getObj(String keyredis){
Object object = redisService.get(keyredis);
if(object !=null){
IqProduct iqProduct = (IqProduct) object;
System. out.println(iqProduct.getProductName());
System. out.println(iqProduct.getId());
System. out.println(iqProduct.getTimestamp());
}
return object;
}

@RequestMapping(value = "/delObj")
public boolean delObj(String keyredis){
boolean del = redisService.del(keyredis);
return del;
}


@RequestMapping(value = "/getredis")
public String getredis(String keyredis){
String getredis = (String) redisService.getKey(keyredis);
return "redis的key是===>"+getredis;
}


@RequestMapping(value = "/delredis")
public String delredis(String keyredis){
redisService.delKey(keyredis);
return "删除成功,请通过getredis进行查询";
}





@RequestMapping(value = "/setList")
public String setList(String keyredis){
List list = new ArrayList();
for (int i = 0;i<10;i++){
IqProduct iqProduct = new IqProduct();
iqProduct.setSort(1);
iqProduct.setTimestamp(new Date().getTime());
iqProduct.setProductName("productname");
list.add(iqProduct);
}
redisService.set(keyredis, list);
return "保存成功,请访问getredis查询redis";
}

@RequestMapping(value = "/getList")
public Object getList(String keyredis){
Object object = redisService.get(keyredis);
if(object !=null){
List<IqProduct> iqProducts = (List<IqProduct>) object;
for (int i = 0;i<iqProducts.size();i++){
IqProduct iqProduct = iqProducts.get(i);
System. out.println(iqProduct.getProductName());
System. out.println(iqProduct.getId());
System. out.println(iqProduct.getTimestamp());
}
}
return object;
}

@RequestMapping(value = "/delList")
public boolean delList(String keyredis){
boolean del = redisService.del(keyredis);
return del;
}


}

6.测试结果

image.png

7.参考文章

Springboot+Redis 配置和使用

关注编程软文,回复领取资源.免费获得大礼包.提供一个平台,让志同道合的人可以走在一起,让我们一起进步。

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
目录
相关文章
|
6天前
|
存储 消息中间件 NoSQL
中间件键值存储模型Redis
【7月更文挑战第11天】
12 3
|
13天前
|
存储 NoSQL Java
Redis10------Set类型,存在着无序的特征存储的顺序和插入的顺序是无关的,set集合的一大特点是不可重复,在redis中支持交集插集等特殊功能,好友列表,共同关注等等
Redis10------Set类型,存在着无序的特征存储的顺序和插入的顺序是无关的,set集合的一大特点是不可重复,在redis中支持交集插集等特殊功能,好友列表,共同关注等等
|
13天前
|
存储 Java
Redis08命令-Hash类型,也叫散列,其中value是一个无序字典,类似于java的HashMap结构,Hash结构可以将对象中的每个字段独立存储,可以针对每字段做CRUD
Redis08命令-Hash类型,也叫散列,其中value是一个无序字典,类似于java的HashMap结构,Hash结构可以将对象中的每个字段独立存储,可以针对每字段做CRUD
|
13天前
|
存储 NoSQL Redis
Redis07命令-String类型字符串,不管是哪种格式,底层都是字节数组形式存储的,最大空间不超过512m,SET添加,MSET批量添加,INCRBY age 2可以,MSET,INCRSETEX
Redis07命令-String类型字符串,不管是哪种格式,底层都是字节数组形式存储的,最大空间不超过512m,SET添加,MSET批量添加,INCRBY age 2可以,MSET,INCRSETEX
|
14天前
|
存储 缓存 NoSQL
网页设计,若依项目修改(It must be done)04在线用户展示---仅仅从Redis取一下数据做展示,查看若依存储的资料,用RDM
网页设计,若依项目修改(It must be done)04在线用户展示---仅仅从Redis取一下数据做展示,查看若依存储的资料,用RDM
|
1月前
|
缓存 NoSQL 安全
玩转Redis!非常强大的Redisson分布式集合,少写60%代码
Redisson是Java的Redis客户端,提供实时数据平台服务,简化了分布式环境下的数据管理。它包含RList、RSet、RMap等分布式集合,支持ConcurrentMap和Set接口,确保线程安全和数据一致性。例如,RMap实现了本地缓存和监听器功能,允许数据监听和本地加速读取。此外,还提供了RSet的排序和去重功能,以及RQueue和RBlockingQueue等队列实现,支持阻塞操作。通过Redisson,开发者能轻松处理分布式系统的数据同步和操作。
|
21天前
|
存储 缓存 NoSQL
Redis为什么速度快:数据结构、存储及IO网络原理总结
Redis为什么速度快:数据结构、存储及IO网络原理总结
|
27天前
|
存储 NoSQL Redis
Redis系列-存储hash主要操作命令
Redis系列-存储hash主要操作命令
|
28天前
|
缓存 NoSQL Java
redis系列之------对象
redis系列之------对象
|
29天前
|
存储 NoSQL Redis
redis存储结构
redis存储结构
28 0