Redis | 尝试封装一个操作工具类

本文涉及的产品
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
简介: 介绍 本次主要介绍以下内容: 1、SpringMVC集成Redis 2、Spring Boot集成Redis(上) 3、Spring Boot集成Redis(中) 4、Spring Boot集成Redis(下) 5、使用redis为我们提供jar进行封装 6、使用Spring Boot提供的方法进行封装 内容比较多,会花一定的时间进行完善。

Redis | 尝试封装一个操作工具类

介绍

本次主要介绍以下内容:

1、SpringMVC集成Redis

2、Spring Boot集成Redis(上)

3、Spring Boot集成Redis(中)

4、Spring Boot集成Redis(下)

5、使用redis为我们提供jar进行封装

6、使用Spring Boot提供的方法进行封装

内容比较多,会花一定的时间进行完善。

第一部分:SpringMVC集成Redis

第一步:依赖

        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>${redis.version}</version>
        </dependency>

第二步:bean注入

    <!-- 引入jedis的properties配置文件 -->
    <!--如果你有多个数据源需要通过<context:property-placeholder管理,且不愿意放在一个配置文件里,那么一定要加上ignore-unresolvable=“true"-->
    <context:property-placeholder location="classpath:properties/redis.properties" ignore-unresolvable="true" />

    <bean id="jedisPool" class="redis.clients.jedis.JedisPool">
        <constructor-arg name="poolConfig" ref="jedisPoolConfig" />
        <constructor-arg name="host" value="${redis.host}" />
        <constructor-arg name="port" value="${redis.port}" type="int" />
        <constructor-arg name="timeout" value="${redis.timeout}" type="int" />
        <constructor-arg name="password" value="${redis.password}" />
        <constructor-arg name="database" value="${redis.database}" type="int" />
    </bean>

    <bean class="redis.clients.jedis.JedisPoolConfig" id="jedisPoolConfig" />

这样,集成就算告一段落了,什么意思?简单来说,你可以开始编写操作Redis的代码了,所以,我们会放到后面说。

第二部分:Spring Boot集成Redis(上)

这部分主要说,将我们的项目换成Spring Boot,应该怎么操作呢?

有两种操作办法,1、依然通过引入配置文件的办法,简单来说,我们需要写一个配置,加载配置文件。2、也就是下面要说的。

jar还是之前那个。

application.yml 中添加如下配置:

# redis
redis:
  host: 
  port: 6379
  timeout: 3
  password: 
  poolMaxTotal: 10
  poolMaxIdle: 10
  poolMaxWait: 3

配置代码:

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

/**
 * @author Wenyi Feng
 * @since 2018-12-04
 */
@Component
@ConfigurationProperties(prefix = "redis")
@Data
public class RedisConfig {
    private String host;
    private int port;
    private int timeout;// 秒
    private String password;
    private int poolMaxTotal;
    private int poolMaxIdle;
    private int poolMaxWait;// 秒
}

构造连接池:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Service;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
 * @author Wenyi Feng
 * @since 2018-12-04
 */
@Service
public class RedisPoolFactory {

    @Autowired
    RedisConfig redisConfig;

    @Bean
    public JedisPool jedisPoolFactory() {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxIdle(redisConfig.getPoolMaxIdle());
        jedisPoolConfig.setMaxTotal(redisConfig.getPoolMaxTotal());
        jedisPoolConfig.setMaxWaitMillis(redisConfig.getPoolMaxWait() * 1000);
        return new JedisPool(jedisPoolConfig, redisConfig.getHost(), redisConfig.getPort(),
                redisConfig.getTimeout() * 1000,
                redisConfig.getPassword(), 0);
    }

}

第三部分:Spring Boot集成Redis(中)

使用Spring Boot的初衷就是简化我们的配置,那我们该怎么做呢?

第一步:依赖

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

第二步:配置

spring:
  redis:
    host: 
    port: 6379
    password: 

这样就行了。
什么?这样就行了?
没错。
当然,操作代码,我们放到后面说。

第四部分:Spring Boot集成Redis(下)

上面是单台Redis,那么集群应该怎么做呢?如下:

spring:
  redis:
    host: 
    port: 6379
    password: 
    cluster:
      nodes: 

使用英文逗号(,)隔开

第五部分:使用redis为我们提供jar进行封装

首先,要明确,Redis十分强大,所以,也是相当负责。当然你也可以觉得很简单。

我们知道redis是以key-value的形式保存数据的,那么这里就有一个问题,集合对象应该怎么保存呢?

所以,这里提供两种解决思路:一是将其转成String进行保存(这是Spring推荐的);二是使用byte[](这是Redis推荐的)。

好了,话不多少,我们开始撸代码。

依赖:

        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>${redis.version}</version>
        </dependency>

