AI 助理
备案控制台
开发者社区 数据库 文章 正文

面向接口编程实现不改代码实现Redis单机/集群之间的切换

2017-10-24 1755
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 开发中一般使用Redis单机，线上使用Redis集群，因此需要实现单机和集群之间的灵活切换pom配置： redis.clients jedis Redis单机和集群之间的灵活切换的封装：JedisClient.

开发中一般使用Redis单机，线上使用Redis集群，因此需要实现单机和集群之间的灵活切换

pom配置：

<!-- Redis客户端 -->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
        </dependency>
    </dependencies>

Redis单机和集群之间的灵活切换的封装：

JedisClient.java 接口 

import java.util.List;

public interface JedisClient {

    String set(String key, String value);
    String get(String key);
    Boolean exists(String key);
    Long expire(String key, int seconds);
    Long ttl(String key);
    Long incr(String key);
    Long hset(String key, String field, String value);
    String hget(String key, String field);
    Long hdel(String key, String... field);
    Boolean hexists(String key, String field);
    List<String> hvals(String key);
    Long del(String key);
}

分别实现JedisClient单机版本和集群版本：

JedisClientCluster.java  JedisClient集群版：

import java.util.List;

import redis.clients.jedis.JedisCluster;

public class JedisClientCluster implements JedisClient {
    
    private JedisCluster jedisCluster;
    

    public JedisCluster getJedisCluster() {
        return jedisCluster;
    }

    public void setJedisCluster(JedisCluster jedisCluster) {
        this.jedisCluster = jedisCluster;
    }

    @Override
    public String set(String key, String value) {
        return jedisCluster.set(key, value);
    }

    @Override
    public String get(String key) {
        return jedisCluster.get(key);
    }

    @Override
    public Boolean exists(String key) {
        return jedisCluster.exists(key);
    }

    @Override
    public Long expire(String key, int seconds) {
        return jedisCluster.expire(key, seconds);
    }

    @Override
    public Long ttl(String key) {
        return jedisCluster.ttl(key);
    }

    @Override
    public Long incr(String key) {
        return jedisCluster.incr(key);
    }

    @Override
    public Long hset(String key, String field, String value) {
        return jedisCluster.hset(key, field, value);
    }

    @Override
    public String hget(String key, String field) {
        return jedisCluster.hget(key, field);
    }

    @Override
    public Long hdel(String key, String... field) {
        return jedisCluster.hdel(key, field);
    }

    @Override
    public Boolean hexists(String key, String field) {
        return jedisCluster.hexists(key, field);
    }

    @Override
    public List<String> hvals(String key) {
        return jedisCluster.hvals(key);
    }

    @Override
    public Long del(String key) {
        return jedisCluster.del(key);
    }

}

JedisClientPool.java JedisClient单机版

import java.util.List;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

public class JedisClientPool implements JedisClient {
    
    private JedisPool jedisPool;

    public JedisPool getJedisPool() {
        return jedisPool;
    }

    public void setJedisPool(JedisPool jedisPool) {
        this.jedisPool = jedisPool;
    }

    @Override
    public String set(String key, String value) {
        Jedis jedis = jedisPool.getResource();
        String result = jedis.set(key, value);
        jedis.close();
        return result;
    }

    @Override
    public String get(String key) {
        Jedis jedis = jedisPool.getResource();
        String result = jedis.get(key);
        jedis.close();
        return result;
    }

    @Override
    public Boolean exists(String key) {
        Jedis jedis = jedisPool.getResource();
        Boolean result = jedis.exists(key);
        jedis.close();
        return result;
    }

    @Override
    public Long expire(String key, int seconds) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.expire(key, seconds);
        jedis.close();
        return result;
    }

    @Override
    public Long ttl(String key) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.ttl(key);
        jedis.close();
        return result;
    }

    @Override
    public Long incr(String key) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.incr(key);
        jedis.close();
        return result;
    }

    @Override
    public Long hset(String key, String field, String value) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.hset(key, field, value);
        jedis.close();
        return result;
    }

    @Override
    public String hget(String key, String field) {
        Jedis jedis = jedisPool.getResource();
        String result = jedis.hget(key, field);
        jedis.close();
        return result;
    }

    @Override
    public Long hdel(String key, String... field) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.hdel(key, field);
        jedis.close();
        return result;
    }

    @Override
    public Boolean hexists(String key, String field) {
        Jedis jedis = jedisPool.getResource();
        Boolean result = jedis.hexists(key, field);
        jedis.close();
        return result;
    }

    @Override
    public List<String> hvals(String key) {
        Jedis jedis = jedisPool.getResource();
        List<String> result = jedis.hvals(key);
        jedis.close();
        return result;
    }

    @Override
    public Long del(String key) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.del(key);
        jedis.close();
        return result;
    }

}

实际使用方法：

