SpringBoot集成Redis6.0的实现示例_Java

前言

redis 是一种高性能的键值存储数据库，被广泛应用于缓存、会话管理、消息队列等场景。redis 6.0 带来了许多新特性，如多线程 i/o、acl 权限控制、resp3 协议等。本文将深入探讨 spring boot 与 redis 6.0 的集成方法和最佳实践，帮助你构建更高效、更可靠的应用。

1. redis 6.0 新特性

1.1 多线程 i/o

redis 6.0 引入了多线程 i/o，提高了网络处理能力，特别是在高并发场景下。

# 查看 redis 版本
redis-server --version
# 配置多线程 i/o
# 在 redis.conf 中设置
io-threads 4
io-threads-do-reads yes

1.2 acl 权限控制

redis 6.0 引入了 acl（access control list），提供了更细粒度的权限控制。

# 创建用户并设置权限
acl setuser alice on >password ~* +@all
# 查看用户权限
acl getuser alice
# 登录验证
auth alice password

1.3 resp3 协议

redis 6.0 引入了 resp3 协议，提供了更丰富的数据类型和更高效的通信方式。

1.4 其他新特性

客户端缓存：支持客户端缓存，减少网络往返
ssl 支持：内置 ssl 支持，提高安全性
时间序列数据结构：优化时间序列数据的存储和查询

2. spring boot 与 redis 集成

2.1 添加依赖

<dependency>
    <groupid>org.springframework.boot</groupid>
    <artifactid>spring-boot-starter-data-redis</artifactid>
</dependency>
<!-- 可选：使用 lettuce 作为 redis 客户端 -->
<dependency>
    <groupid>io.lettuce</groupid>
    <artifactid>lettuce-core</artifactid>
</dependency>
<!-- 可选：使用 jedis 作为 redis 客户端 -->
<dependency>
    <groupid>redis.clients</groupid>
    <artifactid>jedis</artifactid>
</dependency>

2.2 配置 redis

spring:
  redis:
    host: localhost
    port: 6379
    password: password
    database: 0
    timeout: 10000
    lettuce:
      pool:
        max-active: 8
        max-wait: -1
        max-idle: 8
        min-idle: 0

2.3 redis 模板配置

@configuration
public class redisconfig {
    @bean
    public redistemplate<string, object> redistemplate(redisconnectionfactory redisconnectionfactory) {
        redistemplate<string, object> template = new redistemplate<>();
        template.setconnectionfactory(redisconnectionfactory);
        // 设置序列化器
        template.setkeyserializer(new stringredisserializer());
        template.setvalueserializer(new jackson2jsonredisserializer<>(object.class));
        template.sethashkeyserializer(new stringredisserializer());
        template.sethashvalueserializer(new jackson2jsonredisserializer<>(object.class));
        template.afterpropertiesset();
        return template;
    }
    @bean
    public stringredistemplate stringredistemplate(redisconnectionfactory redisconnectionfactory) {
        stringredistemplate template = new stringredistemplate();
        template.setconnectionfactory(redisconnectionfactory);
        return template;
    }
}

3. redis 操作示例

3.1 基本操作

@service
public class redisservice {
    private final redistemplate<string, object> redistemplate;
    private final stringredistemplate stringredistemplate;
    @autowired
    public redisservice(redistemplate<string, object> redistemplate, stringredistemplate stringredistemplate) {
        this.redistemplate = redistemplate;
        this.stringredistemplate = stringredistemplate;
    }
    // 字符串操作
    public void setstring(string key, string value) {
        stringredistemplate.opsforvalue().set(key, value);
    }
    public string getstring(string key) {
        return stringredistemplate.opsforvalue().get(key);
    }
    // 哈希操作
    public void sethash(string key, string hashkey, object value) {
        redistemplate.opsforhash().put(key, hashkey, value);
    }
    public object gethash(string key, string hashkey) {
        return redistemplate.opsforhash().get(key, hashkey);
    }
    // 列表操作
    public void addtolist(string key, object value) {
        redistemplate.opsforlist().rightpush(key, value);
    }
    public list<object> getlist(string key) {
        return redistemplate.opsforlist().range(key, 0, -1);
    }
    // 集合操作
    public void addtoset(string key, object value) {
        redistemplate.opsforset().add(key, value);
    }
    public set<object> getset(string key) {
        return redistemplate.opsforset().members(key);
    }
    // 有序集合操作
    public void addtozset(string key, object value, double score) {
        redistemplate.opsforzset().add(key, value, score);
    }
    public set<object> getzset(string key) {
        return redistemplate.opsforzset().range(key, 0, -1);
    }
}

