欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Redis如何存储对象与集合示例详解

程序员文章站 2022-06-24 23:06:06
前言 大家都知道在项目中,缓存以及mq消息队列可以说是不可或缺的2个重要技术。前者主要是为了减轻数据库压力,大幅度提升性能。后者主要是为了提高用户的体验度,我理解的是再后...

前言

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

这里主要讲redis如何把对象,集合存入,并且取出。下面话不多说了,来一起看看详细的介绍吧。

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

private jedis jedis;private jedispoolconfig config;private jedisshardinfo sharinfo;@beanpublic 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;/** 
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设值和取值

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); 
 } 
 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.测试结果

Redis如何存储对象与集合示例详解

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。