applicationContext-redis.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd
    http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd
    http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">
    
    <!-- 连接redis单机版 -->
    <bean id="jedisClientPool" class="cn.e3mall.common.jedis.JedisClientPool">
        <property name="jedisPool" ref="jedisPool"></property>
    </bean>
    <bean id="jedisPool" class="redis.clients.jedis.JedisPool">
        <constructor-arg name="host" value="192.168.25.162"/>
        <constructor-arg name="port" value="6379"/>
    </bean>
    <!-- 连接redis集群 -->
    <!-- <bean id="jedisClientCluster" class="cn.e3mall.common.jedis.JedisClientCluster">
        <property name="jedisCluster" ref="jedisCluster"/>
    </bean>
    <bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
        <constructor-arg name="nodes">
            <set>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.25.162"></constructor-arg>
                    <constructor-arg name="port" value="7001"></constructor-arg>
                </bean> 
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.25.162"></constructor-arg>
                    <constructor-arg name="port" value="7002"></constructor-arg>
                </bean> 
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.25.162"></constructor-arg>
                    <constructor-arg name="port" value="7003"></constructor-arg>
                </bean> 
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.25.162"></constructor-arg>
                    <constructor-arg name="port" value="7004"></constructor-arg>
                </bean> 
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.25.162"></constructor-arg>
                    <constructor-arg name="port" value="7005"></constructor-arg>
                </bean> 
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.25.162"></constructor-arg>
                    <constructor-arg name="port" value="7006"></constructor-arg>
                </bean> 
            </set>
        </constructor-arg>
    </bean> -->
</beans>

使用：

    @Test
    public void testJedisClient() throws Exception {
        //初始化spring容器
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-redis.xml");
        //从容器中获得JedisClient对象
        JedisClient jedisClient = applicationContext.getBean(JedisClient.class);
        jedisClient.set("mytest", "jedisClient");
        String string = jedisClient.get("mytest");
        System.out.println(string);
        
        
    }

 

文章标签：
云数据库 Tair（兼容 Redis）
Java
Redis
NoSQL
关键词：
云数据库 Tair（兼容 Redis）集群
云数据库 Tair（兼容 Redis）单机
接口云数据库 Tair（兼容 Redis）
编程云数据库 Tair（兼容 Redis）
代码云数据库 Tair（兼容 Redis）
西北野狼
目录
相关文章
赵渝强老师
|
4月前
|
存储 负载均衡 NoSQL
【赵渝强老师】Redis Cluster分布式集群
Redis Cluster是Redis的分布式存储解决方案，通过哈希槽（slot）实现数据分片，支持水平扩展，具备高可用性和负载均衡能力，适用于大规模数据场景。
赵渝强老师
371 2
凉凉心.
|
2月前
|
NoSQL 算法 Redis
【Docker】（3）学习Docker中 镜像与容器数据卷、映射关系！手把手带你安装 MySql主从同步 和 Redis三主三从集群！并且进行主从切换与扩容操作，还有分析 哈希分区 等知识点！
Union文件系统（UnionFS）是一种**分层、轻量级并且高性能的文件系统**，它支持对文件系统的修改作为一次提交来一层层的叠加，同时可以将不同目录挂载到同一个虚拟文件系统下(unite several directories into a single virtual filesystem) Union 文件系统是 Docker 镜像的基础。 镜像可以通过分层来进行继承，基于基础镜像（没有父镜像），可以制作各种具体的应用镜像。
凉凉心.
491 5
游客aimstvzg73tkk
|
3月前
|
存储 监控 NoSQL
Redis高可用架构全解析：从主从复制到集群方案
Redis高可用确保服务持续稳定，避免单点故障导致数据丢失或业务中断。通过主从复制实现数据冗余，哨兵模式支持自动故障转移，Cluster集群则提供分布式数据分片与水平扩展，三者层层递进，保障读写分离、容灾切换与大规模数据存储，构建高性能、高可靠的Redis架构体系。
游客aimstvzg73tkk
309 1
wanderInk
|
8月前
|
存储 NoSQL 数据库
Redis 逻辑数据库与集群模式详解
Redis 是高性能内存键值数据库，广泛用于缓存与实时数据处理。本文深入解析 Redis 逻辑数据库与集群模式：逻辑数据库提供16个独立存储空间，适合小规模隔离；集群模式通过分布式架构支持高并发和大数据量，但仅支持 database 0。文章对比两者特性，讲解配置与实践注意事项，并探讨持久化及性能优化策略，助你根据需求选择最佳方案。
wanderInk
315 5
赵渝强老师
|
5月前
|
负载均衡 NoSQL Redis
【赵渝强老师】Redis的主从复制集群
Redis主从复制是指将一台Redis服务器的数据复制到其他Redis服务器，实现数据热备份、故障恢复、负载均衡及高可用架构的基础。主节点负责写操作，从节点同步数据并可提供读服务，提升并发处理能力。
赵渝强老师
164 5
游客ei4oozwd2l7wm
|
4月前
|
存储 NoSQL 算法
Redis的集群架构与使用经验
本文介绍了Redis的集群架构与使用经验，包括主从复制、哨兵集群及Cluster分片集群的应用场景与实现原理。内容涵盖Redis主从同步机制、数据分片存储方式、事务支持及与Memcached的区别，并讨论了Redis内存用尽时的处理策略。适用于了解Redis高可用与性能优化方案。
游客ei4oozwd2l7wm
192 0
游客wkqymr43luqiu
|
7月前
|
存储 监控 NoSQL
Redis设计与实现——单机Redis实现
Redis 是一个高性能的键值存储系统，支持丰富的数据结构（字符串、列表、哈希等）。其核心由键空间、过期字典和阻塞/监控键组成，通过惰性删除与定期删除策略管理过期数据。持久化方面，Redis 提供 RDB 快照和 AOF 日志两种机制，分别适用于快速恢复和高数据安全性场景。RDB 以二进制格式保存数据库快照，AOF 则记录写操作命令并支持重写优化文件大小。 此外，Redis 支持多数据库切换、内存淘汰策略（如 LRU）、慢查询日志等功能，满足不同业务需求。在生产环境中，推荐结合 RDB 和 AOF 的混合持久化方式，兼顾性能与数据安全。
游客wkqymr43luqiu
266 12
技术自由圈/原疯狂创客圈
|
8月前
|
存储 NoSQL Redis
阿里面试：Redis 为啥那么快？怎么实现的100W并发？说出了6大架构，面试官跪地： 纯内存 + 尖端结构 + 无锁架构 + EDA架构 + 异步日志 + 集群架构
阿里面试：Redis 为啥那么快？怎么实现的100W并发？说出了6大架构，面试官跪地： 纯内存 + 尖端结构 + 无锁架构 + EDA架构 + 异步日志 + 集群架构
技术自由圈/原疯狂创客圈
708 1
阿里面试：Redis 为啥那么快？怎么实现的100W并发？说出了6大架构，面试官跪地： 纯内存 + 尖端结构 + 无锁架构 + EDA架构 + 异步日志 + 集群架构
游客bhmgxanbwhyfe
|
9月前
|
存储 NoSQL 算法
Redis分片集群中数据是怎么存储和读取的 ?
Redis集群采用的算法是哈希槽分区算法。Redis集群中有16384个哈希槽（槽的范围是 0 -16383，哈希槽），将不同的哈希槽分布在不同的Redis节点上面进行管理，也就是说每个Redis节点只负责一部分的哈希槽。在对数据进行操作的时候，集群会对使用CRC16算法对key进行计算并对16384取模（slot = CRC16(key)%16383），得到的结果就是 Key-Value 所放入的槽，通过这个值，去找到对应的槽所对应的Redis节点，然后直接到这个对应的节点上进行存取操作
游客bhmgxanbwhyfe
353 3
东阳马生架构
|
10月前
|
缓存 NoSQL Redis
Redis原理—3.复制、哨兵和集群
详细介绍了Redis的复制原理、哨兵原理和集群原理。
东阳马生架构
417 3