3.2 事务操作

@service
public class redistransactionservice {
    private final redistemplate<string, object> redistemplate;
    @autowired
    public redistransactionservice(redistemplate<string, object> redistemplate) {
        this.redistemplate = redistemplate;
    }
    public void executetransaction() {
        redistemplate.execute(new sessioncallback<object>() {
            @override
            public object execute(redisoperations operations) throws dataaccessexception {
                operations.multi();
                // 执行多个操作
                operations.opsforvalue().set("key1", "value1");
                operations.opsforvalue().set("key2", "value2");
                operations.opsforvalue().set("key3", "value3");
                // 提交事务
                return operations.exec();
            }
        });
    }
}

3.3 管道操作

@service
public class redispipelineservice {
    private final redistemplate<string, object> redistemplate;
    @autowired
    public redispipelineservice(redistemplate<string, object> redistemplate) {
        this.redistemplate = redistemplate;
    }
    public list<object> executepipeline() {
        return redistemplate.executepipelined(new rediscallback<object>() {
            @override
            public object doinredis(redisconnection connection) throws dataaccessexception {
                redisserializer<string> serializer = redistemplate.getstringserializer();
                // 执行多个操作
                connection.set(serializer.serialize("key1"), serializer.serialize("value1"));
                connection.set(serializer.serialize("key2"), serializer.serialize("value2"));
                connection.set(serializer.serialize("key3"), serializer.serialize("value3"));
                return null;
            }
        });
    }
}

4. redis 缓存集成

4.1 缓存配置

@configuration
@enablecaching
public class cacheconfig {
    @bean
    public cachemanager cachemanager(redisconnectionfactory redisconnectionfactory) {
        rediscacheconfiguration config = rediscacheconfiguration.defaultcacheconfig()
            .entryttl(duration.ofminutes(10))
            .prefixcachenamewith("cache:")
            .serializevalueswith(redisserializationcontext.serializationpair.fromserializer(new jackson2jsonredisserializer<>(object.class)));
        return rediscachemanager.builder(redisconnectionfactory)
            .cachedefaults(config)
            .build();
    }
}

4.2 使用缓存

@service
public class userservice {
    private final userrepository userrepository;
    @autowired
    public userservice(userrepository userrepository) {
        this.userrepository = userrepository;
    }
    @cacheable(value = "users", key = "#id")
    public user getuserbyid(long id) {
        return userrepository.findbyid(id)
            .orelsethrow(() -> new usernamenotfoundexception("user not found"));
    }
    @cacheput(value = "users", key = "#user.id")
    public user saveuser(user user) {
        return userrepository.save(user);
    }
    @cacheevict(value = "users", key = "#id")
    public void deleteuser(long id) {
        userrepository.deletebyid(id);
    }
}

5. redis 消息队列

5.1 配置消息监听器

@configuration
public class redismessagelistenerconfig {
    @bean
    public redismessagelistenercontainer redismessagelistenercontainer(redisconnectionfactory redisconnectionfactory) {
        redismessagelistenercontainer container = new redismessagelistenercontainer();
        container.setconnectionfactory(redisconnectionfactory);
        return container;
    }
    @bean
    public messagelisteneradapter messagelisteneradapter() {
        return new messagelisteneradapter(new redismessagelistener());
    }
}

5.2 消息监听器