方案1:

    /**
     * 获取数据
     * @param prefix 前缀
     * @param key
     * @param clazz
     * @param <T>
     * @return
     */
    public <T> T get(KeyPrefix prefix, String key, Class<T> clazz) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();

            // 真正的key
            String realKey = prefix.getPrefix() + key;
            String str = jedis.get(realKey);
            return stringToBean(str, clazz);
        } finally {
            returnToPool(jedis);
        }
    }

    /**
     * 设置对象
     * @param prefix 前缀
     * @param key
     * @param obj
     * @param <T>
     * @return
     */
    public <T> boolean set(KeyPrefix prefix, String key, T obj) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            String str = beanToString(obj);
            if (StringUtils.isEmpty(str)) {
                return false;
            }
            // 生成真正的key
            String realKey = prefix.getPrefix() + key;
            int seconds = prefix.expireSeconds();
            if (seconds <= 0) {
                jedis.set(realKey, str);
            } else {
                jedis.setex(realKey, seconds, str);
            }
            return true;
        } finally {
            returnToPool(jedis);
        }
    }

方案2:

    /**
     * 将值存到Redis中
     * @param key 唯一标识
     * @param value 二进制格式数据
     * @return 返回二进制格式数据,表示操作成功,反之,操作失败
     */
    public byte[] set(byte[] key, byte[] value) {
        Jedis jedis = getResource();
        try {
            jedis.set(key, value);
            return value;
        } finally {
            jedis.close();
        }
    }

    /**
     * 通过一个key获取value
     * @param key 唯一标识
     * @return 二进制格式数据
     */
    public byte[] get(byte[] key) {
        Jedis jedis = getResource();
        try {
            return jedis.get(key);
        } finally {
            jedis.close();
        }
    }

方案一和方案二操作是一样的,不同的处理思路不一样,一个将对象转成字符串(启发:JSON),一个是将对象当作数据,进行序列化进行存储和读取。

第六部分:使用Spring Boot提供的方法进行封装

前面你是不是觉得好简单啊,其实我一直也是这么认为的。下面我们看看Spring是如何为我们解读Redis的。

首先我们知道Spring为我们提供了两个东东。

    @Autowired
    private StringRedisTemplate stringRedisTemplate;

    @Autowired
    private RedisTemplate redisTemplate;

这下,你也应该明白我 前面说的了吧,Spring居然为String单独写了一个,而代码不足10行。

我们看看RedisTemplate提供了哪些方法。

RedisTemplate method 1

RedisTemplate method 2

RedisTemplate method 3

以上是部分截图。

我们来尝试写一个简单的例子:

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * @author Wenyi Feng
 * @since 2018-12-04
 */
@Service
public class ByteRedisService {

    @Resource
    private RedisTemplate<byte[], byte[]> redisTemplate;

    public void set(byte[] key, byte[] value) {
        redisTemplate.opsForValue().set(key, value);
    }

    public byte[] get(byte[] key) {
        return redisTemplate.opsForValue().get(key);
    }

}

参考文档

[1] Shiro安全框架入门 - Redis部分

[2] Java秒杀系统方案优化 高性能高并发实战 - 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
目录
相关文章
|
3月前
|
NoSQL Java Redis
SpringBoot 配置Redis操作
SpringBoot 配置Redis操作
49 0
|
3月前
|
NoSQL Go Redis
Golang实现redis系列-(3)封装RESP协议
Golang实现redis系列-(3)封装RESP协议
36 0
|
3月前
|
缓存 NoSQL Java
RedisTemplate操作Redis,这一篇文章就够了
redis是一款开源的Key-Value数据库,运行在内存中,由C语言编写。企业开发通常采用Redis来实现缓存。同类的产品还有memcache 、memcached 等。
242 1
|
29天前
|
存储 NoSQL Java
Redis 数据结构操作入门
Redis 数据结构操作入门
15 0
|
1月前
|
缓存 NoSQL Java
springboot中集成redis,二次封装成工具类
springboot中集成redis,二次封装成工具类
174 0
|
1月前
|
缓存 NoSQL 数据库
[Redis]——数据一致性,先操作数据库,还是先更新缓存?
[Redis]——数据一致性,先操作数据库,还是先更新缓存?
|
1月前
|
存储 NoSQL Redis
如何在Python中操作Redis数据库
如何在Python中操作Redis数据库
29 0
|
1月前
|
存储 缓存 NoSQL
【Redis】3、Redis 作为缓存(Redis中的穿透、雪崩、击穿、工具类)
【Redis】3、Redis 作为缓存(Redis中的穿透、雪崩、击穿、工具类)
55 0
|
2月前
|
NoSQL 测试技术 Redis
六步操作教你轻松搭建Redis集群
Redis 是我们目前大规模使用的缓存中间件,由于它强大高效而又便捷的功能,得到了广泛的使用。单节点的Redis已经就达到了很高的性能,为了提高可用性我们可以使用Redis集群。本文参考了Rdis的官方文档和使用Redis官方提供的Redis Cluster工具搭建Rdis集群。
43 0
|
2月前
|
NoSQL Java Redis
springboot整合redis过期key监听实现订单过期操作
springboot整合redis过期key监听实现订单过期操作
72 0

热门文章

最新文章