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

在项目中,缓存以及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设值和取值

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);
        }
    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 配置和使用

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

原文发布于微信公众号 - 编程软文(zhuyuansj)

原文发表时间:2018-04-22

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏人工智能LeadAI

使用强大的 Mockito 来测试你的代码

这篇教程介绍了如何使用 Mockito 框架来给软件写测试用例。 1、预备知识 如果需要往下学习,你需要先理解 Junit 框架中的单元测试。 如果你不熟悉 J...

3K6
来自专栏cmazxiaoma的架构师之路

SpringBoot之路(二)之Web进阶

3694
来自专栏小白鼠

SpringBoot几个注解MockMvcWireMockSwagger2@JsonViewHibernate Validator异常处理拦截方式上传下载异步处理RESTSpring Security

只有特定名称或者类型的Bean(通过@ConditionalOnMissingBean修饰)不存在于BeanFactory中时才创建某个Bean

2933
来自专栏Java技术栈

从 0 开始手写一个 Spring MVC 框架,向高手进阶!

Spring框架对于Java后端程序员来说再熟悉不过了,以前只知道它用的反射实现的,但了解之后才知道有很多巧妙的设计在里面。如果不看Spring的源码,你将会失...

2312
来自专栏精讲JAVA

接口方法上的注解无法被 @Aspect 声明的切面拦截的原因分析

在Spring中使用MyBatis的Mapper接口自动生成时,用一个自定义的注解标记在Mapper接口的方法中,再利用@Aspect定义一个切面,拦截这个注解...

3282
来自专栏Jed的技术阶梯

Kafka 中使用 Avro 序列化框架(二):使用 Twitter 的 Bijection 类库实现 avro 的序列化与反序列化

使用传统的 avro API 自定义序列化类和反序列化类比较麻烦,需要根据 schema 生成实体类,需要调用 avro 的 API 实现 对象到 byte[]...

3054
来自专栏猿天地

高性能NIO框架Netty-对象传输

上篇文章高性能NIO框架Netty入门篇我们对Netty做了一个简单的介绍,并且写了一个入门的Demo,客户端往服务端发送一个字符串的消息,服务端回复一个字符串...

3158
来自专栏微信公众号:Java团长

自己手写一个SpringMVC框架

前端框架很多,但没有一个框架称霸,后端框架现在Spring已经完成大一统。所以学习Spring是Java程序员的必修课。

1052
来自专栏菩提树下的杨过

velocity模板引擎学习(3)-异常处理

按上回继续,前面写过一篇Spring MVC下的异常处理、及Spring MVC下的ajax异常处理,今天看下换成velocity模板引擎后,如何处理异常页面:...

2228
来自专栏积累沉淀

干货--Redis+Spring+Struts2实现网站计算器应用项目案例

有关redis的介绍我就不说了,可以参看我前几篇文章,redis快速入门 首先来看一下redis的应用场景 ? 下面是我这个项目的的运行的场景截图 ...

2446

扫码关注云+社区

领取腾讯云代金券