public class redismessagelistener implements messagelistener {
    @override
    public void onmessage(message message, byte[] pattern) {
        string channel = new string(message.getchannel());
        string body = new string(message.getbody());
        system.out.println("received message from channel " + channel + ": " + body);
    }
}

5.3 发送消息

@service
public class redismessageservice {
    private final redistemplate<string, object> redistemplate;
    @autowired
    public redismessageservice(redistemplate<string, object> redistemplate) {
        this.redistemplate = redistemplate;
    }
    public void sendmessage(string channel, object message) {
        redistemplate.convertandsend(channel, message);
    }
}

6. redis 分布式锁

6.1 实现分布式锁

@service
public class redislockservice {
    private final redistemplate<string, object> redistemplate;
    @autowired
    public redislockservice(redistemplate<string, object> redistemplate) {
        this.redistemplate = redistemplate;
    }
    public boolean acquirelock(string lockkey, string requestid, long expiretime) {
        boolean result = redistemplate.opsforvalue().setifabsent(lockkey, requestid, expiretime, timeunit.milliseconds);
        return result != null && result;
    }
    public boolean releaselock(string lockkey, string requestid) {
        string script = "if redis.call('get', keys[1]) == argv[1] then return redis.call('del', keys[1]) else return 0 end";
        redisscript<long> redisscript = redisscript.of(script, long.class);
        long result = redistemplate.execute(redisscript, collections.singletonlist(lockkey), requestid);
        return result != null && result > 0;
    }
}

6.2 使用分布式锁

@service
public class orderservice {
    private final redislockservice redislockservice;
    @autowired
    public orderservice(redislockservice redislockservice) {
        this.redislockservice = redislockservice;
    }
    public void createorder(order order) {
        string lockkey = "order:lock:" + order.getproductid();
        string requestid = uuid.randomuuid().tostring();
        try {
            if (redislockservice.acquirelock(lockkey, requestid, 5000)) {
                // 执行业务逻辑
                system.out.println("acquired lock, processing order");
                // 模拟业务处理
                thread.sleep(2000);
            } else {
                throw new runtimeexception("failed to acquire lock");
            }
        } catch (interruptedexception e) {
            thread.currentthread().interrupt();
            throw new runtimeexception(e);
        } finally {
            redislockservice.releaselock(lockkey, requestid);
        }
    }
}

7. redis 6.0 高级特性

7.1 客户端缓存

@service
public class redisclientcacheservice {
    private final redistemplate<string, object> redistemplate;
    @autowired
    public redisclientcacheservice(redistemplate<string, object> redistemplate) {
        this.redistemplate = redistemplate;
    }
    public void enableclientcache() {
        // 启用客户端缓存
        redistemplate.execute((rediscallback<void>) connection -> {
            connection.setclientname("client1");
            return null;
        });
    }
}

7.2 acl 权限控制

@configuration
public class redisaclconfig {
    @bean
    public lettuceconnectionfactory redisconnectionfactory() {
        redisstandaloneconfiguration config = new redisstandaloneconfiguration();
        config.sethostname("localhost");
        config.setport(6379);
        config.setpassword(redispassword.of("password"));
        config.setdatabase(0);
        lettuceclientconfiguration clientconfig = lettuceclientconfiguration.builder()
            .commandtimeout(duration.ofseconds(10))
            .build();
        return new lettuceconnectionfactory(config, clientconfig);
    }
}

8. 最佳实践

8.1 连接池配置

spring:
  redis:
    lettuce:
      pool:
        max-active: 100
        max-wait: 10000
        max-idle: 50
        min-idle: 10

8.2 序列化配置