热门文章

最新文章

  • 1
    Redis协议简介及持久化Aof文件解析
  • 2
    专访高德地图开放平台的负责人童遥：跨机房同步和多路写入Redis集群方案将得到充分发展
  • 3
    redis 主从切换
  • 4
    【Redis从头学-6】Redis中的Hash数据类型实战场景之购物车
  • 5
    【Redis技术干货】带你彻底认识「内存碎片过高优化」功能和原理
  • 6
    记一次阿里云esc实例被黑客利用redis默认端口6379入侵变成肉鸡的悲惨经历
  • 7
    Redis 6.0 新特性-多线程连环13问！
  • 8
    Redis安装整理(window平台) +php扩展redis
  • 9
    【Redis】细说Redis之zset底层数据结构
  • 10
    java初中级面试题(SSM+Mysql+微服务(SpringCloud+Dubbo)+消息队列(RocketMQ)+缓存(Redis+MongoDB)+设计模式+搜索引擎(ES)+JVM
  • 1
    Redis 缓存失效策略及其应用场景
    392
  • 2
    Redis - 笔记
    169
  • 3
    Redis 安装
    265
  • 4
    详解Redis哨兵模式下，主节点掉线而重新选取主节点的流程
    700
  • 5
    Centos7 安装和配置 Redis 5 教程
    1509
  • 6
    Another Redis Desktop Manager远程连接Redis报错：Client On Error: Error: connect ETIMEDOUT
    1192
  • 7
    Redis与数据库同步指南：订阅Binlog实现数据一致性
    1375
  • 8
    SpringBoot 操作 Redis
    163
  • 9
    redis(缓存)
    123
  • 10
    Redis (分布式锁)
    402

    • 相关课程

    更多
  • 大数据实战项目：反爬虫系统（Lua+Spark+Redis+Hadoop框架搭建）第一阶段
  • 大数据实战项目：反爬虫系统（Lua+Spark+Redis+Hadoop框架搭建）第二阶段
  • 大数据实战项目：反爬虫系统（Lua+Spark+Redis+Hadoop框架搭建）第三阶段
  • Redis入门实战演练
  • 云数据库 Redis 版使用教程
  • Redis数据库入门

    • 相关电子书

    更多
  • Redis集群演化的心路历程——从2.x到3.0时代
  • 微博的Redis定制之路
  • 云数据库Redis版的开源之路
    • 下一篇
    「直播预告」Streaming Lakehouse Meetup EP.2｜Paimon × StarRocks 共话实时湖仓