@configuration
public class redisserializationconfig {
    @bean
    public redistemplate<string, object> redistemplate(redisconnectionfactory redisconnectionfactory) {
        redistemplate<string, object> template = new redistemplate<>();
        template.setconnectionfactory(redisconnectionfactory);
        // 使用 jackson2jsonredisserializer 序列化值
        jackson2jsonredisserializer<object> serializer = new jackson2jsonredisserializer<>(object.class);
        objectmapper mapper = new objectmapper();
        mapper.setvisibility(propertyaccessor.all, jsonautodetect.visibility.any);
        mapper.enabledefaulttyping(objectmapper.defaulttyping.non_final);
        serializer.setobjectmapper(mapper);
        template.setkeyserializer(new stringredisserializer());
        template.setvalueserializer(serializer);
        template.sethashkeyserializer(new stringredisserializer());
        template.sethashvalueserializer(serializer);
        template.afterpropertiesset();
        return template;
    }
}

8.3 错误处理

@service
public class rediserrorhandlingservice {
    private final redistemplate<string, object> redistemplate;
    @autowired
    public rediserrorhandlingservice(redistemplate<string, object> redistemplate) {
        this.redistemplate = redistemplate;
    }
    public object getwitherrorhandling(string key) {
        try {
            return redistemplate.opsforvalue().get(key);
        } catch (redisconnectionfailureexception e) {
            // 处理连接失败
            system.err.println("redis connection failed: " + e.getmessage());
            return null;
        } catch (redissystemexception e) {
            // 处理系统错误
            system.err.println("redis system error: " + e.getmessage());
            return null;
        }
    }
}

9. 案例分析

9.1 缓存系统

某电商系统使用 redis 作为缓存，主要包括：

商品缓存：缓存商品信息，提高查询性能
用户缓存：缓存用户信息，减少数据库查询
订单缓存：缓存订单信息，提高订单处理速度
热点数据缓存：缓存热点商品数据，应对高并发

9.2 会话管理

某 web 应用使用 redis 管理会话，主要包括：

会话存储：将会话数据存储在 redis 中
会话过期：设置会话过期时间，自动清理过期会话
会话共享：在多实例部署中实现会话共享

9.3 消息队列

某系统使用 redis 作为消息队列，主要包括：

任务队列：处理异步任务
事件通知：发送系统事件通知
消息广播：向多个消费者广播消息

10. 性能优化

10.1 连接管理

使用连接池：配置合理的连接池大小
连接超时：设置合理的连接超时时间
连接验证：定期验证连接有效性

10.2 数据结构选择

选择合适的数据结构：根据业务场景选择合适的 redis 数据结构
避免大键：避免存储过大的键值对
使用管道：批量执行命令，减少网络往返

10.3 缓存策略

缓存过期：设置合理的缓存过期时间
缓存预热：在系统启动时预热缓存
缓存更新：使用合适的缓存更新策略

11. 监控与维护

11.1 监控指标

内存使用：监控 redis 内存使用情况
命令执行：监控命令执行次数和耗时
连接数：监控 redis 连接数
命中率：监控缓存命中率

11.2 维护操作

数据备份：定期备份 redis 数据
数据清理：清理过期数据和无用数据
性能优化：根据监控结果优化 redis 配置

12. 未来趋势

12.1 redis 7.0 新特性

redis 7.0 带来了许多新特性，如：

时间序列数据结构：更强大的时间序列数据支持
rdb 快照改进：更高效的 rdb 快照
内存管理改进：更智能的内存管理

12.2 spring data redis 改进

spring data redis 不断改进，提供更强大的功能：

反应式支持：更好的反应式编程支持
函数式编程：支持函数式编程风格
更丰富的 api：提供更丰富的 redis 操作 api

结语

spring boot 与 redis 6.0 的集成是构建高性能、可扩展应用的重要组成部分。通过本文的介绍，你应该对 spring boot 与 redis 6.0 的集成方法和最佳实践有了更深入的了解。

redis 6.0 的新特性为我们提供了更强大的功能和更好的性能，通过合理使用这些特性，我们可以构建更高效、更可靠的应用。

到此这篇关于springboot集成redis6.0的实现示例的文章就介绍到这了,更多相关springboot集成redis6.0内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！


验证码：

SpringBoot集成Redis6.0的实现示例

2026年04月13日 • Java •我要评论

前言